Class FeishuBotBridge

packages/runtime/src/bots/feishu-bridge.ts:58–229

/** Feishu/Lark long-connection bridge backed by the official Channel API. */
export class FeishuBotBridge extends BaseBotAdapter implements SendCapable {
  private channel: LarkChannel | null = null;
  private unsubscribe: Array<() => void> = [];
  private explicitlyStopped = false;

  constructor(settings: BotChannelSettings) {
    super('feishu', settings);
  }

  async start(): Promise<void> {
    if (this.running) return;
    if (!this.settings.enabled) {
      this.reason = 'disabled';
      this.readiness = 'scaffolded';
      return;
    }
    const appId = this.settings.appId?.trim() ?? '';
    const appSecret = this.settings.appSecret?.trim() || this.settings.token.trim();
    if (!appId || !appSecret) {
      this.reason = 'missing-feishu-credentials';
      this.readiness = 'scaffolded';
      this.emitStatusChange();
      return;
    }

    this.explicitlyStopped = false;
    const isLark = this.settings.domain?.trim() === 'larksuite.com';
    const channel = createLarkChannel({
      appId,
      appSecret,
      domain: isLark ? Domain.Lark : Domain.Feishu,
      transport: 'websocket',
      source: 'maka',
      loggerLevel: LoggerLevel.error,
      handshakeTimeoutMs: HANDSHAKE_TIMEOUT_MS,
      policy: {
        dmMode: this.settings.allowedUserIds?.length ? 'allowlist' : 'open',
        dmAllowlist: [...(this.settings.allowedUserIds ?? [])],
        requireMention: false,
      },
    });
    this.channel = channel;
    this.wire(channel, appId);

    try {
      await channel.connect();
      if (this.explicitlyStopped || this.channel !== channel) return;
      this.startedAt = Date.now();
      this.markConnected(channel, appId);
    } catch (error) {
      if (this.explicitlyStopped || this.channel !== channel) return;
      this.running = false;
      this.reason = generalizedErrorMessage(error);
      this.readiness = 'configured';
      this.emitStatusChange();
      await this.disconnectChannel(channel);
    }
  }