Class SlackAdapter

packages/bot-slack/src/adapter.ts:108–987

/** Slack `PlatformAdapter`: ingress via Bolt, egress via Block Kit + streaming. */
export class SlackAdapter implements PlatformAdapter {
  readonly platform = "slack";
  readonly capabilities: SurfaceCapabilities;
  readonly ackDeadlineMs = 3000;

  readonly app: App;
  client: WebClient;
  botUserId = "";
  private readonly store: SlackConversationStore;
  private sink: IngressSink | undefined;
  /** Per-id cache for sender-profile resolution (repeat turns are cheap). */
  private readonly userCache = new Map<string, PlatformUser>();
  /** Set once the Assistant middleware is attached (when assistant !== false). */
  private assistantHandle: AssistantHandle | undefined;
  /** Our team id (from auth.test); native channel streams need it. */
  private teamId: string | undefined;
  /**
   * In-memory native-streaming health for this workspace. Flipped to false the
   * first time `chat.startStream` fails, so subsequent streams skip the native
   * path and go straight to the legacy transport.
   */
  private nativeStreamingOk = true;
  /**
   * In-memory health of native structured `task_update` chunks for this
   * workspace. Flipped to false the first time a chunk append fails (old
   * workspace / missing `assistant:write`), so later turns surface tool
   * progress as `:wrench:` rows instead of retrying chunks.
   */
  private nativeTaskChunksOk = true;

  constructor(private readonly opts: SlackAdapterOptions) {
    const assistantEnabled = opts.assistant !== false;
    this.capabilities = {
      supportsModals: true,
      supportsTyping: false,
      supportsReactions: true,
      supportsStreaming: true,
      supportsEphemeral: true,
      maxBlocksPerMessage: 50,
      supportsSuggestedPrompts: assistantEnabled,
      supportsThreadTitle: assistantEnabled,
    };
    this.app = new App({
      token: opts.botToken,
      appToken: opts.appToken,
      signingSecret: opts.signingSecret,
      socketMode: opts.socketMode ?? true,
      logLevel: opts.logLevel ?? LogLevel.INFO,
      // Without this, Bolt's constructor fires a background auth.test that
      // can't be awaited or error-handled (and phones home from unit tests).
      // start() owns initialization: app.init() below, then our own awaited
      // auth.test — construction stays side-effect-free.
      deferInitialization: true,
    });
    this.client = this.app.client;
    this.store = new SlackConversationStore({
      client: this.client,
      botUserId: "",