+
+
diff --git a/start/routes.ts b/start/routes.ts
index 1a9f86b..326975a 100644
--- a/start/routes.ts
+++ b/start/routes.ts
@@ -9,6 +9,7 @@ const FirmwareCatalogController = () => import('#controllers/firmware_catalog_co
const HealthController = () => import('#controllers/health_controller')
const PagesController = () => import('#controllers/pages_controller')
const CwmpController = () => import('#controllers/cwmp_controller')
+const Tr069TraceController = () => import('#controllers/tr069_trace_controller')
// CWMP/TR-069 endpoint (SOAP/XML) - uses dedicated middleware for XML parsing
router.post('/cwmp10', [CwmpController, 'handle']).use([middleware.cwmpLogger(), middleware.cwmp()])
@@ -18,45 +19,51 @@ router.get('/api/v1/checklife', [HealthController, 'checklife'])
router.get('/api/v1/checkservice', [HealthController, 'checkservice'])
// REST API routes
-router.group(() => {
- // Devices
- router.get('/devices', [DevicesController, 'index'])
- router.get('/devices/criteria-values', [DevicesController, 'criteriaValues'])
- router.get('/devices/:identifier', [DevicesController, 'show'])
- router.delete('/devices/:identifier', [DevicesController, 'destroy'])
- router.post('/devices/:identifier/command', [DevicesController, 'executeCommand'])
- router.post('/devices/:identifier/refresh', [DevicesController, 'refresh'])
+router
+ .group(() => {
+ // Devices
+ router.get('/devices', [DevicesController, 'index'])
+ router.get('/devices/criteria-values', [DevicesController, 'criteriaValues'])
+ router.get('/devices/:identifier', [DevicesController, 'show'])
+ router.delete('/devices/:identifier', [DevicesController, 'destroy'])
+ router.post('/devices/:identifier/command', [DevicesController, 'executeCommand'])
+ router.post('/devices/:identifier/refresh', [DevicesController, 'refresh'])
- // Commands
- router.get('/commands', [CommandsController, 'index'])
- router.get('/commands/:id', [CommandsController, 'show'])
- router.post('/commands', [CommandsController, 'store'])
+ // Commands
+ router.get('/commands', [CommandsController, 'index'])
+ router.get('/commands/:id', [CommandsController, 'show'])
+ router.post('/commands', [CommandsController, 'store'])
- // Unified Configuration API (v1)
- router.get('/configurations', [ConfigurationsV1Controller, 'index'])
- router.get('/configurations/tags', [ConfigurationsV1Controller, 'listTags'])
- router.post('/configurations', [ConfigurationsV1Controller, 'store'])
- router.get('/configurations/:id', [ConfigurationsV1Controller, 'show'])
- router.put('/configurations/:id', [ConfigurationsV1Controller, 'update'])
- router.delete('/configurations/:id', [ConfigurationsV1Controller, 'destroy'])
- router.patch('/configurations/:id/toggle', [ConfigurationsV1Controller, 'toggleEnabled'])
- router.patch('/configurations/:id/tags', [ConfigurationsV1Controller, 'manageTags'])
- router.get('/configurations/:id/history', [ConfigurationsV1Controller, 'history'])
- router.post('/configurations/:id/dry-run', [ConfigurationsV1Controller, 'dryRun'])
- router.get('/configurations/:id/compliance', [ConfigurationsV1Controller, 'compliance'])
+ router.get('/tr069-trace', [Tr069TraceController, 'index'])
+ router.post('/tr069-trace', [Tr069TraceController, 'store'])
+ router.delete('/tr069-trace/:id', [Tr069TraceController, 'destroy'])
- // Firmware Catalog API (v1)
- router.get('/firmware-catalog', [FirmwareCatalogController, 'index'])
- router.get('/firmware-catalog/entries', [FirmwareCatalogController, 'listEntries'])
- router.get('/firmware-catalog/entries/:id', [FirmwareCatalogController, 'showEntry'])
- router.get('/firmware-catalog/routes', [FirmwareCatalogController, 'listRoutes'])
- router.post('/firmware-catalog/entries', [FirmwareCatalogController, 'createEntry'])
- router.put('/firmware-catalog/entries/:id', [FirmwareCatalogController, 'updateEntry'])
- router.delete('/firmware-catalog/entries/:id', [FirmwareCatalogController, 'deleteEntry'])
- router.post('/firmware-catalog/routes', [FirmwareCatalogController, 'createRoute'])
- router.put('/firmware-catalog/routes/:id', [FirmwareCatalogController, 'updateRoute'])
- router.delete('/firmware-catalog/routes/:id', [FirmwareCatalogController, 'deleteRoute'])
-}).prefix('/api/v1')
+ // Unified Configuration API (v1)
+ router.get('/configurations', [ConfigurationsV1Controller, 'index'])
+ router.get('/configurations/tags', [ConfigurationsV1Controller, 'listTags'])
+ router.post('/configurations', [ConfigurationsV1Controller, 'store'])
+ router.get('/configurations/:id', [ConfigurationsV1Controller, 'show'])
+ router.put('/configurations/:id', [ConfigurationsV1Controller, 'update'])
+ router.delete('/configurations/:id', [ConfigurationsV1Controller, 'destroy'])
+ router.patch('/configurations/:id/toggle', [ConfigurationsV1Controller, 'toggleEnabled'])
+ router.patch('/configurations/:id/tags', [ConfigurationsV1Controller, 'manageTags'])
+ router.get('/configurations/:id/history', [ConfigurationsV1Controller, 'history'])
+ router.post('/configurations/:id/dry-run', [ConfigurationsV1Controller, 'dryRun'])
+ router.get('/configurations/:id/compliance', [ConfigurationsV1Controller, 'compliance'])
+
+ // Firmware Catalog API (v1)
+ router.get('/firmware-catalog', [FirmwareCatalogController, 'index'])
+ router.get('/firmware-catalog/entries', [FirmwareCatalogController, 'listEntries'])
+ router.get('/firmware-catalog/entries/:id', [FirmwareCatalogController, 'showEntry'])
+ router.get('/firmware-catalog/routes', [FirmwareCatalogController, 'listRoutes'])
+ router.post('/firmware-catalog/entries', [FirmwareCatalogController, 'createEntry'])
+ router.put('/firmware-catalog/entries/:id', [FirmwareCatalogController, 'updateEntry'])
+ router.delete('/firmware-catalog/entries/:id', [FirmwareCatalogController, 'deleteEntry'])
+ router.post('/firmware-catalog/routes', [FirmwareCatalogController, 'createRoute'])
+ router.put('/firmware-catalog/routes/:id', [FirmwareCatalogController, 'updateRoute'])
+ router.delete('/firmware-catalog/routes/:id', [FirmwareCatalogController, 'deleteRoute'])
+ })
+ .prefix('/api/v1')
// Inertia page routes
router.get('/', [PagesController, 'home'])
@@ -65,6 +72,7 @@ router.post('/devices/:identifier/refresh', [PagesController, 'refreshDevice'])
router.post('/devices/:identifier/get-model', [PagesController, 'getModel'])
router.get('/commands', [PagesController, 'commands']).as('commands.page')
router.get('/commands/fleet', [PagesController, 'commandsFleet'])
+router.get('/tr069-trace', [PagesController, 'tr069Trace'])
router.post('/commands/fleet', [PagesController, 'storeFleetDevices'])
router.post('/commands/fleet/command', [PagesController, 'storeFleetCommand'])
diff --git a/tests/unit/services/tr069_trace_service.spec.ts b/tests/unit/services/tr069_trace_service.spec.ts
new file mode 100644
index 0000000..4c33e0c
--- /dev/null
+++ b/tests/unit/services/tr069_trace_service.spec.ts
@@ -0,0 +1,148 @@
+import { beforeEach, describe, expect, it, vi } from 'vitest'
+
+const fsMocks = vi.hoisted(() => ({
+ appendFileSync: vi.fn(),
+ mkdirSync: vi.fn(),
+ readFileSync: vi.fn(),
+ renameSync: vi.fn(),
+ statSync: vi.fn(),
+}))
+
+const fsPromisesMocks = vi.hoisted(() => ({
+ writeFile: vi.fn(),
+}))
+
+vi.mock('node:fs', () => ({
+ appendFileSync: fsMocks.appendFileSync,
+ mkdirSync: fsMocks.mkdirSync,
+ readFileSync: fsMocks.readFileSync,
+ renameSync: fsMocks.renameSync,
+ statSync: fsMocks.statSync,
+}))
+
+vi.mock('node:fs/promises', () => ({
+ writeFile: fsPromisesMocks.writeFile,
+}))
+
+import { Tr069TraceService } from '../../../app/services/tr069_trace_service.js'
+
+describe('Tr069TraceService', () => {
+ const baseEntry = {
+ deviceId: 'device-123',
+ manufacturer: 'Orange',
+ oui: 'A1B2C3',
+ productClass: 'Livebox',
+ serialNumber: 'SN123456',
+ }
+
+ beforeEach(() => {
+ vi.clearAllMocks()
+ fsMocks.readFileSync.mockImplementation(() => {
+ throw new Error('missing config')
+ })
+ fsMocks.statSync.mockImplementation(() => {
+ throw new Error('missing log')
+ })
+ ;(Tr069TraceService as any).instance = undefined
+ })
+
+ it('returns false for untracked devices', () => {
+ const service = Tr069TraceService.getInstance()
+
+ expect(service.isTraced('unknown-device')).toBe(false)
+ })
+
+ it('returns true after adding a device', async () => {
+ const service = Tr069TraceService.getInstance()
+
+ await service.addDevice(baseEntry)
+
+ expect(service.isTraced(baseEntry.deviceId)).toBe(true)
+ })
+
+ it('lists all traced devices', async () => {
+ const service = Tr069TraceService.getInstance()
+
+ await service.addDevice(baseEntry)
+ await service.addDevice({
+ ...baseEntry,
+ deviceId: 'device-456',
+ serialNumber: 'SN654321',
+ })
+
+ expect(service.list()).toHaveLength(2)
+ expect(service.list().map((entry) => entry.deviceId)).toEqual(['device-123', 'device-456'])
+ })
+
+ it('adds a device with an auto-generated startedAt value', async () => {
+ const service = Tr069TraceService.getInstance()
+
+ await service.addDevice(baseEntry)
+
+ const [entry] = service.list()
+ expect(entry.startedAt).toBeTypeOf('string')
+ expect(Number.isNaN(Date.parse(entry.startedAt))).toBe(false)
+ })
+
+ it('removes a traced device and returns true', async () => {
+ const service = Tr069TraceService.getInstance()
+
+ await service.addDevice(baseEntry)
+
+ await expect(service.removeDevice(baseEntry.deviceId)).resolves.toBe(true)
+ expect(service.isTraced(baseEntry.deviceId)).toBe(false)
+ })
+
+ it('returns false when removing an unknown device', async () => {
+ const service = Tr069TraceService.getInstance()
+
+ await expect(service.removeDevice('unknown-device')).resolves.toBe(false)
+ })
+
+ it('persists config after add and remove operations', async () => {
+ const service = Tr069TraceService.getInstance()
+
+ await service.addDevice(baseEntry)
+ await service.removeDevice(baseEntry.deviceId)
+
+ expect(fsPromisesMocks.writeFile).toHaveBeenCalledTimes(2)
+ expect(fsPromisesMocks.writeFile).toHaveBeenNthCalledWith(
+ 1,
+ expect.stringContaining('config/tr069-trace.json.tmp'),
+ expect.stringContaining(baseEntry.deviceId),
+ 'utf-8'
+ )
+ expect(fsPromisesMocks.writeFile).toHaveBeenNthCalledWith(
+ 2,
+ expect.stringContaining('config/tr069-trace.json.tmp'),
+ JSON.stringify({ entries: [] }, null, 2),
+ 'utf-8'
+ )
+ expect(fsMocks.renameSync).toHaveBeenCalledWith(
+ expect.stringContaining('config/tr069-trace.json.tmp'),
+ expect.stringContaining('config/tr069-trace.json')
+ )
+ })
+
+ it('rotates log files when size exceeds the limit', async () => {
+ const service = Tr069TraceService.getInstance()
+ fsMocks.statSync.mockReturnValue({ size: 10 * 1024 * 1024 })
+
+ await (service as any).doWrite(baseEntry.deviceId, 'CPE→ACS', '
+
+
+
+
+
+
+
+
+ Add device
++ Search by manufacturer, product class, serial number, or device identifier. +
+ + + + +Searching devices…
++ No matching devices found. +
+ +
+
+
+
+
+ | Manufacturer | +Product Class | +Serial Number | +Action | +
|---|---|---|---|
| {{ device.deviceId?.manufacturer || '—' }} | +{{ device.deviceId?.productClass || '—' }} | +{{ device.deviceId?.serialNumber || '—' }} | ++ + | +
+
+
+
+
+
+
+
+
+
+
+ {{ tracedDevices.length }}
+ Traced devices
++ Full SOAP traces are written to per-device files. +
+
+ {{ entriesError }}
+
+
+ {{ actionError }}
+
+
+ Loading traced devices…
+ +
+
+
+
+
+ | Manufacturer | +Product Class | +Serial Number | +Started | +Action | +
|---|---|---|---|---|
| {{ entry.manufacturer || '—' }} | +{{ entry.productClass || '—' }} | +{{ entry.serialNumber || '—' }} | +{{ new Date(entry.startedAt).toLocaleString() }} | ++ + | +
| + No traced devices configured. + | +||||