Function decodeStoredMessageRow

packages/storage/src/sqlite-session-metadata-store.ts:5437–5453

(
  row: { sequence?: unknown; record_json?: unknown },
  sessionId: string,
)

}

function decodeStoredMessageRow(
  row: { sequence?: unknown; record_json?: unknown },
  sessionId: string,
): StoredMessage {
  const sequence = requireStoredMessageSequence(row.sequence, sessionId);
  if (typeof row.record_json !== 'string') {
    throw new StoredSessionMessageIncompatibleError(sessionId, sequence);
  }
  try {
    const parsed = JSON.parse(row.record_json) as unknown;
    return decodeStoredMessage(parsed);
  } catch (error) {
    throw new StoredSessionMessageIncompatibleError(sessionId, sequence, {
      cause: error,
    });
  }
}

interface StoredSessionMessagePayloadRow {
  readonly sequence?: unknown;