Remove code for handling .zip files (#43764)

x-pack/legacy/plugins/integrations_manager/server/registry/extract.ts

@@ -5,7 +5,6 @@
  */
 
 import tar from 'tar';
-import yauzl from 'yauzl';
 import { bufferToStream, streamToBuffer } from './streams';
 
 export interface ArchiveEntry {
@@ -31,40 +30,3 @@ export async function untarBuffer(
     deflatedStream.pipe(inflateStream);
   });
 }
-
-export async function unzipBuffer(
-  buffer: Buffer,
-  filter = (entry: ArchiveEntry): boolean => true,
-  onEntry = (entry: ArchiveEntry): void => {}
-): Promise<void> {
-  const zipfile = await yauzlFromBuffer(buffer, { lazyEntries: true });
-  zipfile.readEntry();
-  zipfile.on('entry', async (entry: yauzl.Entry) => {
-    const path = entry.fileName;
-    if (!filter({ path })) return zipfile.readEntry();
-
-    const entryBuffer = await getZipReadStream(zipfile, entry).then(streamToBuffer);
-    onEntry({ buffer: entryBuffer, path });
-    zipfile.readEntry();
-  });
-  return new Promise((resolve, reject) => zipfile.on('end', resolve).on('error', reject));
-}
-
-function yauzlFromBuffer(buffer: Buffer, opts: yauzl.Options): Promise<yauzl.ZipFile> {
-  return new Promise((resolve, reject) =>
-    yauzl.fromBuffer(buffer, opts, (err?: Error, handle?: yauzl.ZipFile) =>
-      err ? reject(err) : resolve(handle)
-    )
-  );
-}
-
-function getZipReadStream(
-  zipfile: yauzl.ZipFile,
-  entry: yauzl.Entry
-): Promise<NodeJS.ReadableStream> {
-  return new Promise((resolve, reject) =>
-    zipfile.openReadStream(entry, (err?: Error, readStream?: NodeJS.ReadableStream) =>
-      err ? reject(err) : resolve(readStream)
-    )
-  );
-}

x-pack/legacy/plugins/integrations_manager/server/registry/index.ts

@@ -11,7 +11,7 @@ import {
   RegistryPackage,
 } from '../../common/types';
 import { cacheGet, cacheSet } from './cache';
-import { ArchiveEntry, untarBuffer, unzipBuffer } from './extract';
+import { ArchiveEntry, untarBuffer } from './extract';
 import { fetchUrl, getResponseStream } from './requests';
 import { streamToBuffer } from './streams';
 
@@ -61,10 +61,9 @@ async function extract(
   filter = (entry: ArchiveEntry): boolean => true,
   onEntry: (entry: ArchiveEntry) => void
 ) {
-  const libExtract = key.endsWith('.zip') ? unzipBuffer : untarBuffer;
   const archiveBuffer = await getOrFetchArchiveBuffer(key);
 
-  return libExtract(archiveBuffer, filter, onEntry);
+  return untarBuffer(archiveBuffer, filter, onEntry);
 }
 
 async function getOrFetchArchiveBuffer(key: string): Promise<Buffer> {