fix(results): support legacy render refs

src/results/resolver.ts

@@ -1,5 +1,5 @@
 import { config } from "../config.js";
-import { readJsonFile } from "../utils/fileStore.js";
+import { atomicWriteJson, readJsonFile } from "../utils/fileStore.js";
 import {
   type ResultReferenceKind,
   type ResultReferenceRecord,
@@ -68,7 +68,15 @@ export class ResultReferenceResolver {
       throw new Error(`render payload file not found: ${filePath}`);
     }
 
-    const payload = extractRenderJunctionPayload(raw);
+    const payloadCandidate = normalizeRenderPayloadFile(raw, {
+      filePath,
+      projectId: input.projectId,
+    });
+    if (payloadCandidate.repaired) {
+      await atomicWriteJson(filePath, payloadCandidate.file);
+    }
+
+    const payload = extractRenderJunctionPayload(payloadCandidate.data);
     if (!payload) {
       throw new Error("render payload file does not contain a valid junction render payload");
     }
@@ -192,6 +200,39 @@ const normalizeDataForKind = (
   return data;
 };
 
+const normalizeRenderPayloadFile = (
+  value: unknown,
+  context: { filePath: string; projectId?: string },
+): { data: unknown; file: Record<string, unknown>; repaired: boolean } => {
+  if (!isRecord(value) || !("data" in value)) {
+    return {
+      data: value,
+      file: {
+        metadata: buildWrapperMetadata({}, value, context.projectId),
+        location: buildWrapperLocation(undefined, context.filePath),
+        data: value,
+      },
+      repaired: false,
+    };
+  }
+
+  const metadata = buildWrapperMetadata(value.metadata, value, context.projectId);
+  const location = buildWrapperLocation(value.location, context.filePath);
+  const next: Record<string, unknown> = {
+    ...value,
+    metadata,
+    location,
+  };
+
+  return {
+    data: next.data,
+    file: next,
+    repaired:
+      JSON.stringify(metadata) !== JSON.stringify(value.metadata ?? null) ||
+      JSON.stringify(location) !== JSON.stringify(value.location ?? null),
+  };
+};
+
 const unwrapReferencePayload = (value: unknown): Record<string, unknown> | null => {
   if (!isRecord(value)) {
     return null;
@@ -221,3 +262,48 @@ const projectData = (data: unknown, maxItems: number) => {
 
 const isRecord = (value: unknown): value is Record<string, unknown> =>
   typeof value === "object" && value !== null && !Array.isArray(value);
+
+const buildWrapperMetadata = (
+  value: unknown,
+  root: unknown,
+  fallbackProjectId?: string,
+) => {
+  const metadata = isRecord(value) ? { ...value } : {};
+  const source = isRecord(root) ? root : {};
+
+  if (typeof metadata.createdAt !== "string" || metadata.createdAt.trim().length === 0) {
+    const createdAt =
+      typeof source.createdAt === "string" && source.createdAt.trim().length > 0
+        ? source.createdAt.trim()
+        : new Date().toISOString();
+    metadata.createdAt = createdAt;
+  }
+
+  if (
+    typeof metadata.projectId !== "string" ||
+    metadata.projectId.trim().length === 0
+  ) {
+    const projectId =
+      typeof source.projectId === "string" && source.projectId.trim().length > 0
+        ? source.projectId.trim()
+        : fallbackProjectId;
+    if (projectId) {
+      metadata.projectId = projectId;
+    }
+  }
+
+  return metadata;
+};
+
+const buildWrapperLocation = (value: unknown, filePath: string) => {
+  if (isRecord(value)) {
+    return {
+      ...value,
+      file_path: filePath,
+    };
+  }
+
+  return {
+    file_path: filePath,
+  };
+};

src/results/store.ts

@@ -10,9 +10,11 @@ import {
   listJsonFiles,
   readJsonFile,
   removeFileIfExists,
+  toProjectKey,
 } from "../utils/fileStore.js";
 
-export const RESULT_REF_PATTERN = /^res-[a-f0-9-]{16}$/;
+export const RESULT_REF_PATTERN = /^res-[a-f0-9-]{8,64}$/;
+const RESULT_REF_FILE_PATTERN = /^(res-[a-f0-9-]{8,64})(?:\.json)?$/;
 
 export const RESULT_REFERENCE_KIND = {
   dynamicHttpResult: "dynamic-http-result",
@@ -138,12 +140,15 @@ export class ResultReferenceStore {
   }
 
   async getAuthorizedRecord(resultRef: string, context: RetrievalContext) {
-    if (!RESULT_REF_PATTERN.test(resultRef)) {
+    const normalizedResultRef = normalizeResultRef(resultRef);
+    if (!normalizedResultRef) {
       return null;
     }
 
-    const rawRecord = await readJsonFile<unknown>(this.filePath(resultRef));
-    const record = normalizeResultReferenceRecord(rawRecord);
+    const rawRecord = await readJsonFile<unknown>(this.filePath(normalizedResultRef));
+    const record =
+      normalizeResultReferenceRecord(rawRecord) ??
+      normalizeLegacyRenderReferenceRecord(rawRecord, normalizedResultRef, context);
     if (!record) {
       return null;
     }
@@ -301,6 +306,65 @@ const normalizeResultReferenceSource = (
 const isValidResultRef = (value: unknown): value is string =>
   typeof value === "string" && RESULT_REF_PATTERN.test(value);
 
+const normalizeResultRef = (value: string) => {
+  const match = value.trim().match(RESULT_REF_FILE_PATTERN);
+  return match?.[1] ?? null;
+};
+
+const normalizeLegacyRenderReferenceRecord = (
+  value: unknown,
+  resultRef: string,
+  context: RetrievalContext,
+): ResultReferenceRecord | null => {
+  const data = extractLegacyRenderPayload(value);
+  if (!data) {
+    return null;
+  }
+
+  const root = isRecord(value) ? value : {};
+  const metadata = isRecord(root.metadata) ? root.metadata : {};
+  const projectId = firstNonEmptyString(root.projectId, metadata.projectId);
+  const createdAt =
+    firstNonEmptyString(root.createdAt, metadata.createdAt) ?? new Date().toISOString();
+
+  return {
+    resultRef,
+    actorKey: context.actorKey,
+    clientSessionId: context.clientSessionId ?? "",
+    createdAt,
+    data,
+    kind: RESULT_REFERENCE_KIND.renderJunctionsPayload,
+    preview: buildPreview(data),
+    projectId,
+    projectKey: toProjectKey(projectId),
+    schemaVersion: 1,
+    sessionId: context.clientSessionId ?? resultRef,
+    sizeBytes: estimateBytes(data),
+    source: RESULT_REFERENCE_SOURCE.legacy,
+    traceId: "legacy-render-ref",
+  };
+};
+
+const extractLegacyRenderPayload = (value: unknown) => {
+  if (!isRecord(value)) {
+    return null;
+  }
+  const candidate = isRecord(value.data) ? value.data : value;
+  if (!isRecord(candidate.node_area_map)) {
+    return null;
+  }
+  return candidate;
+};
+
+const firstNonEmptyString = (...values: unknown[]) => {
+  for (const value of values) {
+    if (typeof value === "string" && value.trim().length > 0) {
+      return value.trim();
+    }
+  }
+  return undefined;
+};
+
 const isResultPreview = (value: unknown): value is ResultPreview =>
   isRecord(value) &&
   typeof value.count === "number" &&