Method getShellRunUpdate

packages/runtime/src/session-manager.ts:1349–1396

(sessionId: string, ref: string)

  }

  async getShellRunUpdate(sessionId: string, ref: string): Promise<ShellRunUpdate | null> {
    const shellRuns = this.deps.shellRuns;
    if (!shellRuns) return null;
    const own = await shellRuns.getSessionUpdate(sessionId, ref);
    if (own) return own;

    const messages = await this.readShellRunProjectionMessages(sessionId);
    if (!messages) return null;
    const bashToolCalls = shellRunBashToolCallIds(messages);
    let candidate:
      | {
          turnId: string;
          toolUseId: string;
          result: ShellRunUpdate['result'];
        }
      | undefined;
    for (const message of messages) {
      if (
        message.type === 'tool_result' &&
        bashToolCalls.has(message.toolUseId) &&
        message.content.kind === 'shell_run' &&
        message.content.ref === ref &&
        isActiveShellRunStatus(message.content.status)
      ) {
        const { operation: _operation, ...result } = message.content;
        candidate = { turnId: message.turnId, toolUseId: message.toolUseId, result };
      }
    }
    if (!candidate) return null;

    const inheritedFrom = await this.deps.store.readHeader(sessionId);
    const parentSessionId = inheritedFrom.revisionParentSessionId ?? inheritedFrom.parentSessionId;
    if (!parentSessionId) return null;
    const owner = await this.resolveShellRunOwner(parentSessionId, ref);
    return {
      sessionId,
      ownership: owner
        ? {
            kind: 'source_owned',
            sourceSessionId: parentSessionId,
            ownerSessionId: owner.sessionId,
          }
        : { kind: 'source_unavailable', sourceSessionId: parentSessionId },
      sourceTurnId: candidate.turnId,
      sourceToolCallId: candidate.toolUseId,
      result: owner?.result ?? candidate.result,
    };
  }

  async recoverInterruptedSessions(): Promise<string[]> {
    return this.recoverInterruptedSessionsWithPolicy({ kind: 'best_effort' });