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

apps/api/.mocharc.e2e.json

@@ -0,0 +1,6 @@
+{
+  "timeout": 35000,
+  "require": "@swc-node/register",
+  "file": ["e2e/setup.ts"],
+  "exit": true
+}

apps/api/.mocharc.json

@@ -1,8 +1,7 @@
 {
   "timeout": 35000,
-  "require": "@swc-node/register",
-  "node-option": ["no-experimental-strip-types"],
+  "require": ["@swc-node/register", "./src/config/load-test-env.ts"],
   "file": ["e2e/setup.ts"],
   "exit": true,
-  "files": ["e2e/**/*.e2e.ts", "src/**/*.e2e.ts", "src/**/**/*.spec.ts"]
+  "files": ["e2e/**/*.e2e.ts", "src/**/*.e2e.ts", "src/**/*.spec.ts"]
 }

apps/api/package.json

@@ -30,9 +30,9 @@
     "pretest": "pnpm build:metadata",
     "generate:swagger": "ts-node exportOpenAPIJSON.ts",
     "generate:sdk": " (cd ../../libs/internal-sdk && speakeasy run --skip-compile --minimal --skip-versioning) && (cd ../../libs/internal-sdk && pnpm build) ",
-    "test": "cross-env TS_NODE_PROJECT=tsconfig.spec.json TS_NODE_TRANSPILE_ONLY=true NODE_ENV=test NOVU_ENTERPRISE=true CLERK_ENABLED=true NODE_OPTIONS=--no-experimental-strip-types mocha --timeout 15000 --require ts-node/register --exit 'src/**/*.spec.ts'",
-    "test:e2e:novu-v0": "cross-env TS_NODE_PROJECT=tsconfig.spec.json NODE_ENV=test NODE_OPTIONS=--no-experimental-strip-types mocha --timeout 15000 --retries 3 --grep '#novu-v0' --require ts-node/register --exit --file e2e/setup.ts src/**/*.e2e{,-ee}.ts",
-    "test:e2e:novu-v2": "cross-env TS_NODE_PROJECT=tsconfig.spec.json NODE_ENV=test CI_EE_TEST=true CLERK_ENABLED=true NODE_OPTIONS='--max_old_space_size=8192 --no-experimental-strip-types' node scripts/run-novu-v2-e2e-shard.cjs",
+    "test": "cross-env TS_NODE_PROJECT=tsconfig.spec.json TS_NODE_TRANSPILE_ONLY=true NODE_ENV=test NOVU_ENTERPRISE=true CLERK_ENABLED=true mocha --timeout 15000 --require ts-node/register --require ./src/config/load-test-env.ts --exit 'src/**/*.spec.ts' --ignore 'src/**/e2e/**/*.spec.ts'",
+    "test:e2e:novu-v0": "cross-env TS_NODE_PROJECT=tsconfig.spec.json NODE_ENV=test mocha --config .mocharc.e2e.json --timeout 15000 --retries 3 --grep '#novu-v0' --require ts-node/register --exit src/**/*.e2e{,-ee}.ts",
+    "test:e2e:novu-v2": "cross-env TS_NODE_PROJECT=tsconfig.spec.json NODE_ENV=test CI_EE_TEST=true CLERK_ENABLED=true NODE_OPTIONS=--max_old_space_size=8192 node scripts/run-novu-v2-e2e-shard.cjs",
     "migration": "cross-env NODE_ENV=local MIGRATION=true ts-node --transpileOnly",
     "seed:clickhouse": "cross-env NODE_ENV=local ts-node --transpileOnly scripts/seed-clickhouse.ts",
     "seed:triggers": "cross-env NODE_ENV=local ts-node --transpileOnly scripts/seed-triggers.ts",
@@ -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/scripts/run-novu-v2-e2e-shard.cjs

