Function exportSessionMode

packages/node-runtime/src/export/markdown-exporter.ts:272–355

(
  db: DatabaseAdapter,
  params: ExportFilterParams,
  writer: ExportWriter,
  progress?: ExportProgressCallback
)

// ==================== Session mode ====================

function exportSessionMode(
  db: DatabaseAdapter,
  params: ExportFilterParams,
  writer: ExportWriter,
  progress?: ExportProgressCallback
): { totalMessages: number; blockIndex: number } {
  if (!params.segmentIds || params.segmentIds.length === 0) {
    writer.write(`## Statistics\n\n- No sessions selected\n`)
    writer.end()
    return { totalMessages: 0, blockIndex: 0 }
  }

  progress?.({
    stage: 'preparing',
    currentBlock: 0,
    totalBlocks: params.segmentIds.length,
    percentage: 10,
    message: `Preparing to export ${params.segmentIds.length} sessions...`,
  })

  const sessionsSql = `
    SELECT id, start_ts as startTs, end_ts as endTs
    FROM segment
    WHERE id IN (${params.segmentIds.map(() => '?').join(',')})
    ORDER BY start_ts ASC
  `
  const sessions = db.prepare(sessionsSql).all(...params.segmentIds) as Array<{
    id: number
    startTs: number
    endTs: number
  }>

  const totalBlocks = sessions.length
  writer.write(`## Statistics\n\n- Blocks: ${totalBlocks}\n\n`)
  writer.write(`## Conversation Content\n\n`)

  const messagesSql = `
    SELECT msg.id,
           COALESCE(m.group_nickname, m.account_name, m.platform_id) as senderName,
           msg.content,
           msg.ts as timestamp
    FROM message_context mc
    JOIN message msg ON msg.id = mc.message_id
    JOIN member m ON msg.sender_id = m.id
    WHERE mc.segment_id = ?
    ORDER BY msg.ts ASC
  `

  let totalMessages = 0
  let blockIndex = 0

  for (const session of sessions) {
    blockIndex++
    progress?.({
      stage: 'exporting',
      currentBlock: blockIndex,
      totalBlocks,
      percentage: Math.round(15 + ((blockIndex - 1) / totalBlocks) * 80),