f.spilla/insiemesalute-3p-nx
Archived
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

chore(repo): made ZodSerializerDto optional

Browse Source
This commit is contained in:
Francesco Spilla 2025-02-12 17:06:39 +01:00
parent 60b1701d01
commit b180968def
1 changed files with 17 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
apps/ebitemp-api/src/app/modules/validation/zod.serializer.ts
View File

@ -11,6 +11,7 @@ import {
SetMetadata, SetMetadata,
StreamableFile, StreamableFile,
} from '@nestjs/common'; } from '@nestjs/common';
import { chain } from 'lodash';
import { Observable, map } from 'rxjs'; import { Observable, map } from 'rxjs';
import { ZodSchema } from 'zod'; import { ZodSchema } from 'zod';
@ -34,7 +35,7 @@ export class ZodSerializerInterceptor implements NestInterceptor {
} }
intercept(context: ExecutionContext, next: CallHandler): Observable<any> { intercept(context: ExecutionContext, next: CallHandler): Observable<any> {
const { dto: responseSchema } = this.getContextResponseSchema(context); const responseSchema = this.getContextResponseSchema(context);
return next.handle().pipe( return next.handle().pipe(
map((res: object | object[]) => { map((res: object | object[]) => {
@ -51,10 +52,21 @@ export class ZodSerializerInterceptor implements NestInterceptor {
); );
} }
protected getContextResponseSchema(context: ExecutionContext): { protected getContextResponseSchema(context: ExecutionContext): ZodDtoStatic | ZodSchema {
dto: ZodDtoStatic | ZodSchema | undefined; const zodSerializedDto = (() => {
} { const metadata = this.reflector.getAllAndMerge('zodSerializedDtoOptions', [context.getHandler(), context.getClass()]);
return this.reflector.getAllAndMerge('zodSerializedDtoOptions', [context.getHandler(), context.getClass()]); return metadata.dto;
})();
if (zodSerializedDto) return zodSerializedDto;
const swaggerApiResponseType = (() => {
const metadata = this.reflector.getAllAndMerge('swagger/apiResponse', [context.getHandler(), context.getClass()]);
const metadataForStatusCode = chain([metadata[HttpStatus.OK], metadata[HttpStatus.CREATED]]).filter(Boolean).first().value();
return metadataForStatusCode.type;
})();
if (swaggerApiResponseType) return swaggerApiResponseType;
return undefined;
} }
} }