Function registerAutomationRoutes

apps/cli/src/sync/routes.ts:17–145

(server: FastifyInstance, ctx: SyncRouteContext)

import type { SyncRouteContext } from './index'

export function registerAutomationRoutes(server: FastifyInstance, ctx: SyncRouteContext): void {
  const { dsManager, pullEngine, dbManager, serverInfo } = ctx

  // ==================== Config (read-only in CLI mode) ====================

  server.get('/_web/automation/config', async () => {
    return {
      enabled: true,
      port: serverInfo.port,
      token: serverInfo.token,
      host: serverInfo.host,
    }
  })

  // ==================== Data Sources ====================

  server.get('/_web/automation/data-sources', async () => {
    return dsManager.loadAll()
  })

  server.post<{
    Body: { name?: string; baseUrl: string; token: string; intervalMinutes: number; pullLimit?: number }
  }>('/_web/automation/data-sources', async (request) => {
    const ds = dsManager.add(request.body)
    reloadTimer(ds.id)
    return ds
  })

  server.patch<{
    Params: { id: string }
    Body: {
      name?: string
      baseUrl?: string
      token?: string
      intervalMinutes?: number
      pullLimit?: number
      enabled?: boolean
    }
  }>('/_web/automation/data-sources/:id', async (request, reply) => {
    const ds = dsManager.update(request.params.id, request.body)
    if (!ds) return reply.code(404).send({ error: 'Data source not found' })
    reloadTimer(ds.id)
    return ds
  })

  server.delete<{ Params: { id: string } }>('/_web/automation/data-sources/:id', async (request, reply) => {
    stopTimer(request.params.id)
    const ok = dsManager.delete(request.params.id)
    if (!ok) return reply.code(404).send({ error: 'Data source not found' })
    return { success: true }
  })

  // ==================== Import Sessions ====================

  server.post<{
    Params: { id: string }
    Body: { sessions: Array<{ name: string; remoteSessionId: string }> }
  }>('/_web/automation/data-sources/:id/sessions', async (request, reply) => {