[8.x] [Fleet] Reuse package infos for synthetics bulk ops (elastic#19…

…1486) (elastic#193846)

# Backport

This will backport the following commits from `main` to `8.x`:
- [[Fleet] Reuse package infos for synthetics bulk ops
(elastic#191486)](elastic#191486)

<!--- Backport version: 9.4.3 -->

### Questions ?
Please refer to the [Backport tool
documentation](https://github.com/sqren/backport)

<!--BACKPORT
[{"author":{"name":"Shahzad","email":"[email protected]"},"sourceCommit":{"committedDate":"2024-09-24T10:33:22Z","message":"[Fleet]
Reuse package infos for synthetics bulk ops (elastic#191486)\n\n##
Summary\r\n\r\n Reuse package infos for synthetics bulk ops !!\r\n\r\nWe
are just trying to debug Project monitor push API which
interacts\r\nwith fleet code and trying to see what excessive calls are
being made,\r\nwhich can be
reduced.","sha":"6d584d49a73284077d5331c9c5398593f9edd5ea","branchLabelMapping":{"^v9.0.0$":"main","^v8.16.0$":"8.x","^v(\\d+).(\\d+).\\d+$":"$1.$2"}},"sourcePullRequest":{"labels":["release_note:skip","Team:Fleet","v9.0.0","backport:prev-minor","ci:project-deploy-observability","Team:obs-ux-management"],"title":"[Fleet]
Reuse package infos for synthetics bulk
ops","number":191486,"url":"https://github.com/elastic/kibana/pull/191486","mergeCommit":{"message":"[Fleet]
Reuse package infos for synthetics bulk ops (elastic#191486)\n\n##
Summary\r\n\r\n Reuse package infos for synthetics bulk ops !!\r\n\r\nWe
are just trying to debug Project monitor push API which
interacts\r\nwith fleet code and trying to see what excessive calls are
being made,\r\nwhich can be
reduced.","sha":"6d584d49a73284077d5331c9c5398593f9edd5ea"}},"sourceBranch":"main","suggestedTargetBranches":[],"targetPullRequestStates":[{"branch":"main","label":"v9.0.0","branchLabelMappingKey":"^v9.0.0$","isSourceBranch":true,"state":"MERGED","url":"https://github.com/elastic/kibana/pull/191486","number":191486,"mergeCommit":{"message":"[Fleet]
Reuse package infos for synthetics bulk ops (elastic#191486)\n\n##
Summary\r\n\r\n Reuse package infos for synthetics bulk ops !!\r\n\r\nWe
are just trying to debug Project monitor push API which
interacts\r\nwith fleet code and trying to see what excessive calls are
being made,\r\nwhich can be
reduced.","sha":"6d584d49a73284077d5331c9c5398593f9edd5ea"}}]}]
BACKPORT-->

Co-authored-by: Shahzad <[email protected]>

x-pack/plugins/fleet/server/services/package_policy.ts

@@ -105,7 +105,12 @@ import { getAuthzFromRequest, doesNotHaveRequiredFleetAuthz } from './security';
 
 import { storedPackagePolicyToAgentInputs } from './agent_policies';
 import { agentPolicyService } from './agent_policy';
-import { getPackageInfo, getInstallation, ensureInstalledPackage } from './epm/packages';
+import {
+  getPackageInfo,
+  getInstallation,
+  ensureInstalledPackage,
+  getInstallationObject,
+} from './epm/packages';
 import { getAssetsDataFromAssetsMap } from './epm/packages/assets';
 import { compileTemplate } from './epm/agent/agent';
 import { escapeSearchQueryPhrase, normalizeKuery as _normalizeKuery } from './saved_object';
@@ -1874,9 +1879,25 @@ class PackagePolicyClientImpl implements PackagePolicyClient {
   public async buildPackagePolicyFromPackage(
     soClient: SavedObjectsClientContract,
     pkgName: string,
-    logger?: Logger
+    options?: { logger?: Logger; installMissingPackage?: boolean }
   ): Promise<NewPackagePolicy | undefined> {
-    const pkgInstall = await getInstallation({ savedObjectsClient: soClient, pkgName, logger });
+    const pkgInstallObj = await getInstallationObject({
+      savedObjectsClient: soClient,
+      pkgName,
+      logger: options?.logger,
+    });
+    let pkgInstall = pkgInstallObj?.attributes;
+    if (!pkgInstall && options?.installMissingPackage) {
+      const esClient = await appContextService.getInternalUserESClient();
+      const result = await ensureInstalledPackage({
+        esClient,
+        pkgName,
+        savedObjectsClient: soClient,
+      });
+      if (result.package) {
+        pkgInstall = result.package;
+      }
+    }
     if (pkgInstall) {
       const packageInfo = await getPackageInfo({
         savedObjectsClient: soClient,

x-pack/plugins/fleet/server/services/package_policy_service.ts

@@ -164,7 +164,7 @@ export interface PackagePolicyClient {
   buildPackagePolicyFromPackage(
     soClient: SavedObjectsClientContract,
     pkgName: string,
-    logger?: Logger
+    options?: { logger?: Logger; installMissingPackage?: boolean }
   ): Promise<NewPackagePolicy | undefined>;
 
   runExternalCallbacks<A extends ExternalCallback[0]>(

x-pack/plugins/observability_solution/synthetics/server/synthetics_service/private_location/synthetics_private_location.ts

@@ -52,7 +52,7 @@ export class SyntheticsPrivateLocation {
     const newPolicy = await this.server.fleet.packagePolicyService.buildPackagePolicyFromPackage(
       soClient,
       'synthetics',
-      this.server.logger
+      { logger: this.server.logger, installMissingPackage: true }
     );
 
     if (!newPolicy) {