chore(api-service, worker, ws): upgrade to nest js v11

apps/api/package.json

@@ -46,15 +46,15 @@
     "@aws-sdk/client-secrets-manager": "^3.971.0",
     "@godaddy/terminus": "^4.12.1",
     "@google-cloud/storage": "^6.2.3",
-    "@nestjs/axios": "3.0.3",
-    "@nestjs/common": "10.4.18",
-    "@nestjs/core": "10.4.18",
-    "@nestjs/jwt": "10.2.0",
-    "@nestjs/passport": "10.0.3",
-    "@nestjs/platform-express": "10.4.18",
-    "@nestjs/swagger": "7.4.0",
-    "@nestjs/terminus": "10.2.3",
-    "@nestjs/throttler": "6.2.1",
+    "@nestjs/axios": "4.0.1",
+    "@nestjs/common": "11.1.18",
+    "@nestjs/core": "11.1.18",
+    "@nestjs/jwt": "11.0.2",
+    "@nestjs/passport": "11.0.5",
+    "@nestjs/platform-express": "11.1.18",
+    "@nestjs/swagger": "11.2.6",
+    "@nestjs/terminus": "11.1.1",
+    "@nestjs/throttler": "6.5.0",
     "@novu/api": "workspace:*",
     "@novu/application-generic": "workspace:*",
     "@novu/dal": "workspace:*",
