Method settleWorkspaceTurn

src/node/services/taskService.ts:4752–4882

(params: {
    record: WorkspaceTurnTaskHandleRecord;
    next: WorkspaceTurnTaskHandleRecord;
    waiterSettlement:
      | { status: "completed"; result: WorkspaceTurnWaitResult }
      | { status: "error"; error: Error };
  })

  }

  private async settleWorkspaceTurn(params: {
    record: WorkspaceTurnTaskHandleRecord;
    next: WorkspaceTurnTaskHandleRecord;
    waiterSettlement:
      | { status: "completed"; result: WorkspaceTurnWaitResult }
      | { status: "error"; error: Error };
  }): Promise<void> {
    assert(
      params.next.handleId === params.record.handleId,
      "settleWorkspaceTurn requires stable handleId"
    );
    assert(
      params.next.workspaceId === params.record.workspaceId,
      "settleWorkspaceTurn requires stable workspaceId"
    );

    // The settlement lock only persists durable state and resolves waiters. The terminal wake-up is
    // enqueued AFTER the lock is released (no sendMessage / notifier work while holding the lock).
    const pendingNotify = await this.workspaceTurnSettlementLocks.withLock(
      params.record.handleId,
      async (): Promise<
        | { kind: "notify"; outcome: TerminalAttentionOutcome; title?: string }
        | { kind: "drain_pending" }
        | null
      > => {
        const current = await this.taskHandleStore.getWorkspaceTurn(
          params.record.ownerWorkspaceId,
          params.record.handleId
        );
        if (current == null) {
          return null;
        }
        assert(
          current.workspaceId === params.record.workspaceId,
          "settleWorkspaceTurn requires current record to match workspaceId"
        );

        if (this.isTerminalWorkspaceTurnStatus(current.status)) {
          const active = this.activeWorkspaceTurnHandleByWorkspaceId.get(params.record.workspaceId);
          if (
            active?.handleId === params.record.handleId &&
            active.ownerWorkspaceId === params.record.ownerWorkspaceId
          ) {
            this.activeWorkspaceTurnHandleByWorkspaceId.delete(params.record.workspaceId);
          }
          this.settleWorkspaceTurnWaiters(
            current.handleId,
            current.status === "completed"
              ? { status: "completed", result: this.buildWorkspaceTurnWaitResult(current) }
              : {
                  status: "error",
                  error: new Error(
                    current.error ??
                      (current.status === "interrupted"
                        ? "Workspace turn interrupted"
                        : "Workspace turn failed")
                  ),
                }