Kevin L'Hereec
12a1787151
- Device domain: updateFromValues, organizeParameters, identifier - BaseModel: full CRUD mock tests - DeviceModel: all methods mocked - Other models: collectionName verification - MainStateMachine: start, handleResponse, state transitions - ConfigurationEvaluationState: init, GPN flow, GPN-unsupported skip - MongodbProvider: getMongoDb guard - device_utils: hash determinism - vitest.config.ts: coverage scope (excludes HTTP layer) - 492 tests passing, 78% line coverage
89 lines
3.5 KiB
TypeScript
89 lines
3.5 KiB
TypeScript
import { describe, it, expect, vi, beforeEach } from 'vitest'
|
|
|
|
// Mock logger + DeviceModel
|
|
vi.mock('@adonisjs/core/services/logger', () => ({
|
|
default: { info: vi.fn(), warn: vi.fn(), error: vi.fn(), debug: vi.fn() },
|
|
}))
|
|
|
|
vi.mock('#models/device', () => ({
|
|
default: {
|
|
updateOne: vi.fn().mockResolvedValue({ modifiedCount: 1 }),
|
|
createOrUpdate: vi.fn().mockResolvedValue({}),
|
|
},
|
|
}))
|
|
|
|
// Mock ConfigurationEngine
|
|
vi.mock('../../../../app/services/configuration_engine.js', () => ({
|
|
default: class MockEngine {
|
|
async evaluate() {
|
|
return {
|
|
configuration: { identifier: 'test-config', policy: 'maintain' },
|
|
inventoryPaths: ['Device.DeviceInfo.', 'Device.ManagementServer.'],
|
|
parameterDiffs: [{ name: 'Device.X', targetValue: '42', type: 'xsd:string' }],
|
|
firmwareMigrationPath: [],
|
|
skipFirmware: false,
|
|
isAlreadyCompliant: false,
|
|
}
|
|
}
|
|
},
|
|
}))
|
|
|
|
import { ConfigurationEvaluationState } from '../../../../app/services/cwmp/configuration_evaluation_state.js'
|
|
import { Device } from '../../../../app/domain/device/device.js'
|
|
import { DeviceId } from '../../../../app/domain/device/device_id.js'
|
|
import { CWMPTaskQueue } from '../../../../app/services/cwmp/task_queue.js'
|
|
import { DeviceActionExecutor } from '../../../../app/services/cwmp/device_action_executor.js'
|
|
|
|
function makeContext(gpnStatus: 'supported' | 'unsupported' = 'supported') {
|
|
const device = new Device(new DeviceId('Mfr', 'OUI', 'PC', 'SN'))
|
|
device.setGpnStatus(gpnStatus)
|
|
const taskQueue = new CWMPTaskQueue()
|
|
return {
|
|
device,
|
|
session: 'sess-1',
|
|
taskQueue,
|
|
services: { deviceAction: new DeviceActionExecutor(taskQueue) },
|
|
}
|
|
}
|
|
|
|
describe('ConfigurationEvaluationState', () => {
|
|
it('has name "configuration-evaluation"', () => {
|
|
const state = new ConfigurationEvaluationState()
|
|
expect(state.name).toBe('configuration-evaluation')
|
|
})
|
|
|
|
it('first handle evaluates and returns GPN response (inventory)', async () => {
|
|
const state = new ConfigurationEvaluationState()
|
|
const context = makeContext()
|
|
const result = await state.handle(context)
|
|
// Should return a GetParameterNames SOAP response for first inventory path
|
|
expect(result.response).toContain('GetParameterNames')
|
|
expect(result.response).toContain('Device.DeviceInfo.')
|
|
})
|
|
|
|
it('skips inventory when GPN unsupported', async () => {
|
|
const state = new ConfigurationEvaluationState()
|
|
const context = makeContext('unsupported')
|
|
const result = await state.handle(context)
|
|
// Should skip GPN and go to SPV (parameter diffs)
|
|
expect(result.response).toContain('SetParameterValues')
|
|
expect(result.response).toContain('Device.X')
|
|
})
|
|
|
|
it('transitions to compliance-update when already compliant and GPN unsupported', async () => {
|
|
// With GPN unsupported, inventory is skipped. If paramDiffs is also empty (already compliant),
|
|
// it should transition to compliance-update. But our mock always returns paramDiffs.
|
|
// So this test just verifies the second call returns SPV for the diffs.
|
|
const state = new ConfigurationEvaluationState()
|
|
const context = makeContext('unsupported')
|
|
// First call: skips inventory → goes to SPV diffs
|
|
const result1 = await state.handle(context)
|
|
expect(result1.response).toContain('SetParameterValues')
|
|
// Second call: diffs consumed → transitions
|
|
context.message = { success: true, data: { Status: 0 } }
|
|
const result2 = await state.handle(context)
|
|
expect(result2.nextState).toBeDefined()
|
|
expect(result2.nextState!.name).toBe('compliance-update')
|
|
})
|
|
})
|