Method updateChatSubscription

vscode/src/extension.ts:1670–1756

()

  }

  private async updateChatSubscription(): Promise<void> {
    if (!this.isWebviewReady || !this.view) {
      return;
    }

    const workspaceId = this.selectedWorkspaceId;
    if (!workspaceId || this.connectionStatus.mode !== "api") {
      this.subscriptionAbort?.abort();
      this.subscriptionAbort = null;
      this.subscribedWorkspaceId = null;
      return;
    }

    if (
      this.subscribedWorkspaceId === workspaceId &&
      this.subscriptionAbort &&
      !this.subscriptionAbort.signal.aborted
    ) {
      return;
    }

    this.subscriptionAbort?.abort();

    const controller = new AbortController();
    this.subscriptionAbort = controller;
    this.subscribedWorkspaceId = workspaceId;

    this.postMessage({ type: "chatReset", workspaceId });

    const api = await tryGetApiClient(this.context);
    if ("failure" in api) {
      // Drop back to file mode (chat disabled).
      this.connectionStatus = {
        mode: "file",
        baseUrl: api.failure.baseUrl,
        error: `${describeFailure(api.failure)}. (${api.failure.error})`,
      };
      this.postMessage({ type: "connectionStatus", status: this.connectionStatus });
      this.postMessage({
        type: "uiNotice",
        level: "error",
        message: this.connectionStatus.error ?? "mux server unavailable",
      });

      controller.abort();
      if (this.subscriptionAbort === controller) {
        this.subscriptionAbort = null;
        this.subscribedWorkspaceId = null;
      }
      return;
    }

    try {
      const iterator = await api.client.workspace.onChat(
        { workspaceId },
        { signal: controller.signal }
      );