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

wait for upload to finish

pull/1666/head
bethanyj28 2024-02-22 20:29:42 -05:00
parent b956d8a4dd
commit 9dea373bba
1 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
packages/artifact/src/internal/download/download-artifact.ts
View File

@ -80,6 +80,7 @@ export async function streamExtractExternal(
} }
const timer = setTimeout(timerFn, timeout) const timer = setTimeout(timerFn, timeout)
const promises: Promise<void>[] = []
response.message response.message
.on('data', () => { .on('data', () => {
timer.refresh() timer.refresh()
@ -95,11 +96,18 @@ export async function streamExtractExternal(
.on('entry', (entry: unzip.Entry) => { .on('entry', (entry: unzip.Entry) => {
const fullPath = path.normalize(path.join(directory, entry.path)) const fullPath = path.normalize(path.join(directory, entry.path))
core.debug(`Extracting artifact entry: ${fullPath}`) core.debug(`Extracting artifact entry: ${fullPath}`)
entry.pipe(createWriteStream(fullPath)) const writeStream = createWriteStream(fullPath)
promises.push(new Promise((resolve, reject) => {
writeStream.on('finish', () => resolve())
writeStream.on('error', reject)
}))
entry.pipe(writeStream)
}) })
.on('end', () => { .on('end', () => {
clearTimeout(timer) clearTimeout(timer)
resolve() Promise.all(promises)
.then(() => resolve())
.catch(error => reject(error))
}) })
.on('error', (error: Error) => { .on('error', (error: Error) => {
reject(error) reject(error)