Function registerSessionRoutes

packages/http-routes/src/routes/web/sessions.ts:5–85

(server: FastifyInstance, ctx: HttpRouteContext)

import { sessionService, ownerProfileService, PreferencesManager } from '@openchatlab/node-runtime'

export function registerSessionRoutes(server: FastifyInstance, ctx: HttpRouteContext): void {
  const { sessionAdapter: adapter } = ctx

  // Lazy: only owner-profile routes need preferences.json access
  let preferencesInstance: PreferencesManager | null = null
  const preferences = () => {
    preferencesInstance ??= ctx.preferencesManager ?? new PreferencesManager(ctx.pathProvider.getSystemDir())
    return preferencesInstance
  }

  server.get('/_web/sessions', async () => {
    const aiChatCounts = ctx.aiChatManager?.getAIChatCountsBySession()
    return sessionService.listAnalysisSessions(adapter, {
      enrichSession: aiChatCounts?.size
        ? (dto) => ({ ...dto, aiConversationCount: aiChatCounts.get(dto.id) ?? 0 })
        : undefined,
    })
  })

  server.get<{ Params: { id: string } }>('/_web/sessions/:id', async (request) => {
    const session = sessionService.getAnalysisSession(adapter, request.params.id)
    if (!session) {
      throw Object.assign(new Error(`Session not found: ${request.params.id}`), { statusCode: 404 })
    }
    if (ctx.aiChatManager) {
      session.aiConversationCount = ctx.aiChatManager.getAIChats(request.params.id).length
    }
    return session
  })

  server.delete<{ Params: { id: string } }>('/_web/sessions/:id', async (request, reply) => {
    const { id } = request.params
    try {
      const deleted = sessionService.deleteSession(adapter, id)
      if (!deleted) {
        return reply.code(404).send({ success: false, error: 'File not found' })
      }
      return { success: true }
    } catch (err) {
      return reply.code(500).send({ success: false, error: String(err) })
    }
  })

  server.patch<{ Params: { id: string }; Body: { name: string } }>('/_web/sessions/:id/name', async (request) => {
    sessionService.renameSession(adapter, request.params.id, request.body.name)
    return { success: true }
  })

  server.patch<{ Params: { id: string }; Body: { ownerId: string | null } }>(
    '/_web/sessions/:id/owner',
    async (request) => {
      sessionService.updateSessionOwnerId(adapter, request.params.id, request.body.ownerId ?? null)
      return { success: true }
    }
  )

  // Try to auto-apply the stored platform owner profile to this session.
  server.post<{ Params: { id: string } }>('/_web/sessions/:id/owner/apply-profile', async (request) => {