polls will be closed automatically 2 days before event start

server/events/guildScheduledEventCreate.ts

@@ -1,14 +1,17 @@
-import { BaseFetchOptions, ChannelType, GuildBasedChannel, GuildChannelResolvable, GuildMember, GuildScheduledEvent, GuildScheduledEventStatus, Message, TextChannel, messageLink } from "discord.js";
+import { GuildScheduledEvent, Message, TextChannel } from "discord.js";
+import { ScheduledTask, schedule } from "node-cron";
 import { v4 as uuid } from "uuid";
 import { jellyfinHandler } from "../..";
-import { getGuildSpecificTriggerRoleId } from "../helper/roleFilter";
-import { logger } from "../logger";
+import { closePoll } from "../commands/closepoll";
 import { config } from "../configuration";
+import { logger } from "../logger";
 
 
 export const name = 'guildScheduledEventCreate'
 
-export enum Emotes {"1️⃣", "2️⃣", "3️⃣", "4️⃣", "5️⃣", "6️⃣", "7️⃣", "8️⃣", "9️⃣", "🔟"}
+export enum Emotes { "1️⃣", "2️⃣", "3️⃣", "4️⃣", "5️⃣", "6️⃣", "7️⃣", "8️⃣", "9️⃣", "🔟" }
+
+export let task: ScheduledTask | undefined
 
 export async function execute(event: GuildScheduledEvent) {
     const requestId = uuid()
@@ -23,8 +26,6 @@ export async function execute(event: GuildScheduledEvent) {
         logger.info(`Got ${movies.length} random movies. Creating voting`, { guildId: event.guildId, requestId })
         logger.debug(`Movies: ${JSON.stringify(movies.map(movie => movie.name))}`, { guildId: event.guildId, requestId })
 
-
-
         const channel: TextChannel = <TextChannel>(await event.guild?.channels.fetch())?.filter(channel => channel!.id === config.bot.announcement_channel_id).map((value, _) => value)[0] //todo: needs to be done less sketchy
         logger.debug(`Found channel ${JSON.stringify(channel, null, 2)}`)
 
@@ -40,6 +41,42 @@ export async function execute(event: GuildScheduledEvent) {
             sentMessage.react(Emotes[i])
         }
 
+        if(!task){
+            task = schedule("0 * * * * *", () => checkForPollsToClose(event))
+        }
+
         // sentMessage.pin() //todo: uncomment when bot has permission to pin messages. Also update closepoll.ts to only fetch pinned messages
     }
+}
+
+async function checkForPollsToClose(event: GuildScheduledEvent): Promise<void> {
+    const requestId = uuid()
+    logger.info(`Automatic check for poll closing.`, { guildId: event.guildId, requestId })
+    if (!event.guild) {
+        logger.error("No guild in event. Cancelling.", { guildId: event.guildId, requestId })
+        return
+    }
+    //refetch event in case the time changed or the poll is already closed
+    const events = (await event.guild.scheduledEvents.fetch())
+        .filter(event => event.name.toLowerCase().includes("voting offen"))
+        .map((value, _) => value)
+
+    if(!events || events.length <= 0) {
+        logger.info("Did not find any events. Cancelling", { guildId: event.guildId, requestId })
+        return
+    } else if(events.length > 1) {
+        logger.error(`More than one event found. Don't know which one is the right one :( Events: ${JSON.stringify(events, null, 2)}`, { guildId: event.guildId, requestId })
+        return
+    }
+    const updatedEvent = events[0]             //add two hours because of different timezones in discord api and Date.now()
+    if(!updatedEvent.scheduledStartTimestamp) {
+        logger.error("Event does not have a scheduled start time. Cancelling", { guildId: event.guildId, requestId })
+        return
+    }
+    if ((updatedEvent.scheduledStartTimestamp - Date.now()) <= (1000 * 60 * 60 * 24 * 2)) {
+        logger.info("Less than two days until event. Closing poll", { guildId: event.guildId, requestId })
+        closePoll(event.guild, requestId)
+    } else {
+        logger.info(`ScheduledStart: ${updatedEvent.scheduledStartTimestamp}. Now: ${Date.now()}`, { guildId: event.guildId, requestId })
+    }
 }