feat(imap) IMAP plugin

backend/plugins/frontline_api/package.json

@@ -13,12 +13,17 @@
   "license": "ISC",
   "dependencies": {
     "aws-sdk": "^2.1692.0",
+    "base64-stream": "^1.0.0",
     "debug": "^4.4.0",
+    "dotenv": "^17.2.1",
     "erxes-api-shared": "workspace:^",
     "fast-xml-parser": "^5.2.5",
     "fbgraph": "^1.4.4",
+    "ioredis": "^5.7.0",
+    "mailparser": "^3.7.4",
     "moment-timezone": "^0.5.48",
-    "redlock": "5.0.0-beta.2",
+    "node-imap": "^0.9.6",
+    "redlock": "4.2.0",
     "string-strip-html": "^13.4.12",
     "strip-html": "^1.0.2"
   }

backend/plugins/frontline_api/src/main.ts

@@ -8,6 +8,7 @@ import { generateModels } from './connectionResolvers';
 import { initializeCallQueueMonitoring } from '~/modules/integrations/call/worker/callDashboard';
 import automations from './meta/automations';
 import initCallApp from '~/modules/integrations/call/initApp';
+import initImapApp from '~/modules/integrations/imap/configs';
 
 startPlugin({
   name: 'frontline',
@@ -28,8 +29,8 @@ startPlugin({
 
   expressRouter: router,
   onServerInit: async (app) => {
+    await initImapApp(app);
     await initCallApp(app);
-
     try {
       if (getEnv({ name: 'CALL_DASHBOARD_ENABLED' })) {
         await initializeCallQueueMonitoring();

backend/plugins/frontline_api/src/modules/inbox/graphql/resolvers/mutations/integrations.ts

@@ -19,6 +19,12 @@ import {
   facebookRepairIntegrations,
   facebookCreateIntegrations,
 } from '@/integrations/facebook/messageBroker';
+
+import {
+  imapUpdateIntegrations,
+  imapRemoveIntegrations,
+  imapCreateIntegrations,
+} from '@/integrations/imap/messageBroker';
 import {
   callCreateIntegration,
   callRemoveIntergration,
@@ -59,7 +65,8 @@ export const sendCreateIntegration = async (
         return await facebookCreateIntegrations({ subdomain, data });
       case 'calls':
         return await callCreateIntegration({ subdomain, data });
-
+      case 'imap':
+        return await imapCreateIntegrations({ subdomain, data });
       case 'instagram':
         // TODO: Implement Instagram integration
         break;
@@ -89,6 +96,8 @@ export const sendUpdateIntegration = async (
         return await facebookUpdateIntegrations({ subdomain, data });
       case 'calls':
         return await callUpdateIntegration({ subdomain, data });
+      case 'imap':
+        return await imapUpdateIntegrations({ subdomain, data });
       case 'instagram':
         break;
 
@@ -116,6 +125,8 @@ export const sendRemoveIntegration = async (
         return await facebookRemoveIntegrations({ subdomain, data });
       case 'calls':
         return await callRemoveIntergration({ subdomain, data });
+      case 'imap':
+        return await imapRemoveIntegrations({ subdomain, data });
       case 'instagram':
         break;