Discord-InterChat/InterChat

import { buildConnectionButtons } from '#main/interactions/InactiveConnect.js';
import { updateConnections } from '#utils/ConnectedListUtils.js';
import { emojis } from '#utils/Constants.js';
import db from '#utils/Db.js';
import { InfoEmbed } from '#utils/EmbedUtils.js';
import Logger from '#utils/Logger.js';
import { connectedList } from '@prisma/client';
import { stripIndents } from 'common-tags';
import { WebhookClient } from 'discord.js';
import 'dotenv/config';

export default async () => {
  const connections = await findInactiveConnections();
  if (!connections.length) return;

  // disconnect the channel
  await updateConnections(
    { channelId: { in: connections.map((c) => c.channelId) } },
    { connected: false },
  );

  const embed = new InfoEmbed()
    .removeTitle()
    .setDescription(
      stripIndents`
      ### ${emojis.timeout} Paused Due to Inactivity
      Messages will not be sent to this channel until you reconnect because it has been inactive for over 24 hours.

      -# Click the **button** below or use  **\`/connection unpause\`** to resume chatting.
    `,
    );

  connections.forEach(async (connection) => {
    Logger.debug(
      `[InterChat]: Paused connection ${connection.channelId}. Last message at: ${connection.lastActive.toLocaleString()}.`,
    );

    const webhook = new WebhookClient({ url: connection.webhookURL });
    const button = buildConnectionButtons(false, connection.channelId, { customCustomId: 'inactiveConnect' });
    const components = button ? [button] : [];

    await webhook.send({ embeds: [embed], components }).catch(() => null);
  });
};

async function findInactiveConnections(): Promise<connectedList[]> {
  const twentyFourHoursAgo = new Date(Date.now() - 24 * 60 * 60 * 1000);

  // Find all hubs with at least 50 connections
  const start = performance.now();
  const hubsWithInactiveConnections = await db.hub.findMany({
    where: {
      connections: {
        some: { connected: true, lastActive: { lte: twentyFourHoursAgo } }, // Ensures the hub has at least one connection
      },
    },
    include: {
      connections: { where: { connected: true, lastActive: { lte: twentyFourHoursAgo } } },
    },
  });

  const inactiveConnections = hubsWithInactiveConnections
    .filter((hub) => hub.connections.length >= 50) // small hubs will die out if we pause it
    .flatMap((hub) => hub.connections);

  Logger.info(
    `Found ${inactiveConnections.length} inactive connections in ${performance.now() - start}ms.`,
  );

  return inactiveConnections;
}