Move registry/extract to archive/extract

Author: John Schulz

x-pack/plugins/fleet/server/services/epm/registry/extract.ts renamed to x-pack/plugins/fleet/server/services/epm/archive/extract.ts

@@ -7,11 +7,7 @@
 import tar from 'tar';
 import yauzl from 'yauzl';
 import { bufferToStream, streamToBuffer } from '../../../streams';
-
-export interface ArchiveEntry {
-  path: string;
-  buffer?: Buffer;
-}
+import { ArchiveEntry } from './index';
 
 export async function untarBuffer(
   buffer: Buffer,

x-pack/plugins/fleet/server/services/epm/archive/index.ts

@@ -13,10 +13,16 @@ import {
   setArchiveFilelist,
   deleteArchiveFilelist,
 } from './cache';
-import { ArchiveEntry, getBufferExtractor } from '../registry/extract';
+import { getBufferExtractor } from './extract';
 import { parseAndVerifyArchiveEntries } from './validation';
 
 export * from './cache';
+export { untarBuffer, unzipBuffer, getBufferExtractor } from './extract';
+
+export interface ArchiveEntry {
+  path: string;
+  buffer?: Buffer;
+}
 
 export async function getArchivePackage({
   archiveBuffer,

x-pack/plugins/fleet/server/services/epm/archive/validation.ts

@@ -15,7 +15,8 @@ import {
   RegistryVarsEntry,
 } from '../../../../common/types';
 import { PackageInvalidArchiveError } from '../../../errors';
-import { ArchiveEntry, pkgToPkgKey } from '../registry';
+import { ArchiveEntry } from './index';
+import { pkgToPkgKey } from '../registry';
 
 const MANIFESTS: Record<string, Buffer> = {};
 const MANIFEST_NAME = 'manifest.yml';

x-pack/plugins/fleet/server/services/epm/elasticsearch/ingest_pipeline/install.ts

@@ -12,6 +12,7 @@ import {
   InstallablePackage,
 } from '../../../../types';
 import * as Registry from '../../registry';
+import { ArchiveEntry } from '../../archive';
 import { CallESAsCurrentUser } from '../../../../types';
 import { saveInstalledEsRefs } from '../../packages/install';
 import { getInstallationObject } from '../../packages';
@@ -192,7 +193,7 @@ async function installPipeline({
   return { id: pipeline.nameForInstallation, type: ElasticsearchAssetType.ingestPipeline };
 }
 
-const isDirectory = ({ path }: Registry.ArchiveEntry) => path.endsWith('/');
+const isDirectory = ({ path }: ArchiveEntry) => path.endsWith('/');
 
 const isDataStreamPipeline = (path: string, dataStreamDataset: string) => {
   const pathParts = Registry.pathParts(path);

x-pack/plugins/fleet/server/services/epm/packages/assets.ts

@@ -6,7 +6,7 @@
 
 import { InstallablePackage } from '../../../types';
 import * as Registry from '../registry';
-import { getArchiveFilelist } from '../archive/cache';
+import { ArchiveEntry, getArchiveFilelist } from '../archive';
 
 // paths from RegistryPackage are routes to the assets on EPR
 // e.g. `/package/nginx/1.2.0/data_stream/access/fields/fields.yml`
@@ -51,14 +51,14 @@ export async function getAssetsData(
   packageInfo: InstallablePackage,
   filter = (path: string): boolean => true,
   datasetName?: string
-): Promise<Registry.ArchiveEntry[]> {
+): Promise<ArchiveEntry[]> {
   // TODO: Needs to be called to fill the cache but should not be required
 
   await Registry.ensureCachedArchiveInfo(packageInfo.name, packageInfo.version, 'registry');
 
   // Gather all asset data
   const assets = getAssets(packageInfo, filter, datasetName);
-  const entries: Registry.ArchiveEntry[] = assets.map((path) => {
+  const entries: ArchiveEntry[] = assets.map((path) => {
     const buffer = Registry.getAsset(path);
 
     return { path, buffer };

x-pack/plugins/fleet/server/services/epm/registry/index.test.ts

@@ -5,8 +5,8 @@
  */
 
 import { AssetParts } from '../../../types';
-import { getBufferExtractor, pathParts, splitPkgKey } from './index';
-import { untarBuffer, unzipBuffer } from './extract';
+import { pathParts, splitPkgKey } from './index';
+import { getBufferExtractor, untarBuffer, unzipBuffer } from '../archive';
 
 const testPaths = [
   {

x-pack/plugins/fleet/server/services/epm/registry/index.ts

@@ -26,8 +26,6 @@ import { getRegistryUrl } from './registry_url';
 import { appContextService } from '../..';
 import { PackageNotFoundError, PackageCacheError } from '../../../errors';
 
-export { ArchiveEntry, getBufferExtractor } from './extract';
-
 export interface SearchParams {
   category?: CategoryId;
   experimental?: boolean;