Function getSegmentSummaries

packages/core/src/query/session-queries.ts:310–366

(
  db: DatabaseAdapter,
  options?: { limit?: number; timeFilter?: TimeFilter }
)

 * Get session summaries (only sessions that have AI-generated summaries)
 */
export function getSegmentSummaries(
  db: DatabaseAdapter,
  options?: { limit?: number; timeFilter?: TimeFilter }
): SegmentSummaryData[] {
  if (!hasTable(db, 'segment')) return []

  const { limit = 50, timeFilter } = options ?? {}

  let sql = `
    SELECT cs.id, cs.start_ts as startTs, cs.end_ts as endTs,
           cs.message_count as messageCount, cs.summary
    FROM segment cs
    WHERE cs.summary IS NOT NULL AND cs.summary != ''
  `
  const params: unknown[] = []

  if (timeFilter?.startTs !== undefined) {
    sql += ' AND cs.start_ts >= ?'
    params.push(timeFilter.startTs)
  }
  if (timeFilter?.endTs !== undefined) {
    sql += ' AND cs.start_ts <= ?'
    params.push(timeFilter.endTs)
  }

  sql += ' ORDER BY cs.start_ts DESC LIMIT ?'
  params.push(limit)

  const sessions = db.prepare(sql).all(...params) as Array<{
    id: number
    startTs: number
    endTs: number
    messageCount: number
    summary: string | null
  }>

  const participantsSql = `
    SELECT DISTINCT COALESCE(mb.group_nickname, mb.account_name, mb.platform_id) as name
    FROM message_context mc
    JOIN message m ON m.id = mc.message_id
    JOIN member mb ON mb.id = m.sender_id
    WHERE mc.segment_id = ? LIMIT 10
  `

  return sessions.map((session) => {
    const participants = db.prepare(participantsSql).all(session.id) as Array<{ name: string }>

    return {
      id: session.id,
      startTs: session.startTs,
      endTs: session.endTs,
      messageCount: session.messageCount,
      participants: participants.map((p) => p.name),
      summary: session.summary,
    }
  })
}