[TRAC-6] Implement Message Service and basic Command Handling

Dockerfile

@@ -0,0 +1,14 @@
+FROM maven:3.9.4-eclipse-temurin-21-alpine as build
+WORKDIR /app
+COPY pom.xml /app/
+RUN mvn dependency:go-offline
+
+COPY src /app/src/
+RUN mvn clean package -DskipTests
+RUN ls -al /app/target/
+
+FROM openjdk:21-slim
+VOLUME /tmp
+COPY --from=build /app/target/*.jar /trackmycoin.jar
+
+ENTRYPOINT ["java", "-jar", "/trackmycoin.jar"]

src/main/java/com/vladyslavpalamarchuk/trackmycoin/adaptors/telegram/TelegramBotClient.java

@@ -1,11 +1,13 @@
 package com.vladyslavpalamarchuk.trackmycoin.adaptors.telegram;
 
+import lombok.Getter;
 import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Component;
 import org.telegram.telegrambots.meta.generics.TelegramClient;
 
 @Component
 @RequiredArgsConstructor
+@Getter
 public class TelegramBotClient {
 
   private final TelegramClient telegramClient;

src/main/java/com/vladyslavpalamarchuk/trackmycoin/adaptors/telegram/TelegramBotConsumer.java

@@ -1,7 +1,9 @@
 package com.vladyslavpalamarchuk.trackmycoin.adaptors.telegram;
 
+import com.vladyslavpalamarchuk.trackmycoin.service.MessageHandlerService;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 import org.telegram.telegrambots.longpolling.util.LongPollingSingleThreadUpdateConsumer;
 import org.telegram.telegrambots.meta.api.objects.Update;
@@ -12,9 +14,13 @@
 @RequiredArgsConstructor
 public class TelegramBotConsumer implements LongPollingSingleThreadUpdateConsumer {
 
+  @Autowired
+  private final MessageHandlerService messageHandlerService;
+
   @Override
   public void consume(Update update) {
     if (update.hasMessage() && update.getMessage().hasText()) {
+      messageHandlerService.processMessage(update.getMessage().getChatId(), update.getMessage().getText() );
       logUpdateMessage(update.getMessage());
     }
   }

src/main/java/com/vladyslavpalamarchuk/trackmycoin/domain/Command.java

@@ -0,0 +1,21 @@
+package com.vladyslavpalamarchuk.trackmycoin.domain;
+
+import lombok.Getter;
+
+
+@Getter
+public enum Command {
+
+    START("/start", "Welcome to TrackMyCoin 📈💰!\nThis bot helps you track cryptocurrency prices\nand will send you notifications when your target price \nis reached.\n\nFor more information about the bot, type /info."),
+    INFO("/info", "TrackMyCoin — your crypto assistant! 📈💰\n\nEasily track cryptocurrency prices and get notified\nwhen your target price is reached.\nPerfect for traders and crypto enthusiasts!\n\nType /help for a list of all commands."),
+    HELP("/help", "List of commands 👾\nInfo -> /info\nHelp -> /help"),
+    NON_COMMAND("","non command /help ");
+
+    private final String command;
+    private final String description;
+
+    Command(String command, String description) {
+        this.command = command;
+        this.description = description;
+    }
+}

src/main/java/com/vladyslavpalamarchuk/trackmycoin/service/MessageHandlerService.java

@@ -0,0 +1,44 @@
+package com.vladyslavpalamarchuk.trackmycoin.service;
+
+import com.vladyslavpalamarchuk.trackmycoin.adaptors.telegram.TelegramBotClient;
+import com.vladyslavpalamarchuk.trackmycoin.domain.Command;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.telegram.telegrambots.meta.api.methods.send.SendMessage;
+import org.telegram.telegrambots.meta.exceptions.TelegramApiException;
+import java.util.List;
+import java.util.Optional;
+
+@Service
+public class MessageHandlerService {
+
+    @Autowired
+    private TelegramBotClient telegramBotClient;
+
+    private final List<Command> commands = List.of(Command.START , Command.INFO , Command.HELP);
+
+    public void processMessage(Long chatId, String messageText) {
+       Optional<Command> commandOptional = commands.stream()
+                .filter(c ->  c.getCommand().equals(messageText))
+                .findFirst();
+
+       if (commandOptional.isPresent()) {
+           sendWelcomeMessage(chatId, commandOptional.get().getDescription());
+       }else {
+           sendWelcomeMessage(chatId, Command.NON_COMMAND.getDescription());
+       }
+    }
+
+    private void sendWelcomeMessage(Long chatId , String messageText) {
+        SendMessage message = SendMessage
+                .builder()
+                .chatId(chatId)
+                .text(messageText)
+                .build();
+        try {
+            telegramBotClient.getTelegramClient().execute(message);
+        } catch (TelegramApiException e) {
+            e.printStackTrace();
+        }
+    }
+}