Discord Adapter

npm install @chat-adapter/discord

interface DiscordAdapterConfig {
  /** Bot token */
  botToken: string;
  /** Public key for Ed25519 signature verification */
  publicKey: string;
  /** Application ID (bot user ID) */
  applicationId: string;
  /** Role IDs that trigger mention events (e.g., @moderators) */
  mentionRoleIds?: string[];
  /** Logger instance */
  logger: Logger;
  /** Override bot username */
  userName?: string;
}

import { Chat } from 'chat';
import { createDiscordAdapter } from '@chat-adapter/discord';
import { MemoryState } from '@chat-adapter/state-memory';

const chat = new Chat({
  userName: 'my-bot',
  adapters: {
    discord: createDiscordAdapter({
      botToken: process.env.DISCORD_BOT_TOKEN!,
      publicKey: process.env.DISCORD_PUBLIC_KEY!,
      applicationId: process.env.DISCORD_APPLICATION_ID!,
    }),
  },
  state: new MemoryState(),
});

await chat.initialize();

app.post('/webhooks/discord', async (req, res) => {
  const response = await discord.handleWebhook(req, {
    waitUntil: (promise) => {/* handle async work */},
  });
  res.status(response.status).send(await response.text());
});

// Start Gateway listener (keeps WebSocket connection alive)
await discord.startGatewayListener(
  { waitUntil: (p) => {/* keep alive */} },
  180000, // Duration in ms (3 minutes)
  undefined, // AbortSignal (optional)
  'https://your-app.com/webhooks/discord' // Forward events to webhook
);

// The Gateway listener forwards events like:
// - GATEWAY_MESSAGE_CREATE
// - GATEWAY_MESSAGE_REACTION_ADD
// - GATEWAY_MESSAGE_REACTION_REMOVE

// Your webhook handler processes both HTTP Interactions and forwarded Gateway events
app.post('/webhooks/discord', async (req, res) => {
  // Automatically detects interaction type vs. forwarded Gateway event
  const response = await discord.handleWebhook(req);
  res.status(response.status).send(await response.text());
});

chat.onSlashCommand('/deploy', async (event) => {
  await event.channel.post(`Deploying ${event.text}...`);
});

import { Card, Section, Button } from 'chat/cards';

await thread.post(
  <Card title="Moderation Action">
    <Section text="User reported for spam" />
    <Button actionId="ban_user" style="danger">Ban User</Button>
    <Button actionId="warn_user">Warn</Button>
    <Button actionId="dismiss">Dismiss</Button>
  </Card>
);

chat.onAction('ban_user', async (event) => {
  await event.thread.post('User has been banned.');
});

import { Card, Section } from 'chat/cards';

await thread.post(
  <Card title="Build Status" style="primary">
    <Section text="Build #42 completed successfully" />
  </Card>
);

// Unicode emoji
await thread.addReaction(messageId, '👍');
await thread.removeReaction(messageId, '👍');

// Custom emoji (must be from the same server)
await thread.addReaction(messageId, { name: 'custom_emoji', id: '123456789' });

import { readFileSync } from 'fs';

await thread.post({
  text: 'Server logs',
  files: [{
    filename: 'server.log',
    data: readFileSync('./server.log'),
    mimeType: 'text/plain',
  }],
});

// When a message is in a thread, the adapter encodes:
// discord:{guildId}:{parentChannelId}:{threadId}

// When mentioned in a channel (not in a thread), a new thread is auto-created

discord:{guildId}:{channelId}:{threadId}

const dmThreadId = await discord.openDM(userId);
await chat.getThread(dmThreadId).post('Hello!');

const { messages, nextCursor } = await thread.fetchMessages({
  limit: 50,
  direction: 'backward',
  cursor: previousCursor, // Optional for pagination
});