Add findExtendablePollsInChannel

Author: holzmaster

src/service/poll.ts

@@ -1,4 +1,4 @@
-import type { GuildMember, Message, MessageReaction, User } from "discord.js";
+import type { GuildMember, Message, MessageReaction, TextBasedChannel, User } from "discord.js";
 import type { Temporal } from "@js-temporal/polyfill";
 
 import * as legacyDelayedPoll from "@/service/delayedPollLegacy.js";
@@ -55,6 +55,10 @@ export async function findPoll(pollId: PollId): Promise<polls.PollWithOptions |
     return await polls.findPoll(pollId);
 }
 
+export async function findExtendablePollsInChannel(channel: TextBasedChannel): Promise<Poll[]> {
+    return polls.findExtendablePollsInChannel(channel.id);
+}
+
 export async function getExpiredPolls(now: Temporal.Instant): Promise<Poll[]> {
     return await polls.getExpiredPolls(now);
 }

src/storage/poll.ts

@@ -126,6 +126,21 @@ export async function findPoll(pollId: PollId, ctx = db()): Promise<PollWithOpti
     });
 }
 
+export async function findExtendablePollsInChannel(
+    channelId: Snowflake,
+    ctx = db(),
+): Promise<Poll[]> {
+    return ctx
+        .selectFrom("polls")
+        .where("embedChannelId", "=", channelId)
+        .where("extendable", "=", true)
+        .where("ended", "=", false)
+        .orderBy("createdAt", "desc")
+        .limit(25)
+        .selectAll()
+        .execute();
+}
+
 export async function getExpiredPolls(now: Temporal.Instant, ctx = db()): Promise<Poll[]> {
     return await ctx
         .selectFrom("polls")