Adds elasticsearch client to manifest manager context and uses it for…

… bulkUpdate

x-pack/plugins/security_solution/server/endpoint/services/artifacts/manifest_manager/manifest_manager.mock.ts

@@ -5,7 +5,11 @@
  * 2.0.
  */
 
-import { savedObjectsClientMock, loggingSystemMock } from '@kbn/core/server/mocks';
+import {
+  savedObjectsClientMock,
+  loggingSystemMock,
+  elasticsearchServiceMock,
+} from '@kbn/core/server/mocks';
 import type { Logger } from '@kbn/core/server';
 import type { PackagePolicyClient } from '@kbn/fleet-plugin/server';
 import { createPackagePolicyServiceMock } from '@kbn/fleet-plugin/server/mocks';
@@ -89,6 +93,7 @@ export const buildManifestManagerContextMock = (
     logger: loggingSystemMock.create().get() as jest.Mocked<Logger>,
     experimentalFeatures: parseExperimentalConfigValue([]).features,
     packagerTaskPackagePolicyUpdateBatchSize: 10,
+    esClient: elasticsearchServiceMock.createElasticsearchClient(),
   };
 };
 

x-pack/plugins/security_solution/server/endpoint/services/artifacts/manifest_manager/manifest_manager.test.ts

@@ -919,7 +919,7 @@ describe('ManifestManager', () => {
       expect(context.packagePolicyService.bulkUpdate).toHaveBeenNthCalledWith(
         1,
         expect.anything(),
-        undefined,
+        context.esClient,
         [
           createPackagePolicyWithConfigMock({
             id: TEST_POLICY_ID_1,
@@ -990,7 +990,7 @@ describe('ManifestManager', () => {
       expect(context.packagePolicyService.bulkUpdate).toHaveBeenNthCalledWith(
         1,
         expect.anything(),
-        undefined,
+        context.esClient,
         [
           createPackagePolicyWithConfigMock({
             id: TEST_POLICY_ID_1,

x-pack/plugins/security_solution/server/endpoint/services/artifacts/manifest_manager/manifest_manager.ts

@@ -8,6 +8,7 @@
 import pMap from 'p-map';
 import semver from 'semver';
 import { isEqual, isEmpty, chunk } from 'lodash';
+import type { ElasticsearchClient } from '@kbn/core/server';
 import { type Logger, type SavedObjectsClientContract } from '@kbn/core/server';
 import {
   ENDPOINT_EVENT_FILTERS_LIST_ID,
@@ -92,6 +93,7 @@ export interface ManifestManagerContext {
   logger: Logger;
   experimentalFeatures: ExperimentalFeatures;
   packagerTaskPackagePolicyUpdateBatchSize: number;
+  esClient: ElasticsearchClient;
 }
 
 const getArtifactIds = (manifest: ManifestSchema) =>
@@ -112,6 +114,7 @@ export class ManifestManager {
   protected experimentalFeatures: ExperimentalFeatures;
   protected cachedExceptionsListsByOs: Map<string, ExceptionListItemSchema[]>;
   protected packagerTaskPackagePolicyUpdateBatchSize: number;
+  protected esClient: ElasticsearchClient;
 
   constructor(context: ManifestManagerContext) {
     this.artifactClient = context.artifactClient;
@@ -124,6 +127,7 @@ export class ManifestManager {
     this.cachedExceptionsListsByOs = new Map();
     this.packagerTaskPackagePolicyUpdateBatchSize =
       context.packagerTaskPackagePolicyUpdateBatchSize;
+    this.esClient = context.esClient;
   }
 
   /**
@@ -606,8 +610,7 @@ export class ManifestManager {
     for (const currentBatch of updateBatches) {
       const response = await this.packagePolicyService.bulkUpdate(
         this.savedObjectsClient,
-        // @ts-expect-error TS2345
-        undefined,
+        this.esClient,
         currentBatch
       );
 

x-pack/plugins/security_solution/server/plugin.ts

@@ -460,6 +460,7 @@ export class Plugin implements ISecuritySolutionPlugin {
         logger,
         experimentalFeatures: config.experimentalFeatures,
         packagerTaskPackagePolicyUpdateBatchSize: config.packagerTaskPackagePolicyUpdateBatchSize,
+        esClient: core.elasticsearch.client.asInternalUser,
       });
 
       // Migrate artifacts to fleet and then start the minifest task after that is done