Function getSegmentMessages

packages/core/src/query/session-queries.ts:262–305

(
  db: DatabaseAdapter,
  segmentId: number,
  limit: number = 500
)

 * Get messages for a specific chat session
 */
export function getSegmentMessages(
  db: DatabaseAdapter,
  segmentId: number,
  limit: number = 500
): SegmentMessagesData | null {
  if (!hasTable(db, 'segment')) return null

  const session = db
    .prepare(
      `SELECT id, start_ts as startTs, end_ts as endTs, message_count as messageCount
       FROM segment WHERE id = ?`
    )
    .get(segmentId) as { id: number; startTs: number; endTs: number; messageCount: number } | undefined

  if (!session) return null

  const messages = db
    .prepare(
      `SELECT m.id, mb.id as senderId,
              COALESCE(mb.group_nickname, mb.account_name, mb.platform_id) as senderName,
              mb.platform_id as senderPlatformId,
              m.content, m.ts as timestamp
       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 = ? ORDER BY m.ts ASC LIMIT ?`
    )
    .all(segmentId, limit) as unknown as SessionPreviewMessage[]

  const participantsSet = new Set<string>()
  for (const msg of messages) {
    participantsSet.add(msg.senderName)
  }

  return {
    segmentId: session.id,
    startTs: session.startTs,
    endTs: session.endTs,
    messageCount: session.messageCount,
    returnedCount: messages.length,
    participants: Array.from(participantsSet),
    messages,
  }
}

/**
 * Get session summaries (only sessions that have AI-generated summaries)