apps/backend/src/modules/menu/application/menu-availability-rule.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 { ScopeResolutionService } from '../../organizations/scope-resolution.service';
import { DomainConflictError } from '../../../common/errors/domain-conflict.error';
import { assertAvailabilityRuleInput } from './menu-input-validation';
@Injectable()
export class MenuAvailabilityRuleService {
constructor(private readonly database:DatabaseService,private readonly outbox:OutboxService,private readonly scopes:ScopeResolutionService) {}
async create(input:{organizationId:string;productId:string;locationId:string;placeId?:string;operationalUnitId?:string;stationId?:string;channel?:string;startsAt?:string;endsAt?:string;available:boolean;reasonCode?:string;priority?:number;userId?:string}) {
assertAvailabilityRuleInput(input);
const startsAt = input.startsAt ? new Date(input.startsAt) : new Date();
const endsAt = input.endsAt ? new Date(input.endsAt) : null;
if (Number.isNaN(startsAt.getTime()) || (endsAt && Number.isNaN(endsAt.getTime())) || (endsAt && endsAt <= startsAt)) {
throw new DomainConflictError('menu.availability_window_invalid');
}
const scope=await this.scopes.resolve({organizationId:input.organizationId,locationId:input.locationId,placeId:input.placeId,operationalUnitId:input.operationalUnitId});
const owned=await this.database.query<{id:string}>(`select id from products where id=$1 and organization_id=$2 and status='active'`,[input.productId,input.organizationId]);
if(!owned[0]) throw new DomainConflictError('menu.product_or_location_forbidden');
if (input.stationId) {
const station = await this.database.query<{ id: string }>(
`select id from kitchen_stations where id=$1 and organization_id=$2 and location_id=$3 and status='active'`,
[input.stationId, input.organizationId, input.locationId],
);
if (!station[0]) throw new DomainConflictError('menu.station_scope_invalid');
}
const id=randomUUID();
await this.database.transaction(async(tx)=>{
await tx.query(`insert into menu_availability_rules(id,organization_id,product_id,location_id,place_id,operational_unit_id,station_id,channel,starts_at,ends_at,available,reason_code,priority,created_by) values($1,$2,$3,$4,$5,$6,$7,$8,$9::timestamptz,$10::timestamptz,$11,$12,$13,$14)`,[id,input.organizationId,input.productId,input.locationId,scope.placeId??null,scope.operationalUnitId??null,input.stationId??null,input.channel??null,startsAt.toISOString(),endsAt?.toISOString()??null,input.available,input.reasonCode??null,input.priority??0,input.userId??null]);
await this.outbox.append({organizationId:input.organizationId,aggregateType:'Product',aggregateId:input.productId,eventType:'MenuAvailabilityRuleCreated',payload:{ruleId:id,productId:input.productId,locationId:input.locationId,placeId:scope.placeId??null,operationalUnitId:scope.operationalUnitId??null,stationId:input.stationId??null,channel:input.channel??null,startsAt:startsAt.toISOString(),endsAt:endsAt?.toISOString()??null,available:input.available}},tx);
});
return {id};
}
}