Function decodeStoredMessage

packages/core/src/session.ts:961–1082

(value: unknown)

]);

export function decodeStoredMessage(value: unknown): StoredMessage {
  const message = decodeStoredMessageContent(value, decodeCanonicalToolResultContent);
  if (!isRecord(message)) throw new Error('Invalid stored message schema');
  switch (message.type) {
    case 'user':
      if (
        hasExactShape(message, USER_MESSAGE_SHAPE) &&
        hasMessageEnvelope(message, true) &&
        (message.origin === undefined || decodeTurnOrigin(message.origin) !== undefined)
      ) {
        const { displayText, attachments, quotes, inlineReferences, origin, ...envelope } = message;
        const decodedOrigin = origin === undefined ? undefined : decodeTurnOrigin(origin);
        try {
          return {
            ...envelope,
            ...decodeMessageContent({
              text: message.text,
              displayText,
              attachments,
              quotes,
              inlineReferences,
            }),
            ...(decodedOrigin !== undefined ? { origin: decodedOrigin } : {}),
          } as unknown as UserMessage;
        } catch {
          break;
        }
      }
      break;
    case 'assistant':
      if (
        hasExactShape(message, ASSISTANT_MESSAGE_SHAPE) &&
        hasMessageEnvelope(message, true) &&
        typeof message.text === 'string' &&
        typeof message.modelId === 'string' &&
        (message.providerOptions === undefined || isRecord(message.providerOptions)) &&
        (message.thinking === undefined || isAssistantThinking(message.thinking)) &&
        (message.contentOrder === undefined ||
          (Array.isArray(message.contentOrder) &&
            message.contentOrder.every(
              (item) => item === 'thinking' || item === 'text' || item === 'tools',
            )))
      )
        return message as unknown as AssistantMessage;
      break;
    case 'tool_call':
      if (
        hasExactShape(message, TOOL_CALL_MESSAGE_SHAPE) &&
        hasMessageEnvelope(message, true) &&
        typeof message.toolName === 'string' &&
        Object.hasOwn(message, 'args') &&
        (message.activityKind === undefined ||
          (TOOL_ACTIVITY_KINDS as readonly unknown[]).includes(message.activityKind)) &&
        isOptionalString(message.displayName) &&
        isOptionalString(message.intent) &&
        (message.providerOptions === undefined || isRecord(message.providerOptions)) &&
        (message.providerExecuted === undefined || typeof message.providerExecuted === 'boolean') &&
        isOptionalString(message.stepId) &&