From 84d3cef541863a574cef91efb4969a1744ea9718 Mon Sep 17 00:00:00 2001 From: Vallie Joseph Date: Mon, 1 Apr 2024 20:14:07 +0000 Subject: [PATCH] Removing extra logs --- packages/artifact/src/internal/upload/zip.ts | 48 +------------------- 1 file changed, 1 insertion(+), 47 deletions(-) diff --git a/packages/artifact/src/internal/upload/zip.ts b/packages/artifact/src/internal/upload/zip.ts index c5fcb881..68e24636 100644 --- a/packages/artifact/src/internal/upload/zip.ts +++ b/packages/artifact/src/internal/upload/zip.ts @@ -42,47 +42,6 @@ export async function createZipUploadStream( zip.on('warning', zipWarningCallback) zip.on('finish', zipFinishCallback) zip.on('end', zipEndCallback) - - // for (const file of uploadSpecification) { - // await new Promise((resolve, reject) => { - // if (file.sourcePath !== null) { - // core.debug(`createReadStream with: ${file.sourcePath}`) - // // Add a normal file to the zip - // const readStream = createReadStream(file.sourcePath) - // readStream.on('data', chunk => { - // core.debug(`Received ${chunk.length} bytes of data.`) - // }) - // readStream.on('end', () => { - // core.debug('There will be no more data.') - // }) - // readStream.on('error', reject) // Catch any errors from createReadStream - - // core.debug(`readsstream errors: ${readStream.errored}`) - // const entry = zip.entry( - // readStream, - // {name: file.destinationPath}, - // function (err) { - // core.debug(`Is stream paused: ${readStream.isPaused()}`) - // if (err) { - // core.error('An error occurred:', err) - // reject(err) - // } - // core.debug(`Is stream paused: ${readStream.isPaused()}`) - // resolve('resolved artifact') - // } - // ) - // readStream.pipe(entry) - // } else { - // zip.entry(null, {name: `${file.destinationPath}/`}, function (err) { - // if (err) { - // core.error('An error occurred:', err) - // reject(err) - // } - // resolve('resolved artifact') - // }) - // } - // }) - // } // see https://caolan.github.io/async/v3/docs.html#queue for options const fileUploadQueue = async.queue(function (task, callback) { core.debug(`adding file to upload queue ${task}`) @@ -96,22 +55,17 @@ export async function createZipUploadStream( for (const file of uploadSpecification) { if (file.sourcePath !== null) { const readStream = createReadStream(file.sourcePath) - readStream.on('data', chunk => { - core.debug(`Received ${chunk.length} bytes of data.`) - }) readStream.on('end', () => { - core.debug('There will be no more data.') + core.debug('The upload read stream is ending') }) readStream.on('error', function (err) { core.debug(`${err}`) }) // Catch any errors from createReadStream fileUploadQueue.push( zip.entry(readStream, {name: file.destinationPath}, function (err) { - core.debug(`Is stream paused: ${readStream.isPaused()}`) if (err) { core.error('An error occurred:', err) } - core.debug(`Is stream paused: ${readStream.isPaused()}`) }) ) } else {