Skip to content

Commit

Permalink
Use SavedObjectsClient.bulkDelete to delete package assets
Browse files Browse the repository at this point in the history
  • Loading branch information
xcrzx committed Jan 3, 2023
1 parent 4f1d408 commit 31c46ec
Show file tree
Hide file tree
Showing 4 changed files with 8 additions and 18 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -85,7 +85,7 @@ describe('checking migration metadata changes on all registered SO types', () =>
"endpoint:user-artifact": "f94c250a52b30d0a2d32635f8b4c5bdabd1e25c0",
"endpoint:user-artifact-manifest": "8c14d49a385d5d1307d956aa743ec78de0b2be88",
"enterprise_search_telemetry": "fafcc8318528d34f721c42d1270787c52565bad5",
"epm-packages": "2915aee4302d4b00472ed05c21f59b7d498b5206",
"epm-packages": "7d80ba3f1fcd80316aa0b112657272034b66d5a8",
"epm-packages-assets": "9fd3d6726ac77369249e9a973902c2cd615fc771",
"event_loop_delays_daily": "d2ed39cf669577d90921c176499908b4943fb7bd",
"exception-list": "fe8cc004fd2742177cdb9300f4a67689463faf9c",
Expand Down
14 changes: 4 additions & 10 deletions x-pack/plugins/fleet/server/saved_objects/index.ts
Original file line number Diff line number Diff line change
Expand Up @@ -266,19 +266,13 @@ const getSavedObjectTypes = (
},
},
installed_kibana: {
type: 'nested',
properties: {
id: { type: 'keyword' },
type: { type: 'keyword' },
},
type: 'object',
enabled: false,
},
installed_kibana_space_id: { type: 'keyword' },
package_assets: {
type: 'nested',
properties: {
id: { type: 'keyword' },
type: { type: 'keyword' },
},
type: 'object',
enabled: false,
},
install_started_at: { type: 'date' },
install_version: { type: 'keyword' },
Expand Down
5 changes: 2 additions & 3 deletions x-pack/plugins/fleet/server/services/epm/archive/storage.ts
Original file line number Diff line number Diff line change
Expand Up @@ -102,10 +102,9 @@ export async function removeArchiveEntries(opts: {
}) {
const { savedObjectsClient, refs } = opts;
if (!refs) return;
const results = await Promise.all(
refs.map((ref) => savedObjectsClient.delete(ASSETS_SAVED_OBJECT_TYPE, ref.id))
return savedObjectsClient.bulkDelete(
refs.map((ref) => ({ id: ref.id, type: ASSETS_SAVED_OBJECT_TYPE }))
);
return results;
}

export async function saveArchiveEntries(opts: {
Expand Down
5 changes: 1 addition & 4 deletions x-pack/plugins/fleet/server/services/epm/packages/remove.ts
Original file line number Diff line number Diff line change
Expand Up @@ -125,11 +125,8 @@ async function deleteKibanaAssets(
// in the case of a partial install, it is expected that some assets will be not found
// we filter these out before calling delete
const assetsToDelete = foundObjects.map(({ saved_object: { id, type } }) => ({ id, type }));
const promises = assetsToDelete.map(async ({ id, type }) => {
return savedObjectsClient.delete(type, id, { namespace });
});

return Promise.all(promises);
return savedObjectsClient.bulkDelete(assetsToDelete, { namespace });
}

function deleteESAssets(
Expand Down

0 comments on commit 31c46ec

Please sign in to comment.