actions
/
toolkit
mirror of https://github.com/actions/toolkit
1
0
Fork 0
Code

Stop progress bar on message.complete

phantsure/download-progress
Sampark Sharma 2023-02-10 12:02:26 +00:00 committed by GitHub
parent ae026cf7c6
commit 14f28534ef
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
packages/cache/src/internal/downloadUtils.ts vendored
View File

@ -161,8 +161,9 @@ export class DownloadProgress {
} }
} }
async function displayDownloadProgress(socket: any, startTime: number): Promise<void> { async function displayDownloadProgress(message: any, startTime: number): Promise<void> {
while(!socket.destroyed) { const socket = message.socket
while(!message.complete) {
const byteRead = socket.bytesRead const byteRead = socket.bytesRead
const totalBytes = 100000 const totalBytes = 100000
const percentage = (100 * (byteRead / totalBytes)).toFixed( const percentage = (100 * (byteRead / totalBytes)).toFixed(
@ -178,7 +179,7 @@ async function displayDownloadProgress(socket: any, startTime: number): Promise<
core.info( core.info(
`Received ${byteRead} of ${totalBytes} (${percentage}%), ${downloadSpeed} MBs/sec` `Received ${byteRead} of ${totalBytes} (${percentage}%), ${downloadSpeed} MBs/sec`
) )
sleep(10) sleep(100)
} }
} }
@ -206,7 +207,7 @@ export async function downloadCacheHttpClient(
core.debug(`Aborting download, socket timed out after ${SocketTimeout} ms`) core.debug(`Aborting download, socket timed out after ${SocketTimeout} ms`)
}) })
await displayDownloadProgress(downloadResponse.message.socket, startTime) await displayDownloadProgress(downloadResponse.message, startTime)
await pipeResponseToStream(downloadResponse, writeStream) await pipeResponseToStream(downloadResponse, writeStream)