added multithreding for bot

Author: Dema-koder

docker-compose.yml

@@ -39,5 +39,11 @@ services:
       - "8080:8080"
     restart: unless-stopped
 
+  leetcode:
+    image: alfaarghya/alfa-leetcode-api:2.0.1
+    container_name: leetcode
+    ports:
+      - "3000:3000"
+
 volumes:
   postgres_data:

localdev/docker-compose.yml

@@ -0,0 +1,28 @@
+version: '3.8'
+
+services:
+  postgres:
+    image: postgres:15
+    container_name: postgres
+    environment:
+      POSTGRES_USER: app_user
+      POSTGRES_PASSWORD: secretpass
+      POSTGRES_DB: app_db
+    ports:
+      - "5433:5432"
+    volumes:
+      - postgres_data:/var/lib/postgresql/data
+    healthcheck:
+      test: ["CMD-SHELL", "pg_isready -U app_user -d app_db"]
+      interval: 5s
+      timeout: 5s
+      retries: 5
+
+  leetcode:
+    image: alfaarghya/alfa-leetcode-api:2.0.1
+    container_name: leetcode
+    ports:
+      - "3000:3000"
+
+volumes:
+  postgres_data:

src/main/java/org/example/project/data/UserSession.java

@@ -0,0 +1,18 @@
+package org.example.project.data;
+
+import com.plexpt.chatgpt.entity.chat.Message;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import org.example.project.service.DialogMode;
+
+import java.util.ArrayList;
+
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+public class UserSession {
+    private DialogMode dialogMode;
+    private String gptVersion;
+    private ArrayList<Message> messageHistory;
+}

src/main/java/org/example/project/domain/ChatGptMessages.java

@@ -0,0 +1,26 @@
+package org.example.project.domain;
+
+import jakarta.persistence.*;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@Entity
+@Data
+@NoArgsConstructor
+@AllArgsConstructor
+@Builder
+public class ChatGptMessages {
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    private Long id;
+
+    @Column(length = 5000)
+    private String question;
+
+    @Column(length = 5000)
+    private String answer;
+
+    private Long userId;
+}

src/main/java/org/example/project/repository/ChatGptMessagesRepository.java

@@ -0,0 +1,9 @@
+package org.example.project.repository;
+
+import org.example.project.domain.ChatGptMessages;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.stereotype.Repository;
+
+@Repository
+public interface ChatGptMessagesRepository extends JpaRepository<ChatGptMessages, Long> {
+}

src/main/java/org/example/project/service/BotKeyboard.java

@@ -0,0 +1,77 @@
+package org.example.project.service;
+
+import org.springframework.stereotype.Service;
+import org.telegram.telegrambots.meta.api.objects.replykeyboard.ReplyKeyboardMarkup;
+import org.telegram.telegrambots.meta.api.objects.replykeyboard.buttons.KeyboardButton;
+import org.telegram.telegrambots.meta.api.objects.replykeyboard.buttons.KeyboardRow;
+
+import java.util.ArrayList;
+import java.util.List;
+
+@Service
+public class BotKeyboard {
+    public ReplyKeyboardMarkup createMainMenuKeyboard() {
+        ReplyKeyboardMarkup keyboardMarkup = new ReplyKeyboardMarkup();
+        List<KeyboardRow> keyboard = new ArrayList<>();
+
+        // Первая строка кнопок
+        KeyboardRow row1 = new KeyboardRow();
+        row1.add(KeyboardButton.builder()
+                .text("contact")
+                .requestContact(true)
+                .build());
+        row1.add(new KeyboardButton("Настройки"));
+
+        // Вторая строка кнопок
+        KeyboardRow row2 = new KeyboardRow();
+        row2.add(new KeyboardButton("Мой профиль"));
+        row2.add(new KeyboardButton("Контакты"));
+
+        keyboard.add(row1);
+        keyboard.add(row2);
+
+        keyboardMarkup.setKeyboard(keyboard);
+        keyboardMarkup.setResizeKeyboard(true);
+        keyboardMarkup.setOneTimeKeyboard(true);
+
+        return keyboardMarkup;
+    }
+
+    public ReplyKeyboardMarkup createGptVersionKeyboard() {
+        ReplyKeyboardMarkup keyboardMarkup = new ReplyKeyboardMarkup();
+        List<KeyboardRow> keyboard = new ArrayList<>();
+
+        KeyboardRow row1 = new KeyboardRow();
+        row1.add(new KeyboardButton("1"));
+        row1.add(new KeyboardButton("2"));
+
+        KeyboardRow row2 = new KeyboardRow();
+        row2.add(new KeyboardButton("3"));
+        row2.add(new KeyboardButton("4"));
+
+        keyboard.add(row1);
+        keyboard.add(row2);
+
+        keyboardMarkup.setKeyboard(keyboard);
+        keyboardMarkup.setResizeKeyboard(true);
+        keyboardMarkup.setOneTimeKeyboard(true);
+
+        return keyboardMarkup;
+    }
+
+    public ReplyKeyboardMarkup createGptKeyboard() {
+        ReplyKeyboardMarkup keyboardMarkup = new ReplyKeyboardMarkup();
+        List<KeyboardRow> keyboard = new ArrayList<>();
+
+        KeyboardRow row1 = new KeyboardRow();
+        row1.add(new KeyboardButton("Exit"));
+
+        keyboard.add(row1);
+
+        keyboardMarkup.setKeyboard(keyboard);
+        keyboardMarkup.setResizeKeyboard(true);
+        keyboardMarkup.setOneTimeKeyboard(true);
+
+        return keyboardMarkup;
+    }
+}

src/main/java/org/example/project/service/ChatGPTService.java

@@ -12,13 +12,13 @@
 import java.net.Proxy;
 import java.util.ArrayList;
 import java.util.Arrays;
+import java.util.List;
 
 @Slf4j
 @Component
 public class ChatGPTService {
     private ChatGPT chatGPT;
     final ApplicationConfig config;
-    private ArrayList<Message> messageHistory = new ArrayList<>();
 
     public ChatGPTService(ApplicationConfig config) {
         this.config = config;
@@ -32,18 +32,19 @@ public ChatGPTService(ApplicationConfig config) {
                 .init();
     }
 
-    public String sendMessage(String prompt, String question, String model) {
+    public String sendMessage(String prompt, String question, String model, List<Message> history) {
         log.info("Question: {}", question);
 
         Message system = Message.ofSystem(prompt);
         Message message = Message.of(question);
-        messageHistory.add(system);
-        messageHistory.add(message);
 
-        return sendMessagesToChatGPT(model);
+        history.add(system);
+        history.add(message);
+
+        return sendMessagesToChatGPT(model, history);
     }
 
-    private String sendMessagesToChatGPT(String model){
+    private String sendMessagesToChatGPT(String model, List<Message> messageHistory){
         ChatCompletion chatCompletion = ChatCompletion.builder()
                 .model(model)
                 .messages(messageHistory)