vee1e/workorder-desk
1
0
Fork 0
mirror of https://github.com/vee1e/workorder-desk.git synced 2026-09-01 09:50:13 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

test(backend): raise AI surface coverage — provider client, admin agent API, policy, triage skip paths

Browse source
This commit is contained in:
lakshit verma 2026-08-19 20:03:39 +05:30
parent b6a9b64c47
commit b8cb205e69
No known key found for this signature in database
6 changed files with 779 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

46
backend/tests/triage.worker.test.ts
View file

@ -1,5 +1,6 @@
import { providerResult } from './ai-helpers.js';
import { beforeEach, describe, expect, it, vi } from 'vitest';
import { Types } from 'mongoose';
import { ensureTriageConfig, isWorkingHours, runTriage } from '../src/agent/triage.js';
import { agentRepo } from '../src/repositories/agent.repo.js';
import { userRepo } from '../src/repositories/user.repo.js';
@ -114,6 +115,51 @@ describe('triage agent', () => {
expect(runs[0]).toMatchObject({ status: 'error', errorCode: 'AI_UNAVAILABLE' });
});
it('skips triage when outside the configured working hours', async () => {
const { wo } = await makeWorkOrder();
await ensureTriageConfig();
const hour = new Date().getUTCHours();
const excluding = (hour + 2) % 24;
await agentRepo.updateAgentConfig('triage', { workingHours: `${excluding}-${excluding}` }, 'admin');
const outcome = await runTriage(wo.id);
expect(outcome).toBe('skipped');
expect(providerMock.chatComplete).not.toHaveBeenCalled();
});
it('skips triage when the daily action cap is already reached', async () => {
const { wo } = await makeWorkOrder();
await ensureTriageConfig();
await agentRepo.updateAgentConfig('triage', { dailyActionCap: 1 }, 'admin');
await agentRepo.createSuggestion({
workOrderId: wo.id,
runId: new Types.ObjectId().toString(),
summary: 'Already flagged',
suggestedPriority: 'low',
flagForDispatcher: false,
applied: false,
});
const outcome = await runTriage(wo.id);
expect(outcome).toBe('skipped');
expect(providerMock.chatComplete).not.toHaveBeenCalled();
});
it('skips triage when the agent daily spend budget is exhausted', async () => {
const { wo } = await makeWorkOrder();
await agentRepo.chargeSpend('agent:triage', 100);
const outcome = await runTriage(wo.id);
expect(outcome).toBe('skipped');
expect(providerMock.chatComplete).not.toHaveBeenCalled();
});
it('returns retry when the provider fails transiently and records AI_UNAVAILABLE', async () => {
const { wo } = await makeWorkOrder();
providerMock.chatComplete.mockRejectedValue(new providerMock.ProviderError('upstream down', 'network'));
const outcome = await runTriage(wo.id);
expect(outcome).toBe('retry');
const runs = (await agentRepo.listAdminRuns(1, 10)).items.filter((run) => run.mode === 'autonomous');
expect(runs[0]).toMatchObject({ status: 'error', errorCode: 'AI_UNAVAILABLE' });
});
it('claims outbox events with a lease and recovers expired leases', async () => {
const now = new Date('2026-01-01T00:00:00Z');
await agentRepo.enqueueOutbox({ type: 'work_order.created', payloadRef: 'wo-lease-1' });