update(riskassessment):add consumer to create risk assessment

erxes · Oct 17, 2023 · a41a5e0 · a41a5e0
1 parent 595dad9
commit a41a5e0
Showing 1 changed file with 12 additions and 0 deletions.
diff --git a/packages/plugin-riskassessment-api/src/messageBroker.ts b/packages/plugin-riskassessment-api/src/messageBroker.ts
@@ -25,6 +25,18 @@ export const initBroker = async cl => {
       };
     }
   );
+
+  consumeRPCQueue(
+    'riskassessment:riskAssessments.create',
+    async ({ subdomain, data }) => {
+      const models = await generateModels(subdomain);
+
+      return {
+        data: await models.RiskAssessments.addRiskAssessment(data),
+        status: 'success'
+      };
+    }
+  );
 };
 
 export const sendFormsMessage = async (