feature/TRAC-6 (#8)

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

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

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

src/main/java/com/vladyslavpalamarchuk/trackmycoin/adaptors/persistence/package-info.java

@@ -1,5 +1,5 @@
 /**
- * This package contains persistence config for application
- * TODO delete this file after adding new files
+ * This package contains persistence config for application TODO delete this file after adding new
+ * files
  */
 package com.vladyslavpalamarchuk.trackmycoin.adaptors.persistence;

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

@@ -1,12 +1,25 @@
 package com.vladyslavpalamarchuk.trackmycoin.adaptors.telegram;
 
 import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Component;
+import org.telegram.telegrambots.meta.api.methods.send.SendMessage;
+import org.telegram.telegrambots.meta.exceptions.TelegramApiException;
 import org.telegram.telegrambots.meta.generics.TelegramClient;
 
+@Slf4j
 @Component
 @RequiredArgsConstructor
 public class TelegramBotClient {
 
   private final TelegramClient telegramClient;
+
+  public void sendMessage(Long chatId, String messageText) {
+    SendMessage message = SendMessage.builder().chatId(chatId).text(messageText).build();
+    try {
+      telegramClient.execute(message);
+    } catch (TelegramApiException e) {
+      log.error("Fail to send telegram message to chatId: {}", chatId, e);
+    }
+  }
 }

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

@@ -1,5 +1,6 @@
 package com.vladyslavpalamarchuk.trackmycoin.adaptors.telegram;
 
+import com.vladyslavpalamarchuk.trackmycoin.command.CommandProcessorRegistry;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Component;
@@ -12,10 +13,13 @@
 @RequiredArgsConstructor
 public class TelegramBotConsumer implements LongPollingSingleThreadUpdateConsumer {
 
+  private final CommandProcessorRegistry commandProcessorRegistry;
+
   @Override
   public void consume(Update update) {
     if (update.hasMessage() && update.getMessage().hasText()) {
       logUpdateMessage(update.getMessage());
+          commandProcessorRegistry.get(update.getMessage().getText()).process(update);
     }
   }
 

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

@@ -0,0 +1,15 @@
+package com.vladyslavpalamarchuk.trackmycoin.command;
+
+import lombok.Getter;
+import lombok.RequiredArgsConstructor;
+
+@Getter
+@RequiredArgsConstructor
+public enum Command {
+  START("/start"),
+  INFO("/info"),
+  HELP("/help"),
+  NON_COMMAND("");
+
+  private final String command;
+}

src/main/java/com/vladyslavpalamarchuk/trackmycoin/command/CommandProcessorRegistry.java

@@ -0,0 +1,33 @@
+package com.vladyslavpalamarchuk.trackmycoin.command;
+
+import com.vladyslavpalamarchuk.trackmycoin.command.processor.CommandProcessor;
+import java.util.Arrays;
+import java.util.List;
+import java.util.Map;
+import java.util.function.Function;
+import java.util.stream.Collectors;
+import org.springframework.stereotype.Service;
+
+@Service
+public class CommandProcessorRegistry {
+
+  private final Map<Command, CommandProcessor> commandToProcessors;
+
+  public CommandProcessorRegistry(List<CommandProcessor> processors) {
+    commandToProcessors =
+        processors.stream()
+            .collect(Collectors.toMap(CommandProcessor::getCommand, Function.identity()));
+  }
+
+  public CommandProcessor get(String messageText) {
+    if (!messageText.startsWith("/")) {
+      return commandToProcessors.get(Command.NON_COMMAND);
+    }
+
+    return Arrays.stream(Command.values())
+        .filter(c -> c.getCommand().equalsIgnoreCase(messageText))
+        .findFirst()
+        .map(commandToProcessors::get)
+        .orElse(commandToProcessors.get(Command.NON_COMMAND));
+  }
+}

src/main/java/com/vladyslavpalamarchuk/trackmycoin/command/processor/CommandProcessor.java

@@ -0,0 +1,11 @@
+package com.vladyslavpalamarchuk.trackmycoin.command.processor;
+
+import com.vladyslavpalamarchuk.trackmycoin.command.Command;
+import org.telegram.telegrambots.meta.api.objects.Update;
+
+public interface CommandProcessor {
+
+  void process(Update update);
+
+  Command getCommand();
+}

src/main/java/com/vladyslavpalamarchuk/trackmycoin/command/processor/HelpCommandProcess.java

@@ -0,0 +1,28 @@
+package com.vladyslavpalamarchuk.trackmycoin.command.processor;
+
+import com.vladyslavpalamarchuk.trackmycoin.adaptors.telegram.TelegramBotClient;
+import com.vladyslavpalamarchuk.trackmycoin.command.Command;
+import com.vladyslavpalamarchuk.trackmycoin.config.TelegramBotDescription;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Component;
+import org.telegram.telegrambots.meta.api.objects.Update;
+
+@Component
+@RequiredArgsConstructor
+public class HelpCommandProcess implements CommandProcessor {
+
+  private final TelegramBotClient telegramBotClient;
+
+  private final TelegramBotDescription telegramBotDescription;
+
+  @Override
+  public void process(Update update) {
+    telegramBotClient.sendMessage(
+        update.getMessage().getChatId(), telegramBotDescription.getHelp());
+  }
+
+  @Override
+  public Command getCommand() {
+    return Command.HELP;
+  }
+}

src/main/java/com/vladyslavpalamarchuk/trackmycoin/command/processor/InfoCommandProcessor.java

@@ -0,0 +1,28 @@
+package com.vladyslavpalamarchuk.trackmycoin.command.processor;
+
+import com.vladyslavpalamarchuk.trackmycoin.adaptors.telegram.TelegramBotClient;
+import com.vladyslavpalamarchuk.trackmycoin.command.Command;
+import com.vladyslavpalamarchuk.trackmycoin.config.TelegramBotDescription;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Component;
+import org.telegram.telegrambots.meta.api.objects.Update;
+
+@Component
+@RequiredArgsConstructor
+public class InfoCommandProcessor implements CommandProcessor {
+
+  private final TelegramBotClient telegramBotClient;
+
+  private final TelegramBotDescription telegramBotDescription;
+
+  @Override
+  public void process(Update update) {
+    telegramBotClient.sendMessage(
+        update.getMessage().getChatId(), telegramBotDescription.getInfo());
+  }
+
+  @Override
+  public Command getCommand() {
+    return Command.INFO;
+  }
+}

src/main/java/com/vladyslavpalamarchuk/trackmycoin/command/processor/NonCommandProcessor.java

@@ -0,0 +1,27 @@
+package com.vladyslavpalamarchuk.trackmycoin.command.processor;
+
+import com.vladyslavpalamarchuk.trackmycoin.adaptors.telegram.TelegramBotClient;
+import com.vladyslavpalamarchuk.trackmycoin.command.Command;
+import com.vladyslavpalamarchuk.trackmycoin.config.TelegramBotDescription;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Component;
+import org.telegram.telegrambots.meta.api.objects.Update;
+
+@Component
+@RequiredArgsConstructor
+public class NonCommandProcessor implements CommandProcessor {
+  private final TelegramBotClient telegramBotClient;
+
+  private final TelegramBotDescription telegramBotDescription;
+
+  @Override
+  public void process(Update update) {
+    telegramBotClient.sendMessage(
+        update.getMessage().getChatId(), telegramBotDescription.getNonCommand());
+  }
+
+  @Override
+  public Command getCommand() {
+    return Command.NON_COMMAND;
+  }
+}

src/main/java/com/vladyslavpalamarchuk/trackmycoin/command/processor/StartCommandProcessor.java

@@ -0,0 +1,28 @@
+package com.vladyslavpalamarchuk.trackmycoin.command.processor;
+
+import com.vladyslavpalamarchuk.trackmycoin.adaptors.telegram.TelegramBotClient;
+import com.vladyslavpalamarchuk.trackmycoin.command.Command;
+import com.vladyslavpalamarchuk.trackmycoin.config.TelegramBotDescription;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Component;
+import org.telegram.telegrambots.meta.api.objects.Update;
+
+@Component
+@RequiredArgsConstructor
+public class StartCommandProcessor implements CommandProcessor {
+
+  private final TelegramBotClient telegramBotClient;
+
+  private final TelegramBotDescription telegramBotDescription;
+
+  @Override
+  public void process(Update update) {
+    telegramBotClient.sendMessage(
+        update.getMessage().getChatId(), telegramBotDescription.getStart());
+  }
+
+  @Override
+  public Command getCommand() {
+    return Command.START;
+  }
+}

src/main/java/com/vladyslavpalamarchuk/trackmycoin/config/TelegramBotDescription.java

@@ -0,0 +1,19 @@
+package com.vladyslavpalamarchuk.trackmycoin.config;
+
+import lombok.Data;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.stereotype.Component;
+
+@Data
+@Component
+@ConfigurationProperties(prefix = "description")
+public class TelegramBotDescription {
+
+  private String start;
+
+  private String info;
+
+  private String help;
+
+  private String nonCommand;
+}

src/main/java/com/vladyslavpalamarchuk/trackmycoin/domain/package-info.java

@@ -1,5 +1,2 @@
-/**
- * This package contains domain entities
- * TODO delete this file after adding new files
- */
+/** This package contains domain entities TODO delete this file after adding new files */
 package com.vladyslavpalamarchuk.trackmycoin.domain;

src/main/java/com/vladyslavpalamarchuk/trackmycoin/service/package-info.java

@@ -1,5 +1,5 @@
 /**
- * This package contains business logic of the application
- * TODO delete this file after adding new files
+ * This package contains business logic of the application TODO delete this file after adding new
+ * files
  */
 package com.vladyslavpalamarchuk.trackmycoin.service;

src/main/resources/application.yml

@@ -7,4 +7,19 @@ spring:
     url: ${POSTGRESQL_JDBC_URL}
     username: ${POSTGRESQL_USERNAME}
     password: ${POSTGRESQL_PASSWORD}
-    driver-class-name: org.postgresql.Driver
+    driver-class-name: org.postgresql.Driver
+description:
+  start: "Welcome to TrackMyCoin 📈💰!
+          \n\nThis bot helps you track cryptocurrency prices
+          and will send you notifications when your target price 
+          is reached.
+          \n\nFor more information about the bot, type /info."
+  info: "TrackMyCoin — your crypto assistant 📈💰!
+  
+         \nEasily track cryptocurrency prices and get notified
+         when your target price is reached.
+         \nPerfect for traders and crypto enthusiasts!
+  
+         \nType /help for a list of all commands."
+  help: "List of commands 👾\nInfo -> /info\nHelp -> /help"
+  non_command: "non command /help "