[backend] Fix migration for old platforms with nested IDs

OpenCTI-Platform · Jan 29, 2025 · c9d9e3b · c9d9e3b
1 parent 3fbff92
commit c9d9e3b
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/opencti-platform/opencti-graphql/src/database/engine.js b/opencti-platform/opencti-graphql/src/database/engine.js
@@ -1663,7 +1663,6 @@ export const elFindByIds = async (context, user, ids, opts = {}) => {
       logApp.debug('[SEARCH] elInternalLoadById', { query });
       const searchType = `${ids} (${types ? types.join(', ') : 'Any'})`;
       const data = await elRawSearch(context, user, searchType, query).catch((err) => {
-        logApp.error(JSON.stringify(query));
         throw DatabaseError('Find direct ids fail', { cause: err, query });
       });
       const elements = data.hits.hits;

diff --git a/opencti-platform/opencti-graphql/src/migrations/1733912620469-clean-deprecated-rels.js b/opencti-platform/opencti-graphql/src/migrations/1733912620469-clean-deprecated-rels.js
@@ -37,7 +37,7 @@ export const up = async (next) => {
       const threat = threats[i];
       const relatedToIds = threat[relKeyRelatedTo] ?? [];
       const newIds = [];
-      const groupIds = R.splitEvery(5000, relatedToIds.filter((id) => isNotEmptyField(id)));
+      const groupIds = R.splitEvery(5000, relatedToIds.flat(Infinity).filter((id) => isNotEmptyField(id)));
       for (let index = 0; index < groupIds.length; index += 1) {
         const workingIds = groupIds[index];
         const entitiesBaseData = await elFindByIds(context, SYSTEM_USER, workingIds, { baseData: true });
@@ -95,7 +95,7 @@ export const up = async (next) => {
       const location = locations[i];
       const locatedAtIds = location[relKeyLocatedAt] ?? [];
       const newIds = [];
-      const groupIds = R.splitEvery(5000, locatedAtIds.filter((id) => isNotEmptyField(id)));
+      const groupIds = R.splitEvery(5000, locatedAtIds.flat(Infinity).filter((id) => isNotEmptyField(id)));
       for (let index = 0; index < groupIds.length; index += 1) {
         const workingIds = groupIds[index];
         const entitiesBaseData = await elFindByIds(context, SYSTEM_USER, workingIds, { baseData: true });