Use create instead of update

OpenCTI-Platform · Dec 30, 2024 · bb0bbc9 · bb0bbc9
1 parent 308b360
commit bb0bbc9
Showing 1 changed file with 5 additions and 10 deletions.
diff --git a/opencti-platform/opencti-graphql/src/manager/taskManager.js b/opencti-platform/opencti-graphql/src/manager/taskManager.js
@@ -4,7 +4,7 @@ import * as R from 'ramda';
 import { Promise as BluePromise } from 'bluebird';
 import { ENTITY_TYPE_WORKSPACE } from '../modules/workspace/workspace-types';
 import { ENTITY_TYPE_PUBLIC_DASHBOARD } from '../modules/publicDashboard/publicDashboard-types';
-import { buildCreateEvent, lockResource, storeUpdateEvent } from '../database/redis';
+import { buildCreateEvent, lockResource, storeCreateEntityEvent, storeUpdateEvent } from '../database/redis';
 import {
   ACTION_TYPE_ADD,
   ACTION_TYPE_ENRICHMENT,
@@ -415,13 +415,10 @@ const executeShare = async (context, user, actionContext, element, containerId)
     }
   }
   if (containerId) {
-    logApp.info('ANGIE - Need to push update on container', { containerId });
     const objectStoreBase = await storeLoadByIdWithRefs(context, user, containerId);
-    logApp.info('ANGIE - storeObject', { objectStoreBase });
-    // FIXME what to update ??
-    const newObject = { ...objectStoreBase, description: objectStoreBase.description ? `${objectStoreBase.description}.` : '.' };
     const message = `Updating share on parent ${containerId} after sharing all content.`;
-    await storeUpdateEvent(context, user, objectStoreBase, newObject, message, {});
+    // simulate a create event to update downstream openCTI
+    await storeCreateEntityEvent(context, user, objectStoreBase, message, {});
   }
 };
 const executeUnshare = async (context, user, actionContext, element, containerId) => {
@@ -448,10 +445,8 @@ const executeUnshare = async (context, user, actionContext, element, containerId
   if (containerId) {
     logApp.info('ANGIE - Need to push update on container', { containerId });
     const objectStoreBase = await storeLoadByIdWithRefs(context, user, containerId);
-    // FIXME what to update ??
-    const newObject = { ...objectStoreBase, description: objectStoreBase.description ? `${objectStoreBase.description}.` : '.' };
-    const message = `Updating share on parent ${containerId} after sharing all content.`;
-    await storeUpdateEvent(context, user, objectStoreBase, newObject, message, {});
+    const message = `Updating share on parent ${containerId} after unsharing all content.`;
+    await storeCreateEntityEvent(context, user, objectStoreBase, message, {});
   }
 };
 const executeShareMultiple = async (context, user, actionContext, element) => {