admin-valentin/ceo-api
1
0
Fork 0
Code Issues Pull requests Projects Releases 2 Packages Wiki Activity Actions

feat(CC-064): add ObligationsController (deadlines & obligations with risk level)

Browse source
This commit is contained in:
admin-valentin 2026-08-01 21:24:22 +00:00
parent 9953cce2d4
commit 1758150ceb
1 changed files with 51 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

51
src/obligations/obligations.controller.ts Normal file
View file

@ -0,0 +1,51 @@
import { Body, Controller, Get, IsOptional, IsString, NotFoundException, Param, ParseUUIDPipe, Patch, Post, Query } from '@nestjs/common';
import { and, desc, eq } from 'drizzle-orm';
import { CurrentSession } from '../auth/session.decorator';
import type { AuthenticatedSession } from '../auth/tenant.guard';
import { db } from '../db/client';
import { obligations } from '../db/schema';
class CreateObligationDto {
@IsString() title!: string;
@IsOptional() @IsString() description?: string;
@IsOptional() @IsString() category?: string;
@IsOptional() @IsString() dueDate?: string;
@IsOptional() @IsString() owner?: string;
@IsOptional() @IsString() contractId?: string;
@IsOptional() @IsString() riskLevel?: string;
}
class UpdateObligationDto {
@IsOptional() @IsString() title?: string;
@IsOptional() @IsString() description?: string;
@IsOptional() @IsString() status?: string;
@IsOptional() @IsString() dueDate?: string;
@IsOptional() @IsString() owner?: string;
@IsOptional() @IsString() evidenceUrl?: string;
@IsOptional() @IsString() riskLevel?: string;
}
@Controller('obligations')
export class ObligationsController {
@Get()
async list(@CurrentSession() session: AuthenticatedSession, @Query('status') status?: string) {
const where = status
? and(eq(obligations.tenantId, session.tenantId), eq(obligations.status, status))
: eq(obligations.tenantId, session.tenantId);
return db.query.obligations.findMany({ where, orderBy: desc(obligations.createdAt), limit: 200 });
}
@Post()
async create(@CurrentSession() session: AuthenticatedSession, @Body() dto: CreateObligationDto) {
const [obligation] = await db.insert(obligations).values({ ...dto, tenantId: session.tenantId }).returning();
return obligation;
}
@Patch(':id')
async update(@CurrentSession() session: AuthenticatedSession, @Param('id', ParseUUIDPipe) id: string, @Body() dto: UpdateObligationDto) {
const [updated] = await db.update(obligations).set({ ...dto, updatedAt: new Date() })
.where(and(eq(obligations.id, id), eq(obligations.tenantId, session.tenantId))).returning();
if (!updated) throw new NotFoundException('Obligation not found');
return updated;
}
}