@@ -14,6 +14,8 @@ const DEFAULT_MOCHA_REPORTER = process.env.CI ? 'dot' : 'spec';
 const MOCHA_REPORTER = process.env.NOVU_V2_MOCHA_REPORTER || DEFAULT_MOCHA_REPORTER;
 
 const MOCHA_ARGS = [
+  '--config',
+  '.mocharc.e2e.json',
   '--timeout',
   '30000',
   '--retries',
@@ -23,11 +25,7 @@ const MOCHA_ARGS = [
   MOCHA_REPORTER,
   '--grep',
   NOVU_V2_TAG,
-  '--require',
-  './swc-register.js',
   '--exit',
-  '--file',
-  'e2e/setup.ts',
 ];
 
 function toPosixPath(filePath) {
@@ -152,7 +150,10 @@ function collectWeightedFiles() {
 }
 
 function isLighterShard(candidate, current) {
-  return candidate.weight < current.weight || (candidate.weight === current.weight && candidate.files.length < current.files.length);
+  return (
+    candidate.weight < current.weight ||
+    (candidate.weight === current.weight && candidate.files.length < current.files.length)
+  );
 }
 
 function pickLightestShard(shards) {
@@ -187,7 +188,9 @@ function getShard(weightedFiles, shardIndex, totalShards) {
 }
 
 function printShardSummary(shardIndex, totalShards, shard) {
-  console.log(`Running Novu V2 E2E shard ${shardIndex}/${totalShards} with ${shard.files.length} files (weight ${shard.weight}).`);
+  console.log(
+    `Running Novu V2 E2E shard ${shardIndex}/${totalShards} with ${shard.files.length} files (weight ${shard.weight}).`
+  );
 }
 
 function runMocha(filePaths) {

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/billing/e2e/checkout-session-completed.e2e-ee.ts

@@ -1,3 +1,4 @@
+import { CheckoutSessionCompletedHandler, GetPrices, VerifyCustomer } from '@novu/ee-billing';
 import { ApiServiceLevelEnum, StripeBillingIntervalEnum } from '@novu/shared';
 import { expect } from 'chai';
 import sinon from 'sinon';
@@ -147,13 +148,6 @@ describe('webhook event - checkout.session.completed #novu-v2', () => {
     },
   };
 
-  const eeBilling = require('@novu/ee-billing');
-  if (!eeBilling) {
-    throw new Error('ee-billing does not exist');
-  }
-
-  const { CheckoutSessionCompletedHandler, VerifyCustomer, GetPrices } = eeBilling;
-
   let verifyCustomerStub: sinon.SinonStub;
   let getPricesStub: sinon.SinonStub;
   const analyticsServiceStub = {

apps/api/src/app/billing/e2e/create-checkout-session.e2e-ee.ts

@@ -1,3 +1,4 @@
+import { CreateCheckoutSession } from '@novu/ee-billing';
 import { ApiServiceLevelEnum, StripeBillingIntervalEnum } from '@novu/shared';
 import { expect } from 'chai';
 import sinon from 'sinon';
@@ -23,12 +24,10 @@ const checkoutSessionCreateParamsMock = {
 };
 
 describe('Create checkout session #novu-v2', async () => {
-  if (!require('@novu/ee-billing').CreateCheckoutSession) {
+  if (!CreateCheckoutSession) {
     throw new Error("CreateCheckoutSession doesn't exist");
   }
 
-  const { CreateCheckoutSession } = require('@novu/ee-billing');
-
   const getOrCreateCustomer = {
     execute: () => Promise.resolve({ id: 'customer_id' }),
   };

apps/api/src/app/billing/e2e/create-subscription.e2e-ee.ts

@@ -1,16 +1,15 @@
+import {
+  CreateSubscription,
+  CreateSubscriptionCommand,
+  GetPrices,
+  UpdateServiceLevel,
+} from '@novu/ee-billing';
+import { StripeSubscriptionStatusEnum, StripeUsageTypeEnum } from '@novu/ee-billing/src/stripe/types';
 import { ApiServiceLevelEnum, StripeBillingIntervalEnum } from '@novu/shared';
 import { expect } from 'chai';
 import sinon from 'sinon';
 
-const { StripeSubscriptionStatusEnum, StripeUsageTypeEnum } = require('@novu/ee-billing/src/stripe/types');
-
 describe('CreateSubscription #novu-v2', () => {
-  const eeBilling = require('@novu/ee-billing');
-  if (!eeBilling) {
-    throw new Error('ee-billing does not exist');
-  }
-
-  const { CreateSubscription, GetPrices, UpdateServiceLevel, CreateSubscriptionCommand } = eeBilling;
 
   const stripeStub = {
     subscriptions: {

apps/api/src/app/billing/e2e/create-usage-records.e2e-ee.ts

@@ -1,11 +1,11 @@
 // biome-ignore lint/style/noRestrictedImports: <explanation>
 import { Logger } from '@nestjs/common';
+import { CreateUsageRecords, CreateUsageRecordsCommand } from '@novu/ee-billing';
+import { StripeUsageTypeEnum } from '@novu/ee-billing/src/stripe/types';
 import { ApiServiceLevelEnum, StripeBillingIntervalEnum } from '@novu/shared';
 import { expect } from 'chai';
 import sinon from 'sinon';
 
-const { StripeUsageTypeEnum } = require('@novu/ee-billing/src/stripe/types');
-
 const mockMonthlyBusinessSubscription = {
   id: 'subscription_id',
   items: {
@@ -23,12 +23,6 @@ const mockMonthlyBusinessSubscription = {
 };
 
 describe('CreateUsageRecords #novu-v2', () => {
-  const eeBilling = require('@novu/ee-billing');
-  if (!eeBilling) {
-    throw new Error('ee-billing does not exist');
-  }
-  const { CreateUsageRecords, CreateUsageRecordsCommand } = eeBilling;
-
   const stripeStub = {
     subscriptionItems: {
       createUsageRecord: () => {},

apps/api/src/app/billing/e2e/customer-subscription-created.e2e-ee.ts

@@ -1,3 +1,4 @@
+import { CustomerSubscriptionCreatedHandler, UpdateServiceLevel, VerifyCustomer } from '@novu/ee-billing';
 import { ApiServiceLevelEnum, StripeBillingIntervalEnum } from '@novu/shared';
 import { expect } from 'chai';
 import sinon from 'sinon';
@@ -127,13 +128,6 @@ const verifyCustomerMock = {
 };
 
 describe('webhook event - customer.subscription.created #novu-v2', () => {
-  const eeBilling = require('@novu/ee-billing');
-  if (!eeBilling) {
-    throw new Error('ee-billing does not exist');
-  }
-
-  const { CustomerSubscriptionCreatedHandler, VerifyCustomer, UpdateServiceLevel } = eeBilling;
-
   let verifyCustomerStub: sinon.SinonStub;
   let updateServiceLevelStub: sinon.SinonStub;
 

apps/api/src/app/billing/e2e/customer-subscription-deleted.e2e-ee.ts

@@ -1,3 +1,10 @@
+import {
+  CreateSubscription,
+  CustomerSubscriptionDeletedHandler,
+  UpdateServiceLevel,
+  UpdateServiceLevelCommand,
+  VerifyCustomer,
+} from '@novu/ee-billing';
 import { ApiServiceLevelEnum, StripeBillingIntervalEnum } from '@novu/shared';
 import { expect } from 'chai';
 import sinon from 'sinon';
@@ -98,19 +105,6 @@ const verifyCustomerMock = {
 };
 
 describe.skip('webhook event - customer.subscription.deleted #novu-v2', () => {
-  const eeBilling = require('@novu/ee-billing');
-  if (!eeBilling) {
-    throw new Error('ee-billing does not exist');
-  }
-
-  const {
-    CustomerSubscriptionDeletedHandler,
-    VerifyCustomer,
-    UpdateServiceLevel,
-    UpdateServiceLevelCommand,
-    CreateSubscription,
-  } = eeBilling;
-
   const stripeStub = {
     customers: {
       update: sinon.stub(),

apps/api/src/app/billing/e2e/get-platform-notification-usage.e2e-ee.ts

@@ -1,18 +1,15 @@
 import { PinoLogger } from '@novu/application-generic';
+import {
+  GetPlatformNotificationUsage,
+  GetPlatformNotificationUsageCommand,
+} from '@novu/ee-billing';
 import { CommunityOrganizationRepository, EnvironmentRepository, NotificationRepository } from '@novu/dal';
 import { ApiServiceLevelEnum, isClerkEnabled } from '@novu/shared';
 import { UserSession } from '@novu/testing';
 import { expect } from 'chai';
 import sinon from 'sinon';
 
 describe('GetPlatformNotificationUsage #novu-v2', () => {
-  const eeBilling = require('@novu/ee-billing');
-  if (!eeBilling) {
-    throw new Error('ee-billing does not exist');
-  }
-
-  const { GetPlatformNotificationUsage, GetPlatformNotificationUsageCommand } = eeBilling;
-
   const environmentRepo = new EnvironmentRepository();
   const notificationRepo = new NotificationRepository();
   const communityOrganizationRepo = new CommunityOrganizationRepository();

apps/api/src/app/billing/e2e/get-portal-link.e2e-ee.ts

@@ -1,11 +1,12 @@
+import { GetPortalLink } from '@novu/ee-billing';
 import { expect } from 'chai';
 import sinon from 'sinon';
 
 const dashboardOrigin = process.env.DASHBOARD_URL;
 
 describe('Get portal link #novu-v2', async () => {
   it('Get portal link', async () => {
-    if (!require('@novu/ee-billing').GetPortalLink) {
+    if (!GetPortalLink) {
       throw new Error("GetPortalLink doesn't exist");
     }
     const stubObject = {
@@ -27,7 +28,7 @@ describe('Get portal link #novu-v2', async () => {
 
     const stub = sinon.stub(stubObject.billingPortal.sessions, 'create').resolves({ url: 'url' });
 
-    const usecase = new (require('@novu/ee-billing').GetPortalLink)(stubObject, getCustomerUsecase);
+    const usecase = new GetPortalLink(stubObject, getCustomerUsecase);
 
     const result = await usecase.execute({
       environmentId: 'environment_dd',

apps/api/src/app/billing/e2e/get-prices.e2e-ee.ts

@@ -1,15 +1,9 @@
+import { GetPrices, GetPricesCommand } from '@novu/ee-billing';
 import { ApiServiceLevelEnum, StripeBillingIntervalEnum } from '@novu/shared';
 import { expect } from 'chai';
 import sinon from 'sinon';
 
 describe('GetPrices #novu-v2', () => {
-  const eeBilling = require('@novu/ee-billing');
-  if (!eeBilling) {
-    throw new Error('ee-billing does not exist');
-  }
-
-  const { GetPrices, GetPricesCommand } = eeBilling;
-
   const stripeStub = {
     prices: {
       list: sinon.stub(),

apps/api/src/app/billing/e2e/get-subscription.e2e-ee.ts

@@ -1,3 +1,4 @@
+import { GetPlatformNotificationUsageCommand, GetSubscription, GetSubscriptionCommand } from '@novu/ee-billing';
 import { ApiServiceLevelEnum } from '@novu/shared';
 import { UserSession } from '@novu/testing';
 import { expect } from 'chai';
@@ -56,13 +57,6 @@ const mockedStripeCustomer: DeepPartial<Stripe.Customer> = {
 describe('GetSubscription #novu-v2', async () => {
   let session: UserSession;
 
-  const eeBilling = require('@novu/ee-billing');
-  if (!eeBilling) {
-    throw new Error('ee-billing does not exist');
-  }
-
-  const { GetPlatformNotificationUsageCommand, GetSubscription, GetSubscriptionCommand } = eeBilling;
-
   const communityOrganizationRepo = {
     findById: () =>
       Promise.resolve({