diff --git a/src/main/java/oop/project/TelegramBot.java b/src/main/java/oop/project/TelegramBot.java index f338f8b..7809474 100644 --- 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 index 106ae82..47bc37a 100644 --- 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 subscribedUsers = database.getSubscribedUsers(); List upcomingMovies = movieService.getUpcomingMovies();