apps/backend/src/modules/incidents/application/operational-case.service.tsTypeScript
import { Injectable } from '@nestjs/common';
import { randomUUID } from 'node:crypto';
import { DatabaseService } from '../../../infrastructure/database/database.service';
import { OutboxService } from '../../../infrastructure/outbox/outbox.service';
import { DomainConflictError } from '../../../common/errors/domain-conflict.error';
import {
assertOperationalCaseCreateInput,
assertOperationalCaseEvidenceInput,
assertOperationalCaseResolveInput,
assertOperationalCaseScope,
} from './operational-case-input-validation';
@Injectable()
export class OperationalCaseService {
constructor(private readonly database:DatabaseService,private readonly outbox:OutboxService) {}
async create(input:unknown) {
assertOperationalCaseCreateInput(input);
const id=randomUUID();
await this.database.query(`insert into operational_cases(id,organization_id,location_id,case_type,severity,title,summary,affected_entity_type,affected_entity_id,opened_by_user_id) values($1,$2,$3,$4,$5,$6,$7,$8,$9,$10)`,[id,input.organizationId,input.locationId,input.caseType,input.severity,input.title,input.summary,input.affectedEntityType??null,input.affectedEntityId??null,input.openedByUserId??null]);
await this.outbox.append({organizationId:input.organizationId,aggregateType:'OperationalCase',aggregateId:id,eventType:'OperationalCaseOpened',payload:{caseId:id,caseType:input.caseType,severity:input.severity,locationId:input.locationId}});
return {id,status:'open'};
}
async list(input:unknown) {
assertOperationalCaseScope(input);
return this.database.query(`select id,case_type,severity,status,title,summary,affected_entity_type,affected_entity_id,outcome,opened_at,resolved_at,version from operational_cases where organization_id=$1 and location_id=$2 order by case status when 'open' then 0 when 'investigating' then 1 when 'resolved' then 2 else 3 end, case severity when 'critical' then 0 when 'high' then 1 when 'medium' then 2 else 3 end, opened_at desc`,[input.organizationId,input.locationId]);
}
async get(input:unknown) {
assertOperationalCaseScope(input);
if (typeof input.caseId !== 'string' || input.caseId.trim().length === 0 || input.caseId.length > 200) {
throw new DomainConflictError('incidents.input_invalid');
}
const rows=await this.database.query(`select id,case_type,severity,status,title,summary,affected_entity_type,affected_entity_id,evidence,decision,outcome,opened_by_user_id,resolved_by_user_id,opened_at,resolved_at,version from operational_cases where id=$1 and organization_id=$2 and location_id=$3`,[input.caseId,input.organizationId,input.locationId]);
if(!rows[0]) throw new DomainConflictError('operational_case.not_found');
return rows[0];
}
async addEvidence(input:unknown) {
assertOperationalCaseEvidenceInput(input);
const rows=await this.database.query<{id:string;evidence:unknown[];version:number}>(`update operational_cases set evidence=evidence || $1::jsonb,version=version+1 where id=$2 and organization_id=$3 and location_id=$4 and status in ('open','investigating') and ($5::bigint is null or version=$5) returning id,evidence,version`,[JSON.stringify([input.evidence]),input.caseId,input.organizationId,input.locationId,input.expectedVersion??null]);
if(!rows[0]) throw new DomainConflictError('operational_case.evidence_conflict');
return rows[0];
}
async resolve(input:unknown) {
assertOperationalCaseResolveInput(input);
const rows=await this.database.query<{id:string;status:string;version:number}>(`update operational_cases set status='resolved',outcome=$1,decision=$2::jsonb,resolved_by_user_id=$3,resolved_at=now(),version=version+1 where id=$4 and organization_id=$5 and location_id=$6 and status in ('open','investigating') and ($7::bigint is null or version=$7) returning id,status,version`,[input.outcome,input.decision?JSON.stringify(input.decision):null,input.userId??null,input.caseId,input.organizationId,input.locationId,input.expectedVersion??null]);
if(!rows[0]) throw new DomainConflictError('operational_case.resolve_conflict');
await this.outbox.append({organizationId:input.organizationId,aggregateType:'OperationalCase',aggregateId:input.caseId,eventType:'OperationalCaseResolved',payload:{caseId:input.caseId,outcome:input.outcome,version:rows[0].version}});
return rows[0];
}
}