Function storeLargeValue

apps/sim/lib/execution/payloads/store.ts:162–202

(
  value: unknown,
  json: string,
  size: number,
  context: LargeValueStoreContext
)

}

export async function storeLargeValue(
  value: unknown,
  json: string,
  size: number,
  context: LargeValueStoreContext
): Promise<LargeValueRef> {
  assertDurableLargeValueSize(size)
  const referencedKeys = collectLargeValueKeys(value)
  const id = `lv_${generateShortId(12)}`
  let key = await persistValue(id, json, context)
  if (key) {
    // Only clean up the uploaded object when registration definitively did NOT
    // record ownership (returns false). If registration THROWS, the metadata
    // state is uncertain (a row may have partially committed), so we propagate
    // without deleting — deleting could orphan a metadata row pointing at a
    // now-missing object.
    const registered = await registerPersistedValueOwner(key, size, referencedKeys, context)
    if (!registered) {
      await deleteUntrackedPersistedValue(key)
      if (context.requireDurable) {
        throw new Error('Failed to persist large execution value metadata')
      }
      key = undefined
    }
  }
  const cached = cacheLargeValue(id, value, size, context, { recoverable: Boolean(key) })
  if (!key && !cached) {
    throw new Error('Cannot retain large execution value without durable storage')
  }

  return {
    __simLargeValueRef: true,
    version: LARGE_VALUE_REF_VERSION,
    id,
    kind: getKind(value),
    size,
    key,
    executionId: context.executionId,
    preview: getPreview(value),
  }
}

export async function materializeLargeValueRef(
  ref: LargeValueRef,