Method openConnection

packages/runtime/src/bots/dingtalk-bridge.ts:265–314

()

  }

  protected override async openConnection(): Promise<void> {
    const token = await this.refreshTokenIfNeeded();
    if (!token) {
      this.readiness = 'configured';
      this.emitStatusChange();
      this.scheduleReconnect();
      return;
    }
    try {
      const response = await proxiedFetch(`${DINGTALK_API}/v1.0/gateway/connections/open`, {
        method: 'POST',
        headers: {
          'Content-Type': 'application/json',
          'x-acs-dingtalk-access-token': token,
        },
        body: JSON.stringify({
          clientId: this.settings.appId?.trim(),
          clientSecret: this.settings.appSecret?.trim(),
          subscriptions: [
            { type: 'EVENT', topic: '*' },
            { type: 'CALLBACK', topic: DINGTALK_TOPIC_BOT_MESSAGES },
          ],
          ua: 'Maka/0.1',
          localIp: '127.0.0.1',
        }),
        timeoutMs: 10_000,
      });
      const json = (await response
        .json()
        .catch(() => null)) as DingTalkConnectionOpenResponse | null;
      if (
        !response.ok ||
        !json ||
        typeof json.endpoint !== 'string' ||
        typeof json.ticket !== 'string'
      ) {
        this.reason = `connections-open-${response.status}`;
        this.readiness = 'configured';
        this.emitStatusChange();
        this.scheduleReconnect();
        return;
      }
      this.connect(`${json.endpoint}?ticket=${encodeURIComponent(json.ticket)}`);
    } catch (error) {
      this.reason = error instanceof Error ? error.message : String(error);
      this.readiness = 'configured';
      this.emitStatusChange();
      this.scheduleReconnect();
    }
  }

  protected override handleWsMessage(raw: string): void {
    let frame: DingTalkStreamFrame;