feat: Added support for azure blob storage in queue-manager

Author: bhavik

apps/queue-manager/src/.env.development

@@ -3,11 +3,23 @@ RABBITMQ_CONN_URL=amqp://guest:guest@localhost:5672
 MONGO_URL=mongodb://localhost:27017/impler-db
 
 # Storage
+STORAGE_TYPE=s3
 S3_REGION=us-east-1
 S3_LOCAL_STACK=http://localhost:4566
 S3_BUCKET_NAME=impler
 AWS_ACCESS_KEY_ID=
 AWS_SECRET_ACCESS_KEY=
 
+AZURE_STORAGE_CONNECTION_STRING=
+AZURE_STORAGE_CONTAINER=
+
 # Analytics
-SENTRY_DSN=
+SENTRY_DSN=
+
+# Email
+SES_REGION=
+SES_ACCESS_KEY_ID=
+SES_SECRET_ACCESS_KEY=
+EMAIL_FROM=
+ALERT_EMAIL_FROM=
+EMAIL_FROM_NAME=

apps/queue-manager/src/.env.production

@@ -3,11 +3,23 @@ RABBITMQ_CONN_URL=amqp://guest:guest@localhost:5672
 MONGO_URL=mongodb://localhost:27017/impler-db
 
 # Storage
+STORAGE_TYPE=s3
 S3_REGION=us-east-1
 S3_LOCAL_STACK=http://localhost:4566
 S3_BUCKET_NAME=impler
 AWS_ACCESS_KEY_ID=
 AWS_SECRET_ACCESS_KEY=
 
+AZURE_STORAGE_CONNECTION_STRING=
+AZURE_STORAGE_CONTAINER=
+
 # Analytics
-SENTRY_DSN=
+SENTRY_DSN=
+
+# Email
+SES_REGION=
+SES_ACCESS_KEY_ID=
+SES_SECRET_ACCESS_KEY=
+EMAIL_FROM=
+ALERT_EMAIL_FROM=
+EMAIL_FROM_NAME=

apps/queue-manager/src/.env.test

@@ -3,11 +3,20 @@ RABBITMQ_CONN_URL=amqp://guest:guest@localhost:5672
 MONGO_URL=mongodb://localhost:27017/impler-db
 
 # Storage
+STORAGE_TYPE=s3
 S3_REGION=us-east-1
 S3_LOCAL_STACK=http://localhost:4566
 S3_BUCKET_NAME=impler
 AWS_ACCESS_KEY_ID=
 AWS_SECRET_ACCESS_KEY=
 
 # Analytics
-SENTRY_DSN=
+SENTRY_DSN=
+
+# Email
+SES_REGION=
+SES_ACCESS_KEY_ID=
+SES_SECRET_ACCESS_KEY=
+EMAIL_FROM=
+ALERT_EMAIL_FROM=
+EMAIL_FROM_NAME=

apps/queue-manager/src/.example.env

@@ -4,9 +4,18 @@ RABBITMQ_CONN_URL=amqp://guest:guest@localhost:5672
 MONGO_URL=mongodb://localhost:27017/impler-db
 
 # Storage
+STORAGE_TYPE=s3
 S3_REGION=us-east-1
 S3_LOCAL_STACK=http://localhost:4566
 S3_BUCKET_NAME=impler
 
 # Analytics
-SENTRY_DSN=
+SENTRY_DSN=
+
+# Email
+SES_REGION=
+SES_ACCESS_KEY_ID=
+SES_SECRET_ACCESS_KEY=
+EMAIL_FROM=
+ALERT_EMAIL_FROM=
+EMAIL_FROM_NAME=

apps/queue-manager/src/config/env-validator.ts

@@ -1,13 +1,17 @@
 import { str, ValidatorSpec } from 'envalid';
 import * as envalid from 'envalid';
-import { ENVTypesEnum } from '@impler/shared';
+import { ENVTypesEnum, StorageTypeEnum } from '@impler/shared';
 
 // eslint-disable-next-line @typescript-eslint/no-explicit-any
 const validators: { [K in keyof any]: ValidatorSpec<any[K]> } = {
   NODE_ENV: str({
     choices: [ENVTypesEnum.DEV, ENVTypesEnum.TEST, ENVTypesEnum.PROD, ENVTypesEnum.CI, ENVTypesEnum.LOCAL],
     default: ENVTypesEnum.LOCAL,
   }),
+  STORAGE_TYPE: str({
+    choices: [StorageTypeEnum.S3, StorageTypeEnum.AZURE],
+    default: StorageTypeEnum.S3,
+  }),
   MONGO_URL: str(),
   RABBITMQ_CONN_URL: str(),
   S3_LOCAL_STACK: str({

apps/queue-manager/src/helpers/services.helper.ts

@@ -1,12 +1,14 @@
-import { EmailService, S3StorageService, SESEmailService, StorageService } from '@impler/services';
+import { StorageTypeEnum } from '@impler/shared';
+import { AzureStorageService, EmailService, S3StorageService, SESEmailService, StorageService } from '@impler/services';
 
 let storageService: StorageService;
 let emailService: EmailService;
 
 // Implementing singleton pattern for storage service
 export function getStorageServiceClass() {
   if (storageService) return storageService;
-  storageService = new S3StorageService();
+  storageService =
+    process.env.STORAGE_TYPE === StorageTypeEnum.AZURE ? new AzureStorageService() : new S3StorageService();
 
   return storageService;
 }