Function upsertSubagentReportArtifact

src/node/services/subagentReportArtifacts.ts:242–349

(params: {
  /** Workspace id that owns the session dir we're writing into (used for file locking). */
  workspaceId: string;
  workspaceSessionDir: string;
  childTaskId: string;
  parentWorkspaceId: string;
  ancestorWorkspaceIds: string[];
  reportMarkdown: string;
  /** Task-level model string used when running the sub-agent (optional for legacy entries). */
  model?: string;
  /** Task-level thinking/reasoning level used when running the sub-agent (optional for legacy entries). */
  thinkingLevel?: ThinkingLevel;
  workflowOwnedAncestorWorkspaceIds?: string[];
  planFilePath?: string;
  structuredOutput?: unknown;
  title?: string;
  nowMs?: number;
})

}

export async function upsertSubagentReportArtifact(params: {
  /** Workspace id that owns the session dir we're writing into (used for file locking). */
  workspaceId: string;
  workspaceSessionDir: string;
  childTaskId: string;
  parentWorkspaceId: string;
  ancestorWorkspaceIds: string[];
  reportMarkdown: string;
  /** Task-level model string used when running the sub-agent (optional for legacy entries). */
  model?: string;
  /** Task-level thinking/reasoning level used when running the sub-agent (optional for legacy entries). */
  thinkingLevel?: ThinkingLevel;
  workflowOwnedAncestorWorkspaceIds?: string[];
  planFilePath?: string;
  structuredOutput?: unknown;
  title?: string;
  nowMs?: number;
}): Promise<SubagentReportArtifactIndexEntry> {
  let updated: SubagentReportArtifactIndexEntry | null = null;

  await workspaceFileLocks.withLock(params.workspaceId, async () => {
    const nowMs = params.nowMs ?? Date.now();

    const model =
      typeof params.model === "string" && params.model.trim().length > 0
        ? params.model.trim()
        : undefined;
    const thinkingLevel = coerceThinkingLevel(params.thinkingLevel);

    const planFilePath =
      typeof params.planFilePath === "string" && params.planFilePath.trim().length > 0
        ? params.planFilePath.trim()
        : undefined;

    const file = await readSubagentReportArtifactsFile(params.workspaceSessionDir);
    const existing = file.artifactsByChildTaskId[params.childTaskId] ?? null;
    const createdAtMs = existing?.createdAtMs ?? nowMs;

    // Write the report payload first so we never publish an index entry without a report body.
    const reportPath = getSubagentReportArtifactPath(
      params.workspaceSessionDir,
      params.childTaskId
    );
    try {
      await fsPromises.mkdir(path.dirname(reportPath), { recursive: true });
      await writeFileAtomic(
        reportPath,
        JSON.stringify(
          {
            childTaskId: params.childTaskId,
            parentWorkspaceId: params.parentWorkspaceId,
            createdAtMs,
            updatedAtMs: nowMs,
            model,
            thinkingLevel,
            title: params.title,
            ancestorWorkspaceIds: params.ancestorWorkspaceIds,
            workflowOwnedAncestorWorkspaceIds: params.workflowOwnedAncestorWorkspaceIds,