From c50b7f677378a02531b1622adf5e1b0c8cf54d34 Mon Sep 17 00:00:00 2001
From: criamico <mariacristina.amico@elastic.co>
Date: Thu, 6 Oct 2022 14:51:07 +0200
Subject: [PATCH] Rename getRegistryPackage to getPackage

---
 .../server/services/epm/package_service.mock.ts      |  2 +-
 .../fleet/server/services/epm/package_service.ts     | 10 +++++-----
 .../fleet/server/services/epm/packages/get.ts        | 12 ++++++------
 .../fleet/server/services/epm/packages/install.ts    |  2 +-
 .../fleet/server/services/epm/registry/index.ts      |  2 +-
 5 files changed, 14 insertions(+), 14 deletions(-)

diff --git a/x-pack/plugins/fleet/server/services/epm/package_service.mock.ts b/x-pack/plugins/fleet/server/services/epm/package_service.mock.ts
index f703399ca6df79..806f295ec2c4e3 100644
--- a/x-pack/plugins/fleet/server/services/epm/package_service.mock.ts
+++ b/x-pack/plugins/fleet/server/services/epm/package_service.mock.ts
@@ -11,7 +11,7 @@ const createClientMock = (): jest.Mocked<PackageClient> => ({
   getInstallation: jest.fn(),
   ensureInstalledPackage: jest.fn(),
   fetchFindLatestPackage: jest.fn(),
-  getRegistryPackage: jest.fn(),
+  getPackage: jest.fn(),
   reinstallEsAssets: jest.fn(),
 });
 
diff --git a/x-pack/plugins/fleet/server/services/epm/package_service.ts b/x-pack/plugins/fleet/server/services/epm/package_service.ts
index b6858b6f633a0f..45fb6737713272 100644
--- a/x-pack/plugins/fleet/server/services/epm/package_service.ts
+++ b/x-pack/plugins/fleet/server/services/epm/package_service.ts
@@ -26,7 +26,7 @@ import { checkSuperuser } from '../../routes/security';
 import { FleetUnauthorizedError } from '../../errors';
 
 import { installTransforms, isTransform } from './elasticsearch/transform/install';
-import { fetchFindLatestPackageOrThrow, getRegistryPackage } from './registry';
+import { fetchFindLatestPackageOrThrow, getPackage } from './registry';
 import { ensureInstalledPackage, getInstallation } from './packages';
 
 export type InstalledAssetType = EsAssetReference;
@@ -47,7 +47,7 @@ export interface PackageClient {
 
   fetchFindLatestPackage(packageName: string): Promise<RegistryPackage | BundledPackage>;
 
-  getRegistryPackage(
+  getPackage(
     packageName: string,
     packageVersion: string
   ): Promise<{ packageInfo: ArchivePackage; paths: string[] }>;
@@ -121,13 +121,13 @@ class PackageClientImpl implements PackageClient {
     return fetchFindLatestPackageOrThrow(packageName);
   }
 
-  public async getRegistryPackage(
+  public async getPackage(
     packageName: string,
     packageVersion: string,
-    options?: Parameters<typeof getRegistryPackage>['2']
+    options?: Parameters<typeof getPackage>['2']
   ) {
     await this.#runPreflight();
-    return getRegistryPackage(packageName, packageVersion, options);
+    return getPackage(packageName, packageVersion, options);
   }
 
   public async reinstallEsAssets(
diff --git a/x-pack/plugins/fleet/server/services/epm/packages/get.ts b/x-pack/plugins/fleet/server/services/epm/packages/get.ts
index bcd0ecd2c36ff1..0ce4e3c1cbea36 100644
--- a/x-pack/plugins/fleet/server/services/epm/packages/get.ts
+++ b/x-pack/plugins/fleet/server/services/epm/packages/get.ts
@@ -277,11 +277,12 @@ export async function getPackageFromSource(options: {
         logger.debug(`retrieved installed package ${pkgName}-${pkgVersion} from ES`);
       }
     }
-    // for packages not in cache or package storage and installed from registry, check registry
+    // install source is now archive in all cases
+    // See https://github.com/elastic/kibana/issues/115032
     if (!res && pkgInstallSource === 'registry') {
       try {
-        res = await Registry.getRegistryPackage(pkgName, pkgVersion);
-        logger.debug(`retrieved installed package ${pkgName}-${pkgVersion} from registry`);
+        res = await Registry.getPackage(pkgName, pkgVersion);
+        logger.debug(`retrieved installed package ${pkgName}-${pkgVersion}`);
       } catch (error) {
         if (error instanceof PackageFailedVerificationError) {
           throw error;
@@ -291,9 +292,8 @@ export async function getPackageFromSource(options: {
       }
     }
   } else {
-    // else package is not installed or installed and missing from cache and storage and installed from registry
-    res = await Registry.getRegistryPackage(pkgName, pkgVersion, { ignoreUnverified });
-    logger.debug(`retrieved uninstalled package ${pkgName}-${pkgVersion} from registry`);
+    res = await Registry.getPackage(pkgName, pkgVersion, { ignoreUnverified });
+    logger.debug(`retrieved uninstalled package ${pkgName}-${pkgVersion}`);
   }
   if (!res) {
     throw new FleetError(`package info for ${pkgName}-${pkgVersion} does not exist`);
diff --git a/x-pack/plugins/fleet/server/services/epm/packages/install.ts b/x-pack/plugins/fleet/server/services/epm/packages/install.ts
index 91e2c7d241fd7b..ebd0bde8b09b45 100644
--- a/x-pack/plugins/fleet/server/services/epm/packages/install.ts
+++ b/x-pack/plugins/fleet/server/services/epm/packages/install.ts
@@ -302,7 +302,7 @@ async function installPackageFromRegistry({
       Registry.fetchFindLatestPackageOrThrow(pkgName, {
         ignoreConstraints,
       }),
-      Registry.getRegistryPackage(pkgName, pkgVersion, {
+      Registry.getPackage(pkgName, pkgVersion, {
         ignoreUnverified: force && !neverIgnoreVerificationError,
       }),
     ]);
diff --git a/x-pack/plugins/fleet/server/services/epm/registry/index.ts b/x-pack/plugins/fleet/server/services/epm/registry/index.ts
index 3303c4c2501d43..3f648a7fd73dce 100644
--- a/x-pack/plugins/fleet/server/services/epm/registry/index.ts
+++ b/x-pack/plugins/fleet/server/services/epm/registry/index.ts
@@ -272,7 +272,7 @@ async function getPackageInfoFromArchiveOrCache(
   }
 }
 
-export async function getRegistryPackage(
+export async function getPackage(
   name: string,
   version: string,
   options?: { ignoreUnverified?: boolean }