Function getMaxMessageTimestampFromFile

packages/sync/src/pull-engine.ts:105–141

(filePath: string)

}

function getMaxMessageTimestampFromFile(filePath: string): number | null {
  try {
    let maxTs: number | null = null
    const visitTimestamp = (value: unknown) => {
      const ts = typeof value === 'string' && value.trim() !== '' ? Number(value) : value
      if (typeof ts === 'number' && Number.isFinite(ts)) {
        maxTs = maxTs === null ? ts : Math.max(maxTs, ts)
      }
    }

    if (filePath.endsWith('.jsonl')) {
      const content = fs.readFileSync(filePath, 'utf-8')
      for (const line of content.split('\n')) {
        const trimmed = line.trim()
        if (!trimmed) continue
        try {
          const obj = JSON.parse(trimmed)
          if (obj._type === 'message') visitTimestamp(obj.timestamp)
        } catch {
          continue
        }
      }
      return maxTs
    }

    const raw = fs.readFileSync(filePath, 'utf-8')
    const parsed = JSON.parse(raw)
    if (Array.isArray(parsed.messages)) {
      for (const message of parsed.messages) {
        visitTimestamp(message?.timestamp)
      }
    }
    return maxTs
  } catch {
    return null
  }
}

function cleanupTempFile(filePath: string): void {
  try {