Function recoverFromContent

packages/utils/src/lib/wal.ts:104–139

(
  content: string,
  decode: Codec<T>['decode'],
)

 * @returns Recovery result with records, errors, and partial tail
 */
export function recoverFromContent<T>(
  content: string,
  decode: Codec<T>['decode'],
): RecoverResult<T> {
  const lines = content.split('\n');
  const clean = content.endsWith('\n');

  const out = lines.slice(0, -1).reduce(
    (a, l, i) => {
      if (!l) {
        return a;
      }
      try {
        return {
          ...a,
          records: [...a.records, decode(l)],
        };
      } catch (error) {
        return {
          ...a,
          errors: [
            ...a.errors,
            { lineNo: i + 1, line: l, error: error as Error },
          ],
        };
      }
    },
    { records: [] as T[], errors: [] as RecoverResult<T>['errors'] },
  );

  const tail = lines.at(-1);
  return {
    ...out,
    partialTail: clean || !tail ? null : tail,
  };
}

/**
 * Write-Ahead Log implementation for crash-safe append-only logging.