Merge pull request #4986 from novuhq/move-inbound-mail-parser-to-worker

Refactor move inbound mail parser to worker

apps/api/src/app/auth/usecases/login/login.usecase.ts

@@ -2,12 +2,11 @@ import * as bcrypt from 'bcrypt';
 import { Injectable, UnauthorizedException } from '@nestjs/common';
 import { differenceInMinutes, parseISO } from 'date-fns';
 import { UserRepository, UserEntity, OrganizationRepository } from '@novu/dal';
-import { AnalyticsService, AuthService } from '@novu/application-generic';
+import { AnalyticsService, AuthService, createHash } from '@novu/application-generic';
 
 import { LoginCommand } from './login.command';
 import { ApiException } from '../../../shared/exceptions/api.exception';
 import { normalizeEmail } from '../../../shared/helpers/email-normalization.service';
-import { createHash } from '../../../shared/helpers/hmac.service';
 
 @Injectable()
 export class Login {

apps/api/src/app/auth/usecases/register/user-register.usecase.ts

@@ -2,14 +2,13 @@ import { Inject, Injectable } from '@nestjs/common';
 import { OrganizationEntity, UserRepository } from '@novu/dal';
 import * as bcrypt from 'bcrypt';
 import { SignUpOriginEnum } from '@novu/shared';
-import { AnalyticsService, AuthService } from '@novu/application-generic';
+import { AnalyticsService, AuthService, createHash } from '@novu/application-generic';
 
 import { UserRegisterCommand } from './user-register.command';
 import { normalizeEmail } from '../../../shared/helpers/email-normalization.service';
 import { ApiException } from '../../../shared/exceptions/api.exception';
 import { CreateOrganization } from '../../../organization/usecases/create-organization/create-organization.usecase';
 import { CreateOrganizationCommand } from '../../../organization/usecases/create-organization/create-organization.command';
-import { createHash } from '../../../shared/helpers/hmac.service';
 
 @Injectable()
 export class UserRegister {

apps/api/src/app/inbound-parse/inbound-parse.module.ts

@@ -3,13 +3,11 @@ import { CompileTemplate, WorkflowInMemoryProviderService } from '@novu/applicat
 
 import { USE_CASES } from './usecases';
 import { InboundParseController } from './inbound-parse.controller';
-import { GetMxRecord } from './usecases/get-mx-record/get-mx-record.usecase';
 
 import { SharedModule } from '../shared/shared.module';
 import { AuthModule } from '../auth/auth.module';
-import { InboundParseWorkerService } from './services/inbound-parse.worker.service';
 
-const PROVIDERS = [GetMxRecord, CompileTemplate, InboundParseWorkerService];
+const PROVIDERS = [CompileTemplate];
 
 const memoryQueueService = {
   provide: WorkflowInMemoryProviderService,

apps/api/src/app/inbound-parse/usecases/index.ts

@@ -1,3 +1,3 @@
-import { InboundEmailParse } from './inbound-email-parse/inbound-email-parse.usecase';
+import { GetMxRecord } from './get-mx-record/get-mx-record.usecase';
 
-export const USE_CASES = [InboundEmailParse];
+export const USE_CASES = [GetMxRecord];

apps/api/src/app/subscribers/e2e/chat-oauth-callback.e2e.ts

@@ -5,7 +5,7 @@ import * as sinon from 'sinon';
 import { UserSession } from '@novu/testing';
 import { ChannelTypeEnum, ChatProviderIdEnum } from '@novu/shared';
 import { IntegrationRepository, SubscriberRepository } from '@novu/dal';
-import { createHash } from '../../shared/helpers/hmac.service';
+import { createHash } from '@novu/application-generic';
 
 const axiosInstance = axios.create();
 

apps/api/src/app/subscribers/e2e/chat-oauth.e2e.ts

@@ -4,7 +4,7 @@ import axios from 'axios';
 import { UserSession } from '@novu/testing';
 import { ChannelTypeEnum, ChatProviderIdEnum } from '@novu/shared';
 import { IntegrationRepository, SubscriberRepository } from '@novu/dal';
-import { createHash } from '../../shared/helpers/hmac.service';
+import { createHash } from '@novu/application-generic';
 
 const axiosInstance = axios.create();
 

apps/api/src/app/subscribers/usecases/chat-oauth/chat-oauth.usecase.ts

@@ -2,9 +2,9 @@ import { Injectable, NotFoundException } from '@nestjs/common';
 
 import { ChannelTypeEnum } from '@novu/stateless';
 import { IntegrationEntity, IntegrationRepository, EnvironmentRepository, ICredentialsEntity } from '@novu/dal';
+import { createHash } from '@novu/application-generic';
 
 import { ChatOauthCommand } from './chat-oauth.command';
-import { createHash } from '../../../shared/helpers/hmac.service';
 import { ApiException } from '../../../shared/exceptions/api.exception';
 
 @Injectable()

apps/api/src/app/user/usecases/get-my-profile/get-my-profile.usecase.ts

@@ -1,7 +1,9 @@
 import { Injectable, NotFoundException, Logger } from '@nestjs/common';
+
 import { UserRepository } from '@novu/dal';
+import { createHash } from '@novu/application-generic';
+
 import { GetMyProfileCommand } from './get-my-profile.dto';
-import { createHash } from '../../../shared/helpers/hmac.service';
 @Injectable()
 export class GetMyProfileUsecase {
   constructor(private readonly userRepository: UserRepository) {}

apps/api/src/app/widgets/e2e/initialize-widget-session.e2e.ts

@@ -2,11 +2,11 @@ import { IntegrationRepository } from '@novu/dal';
 import { ChannelTypeEnum, InAppProviderIdEnum } from '@novu/shared';
 import { UserSession } from '@novu/testing';
 import { expect } from 'chai';
-import { createHash } from '../../shared/helpers/hmac.service';
 import {
   buildIntegrationKey,
   CacheInMemoryProviderService,
   CacheService,
+  createHash,
   InvalidateCacheService,
 } from '@novu/application-generic';
 

apps/api/src/app/widgets/usecases/initialize-session/initialize-session.usecase.ts

@@ -9,13 +9,13 @@ import {
   SelectIntegrationCommand,
   SelectIntegration,
   AuthService,
+  createHash,
 } from '@novu/application-generic';
 
 import { ApiException } from '../../../shared/exceptions/api.exception';
 import { InitializeSessionCommand } from './initialize-session.command';
 
 import { SessionInitializeResponseDto } from '../../dtos/session-initialize-response.dto';
-import { createHash } from '../../../shared/helpers/hmac.service';
 
 @Injectable()
 export class InitializeSession {

apps/worker/src/app/shared/utils/index.ts

@@ -1,4 +1,3 @@
 export * from './constants';
 export * from './exceptions';
-export * from './hmac';
 export * from './cron-health';