[backend] Migration to remove representative in DB (#7484)

(cherry picked from commit af5f572)

opencti-platform/opencti-graphql/src/database/engine.js

@@ -3605,7 +3605,7 @@ export const elUpdateElement = async (instance) => {
   // If entity with a name, must update connections
   let connectionPromise = Promise.resolve();
   if (esData.name && isStixObject(instance.entity_type)) {
-    connectionPromise = elUpdateConnectionsOfElement(instance.internal_id, { name: esData.representative.main });
+    connectionPromise = elUpdateConnectionsOfElement(instance.internal_id, { name: extractEntityRepresentativeName(esData) });
   }
   return Promise.all([replacePromise, connectionPromise]);
 };

opencti-platform/opencti-graphql/src/database/middleware.js

@@ -17,7 +17,7 @@ import {
   UnsupportedError,
   ValidationError
 } from '../config/errors';
-import { extractEntityRepresentativeName, extractRepresentative } from './entity-representative';
+import { extractEntityRepresentativeName } from './entity-representative';
 import {
   buildPagination,
   computeAverage,
@@ -854,7 +854,6 @@ const partialInstanceWithInputs = (instance, inputs) => {
     _index: instance._index,
     internal_id: instance.internal_id,
     entity_type: instance.entity_type,
-    representative: extractRepresentative(instance),
     ...inputData,
   };
 };

opencti-platform/opencti-graphql/src/migrations/1718719160224-remove-representative.js

@@ -0,0 +1,31 @@
+import { logApp } from '../config/conf';
+import { elUpdateByQueryForMigration } from '../database/engine';
+import { READ_DATA_INDICES } from '../database/utils';
+
+const message = '[MIGRATION] Remove representative field';
+
+export const up = async (next) => {
+  logApp.info(`${message} > started`);
+  const updateQuery = {
+    script: {
+      params: { fieldToRemove: 'representative' },
+      source: 'ctx._source.remove(params.fieldToRemove)',
+    },
+    query: {
+      bool: {
+        must: [{ exists: { field: 'representative' } }],
+      },
+    },
+  };
+  await elUpdateByQueryForMigration(
+    message,
+    READ_DATA_INDICES,
+    updateQuery
+  );
+  logApp.info(`${message} > done`);
+  next();
+};
+
+export const down = async (next) => {
+  next();
+};