Method wire

packages/runtime/src/bots/feishu-bridge.ts:176–205

(channel: LarkChannel, appId: string)

  }

  private wire(channel: LarkChannel, appId: string): void {
    this.unsubscribe.push(
      channel.on('message', (message) => {
        const receivedAt = Date.now();
        const event = feishuMessageToEvent(message, receivedAt, this.settings.allowedUserIds);
        if (!event || this.channel !== channel) return;
        this.lastEventAt = receivedAt;
        this.readiness = 'operational';
        this.reason = undefined;
        this.emitIncomingMessage(event);
        this.emitStatusChange();
      }),
      channel.on('error', (error) => {
        if (this.channel !== channel || this.explicitlyStopped) return;
        this.reason = generalizedErrorMessage(error);
        this.readiness = this.readiness === 'operational' ? 'degraded' : 'configured';
        this.emitStatusChange();
      }),
      channel.on('reconnecting', () => {
        if (this.channel !== channel || this.explicitlyStopped) return;
        this.running = false;
        this.reason = 'reconnecting';
        this.emitStatusChange();
      }),
      channel.on('reconnected', () => {
        if (this.channel !== channel || this.explicitlyStopped) return;
        this.markConnected(channel, appId);
      }),
    );
  }

  /** Shared connected-state transition for the initial handshake and reconnects. */
  private markConnected(channel: LarkChannel, appId: string): void {