refactor(echo): rename chimera to echo

apps/api/package.json

@@ -117,7 +117,7 @@
     "typescript": "4.9.5"
   },
   "optionalDependencies": {
-    "@novu/ee-chimera": "^0.24.1",
+    "@novu/ee-echo-api": "^0.24.1",
     "@novu/ee-auth": "^0.24.1",
     "@novu/ee-billing": "^0.24.1",
     "@novu/ee-translation": "^0.24.1"

apps/api/src/app.module.ts

@@ -44,8 +44,8 @@ const enterpriseImports = (): Array<Type | DynamicModule | Promise<DynamicModule
     if (require('@novu/ee-auth')?.EEAuthModule) {
       modules.push(require('@novu/ee-auth')?.EEAuthModule);
     }
-    if (require('@novu/ee-chimera')?.ChimeraModule) {
-      modules.push(require('@novu/ee-chimera')?.ChimeraModule);
+    if (require('@novu/ee-echo-api')?.EchoModule) {
+      modules.push(require('@novu/ee-echo-api')?.EchoModule);
     }
     if (require('@novu/ee-translation')?.EnterpriseTranslationModule) {
       modules.push(require('@novu/ee-translation')?.EnterpriseTranslationModule);

apps/api/src/app/events/usecases/send-test-email/send-test-email.usecase.ts

@@ -89,10 +89,10 @@ export class SendTestEmail {
 
     if (command.chimera) {
       if (process.env.NOVU_ENTERPRISE === 'true' || process.env.CI_EE_TEST === 'true') {
-        if (!require('@novu/ee-chimera')?.PreviewStep) {
+        if (!require('@novu/ee-echo-api')?.PreviewStep) {
           throw new ApiException('Chimera module is not loaded');
         }
-        const service = this.moduleRef.get(require('@novu/ee-chimera')?.PreviewStep, { strict: false });
+        const service = this.moduleRef.get(require('@novu/ee-echo-api')?.PreviewStep, { strict: false });
         const data = await service.execute({
           workflowId: command.workflowId,
           stepId: command.stepId,

apps/worker/package.json

@@ -84,7 +84,7 @@
     "typescript": "4.9.5"
   },
   "optionalDependencies": {
-    "@novu/ee-chimera-connect": "^0.24.1",
+    "@novu/ee-echo-worker": "^0.24.1",
     "@novu/ee-auth": "^0.24.1",
     "@novu/ee-billing": "^0.24.1",
     "@novu/ee-translation": "^0.24.1"

apps/worker/src/app/workflow/usecases/send-message/send-message.usecase.ts

@@ -53,7 +53,7 @@ import { PlatformException } from '../../../shared/utils';
 
 @Injectable()
 export class SendMessage {
-  private chimeraConnector: IUseCaseInterfaceInline;
+  private resonateUsecase: IUseCaseInterfaceInline;
 
   constructor(
     private sendMessageEmail: SendMessageEmail,
@@ -74,7 +74,7 @@ export class SendMessage {
     private analyticsService: AnalyticsService,
     protected moduleRef: ModuleRef
   ) {
-    this.chimeraConnector = requireInject('chimera_connector', this.moduleRef);
+    this.resonateUsecase = requireInject('resonate', this.moduleRef);
   }
 
   @InstrumentUsecase()
@@ -88,7 +88,7 @@ export class SendMessage {
 
     const stepType = command.step?.template?.type;
 
-    const chimeraResponse = await this.chimeraConnector.execute<
+    const resonateResponse = await this.resonateUsecase.execute<
       SendMessageCommand & { variables: IFilterVariables },
       ExecuteOutput<IChimeraChannelResponse> | null
     >({
@@ -121,7 +121,7 @@ export class SendMessage {
        * This is intentional, so that mixpanel can automatically reshard it.
        */
       this.analyticsService.mixpanelTrack('Process Workflow Step - [Triggers]', '', {
-        workflowType: chimeraResponse?.outputs ? 'ECHO' : 'REGULAR',
+        workflowType: resonateResponse?.outputs ? 'ECHO' : 'REGULAR',
         _template: command.job._templateId,
         _organization: command.organizationId,
         _environment: command.environmentId,
@@ -164,7 +164,7 @@ export class SendMessage {
     const sendMessageCommand = SendMessageCommand.create({
       ...command,
       compileContext: payload,
-      chimeraData: chimeraResponse,
+      chimeraData: resonateResponse,
     });
 
     switch (stepType) {

apps/worker/src/app/workflow/workflow.module.ts

@@ -76,10 +76,10 @@ const enterpriseImports = (): Array<Type | DynamicModule | Promise<DynamicModule
         modules.push(require('@novu/ee-billing')?.BillingModule.forRoot(activeWorkers));
       }
 
-      if (require('@novu/ee-chimera-connect')?.ChimeraConnectorModule) {
+      if (require('@novu/ee-echo-worker')?.EchoGatewayModule) {
         Logger.log('Importing enterprise chimera connector module', 'EnterpriseImport');
 
-        modules.push(require('@novu/ee-chimera-connect')?.ChimeraConnectorModule);
+        modules.push(require('@novu/ee-echo-worker')?.EchoGatewayModule);
       }
     }
   } catch (e) {

enterprise/packages/chimera/package.json → enterprise/packages/echo/echo-api/package.json

@@ -1,5 +1,5 @@
 {
-  "name": "@novu/ee-chimera",
+  "name": "@novu/ee-echo-api",
   "version": "0.24.1",
   "private": true,
   "main": "dist/index.js",

enterprise/packages/echo/echo-api/src

@@ -0,0 +1 @@
+../../../../.source/echo/echo-api/src

enterprise/packages/chimera/tsconfig.json → enterprise/packages/echo/echo-api/tsconfig.json

@@ -1,5 +1,5 @@
 {
-  "extends": "../../../tsconfig.json",
+  "extends": "../../../../tsconfig.json",
   "compilerOptions": {
     "allowSyntheticDefaultImports": true,
     "outDir": "dist",

enterprise/packages/echo/echo-web/src

@@ -0,0 +1 @@
+../../../../.source/echo/echo-web/src

enterprise/packages/chimera-connect/package.json → enterprise/packages/echo/echo-worker/package.json

@@ -1,5 +1,5 @@
 {
-  "name": "@novu/ee-chimera-connect",
+  "name": "@novu/ee-echo-worker",
   "version": "0.24.1",
   "private": true,
   "main": "dist/index.js",

enterprise/packages/echo/echo-worker/src

@@ -0,0 +1 @@
+../../../../.source/echo/echo-worker/src

enterprise/packages/chimera-connect/tsconfig.json → enterprise/packages/echo/echo-worker/tsconfig.json

@@ -1,5 +1,5 @@
 {
-  "extends": "../../../tsconfig.json",
+  "extends": "../../../../tsconfig.json",
   "compilerOptions": {
     "allowSyntheticDefaultImports": true,
     "outDir": "dist",

packages/application-generic/package.json

@@ -165,7 +165,7 @@
     "slugify": "^1.4.6"
   },
   "optionalDependencies": {
-    "@novu/ee-chimera-connect": "^0.24.1",
+    "@novu/ee-echo-worker": "^0.24.1",
     "@novu/ee-shared-services": "^0.24.1",
     "@taskforcesh/bullmq-pro": "5.1.14"
   },

packages/application-generic/src/usecases/add-job/add-job.usecase.ts

@@ -44,7 +44,7 @@ const LOG_CONTEXT = 'AddJob';
 
 @Injectable()
 export class AddJob {
-  private chimeraConnector: IUseCaseInterfaceInline;
+  private resonateUsecase: IUseCaseInterfaceInline;
 
   constructor(
     private jobRepository: JobRepository,
@@ -60,7 +60,7 @@ export class AddJob {
     private conditionsFilter: ConditionsFilter,
     private moduleRef: ModuleRef
   ) {
-    this.chimeraConnector = requireInject('chimera_connector', this.moduleRef);
+    this.resonateUsecase = requireInject('resonate', this.moduleRef);
   }
 
   @InstrumentUsecase()
@@ -108,7 +108,7 @@ export class AddJob {
     let digestAmount: number | undefined;
     let digestCreationResult: DigestCreationResultEnum | undefined;
     if (job.type === StepTypeEnum.DIGEST) {
-      const chimeraResponse = await this.chimeraConnector.execute<
+      const resonateResponse = await this.resonateUsecase.execute<
         AddJobCommand,
         ExecuteOutput<IChimeraDigestResponse>
       >(command);
@@ -119,7 +119,7 @@ export class AddJob {
         stepMetadata: job.digest,
         payload: job.payload,
         overrides: job.overrides,
-        chimeraResponse: chimeraResponse?.outputs,
+        chimeraResponse: resonateResponse?.outputs,
       });
 
       Logger.debug(`Digest step amount is: ${digestAmount}`, LOG_CONTEXT);
@@ -128,7 +128,7 @@ export class AddJob {
         MergeOrCreateDigestCommand.create({
           job,
           filtered,
-          chimeraData: chimeraResponse?.outputs,
+          chimeraData: resonateResponse?.outputs,
         })
       );
 
@@ -163,12 +163,12 @@ export class AddJob {
     let delayAmount: number | undefined = undefined;
 
     if (job.type === StepTypeEnum.DELAY) {
-      const chimeraResponse = await this.chimeraConnector.execute<
+      const resonateResponse = await this.resonateUsecase.execute<
         AddJobCommand,
         ExecuteOutput<IChimeraDigestResponse>
       >(command);
 
-      command.chimeraResponse = chimeraResponse;
+      command.chimeraResponse = resonateResponse;
       delayAmount = await this.addDelayJob.execute(command);
 
       Logger.debug(`Delay step Amount is: ${delayAmount}`, LOG_CONTEXT);

packages/application-generic/src/utils/require-inject.ts

@@ -4,27 +4,24 @@ import { ModuleRef } from '@nestjs/core';
 import { ChatProviderIdEnum } from '@novu/shared';
 
 export const requireInject = (inject: RequireInject, moduleRef?: ModuleRef) => {
-  if (inject === RequireInjectEnum.CHIMERA_CONNECT) {
-    return initiateChimeraConnector(moduleRef);
+  if (inject === RequireInjectEnum.RESONATE) {
+    return initiateResonateProvider(moduleRef);
   }
 };
 
-const initiateChimeraConnector = (moduleRef: ModuleRef) => {
+const initiateResonateProvider = (moduleRef: ModuleRef) => {
   try {
     if (
       process.env.NOVU_ENTERPRISE === 'true' ||
       process.env.CI_EE_TEST === 'true'
     ) {
-      if (!require('@novu/ee-chimera-connect')?.ChimeraConnector) {
-        throw new PlatformException('ChimeraConnector module is not loaded');
+      if (!require('@novu/ee-echo-worker')?.Resonate) {
+        throw new PlatformException('Resonate provider is not loaded');
       }
 
-      return moduleRef.get(
-        require('@novu/ee-chimera-connect')?.ChimeraConnector,
-        {
-          strict: false,
-        }
-      );
+      return moduleRef.get(require('@novu/ee-echo-worker')?.Resonate, {
+        strict: false,
+      });
     } else {
       return {
         execute: () => {
@@ -36,7 +33,7 @@ const initiateChimeraConnector = (moduleRef: ModuleRef) => {
     Logger.error(
       e,
       `Unexpected error while importing enterprise modules`,
-      'ChimeraConnector'
+      'Resonate'
     );
     throw e;
   }
@@ -45,7 +42,7 @@ const initiateChimeraConnector = (moduleRef: ModuleRef) => {
 type RequireInject = `${RequireInjectEnum}`;
 
 enum RequireInjectEnum {
-  CHIMERA_CONNECT = 'chimera_connector',
+  RESONATE = 'resonate',
 }
 
 export interface IChimeraDigestResponse {