@@ -129,9 +129,9 @@
   },
   "devDependencies": {
     "@faker-js/faker": "^6.0.0",
-    "@nestjs/cli": "10.4.5",
-    "@nestjs/schematics": "10.1.4",
-    "@nestjs/testing": "10.4.18",
+    "@nestjs/cli": "11.0.17",
+    "@nestjs/schematics": "11.0.10",
+    "@nestjs/testing": "11.1.18",
     "@stoplight/spectral-cli": "^6.15.0",
     "@swc-node/register": "1.10.10",
     "@types/async": "^3.2.1",

apps/api/scripts/generate-metadata.ts

@@ -8,7 +8,7 @@
  */
 import fs from 'node:fs';
 import path from 'node:path';
-import { PluginMetadataGenerator } from '@nestjs/cli/lib/compiler/plugins';
+import { PluginMetadataGenerator } from '@nestjs/cli/lib/compiler/plugins/plugin-metadata-generator';
 import { ReadonlyVisitor } from '@nestjs/swagger/dist/plugin';
 
 const tsconfigPath = 'tsconfig.build.json';

apps/api/src/app/auth/framework/community.user.auth.guard.ts

@@ -14,7 +14,7 @@ export class CommunityUserAuthGuard extends AuthGuard([PassportStrategyEnum.JWT,
     this.logger.setContext(this.constructor.name);
   }
 
-  getAuthenticateOptions(context: ExecutionContext): IAuthModuleOptions<any> {
+  getAuthenticateOptions(context: ExecutionContext): IAuthModuleOptions {
     const request = context.switchToHttp().getRequest();
     const authorizationHeader = request.headers.authorization;
 

apps/api/src/app/auth/services/passport/apikey.strategy.ts

@@ -20,24 +20,25 @@ export class ApiKeyStrategy extends PassportStrategy(HeaderAPIKeyStrategy) {
     private readonly inMemoryLRUCacheService: InMemoryLRUCacheService
   ) {
     super(
-      { header: HttpRequestHeaderKeysEnum.AUTHORIZATION, prefix: `${ApiAuthSchemeEnum.API_KEY} ` },
-      true,
-      async (apikey: string, verified: (err: Error | null, user?: UserSessionData | false) => void) => {
-        try {
-          const user = await this.validateApiKey(apikey);
+      {
+        header: HttpRequestHeaderKeysEnum.AUTHORIZATION,
+        prefix: `${ApiAuthSchemeEnum.API_KEY} `,
+      },
+      false
+    );
+  }
 
-          if (!user) {
-            return verified(null, false);
-          }
+  async validate(apiKey: string): Promise<UserSessionData | false> {
+    const user = await this.validateApiKey(apiKey);
 
-          addNewRelicTraceAttributes(user);
+    if (!user) {
 
-          return verified(null, user);
-        } catch (err) {
-          return verified(err as Error, false);
-        }
-      }
-    );
+      return false;
+    }
+
+    addNewRelicTraceAttributes(user);
+
+    return user;
   }
 
   private async validateApiKey(apiKey: string): Promise<UserSessionData | null> {

apps/api/src/app/contexts/dtos/create-context-request.dto.ts

@@ -1,4 +1,4 @@
-import { ApiProperty } from '@nestjs/swagger';
+import { ApiProperty, ApiPropertyOptional } from '@nestjs/swagger';
 import { IsValidContextData } from '@novu/application-generic';
 import { CONTEXT_IDENTIFIER_REGEX, ContextData, ContextId, ContextType } from '@novu/shared';
 import { IsDefined, IsOptional, IsString, Matches, MaxLength, MinLength } from 'class-validator';
@@ -37,11 +37,10 @@ export class CreateContextRequestDto {
   })
   id: ContextId;
 
-  @ApiProperty({
+  @ApiPropertyOptional({
     description: 'Optional custom data to associate with this context.',
     example: { tenantName: 'Acme Corp', region: 'us-east-1', settings: { theme: 'dark' } },
-    required: false,
-    type: 'object',
+    type: Object,
     additionalProperties: true,
   })
   @IsOptional()

apps/api/src/app/contexts/dtos/update-context-request.dto.ts

@@ -7,8 +7,7 @@ export class UpdateContextRequestDto {
   @ApiProperty({
     description: 'Custom data to associate with this context. Replaces existing data.',
     example: { tenantName: 'Acme Corp', region: 'us-east-1', settings: { theme: 'dark' } },
-    required: true,
-    type: 'object',
+    type: Object,
     additionalProperties: true,
   })
   @IsDefined()

apps/api/src/app/events/dtos/trigger-event-request.dto.ts

@@ -32,14 +32,13 @@ export class WorkflowToStepControlValuesDto {
    * @type {Record<stepId, Data>}
    * @optional
    */
-  @ApiProperty({
+  @ApiPropertyOptional({
     description: 'A mapping of step IDs to their corresponding data.',
-    type: 'object',
+    type: Object,
     additionalProperties: {
       type: 'object',
       additionalProperties: true,
     },
-    required: false,
   })
   steps?: Record<string, Record<string, unknown>>;
 }
@@ -229,12 +228,11 @@ export class TriggerEventRequestDto {
   @IsDefined()
   name: string;
 
-  @ApiProperty({
+  @ApiPropertyOptional({
     description: `The payload object is used to pass additional custom information that could be 
     used to render the workflow, or perform routing rules based on it. 
       This data will also be available when fetching the notifications feed from the API to display certain parts of the UI.`,
-    type: 'object',
-    required: false,
+    type: Object,
     additionalProperties: true,
     example: {
       comment_id: 'string',
@@ -262,7 +260,6 @@ export class TriggerEventRequestDto {
       },
     },
     type: TriggerOverrides,
-    required: false,
   })
   @IsObject()
   @IsOptional()
@@ -314,29 +311,27 @@ export class TriggerEventRequestDto {
   @IsOptional()
   transactionId?: string;
 
-  @ApiProperty({
+  @ApiPropertyOptional({
     description: `It is used to display the Avatar of the provided actor's subscriber id or actor object.
     If a new actor object is provided, we will create a new subscriber in our system`,
     oneOf: [
       { type: 'string', description: 'Unique identifier of a subscriber in your systems' },
       { $ref: getSchemaPath(SubscriberPayloadDto) },
     ],
-    required: false,
   })
   @IsOptional()
   @ValidateIf((_, value) => typeof value !== 'string')
   @ValidateNested()
   @Type(() => SubscriberPayloadDto)
   actor?: TriggerRecipientSubscriber;
 
-  @ApiProperty({
+  @ApiPropertyOptional({
     description: `It is used to specify a tenant context during trigger event.
     Existing tenants will be updated with the provided details.`,
     oneOf: [
       { type: 'string', description: 'Unique identifier of a tenant in your system' },
       { $ref: getSchemaPath(TenantPayloadDto) },
     ],
-    required: false,
   })
   @IsOptional()
   @ValidateIf((_, value) => typeof value !== 'string')

apps/api/src/app/events/dtos/trigger-event-to-all-request.dto.ts

@@ -21,11 +21,10 @@ export class TriggerEventToAllRequestDto {
         text: 'string',
       },
     },
-    type: 'object',
+    type: Object,
     description: `The payload object is used to pass additional information that 
     could be used to render the template, or perform routing rules based on it. 
       For In-App channel, payload data are also available in <Inbox />`,
-    required: true,
     additionalProperties: true,
   })
   @IsObject()
@@ -45,7 +44,6 @@ export class TriggerEventToAllRequestDto {
       type: 'object',
       additionalProperties: true,
     },
-    required: false,
   })
   @IsObject()
   @IsOptional()

apps/api/src/app/layouts-v2/dtos/generate-layout-preview-response.dto.ts

@@ -1,4 +1,4 @@
-import { ApiExtraModels, ApiProperty, ApiPropertyOptional, getSchemaPath } from '@nestjs/swagger';
+import { ApiExtraModels, ApiProperty, ApiPropertyOptional, getSchemaPath, type ApiPropertyOptions } from '@nestjs/swagger';
 import { ChannelTypeEnum } from '@novu/shared';
 import { Type } from 'class-transformer';
 import { IsOptional, IsString, ValidateNested } from 'class-validator';
@@ -23,7 +23,7 @@ export class GenerateLayoutPreviewResponseDto {
 
   @ApiPropertyOptional({
     description: 'The payload schema that was used to generate the preview payload example',
-    type: 'object',
+    type: Object,
     nullable: true,
     additionalProperties: true,
   })
@@ -32,7 +32,7 @@ export class GenerateLayoutPreviewResponseDto {
 
   @ApiProperty({
     description: 'Preview result',
-    type: 'object',
+    type: Object,
     oneOf: [
       {
         properties: {
@@ -41,7 +41,7 @@ export class GenerateLayoutPreviewResponseDto {
         },
       },
     ],
-  })
+  } as ApiPropertyOptions)
   result: {
     type: ChannelTypeEnum.EMAIL;
     preview?: EmailLayoutRenderOutput;

apps/api/src/app/notifications/dtos/activities-response.dto.ts

@@ -254,8 +254,7 @@ export class ActivityNotificationJobResponseDto {
 
   @ApiPropertyOptional({
     description: 'Optional context object for additional error details.',
-    type: 'object',
-    required: false,
+    type: Object,
     additionalProperties: true,
     example: {
       workflowId: 'some_wf_id',
@@ -430,8 +429,7 @@ export class ActivityNotificationResponseDto {
 
   @ApiPropertyOptional({
     description: 'Payload of the notification',
-    type: 'object',
-    required: false,
+    type: Object,
     additionalProperties: true,
   })
   payload?: Record<string, unknown>; // Added to align with NotificationEntity
@@ -444,16 +442,14 @@ export class ActivityNotificationResponseDto {
 
   @ApiPropertyOptional({
     description: 'Controls associated with the notification',
-    type: 'object',
-    required: false,
+    type: Object,
     additionalProperties: true,
   })
   controls?: Record<string, unknown>; // Added to align with NotificationEntity
 
   @ApiPropertyOptional({
     description: 'To field for subscriber definition',
-    type: 'object',
-    required: false,
+    type: Object,
     additionalProperties: true,
   })
   to?: Record<string, unknown>; // Added to align with NotificationEntity

apps/api/src/app/shared/dtos/subscriptions/create-subscriptions-response.dto.ts

@@ -120,8 +120,7 @@ export class SubscriptionPreferenceDto {
 
   @ApiPropertyOptional({
     description: 'Optional condition using JSON Logic rules',
-    required: false,
-    type: 'object',
+    type: Object,
     additionalProperties: true,
     example: { and: [{ '===': [{ var: 'tier' }, 'premium'] }] },
   })

apps/api/src/app/shared/dtos/subscriptions/create-subscriptions.dto.ts

@@ -39,19 +39,17 @@ export class TopicSubscriberIdentifierDto {
 }
 
 export class BasePreferenceDto {
-  @ApiProperty({
+  @ApiPropertyOptional({
     description: 'Whether the preference is enabled. Used when condition is not provided.',
-    required: false,
     type: Boolean,
     example: true,
   })
   @IsOptional()
   enabled?: boolean;
 
-  @ApiProperty({
+  @ApiPropertyOptional({
     description: 'Optional condition using JSON Logic rules',
-    required: false,
-    type: 'object',
+    type: Object,
     additionalProperties: true,
     example: { and: [{ '===': [{ var: 'tier' }, 'premium'] }] },
   })

apps/api/src/app/shared/framework/response.interceptor.ts

@@ -11,7 +11,7 @@ export interface Response<T> {
 @Injectable()
 export class ResponseInterceptor<T> implements NestInterceptor<T, Response<T>> {
   intercept(context, next: CallHandler): Observable<Response<T>> {
-    if (context.getType() === 'graphql') return next.handle();
+    if ((context.getType() as string) === 'graphql') return next.handle();
 
     return next.handle().pipe(
       map((data) => {

apps/api/src/app/shared/framework/user.decorator.ts

@@ -14,7 +14,8 @@ export interface SubscriberSession extends SubscriberEntity {
 }
 
 export const SubscriberSession = createParamDecorator((data, ctx) => {
-  const req = ctx.getType() === 'graphql' ? ctx.getArgs()[2].req : ctx.switchToHttp().getRequest();
+  const req =
+    (ctx.getType() as string) === 'graphql' ? ctx.getArgs()[2].req : ctx.switchToHttp().getRequest();
 
   if (req.user) {
     return req.user;

apps/api/src/app/subscribers-v2/dtos/get-subscriber-notifications-response.dto.ts

@@ -1,4 +1,4 @@
-import { ApiProperty } from '@nestjs/swagger';
+import { ApiProperty, type ApiPropertyOptions } from '@nestjs/swagger';
 import { InboxNotificationDto } from '../../inbox/dtos/inbox-notification.dto';
 import type { NotificationFilter } from '../../inbox/utils/types';
 
@@ -17,7 +17,7 @@ export class GetSubscriberNotificationsResponseDto {
 
   @ApiProperty({
     description: 'The filter applied to the notifications',
-    type: 'object',
-  })
+    type: Object,
+  } as ApiPropertyOptions)
   filter: NotificationFilter;
 }

apps/api/src/app/widgets/dtos/feeds-response.dto.ts

@@ -207,29 +207,27 @@ export class NotificationFeedItemDto implements INotificationDto {
   })
   status: 'sent' | 'error' | 'warning';
 
-  @ApiProperty({
+  @ApiPropertyOptional({
     description: 'The payload that was used to send the notification trigger.',
-    type: 'object',
+    type: Object,
     additionalProperties: true,
-    required: false,
     example: { key: 'value' },
   })
   payload?: Record<string, unknown>;
 
   @ApiPropertyOptional({
     description: 'The data sent with the notification.',
-    type: 'object',
+    type: Object,
     nullable: true,
     example: { key: 'value' },
     additionalProperties: true,
   })
   data?: Record<string, unknown> | null;
 
-  @ApiProperty({
+  @ApiPropertyOptional({
     description: 'Provider-specific overrides used when triggering the notification.',
-    type: 'object',
+    type: Object,
     additionalProperties: true,
-    required: false,
     example: { overrideKey: 'overrideValue' },
   })
   overrides?: Record<string, unknown>;