Minor fixes

aqerd · Dec 2, 2024 · 00e25d2 · 00e25d2
1 parent 1eb925a
commit 00e25d2
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/src/main/java/oop/project/TelegramBot.java b/src/main/java/oop/project/TelegramBot.java
@@ -6,6 +6,7 @@
 import java.sql.SQLException;
 import java.util.concurrent.Executors;
 import java.util.concurrent.ExecutorService;
+import oop.project.services.BroadcastingService;
 import org.telegram.telegrambots.meta.generics.TelegramClient;
 import org.telegram.telegrambots.meta.api.objects.Update;
 import org.telegram.telegrambots.client.okhttp.OkHttpTelegramClient;
@@ -14,9 +15,12 @@
 public class TelegramBot implements LongPollingSingleThreadUpdateConsumer {
     private final ExecutorService EXECUTOR = Executors.newFixedThreadPool(10);
     private static TelegramClient telegramClient = null;
+    private final Database database = new Database();
 
     public TelegramBot(String botToken) throws SQLException {
         telegramClient = new OkHttpTelegramClient(botToken);
+        BroadcastingService broadcastingService = new BroadcastingService(database, telegramClient);
+        BroadcastingService.startBroadcasting();
     }
 
     public static TelegramClient getTelegramClient() {

diff --git a/src/main/java/oop/project/services/BroadcastingService.java b/src/main/java/oop/project/services/BroadcastingService.java
@@ -22,7 +22,7 @@ public BroadcastingService(Database database, TelegramClient telegramClient) {
         this.movieService = new MovieService();
     }
 
-    public void startBroadcasting() {
+    public static void startBroadcasting() {
         scheduler.scheduleAtFixedRate(() -> {
             List<Long> subscribedUsers = database.getSubscribedUsers();
             List<FilmDeserializer> upcomingMovies = movieService.getUpcomingMovies();