reacord/packages/reacord/library/reacord-client.ts

import type { APIInteraction } from "discord.js"
import {
  Client,
  GatewayDispatchEvents,
  GatewayIntentBits,
  InteractionType,
} from "discord.js"
import * as React from "react"
import type { ReacordInstance } from "./reacord-instance.js"
import { ReacordInstancePrivate } from "./reacord-instance.js"
import { InstanceProvider } from "./react/instance-context"
import type { Renderer } from "./renderer.js"
import {
  ChannelMessageRenderer,
  EphemeralInteractionReplyRenderer,
  InteractionReplyRenderer,
} from "./renderer.js"

/**
 * @category Core
 */
export type ReacordConfig = {
  /** Discord bot token */
  token: string

  /**
   * The max number of active instances.
   * When this limit is exceeded, the oldest instances will be cleaned up
   * to prevent memory leaks.
   */
  maxInstances?: number
}

/**
 * Info for replying to an interaction. For Discord.js
 * (and probably other libraries) you should be able to pass the
 * interaction object directly:
 * ```js
 * client.on("interactionCreate", (interaction) => {
 *   if (interaction.isChatInputCommand() && interaction.commandName === "hi") {
 *     interaction.reply("hi lol")
 *   }
 * })
 * ```
 */
export type InteractionInfo = {
  id: string
  token: string
}

/**
 * @category Core
 */
export class ReacordClient {
  private readonly config: Required<ReacordConfig>
  private readonly client: Client
  private instances: ReacordInstancePrivate[] = []
  private destroyed = false

  constructor(config: ReacordConfig) {
    this.config = {
      ...config,
      maxInstances: config.maxInstances ?? 50,
    }

    this.client = new Client({ intents: [GatewayIntentBits.Guilds] })
    this.client.login(this.config.token).catch(console.error)

    this.client.ws.on(
      GatewayDispatchEvents.InteractionCreate,
      (interaction: APIInteraction) => {
        if (interaction.type !== InteractionType.MessageComponent) return
        for (const instance of this.instances) {
          instance.handleInteraction(interaction, this)
        }
      },
    )
  }

  send(channelId: string, initialContent?: React.ReactNode): ReacordInstance {
    return this.createInstance(
      new ChannelMessageRenderer(channelId, this.client),
      initialContent,
    )
  }

  reply(
    interaction: InteractionInfo,
    initialContent?: React.ReactNode,
  ): ReacordInstance {
    return this.createInstance(
      new InteractionReplyRenderer(interaction),
      initialContent,
    )
  }

  ephemeralReply(
    interaction: InteractionInfo,
    initialContent?: React.ReactNode,
  ): ReacordInstance {
    return this.createInstance(
      new EphemeralInteractionReplyRenderer(interaction),
      initialContent,
    )
  }

  destroy() {
    this.client.destroy()
    this.destroyed = true
  }

  private createInstance(
    renderer: Renderer,
    initialContent?: React.ReactNode,
  ): ReacordInstance {
    if (this.destroyed) throw new Error("ReacordClient is destroyed")

    const instance = new ReacordInstancePrivate(renderer)

    this.instances.push(instance)

    if (this.instances.length > this.config.maxInstances) {
      void this.instances[0]?.deactivate()
      this.removeInstance(this.instances[0]!)
    }

    const publicInstance: ReacordInstance = {
      render: (content: React.ReactNode) => {
        instance.render(
          React.createElement(
            InstanceProvider,
            { value: publicInstance },
            content,
          ),
        )
      },
      deactivate: () => {
        this.removeInstance(instance)
        renderer.deactivate().catch(console.error)
      },
      destroy: () => {
        this.removeInstance(instance)
        renderer.destroy().catch(console.error)
      },
    }

    if (initialContent !== undefined) {
      publicInstance.render(initialContent)
    }

    return publicInstance
  }

  private removeInstance(instance: ReacordInstancePrivate) {
    this.instances = this.instances.filter((the) => the !== instance)
  }
}