import cron from 'node-cron';
import { PrismaClient } from '@prisma/client';
import { TextChannel } from 'discord.js';
const prisma = new PrismaClient();


class Scheduler {
  public start() {
    // Run every minute
    cron.schedule('* * * * *', async () => {
      const now = new Date();
      const giveaways = await prisma.giveaway.findMany({
        where: {
          endsAt: {
            lte: now,
          },
        },
      });

      for (const giveaway of giveaways) {
        await this.endGiveaway(giveaway.id);
      }
    });
  }

  private async endGiveaway(giveawayId: number) {
    const giveaway = await prisma.giveaway.findUnique({
      where: { id: giveawayId },
    });

    if (!giveaway) return;

    const channel = await client.channels.fetch(giveaway.channelId) as TextChannel;
    if (!channel) return;

    const message = await channel.messages.fetch(giveaway.messageId);
    if (!message) return;

    const users = await message.reactions.resolve('🎉')?.users.fetch();
    if (!users) return;

    const participants = users.filter(user => !user.bot).map(user => user.id);
    if (participants.length === 0) {
      await channel.send(`No participants for the giveaway: ${giveaway.prize}`);
      return;
    }

    const winners = this.pickWinners(participants, giveaway.winners);

    await channel.send(`Congratulations to the winners of the giveaway for **${giveaway.prize}**: ${winners.map(id => `<@${id}>`).join(', ')}`);

    await prisma.giveaway.delete({
      where: { id: giveawayId },
    });
  }

  private pickWinners(participants: string[], winnerCount: number): string[] {
    const winners = new Set<string>();
    while (winners.size < winnerCount && winners.size < participants.length) {
      const randomIndex = Math.floor(Math.random() * participants.length);
      winners.add(participants[randomIndex]);
    }
    return Array.from(winners);
  }
}

const scheduler = new Scheduler();
export default scheduler;

import cron from 'node-cron';
import { PrismaClient } from '@prisma/client';
import { TextChannel } from 'discord.js';
const prisma = new PrismaClient();


class Scheduler {
  public start() {
    // Run every minute
    cron.schedule('* * * * *', async () => {
      const now = new Date();
      const giveaways = await prisma.giveaway.findMany({
        where: {
          endsAt: {
            lte: now,
          },
        },
      });

      for (const giveaway of giveaways) {
        await this.endGiveaway(giveaway.id);
      }
    });
  }

  private async endGiveaway(giveawayId: number) {
    const giveaway = await prisma.giveaway.findUnique({
      where: { id: giveawayId },
    });

    if (!giveaway) return;

    const channel = await client.channels.fetch(giveaway.channelId) as TextChannel;
    if (!channel) return;

    const message = await channel.messages.fetch(giveaway.messageId);
    if (!message) return;

    const users = await message.reactions.resolve('🎉')?.users.fetch();
    if (!users) return;

    const participants = users.filter(user => !user.bot).map(user => user.id);
    if (participants.length === 0) {
      await channel.send(`No participants for the giveaway: ${giveaway.prize}`);
      return;
    }

    const winners = this.pickWinners(participants, giveaway.winners);

    await channel.send(`Congratulations to the winners of the giveaway for **${giveaway.prize}**: ${winners.map(id => `<@${id}>`).join(', ')}`);

    await prisma.giveaway.delete({
      where: { id: giveawayId },
    });
  }

  private pickWinners(participants: string[], winnerCount: number): string[] {
    const winners = new Set<string>();
    while (winners.size < winnerCount && winners.size < participants.length) {
      const randomIndex = Math.floor(Math.random() * participants.length);
      winners.add(participants[randomIndex]);
    }
    return Array.from(winners);
  }
}

const scheduler = new Scheduler();
export default scheduler;