Class SlackAdapter

src/runtime/adapters/slack.ts:58–885

// ---------------------------------------------------------------------------

export class SlackAdapter implements PlatformAdapter, MessageSender {
  readonly name = "slack";

  private app: App | null = null;
  private agent: IPackAgent | null = null;
  private readonly options: SlackAdapterOptions;
  private botUserId: string | null = null;
  private lastThreadByChannel = new Map<string, string>();
  private rootDir = "";
  private ipcBroadcaster: IpcBroadcaster | null = null;

  constructor(options: SlackAdapterOptions) {
    this.options = options;
  }

  async start(ctx: AdapterContext): Promise<void> {
    this.agent = ctx.agent;
    this.rootDir = ctx.rootDir;
    this.ipcBroadcaster = ctx.ipcBroadcaster ?? null;

    this.app = new App({
      token: this.options.botToken,
      appToken: this.options.appToken,
      socketMode: true,
      ignoreSelf: true,
      logLevel: LogLevel.INFO,
    });

    const auth = await this.app.client.auth.test({
      token: this.options.botToken,
    });
    this.botUserId =
      typeof auth.user_id === "string" ? auth.user_id : null;

    this.registerListeners(this.app);
    await this.app.start();

    const identity = this.botUserId ? `<@${this.botUserId}>` : "Slack bot";
    console.log(`[SlackAdapter] Started as ${identity}`);
  }

  async stop(): Promise<void> {
    if (this.app) {
      await this.app.stop();
      this.app = null;
    }
    console.log("[SlackAdapter] Stopped");
  }

  // -------------------------------------------------------------------------
  // MessageSender – proactive message sending
  // -------------------------------------------------------------------------

  /**
   * Public method: send a message to a specific Slack channel/DM.
   * channelId formats:
   *   - slack-dm-<teamId>-<channelId>
   *   - slack-thread-<teamId>-<channel>-<threadTs>