Hw5 1

.gitignore

@@ -1,6 +1,7 @@
 # Compiled class file
 *.class
 
+
 # Log file
 *.log
 
@@ -22,5 +23,9 @@
 # virtual machine crash logs, see http://www.java.com/en/download/help/error_hotspot.xml
 hs_err_pid*
 
-# IJ IDEA #
-.idea
+# idea
+FP/.idea/
+
+# volumes
+FP/migrations/
+FP/rabbitmq/

FP/bot/pom.xml

@@ -0,0 +1,88 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <groupId>org.example</groupId>
+        <artifactId>FP</artifactId>
+        <version>1.0</version>
+    </parent>
+
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>bot</artifactId>
+
+    <properties>
+        <starter-validation.version>3.0.1</starter-validation.version>
+        <starter-web.version>2.7.6</starter-web.version>
+    </properties>
+
+    <dependencies>
+        <!--Swagger UI-->
+        <dependency>
+            <groupId>org.springdoc</groupId>
+            <artifactId>springdoc-openapi-starter-webmvc-ui</artifactId>
+            <version>2.0.2</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.commons</groupId>
+            <artifactId>commons-lang3</artifactId>
+            <version>3.10</version>
+        </dependency>
+        <!--Swagger UI-->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-validation</artifactId>
+            <version>${starter-validation.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-web</artifactId>
+            <version>${starter-web.version}</version>
+            <exclusions>
+                <exclusion>
+                    <groupId>org.apache.logging.log4j</groupId>
+                    <artifactId>log4j-to-slf4j</artifactId>
+                </exclusion>
+            </exclusions>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-devtools</artifactId>
+            <scope>runtime</scope>
+            <optional>true</optional>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-configuration-processor</artifactId>
+            <optional>true</optional>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-context-indexer</artifactId>
+            <optional>true</optional>
+        </dependency>
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+            <optional>true</optional>
+        </dependency>
+        <!--Для бота-->
+        <dependency>
+            <groupId>com.github.pengrad</groupId>
+            <artifactId>java-telegram-bot-api</artifactId>
+            <version>6.6.0</version>
+        </dependency>
+        <!--Для бота-->
+        <dependency>
+            <groupId>org.junit.jupiter</groupId>
+            <artifactId>junit-jupiter</artifactId>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.maven.plugins</groupId>
+            <artifactId>maven-surefire-plugin</artifactId>
+            <version>2.22.2</version>
+        </dependency>
+    </dependencies>
+</project>

FP/bot/src/main/java/ru/tinkoff/edu/java/bot/BotApplication.java

@@ -0,0 +1,21 @@
+package ru.tinkoff.edu.java.bot;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.boot.context.properties.EnableConfigurationProperties;
+import ru.tinkoff.edu.java.bot.configuration.ApplicationConfig;
+import ru.tinkoff.edu.java.bot.firstBot.BotMain;
+
+
+@SpringBootApplication
+@EnableConfigurationProperties(ApplicationConfig.class)
+public class BotApplication
+{
+        public static void main(String[] args){
+                var ctx = SpringApplication.run(BotApplication.class, args);
+                ApplicationConfig config = ctx.getBean(ApplicationConfig.class);
+
+                BotMain bot = new BotMain(config.bot().token());
+                bot.start();
+        }
+}

FP/bot/src/main/java/ru/tinkoff/edu/java/bot/api/BotController.java

@@ -0,0 +1,14 @@
+package ru.tinkoff.edu.java.bot.api;
+
+import org.springframework.web.bind.annotation.*;
+import ru.tinkoff.edu.java.bot.api.model.LinkUpdate;
+
+@RestController
+@RequestMapping("/update")
+public class BotController {
+
+    @PostMapping
+    public String updateChat(@RequestBody LinkUpdate update) {
+        return update.toString();
+    }
+}

FP/bot/src/main/java/ru/tinkoff/edu/java/bot/api/exceptionHandler/BotExceptionHandler.java

@@ -0,0 +1,36 @@
+package ru.tinkoff.edu.java.bot.api.exceptionHandler;
+
+import org.springframework.http.converter.HttpMessageNotReadableException;
+import org.springframework.web.HttpRequestMethodNotSupportedException;
+import org.springframework.http.HttpStatus;
+import org.springframework.web.bind.annotation.ExceptionHandler;
+import org.springframework.web.bind.annotation.ResponseStatus;
+import org.springframework.web.bind.annotation.RestControllerAdvice;
+import ru.tinkoff.edu.java.bot.api.model.ApiErrorResponse;
+
+@RestControllerAdvice
+public class BotExceptionHandler {
+
+    private String getDescription(String message) {
+        ApiErrorResponse errorObj = new ApiErrorResponse(
+                message,
+                null,
+                null,
+                null,
+                null
+        );
+        return errorObj.description();
+    }
+
+    @ExceptionHandler(HttpMessageNotReadableException.class)
+    @ResponseStatus(HttpStatus.BAD_REQUEST)
+    public String MessageNotReadable(HttpMessageNotReadableException Exception) {
+        return getDescription("Некорректные значения параметров или их нет!");
+    }
+
+    @ExceptionHandler(HttpRequestMethodNotSupportedException.class)
+    @ResponseStatus(HttpStatus.BAD_REQUEST)
+    public String MethodNotSupported(HttpRequestMethodNotSupportedException Exception) {
+        return getDescription("Метод не разрешен!");
+    }
+}

FP/bot/src/main/java/ru/tinkoff/edu/java/bot/api/model/ApiErrorResponse.java

@@ -0,0 +1,11 @@
+package ru.tinkoff.edu.java.bot.api.model;
+
+import java.util.List;
+
+public record ApiErrorResponse(
+        String description,
+        String code,
+        String exceptionName,
+        String exceptionMessage,
+        List<String> stacktrace
+) {}

FP/bot/src/main/java/ru/tinkoff/edu/java/bot/api/model/LinkUpdate.java

@@ -0,0 +1,6 @@
+package ru.tinkoff.edu.java.bot.api.model;
+
+import java.util.List;
+
+public record LinkUpdate(long id, String url, String description, List<Long> tgChatIds) {
+}

FP/bot/src/main/java/ru/tinkoff/edu/java/bot/configuration/ApplicationConfig.java

@@ -0,0 +1,18 @@
+package ru.tinkoff.edu.java.bot.configuration;
+
+import jakarta.validation.constraints.NotNull;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.scheduling.annotation.EnableScheduling;
+import org.springframework.validation.annotation.Validated;
+import ru.tinkoff.edu.java.bot.configuration.configRecords.Bot;
+import ru.tinkoff.edu.java.bot.configuration.configRecords.Scheduler;
+
+@Validated
+@EnableScheduling
+@ConfigurationProperties(prefix = "app", ignoreUnknownFields = false)
+public record ApplicationConfig(
+        @NotNull String test,
+        @NotNull Scheduler scheduler,
+        Bot bot
+) {
+}

FP/bot/src/main/java/ru/tinkoff/edu/java/bot/configuration/RabbitMQConfiguration.java

@@ -0,0 +1,78 @@
+package ru.tinkoff.edu.java.bot.configuration;
+
+import org.springframework.amqp.core.*;
+import org.springframework.amqp.support.converter.ClassMapper;
+import org.springframework.amqp.support.converter.DefaultClassMapper;
+import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
+import org.springframework.amqp.support.converter.MessageConverter;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import ru.tinkoff.edu.java.bot.api.model.LinkUpdate;
+
+import java.util.HashMap;
+import java.util.Map;
+
+@Configuration
+public class RabbitMQConfiguration {
+
+    private final ApplicationConfig config;
+
+    public RabbitMQConfiguration(ApplicationConfig config) {
+        this.config = config;
+    }
+
+    @Bean
+    Queue queue() {
+        return QueueBuilder.durable(config.queueName())
+                .withArgument("x-dead-letter-exchange", config.exchangeName())
+                .withArgument("x-dead-letter-routing-key", config.routingKey() + ".dlq")
+                .build();
+    }
+
+
+    @Bean
+    Queue deadLetterQueue() {
+        return new Queue(config.queueName() + ".dlq", true);
+    }
+
+    @Bean
+    DirectExchange exchange() {
+        return new DirectExchange(config.exchangeName());
+    }
+
+    @Bean
+    Binding binding(Queue queue, DirectExchange exchange) {
+        return BindingBuilder.bind(queue).to(exchange).with(config.routingKey());
+    }
+
+    @Bean
+    Binding dlqBinding(Queue deadLetterQueue, DirectExchange exchange) {
+        return BindingBuilder.bind(deadLetterQueue).to(exchange).with(config.routingKey() + ".dlq");
+    }
+
+    @Bean
+    public ClassMapper classMapper() {
+        Map<String, Class<?>> mappings = new HashMap<>();
+        mappings.put("ru.tinkoff.edu.java.bot.api.model.LinkUpdate", LinkUpdate.class);
+
+        DefaultClassMapper classMapper = new DefaultClassMapper();
+        classMapper.setTrustedPackages("ru.tinkoff.edu.java.bot.api.model.*");
+        classMapper.setIdClassMapping(mappings);
+        return classMapper;
+    }
+
+    @Bean
+    public MessageConverter jsonMessageConverter(ClassMapper classMapper) {
+        Jackson2JsonMessageConverter jsonConverter = new Jackson2JsonMessageConverter();
+        jsonConverter.setClassMapper(classMapper);
+        return jsonConverter;
+    }
+
+
+    @Bean
+    public ScrapperQueueListener scrapperQueueListener(AmqpTemplate rabbitTemplate, UpdateService updateService) {
+        return new ScrapperQueueListener(rabbitTemplate, updateService);
+    }
+
+
+}

FP/bot/src/main/java/ru/tinkoff/edu/java/bot/configuration/configRecords/Bot.java

@@ -0,0 +1,4 @@
+package ru.tinkoff.edu.java.bot.configuration.configRecords;
+
+public record Bot(String token, String name) {
+}

FP/bot/src/main/java/ru/tinkoff/edu/java/bot/configuration/configRecords/Scheduler.java

@@ -0,0 +1,5 @@
+package ru.tinkoff.edu.java.bot.configuration.configRecords;
+
+import java.time.Duration;
+
+public record Scheduler(Duration interval) {}

FP/bot/src/main/java/ru/tinkoff/edu/java/bot/firstBot/BotMain.java

@@ -0,0 +1,36 @@
+package ru.tinkoff.edu.java.bot.firstBot;
+
+import com.pengrad.telegrambot.TelegramBot;
+import com.pengrad.telegrambot.request.SendMessage;
+import org.springframework.boot.context.properties.EnableConfigurationProperties;
+import ru.tinkoff.edu.java.bot.configuration.ApplicationConfig;
+
+
+@EnableConfigurationProperties(ApplicationConfig.class)
+public class BotMain {
+
+    String token;
+    static TelegramBot bot;
+
+    public BotMain(String token) {
+        this.token = token;
+    }
+
+    public void start() {
+        bot = new TelegramBot(token);
+        bot.setUpdatesListener(new Updater(bot));
+    }
+
+    public void end() {
+        bot.removeGetUpdatesListener();
+    }
+
+    public static void apiCommand(long tgChatId, String command) {
+
+        MessageHandler handler = new MessageHandler();
+        String[] parse = command.split(" ");
+        if(parse.length > 1) command = handler.call_command(parse[0], parse[1]);
+        else command = handler.call_command(parse[0]);
+        bot.execute(new SendMessage(tgChatId, command));
+    }
+}

FP/bot/src/main/java/ru/tinkoff/edu/java/bot/firstBot/DB.java

@@ -0,0 +1,42 @@
+package ru.tinkoff.edu.java.bot.firstBot;
+
+import java.util.ArrayList;
+
+public class DB {
+
+    static ArrayList<String> list = new ArrayList();
+
+    public static void addLink(String link) {
+        list.add(link);
+    }
+
+    public static void rmLink(String link) {
+        list.remove(link);
+    }
+
+    public static String getListParse() {
+
+        int i = 1;
+
+        String out_list = "";
+
+        for(String element: list){
+
+            out_list += element;
+
+            if(i != list.size()) {
+                out_list += ", ";
+            }
+            i++;
+        }
+        return out_list;
+    }
+
+    public static boolean listIsEmpty() {
+        return list.isEmpty();
+    }
+
+    public static boolean linkContain(String link) {
+        return list.contains(link);
+    }
+}