Function queryStats

packages/node-runtime/src/services/push-importer.ts:123–133

(db: DatabaseAdapter)

}

function queryStats(db: DatabaseAdapter): PushImportResult['session'] {
  const row = db.prepare('SELECT COUNT(*) as total, MIN(ts) as first, MAX(ts) as last FROM message').get() as {
    total: number
    first: number | null
    last: number | null
  }
  const memberRow = db
    .prepare(`SELECT COUNT(*) as cnt FROM member WHERE COALESCE(account_name, '') != ?`)
    .get(SYSTEM_MEMBER_NAME) as { cnt: number }
  return { totalCount: row.total, memberCount: memberRow.cnt, firstTimestamp: row.first, lastTimestamp: row.last }
}

function normalizeSenderAccountName(sender: string, accountName: string | undefined): string | undefined {
  return sender === SYSTEM_SENDER_ID ? SYSTEM_MEMBER_NAME : accountName