Skip to content

Commit 55bda71

Browse files
Fix race condition in retrieveSignedPackage (#82)
1 parent d667aba commit 55bda71

1 file changed

Lines changed: 17 additions & 17 deletions

File tree

src/RokuDeploy.ts

Lines changed: 17 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -635,24 +635,24 @@ export class RokuDeploy {
635635

636636
await this.fsExtra.ensureDir(path.dirname(pkgFilePath));
637637
let writeStream: _fsExtra.WriteStream;
638-
try {
639-
return await new Promise<string>((resolve, reject) => {
640-
writeStream = this.fsExtra.createWriteStream(pkgFilePath);
641-
this.request.get(requestOptions)
642-
.on('error', (err) => reject(err))
643-
.on('response', (response) => {
644-
if (response.statusCode !== 200) {
645-
reject(new Error('Invalid response code: ' + response.statusCode));
646-
}
638+
return new Promise<string>((resolve, reject) => {
639+
writeStream = this.fsExtra.createWriteStream(pkgFilePath);
640+
this.request.get(requestOptions)
641+
.on('error', (err) => {
642+
try {
643+
writeStream.close();
644+
} catch { }
645+
reject(err);
646+
})
647+
.on('response', (response) => {
648+
if (response.statusCode !== 200) {
649+
reject(new Error('Invalid response code: ' + response.statusCode));
650+
} else {
647651
resolve(pkgFilePath);
648-
})
649-
.pipe(writeStream);
650-
});
651-
} finally {
652-
try {
653-
writeStream.close();
654-
} catch { }
655-
}
652+
}
653+
})
654+
.pipe(writeStream);
655+
});
656656
}
657657

658658
/**

0 commit comments

Comments
 (0)