diff --git a/x-pack/plugins/ingest_manager/server/routes/epm/handlers.ts b/x-pack/plugins/ingest_manager/server/routes/epm/handlers.ts
index 7ae896c1f30a6..fada1e754a449 100644
--- a/x-pack/plugins/ingest_manager/server/routes/epm/handlers.ts
+++ b/x-pack/plugins/ingest_manager/server/routes/epm/handlers.ts
@@ -26,10 +26,12 @@ import {
   BulkUpgradePackagesFromRegistryRequestSchema,
 } from '../../types';
 import {
+  bulkInstallPackages,
   getCategories,
   getPackages,
   getFile,
   getPackageInfo,
+  handleInstallPackageFailure,
   installPackage,
   removeInstallation,
   getLimitedPackages,
@@ -37,10 +39,6 @@ import {
 } from '../../services/epm/packages';
 import { defaultIngestErrorHandler } from '../../errors';
 import { splitPkgKey } from '../../services/epm/registry';
-import {
-  handleInstallPackageFailure,
-  bulkInstallPackages,
-} from '../../services/epm/packages/install';
 
 export const getCategoriesHandler: RequestHandler<
   undefined,
diff --git a/x-pack/plugins/ingest_manager/server/services/epm/packages/bulk_install_packages.ts b/x-pack/plugins/ingest_manager/server/services/epm/packages/bulk_install_packages.ts
new file mode 100644
index 0000000000000..7b37206b70bfe
--- /dev/null
+++ b/x-pack/plugins/ingest_manager/server/services/epm/packages/bulk_install_packages.ts
@@ -0,0 +1,54 @@
+/*
+ * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
+ * or more contributor license agreements. Licensed under the Elastic License;
+ * you may not use this file except in compliance with the Elastic License.
+ */
+
+import * as Registry from '../registry';
+import { getInstallationObject } from './index';
+import {
+  BulkInstallPackagesParams,
+  BulkInstallResponse,
+  upgradePackage,
+  bulkInstallErrorToOptions,
+} from './install';
+
+export async function bulkInstallPackages({
+  savedObjectsClient,
+  packagesToUpgrade,
+  callCluster,
+}: BulkInstallPackagesParams): Promise<BulkInstallResponse[]> {
+  const installedAndLatestPromises = packagesToUpgrade.map((pkgToUpgrade) =>
+    Promise.all([
+      getInstallationObject({ savedObjectsClient, pkgName: pkgToUpgrade }),
+      Registry.fetchFindLatestPackage(pkgToUpgrade),
+    ])
+  );
+  const installedAndLatestResults = await Promise.allSettled(installedAndLatestPromises);
+  const installResponsePromises = installedAndLatestResults.map(async (result, index) => {
+    const pkgToUpgrade = packagesToUpgrade[index];
+    if (result.status === 'fulfilled') {
+      const [installedPkg, latestPkg] = result.value;
+      return upgradePackage({
+        savedObjectsClient,
+        callCluster,
+        installedPkg,
+        latestPkg,
+        pkgToUpgrade,
+      });
+    } else {
+      return bulkInstallErrorToOptions({ pkgToUpgrade, error: result.reason });
+    }
+  });
+  const installResults = await Promise.allSettled(installResponsePromises);
+  const installResponses = installResults.map((result, index) => {
+    const pkgToUpgrade = packagesToUpgrade[index];
+    if (result.status === 'fulfilled') {
+      return result.value;
+    } else {
+      return bulkInstallErrorToOptions({ pkgToUpgrade, error: result.reason });
+    }
+  });
+
+  return installResponses;
+}
diff --git a/x-pack/plugins/ingest_manager/server/services/epm/packages/get_install_type.test.ts b/x-pack/plugins/ingest_manager/server/services/epm/packages/get_install_type.test.ts
new file mode 100644
index 0000000000000..cce4b7fee8fd7
--- /dev/null
+++ b/x-pack/plugins/ingest_manager/server/services/epm/packages/get_install_type.test.ts
@@ -0,0 +1,101 @@
+/*
+ * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
+ * or more contributor license agreements. Licensed under the Elastic License;
+ * you may not use this file except in compliance with the Elastic License.
+ */
+import { SavedObject } from 'src/core/server';
+import { ElasticsearchAssetType, Installation, KibanaAssetType } from '../../../types';
+import { getInstallType } from './install';
+
+const mockInstallation: SavedObject<Installation> = {
+  id: 'test-pkg',
+  references: [],
+  type: 'epm-packages',
+  attributes: {
+    id: 'test-pkg',
+    installed_kibana: [{ type: KibanaAssetType.dashboard, id: 'dashboard-1' }],
+    installed_es: [{ type: ElasticsearchAssetType.ingestPipeline, id: 'pipeline' }],
+    es_index_patterns: { pattern: 'pattern-name' },
+    name: 'test packagek',
+    version: '1.0.0',
+    install_status: 'installed',
+    install_version: '1.0.0',
+    install_started_at: new Date().toISOString(),
+  },
+};
+const mockInstallationUpdateFail: SavedObject<Installation> = {
+  id: 'test-pkg',
+  references: [],
+  type: 'epm-packages',
+  attributes: {
+    id: 'test-pkg',
+    installed_kibana: [{ type: KibanaAssetType.dashboard, id: 'dashboard-1' }],
+    installed_es: [{ type: ElasticsearchAssetType.ingestPipeline, id: 'pipeline' }],
+    es_index_patterns: { pattern: 'pattern-name' },
+    name: 'test packagek',
+    version: '1.0.0',
+    install_status: 'installing',
+    install_version: '1.0.1',
+    install_started_at: new Date().toISOString(),
+  },
+};
+
+describe('getInstallType', () => {
+  it('should return correct type when installing and no other version is currently installed', () => {
+    const installTypeInstall = getInstallType({ pkgVersion: '1.0.0', installedPkg: undefined });
+    expect(installTypeInstall).toBe('install');
+
+    // @ts-expect-error can only be 'install' if no installedPkg given
+    expect(installTypeInstall === 'update').toBe(false);
+    // @ts-expect-error can only be 'install' if no installedPkg given
+    expect(installTypeInstall === 'reinstall').toBe(false);
+    // @ts-expect-error can only be 'install' if no installedPkg given
+    expect(installTypeInstall === 'reupdate').toBe(false);
+    // @ts-expect-error can only be 'install' if no installedPkg given
+    expect(installTypeInstall === 'rollback').toBe(false);
+  });
+
+  it('should return correct type when installing the same version', () => {
+    const installTypeReinstall = getInstallType({
+      pkgVersion: '1.0.0',
+      installedPkg: mockInstallation,
+    });
+    expect(installTypeReinstall).toBe('reinstall');
+
+    // @ts-expect-error cannot be 'install' if given installedPkg
+    expect(installTypeReinstall === 'install').toBe(false);
+  });
+
+  it('should return correct type when moving from one version to another', () => {
+    const installTypeUpdate = getInstallType({
+      pkgVersion: '1.0.1',
+      installedPkg: mockInstallation,
+    });
+    expect(installTypeUpdate).toBe('update');
+
+    // @ts-expect-error cannot be 'install' if given installedPkg
+    expect(installTypeUpdate === 'install').toBe(false);
+  });
+
+  it('should return correct type when update fails and trys again', () => {
+    const installTypeReupdate = getInstallType({
+      pkgVersion: '1.0.1',
+      installedPkg: mockInstallationUpdateFail,
+    });
+    expect(installTypeReupdate).toBe('reupdate');
+
+    // @ts-expect-error cannot be 'install' if given installedPkg
+    expect(installTypeReupdate === 'install').toBe(false);
+  });
+
+  it('should return correct type when attempting to rollback from a failed update', () => {
+    const installTypeRollback = getInstallType({
+      pkgVersion: '1.0.0',
+      installedPkg: mockInstallationUpdateFail,
+    });
+    expect(installTypeRollback).toBe('rollback');
+
+    // @ts-expect-error cannot be 'install' if given installedPkg
+    expect(installTypeRollback === 'install').toBe(false);
+  });
+});
diff --git a/x-pack/plugins/ingest_manager/server/services/epm/packages/index.ts b/x-pack/plugins/ingest_manager/server/services/epm/packages/index.ts
index 57c4f77432455..e3584f6bc4c12 100644
--- a/x-pack/plugins/ingest_manager/server/services/epm/packages/index.ts
+++ b/x-pack/plugins/ingest_manager/server/services/epm/packages/index.ts
@@ -12,6 +12,8 @@ import {
   InstallationStatus,
   KibanaAssetType,
 } from '../../../types';
+
+export { bulkInstallPackages } from './bulk_install_packages';
 export {
   getCategories,
   getFile,
@@ -23,7 +25,7 @@ export {
   SearchParams,
 } from './get';
 
-export { installPackage, ensureInstalledPackage } from './install';
+export { handleInstallPackageFailure, installPackage, ensureInstalledPackage } from './install';
 export { removeInstallation } from './remove';
 
 type RequiredPackage = 'system' | 'endpoint';
diff --git a/x-pack/plugins/ingest_manager/server/services/epm/packages/install.test.ts b/x-pack/plugins/ingest_manager/server/services/epm/packages/install.test.ts
index 683c28ccf41af..2c01792b3f945 100644
--- a/x-pack/plugins/ingest_manager/server/services/epm/packages/install.test.ts
+++ b/x-pack/plugins/ingest_manager/server/services/epm/packages/install.test.ts
@@ -6,33 +6,27 @@
 
 import { ElasticsearchAssetType, Installation, KibanaAssetType } from '../../../types';
 import { SavedObject } from 'src/core/server';
-jest.mock('./install', () => ({
-  ...(jest.requireActual('./install') as {}),
-  bulkInstallPackages: jest.fn(async () => {
-    return [
-      {
-        name: 'blah',
-        assets: [],
-        newVersion: '',
-        oldVersion: '',
-        statusCode: 200,
-      },
-    ];
-  }),
-}));
 
+jest.mock('./install');
+jest.mock('./bulk_install_packages');
 jest.mock('./get', () => ({
   ...(jest.requireActual('./get') as {}),
   getInstallation: jest.fn(async () => {
     return mockInstallation.attributes;
   }),
 }));
-import { getInstallType, ensureInstalledDefaultPackages } from './install';
-
+import { bulkInstallPackages } from './bulk_install_packages';
+const { ensureInstalledDefaultPackages } = jest.requireActual('./install');
 import { savedObjectsClientMock } from 'src/core/server/mocks';
 import { appContextService } from '../../app_context';
 import { createAppContextStartContractMock } from '../../../mocks';
 
+// if we add this assertion, TS will type check the return value
+// and the editor will also know about .mockImplementation, .mock.calls, etc
+const mockedBulkInstallPackages = bulkInstallPackages as jest.MockedFunction<
+  typeof bulkInstallPackages
+>;
+
 const mockInstallation: SavedObject<Installation> = {
   id: 'test-pkg',
   references: [],
@@ -49,22 +43,7 @@ const mockInstallation: SavedObject<Installation> = {
     install_started_at: new Date().toISOString(),
   },
 };
-const mockInstallationUpdateFail: SavedObject<Installation> = {
-  id: 'test-pkg',
-  references: [],
-  type: 'epm-packages',
-  attributes: {
-    id: 'test-pkg',
-    installed_kibana: [{ type: KibanaAssetType.dashboard, id: 'dashboard-1' }],
-    installed_es: [{ type: ElasticsearchAssetType.ingestPipeline, id: 'pipeline' }],
-    es_index_patterns: { pattern: 'pattern-name' },
-    name: 'test packagek',
-    version: '1.0.0',
-    install_status: 'installing',
-    install_version: '1.0.1',
-    install_started_at: new Date().toISOString(),
-  },
-};
+
 describe('install', () => {
   describe('ensureInstalledDefaultPackages', () => {
     beforeEach(async () => {
@@ -74,68 +53,20 @@ describe('install', () => {
       appContextService.stop();
     });
     it('should return an array of Installation objects when successful', async () => {
+      mockedBulkInstallPackages.mockImplementation(async function () {
+        return [
+          {
+            name: 'blah',
+            assets: [],
+            newVersion: '',
+            oldVersion: '',
+            statusCode: 200,
+          },
+        ];
+      });
       const soClient = savedObjectsClientMock.create();
       const resp = await ensureInstalledDefaultPackages(soClient, jest.fn());
       expect(resp).toEqual([mockInstallation.attributes]);
     });
   });
-  describe('getInstallType', () => {
-    it('should return correct type when installing and no other version is currently installed', () => {
-      const installTypeInstall = getInstallType({ pkgVersion: '1.0.0', installedPkg: undefined });
-      expect(installTypeInstall).toBe('install');
-
-      // @ts-expect-error can only be 'install' if no installedPkg given
-      expect(installTypeInstall === 'update').toBe(false);
-      // @ts-expect-error can only be 'install' if no installedPkg given
-      expect(installTypeInstall === 'reinstall').toBe(false);
-      // @ts-expect-error can only be 'install' if no installedPkg given
-      expect(installTypeInstall === 'reupdate').toBe(false);
-      // @ts-expect-error can only be 'install' if no installedPkg given
-      expect(installTypeInstall === 'rollback').toBe(false);
-    });
-
-    it('should return correct type when installing the same version', () => {
-      const installTypeReinstall = getInstallType({
-        pkgVersion: '1.0.0',
-        installedPkg: mockInstallation,
-      });
-      expect(installTypeReinstall).toBe('reinstall');
-
-      // @ts-expect-error cannot be 'install' if given installedPkg
-      expect(installTypeReinstall === 'install').toBe(false);
-    });
-
-    it('should return correct type when moving from one version to another', () => {
-      const installTypeUpdate = getInstallType({
-        pkgVersion: '1.0.1',
-        installedPkg: mockInstallation,
-      });
-      expect(installTypeUpdate).toBe('update');
-
-      // @ts-expect-error cannot be 'install' if given installedPkg
-      expect(installTypeUpdate === 'install').toBe(false);
-    });
-
-    it('should return correct type when update fails and trys again', () => {
-      const installTypeReupdate = getInstallType({
-        pkgVersion: '1.0.1',
-        installedPkg: mockInstallationUpdateFail,
-      });
-      expect(installTypeReupdate).toBe('reupdate');
-
-      // @ts-expect-error cannot be 'install' if given installedPkg
-      expect(installTypeReupdate === 'install').toBe(false);
-    });
-
-    it('should return correct type when attempting to rollback from a failed update', () => {
-      const installTypeRollback = getInstallType({
-        pkgVersion: '1.0.0',
-        installedPkg: mockInstallationUpdateFail,
-      });
-      expect(installTypeRollback).toBe('rollback');
-
-      // @ts-expect-error cannot be 'install' if given installedPkg
-      expect(installTypeRollback === 'install').toBe(false);
-    });
-  });
 });
diff --git a/x-pack/plugins/ingest_manager/server/services/epm/packages/install.ts b/x-pack/plugins/ingest_manager/server/services/epm/packages/install.ts
index 79fe00273cbb8..eca2e4ae8b878 100644
--- a/x-pack/plugins/ingest_manager/server/services/epm/packages/install.ts
+++ b/x-pack/plugins/ingest_manager/server/services/epm/packages/install.ts
@@ -45,6 +45,7 @@ import {
 import { getPackageSavedObjects } from './get';
 import { installTransformForDataset } from '../elasticsearch/transform/install';
 import { appContextService } from '../../app_context';
+import { bulkInstallPackages } from './bulk_install_packages';
 
 export async function installLatestPackage(options: {
   savedObjectsClient: SavedObjectsClientContract;
@@ -169,8 +170,8 @@ export async function handleInstallPackageFailure({
   }
 }
 
-type BulkInstallResponse = BulkInstallPackageInfo | IBulkInstallPackageError;
-function bulkInstallErrorToOptions({
+export type BulkInstallResponse = BulkInstallPackageInfo | IBulkInstallPackageError;
+export function bulkInstallErrorToOptions({
   pkgToUpgrade,
   error,
 }: {
@@ -192,7 +193,7 @@ interface UpgradePackageParams {
   latestPkg: UnwrapPromise<ReturnType<typeof Registry.fetchFindLatestPackage>>;
   pkgToUpgrade: string;
 }
-async function upgradePackage({
+export async function upgradePackage({
   savedObjectsClient,
   callCluster,
   installedPkg,
@@ -238,51 +239,11 @@ async function upgradePackage({
   }
 }
 
-interface BulkInstallPackagesParams {
+export interface BulkInstallPackagesParams {
   savedObjectsClient: SavedObjectsClientContract;
   packagesToUpgrade: string[];
   callCluster: CallESAsCurrentUser;
 }
-export async function bulkInstallPackages({
-  savedObjectsClient,
-  packagesToUpgrade,
-  callCluster,
-}: BulkInstallPackagesParams): Promise<BulkInstallResponse[]> {
-  const installedAndLatestPromises = packagesToUpgrade.map((pkgToUpgrade) =>
-    Promise.all([
-      getInstallationObject({ savedObjectsClient, pkgName: pkgToUpgrade }),
-      Registry.fetchFindLatestPackage(pkgToUpgrade),
-    ])
-  );
-  const installedAndLatestResults = await Promise.allSettled(installedAndLatestPromises);
-  const installResponsePromises = installedAndLatestResults.map(async (result, index) => {
-    const pkgToUpgrade = packagesToUpgrade[index];
-    if (result.status === 'fulfilled') {
-      const [installedPkg, latestPkg] = result.value;
-      return upgradePackage({
-        savedObjectsClient,
-        callCluster,
-        installedPkg,
-        latestPkg,
-        pkgToUpgrade,
-      });
-    } else {
-      return bulkInstallErrorToOptions({ pkgToUpgrade, error: result.reason });
-    }
-  });
-  const installResults = await Promise.allSettled(installResponsePromises);
-  const installResponses = installResults.map((result, index) => {
-    const pkgToUpgrade = packagesToUpgrade[index];
-    if (result.status === 'fulfilled') {
-      return result.value;
-    } else {
-      return bulkInstallErrorToOptions({ pkgToUpgrade, error: result.reason });
-    }
-  });
-
-  return installResponses;
-}
-
 interface InstallPackageParams {
   savedObjectsClient: SavedObjectsClientContract;
   pkgkey: string;