Function parseLocalMemoryMarkdownRaw

packages/core/src/local-memory.ts:621–711

(input: string)

}

function parseLocalMemoryMarkdownRaw(input: string): LocalMemoryRawParseResult {
  const size = new TextEncoder().encode(input).byteLength;
  if (size > LOCAL_MEMORY_MAX_BYTES) {
    return {
      entries: [],
      activeEntries: [],
      archivedEntries: [],
      safeMode: true,
      reason: 'oversize',
    };
  }
  if (input.trim().length === 0) {
    return {
      entries: [],
      activeEntries: [],
      archivedEntries: [],
      safeMode: false,
      reason: 'empty',
    };
  }

  const entries: LocalMemoryRawEntry[] = [];
  const lines = input.split(/\r?\n/);
  let current: { title: string; body: string[]; meta?: Record<string, string> } | null = null;

  const flush = () => {
    if (!current) return;
    const content = current.body.join('\n').trim();
    if (content.length > 0) {
      const id = current.meta?.id || slugId(current.title);
      const origin = normalizeOrigin(current.meta?.origin);
      const source = normalizeSource(current.meta?.source, origin);
      const status = normalizeEntryStatus(current.meta?.status, false);
      const scope = normalizeScope(current.meta?.scope);
      const createdAt = parseFiniteNumber(current.meta?.createdAt);
      const updatedAt = parseFiniteNumber(current.meta?.updatedAt);
      const proposedAt = parseFiniteNumber(current.meta?.proposedAt);
      const confirmedAt = parseFiniteNumber(current.meta?.confirmedAt);
      const archivedAt = parseFiniteNumber(current.meta?.archivedAt);
      const rejectedAt = parseFiniteNumber(current.meta?.rejectedAt);
      const decayTtlMs = parseFiniteNumber(current.meta?.decayTtlMs);
      const approvedBy = current.meta?.approvedBy === 'user' ? 'user' : undefined;
      const approvalSurface = normalizeApprovalSurface(current.meta?.approvalSurface);
      entries.push({
        id,
        origin,
        source,
        status,
        title: current.title,
        content: content.slice(0, 500),
        promptContent: content,
        scope,
        ...(current.meta?.sessionId ? { sessionId: current.meta.sessionId } : {}),
        ...(current.meta?.proposalId ? { proposalId: current.meta.proposalId } : {}),
        ...(current.meta?.sourceTurnId ? { sourceTurnId: current.meta.sourceTurnId } : {}),
        ...(Number.isFinite(createdAt) ? { createdAt } : {}),
        ...(Number.isFinite(updatedAt) ? { updatedAt } : {}),
        ...(Number.isFinite(proposedAt) ? { proposedAt } : {}),