download file from s3 with await

gistfile1.txt

async function waitForDownloadStreamToFinish(
	readable: StreamingBlobPayloadOutputTypes,
	writeStream: fs.WriteStream,
) {
	return new Promise(async (resolve, reject) => {
		(readable as http.IncomingMessage)
			.pipe(writeStream)
			.on("error", (err: Error) => reject(err))
			.on("close", () => resolve(null));
	});
}

	let totalBytes = 0;
	let progressHandler = new Transform({
		transform(chunk, encoding, callback) {
			totalBytes += chunk.length;
			onlyOncePerSecond(() => {
				logger.log("Download S3", totalBytes, "/", fileSize);
			});
			this.push(chunk);
			callback();
		},
	});

	const params = {
		Bucket: process.env.BUCKET!,
		Key: Key,
		progressHandler,
	};
	// logger.log(params);
	const res = await s3.send(new GetObjectCommand(params));

		if (!fs.existsSync(path.dirname(restoreTo))) {
			fs.mkdirSync(path.dirname(restoreTo), { mode: 0o777, recursive: true });
		}
		let writeStream = fs.createWriteStream(restoreTo);
		await waitForDownloadStreamToFinish(res.Body, writeStream);