Log progress of s3 download

packages/backend-common/src/s3.ts

@@ -154,20 +154,29 @@ export const downloadObject = async (
 	if (!data.Body) {
 		throw new Error(`Failed to retrieve object ${key} from bucket ${bucket}`);
 	}
-	await downloadS3Data(data.Body as Readable, destinationPath, key);
-	return {
+	await downloadS3Data(
+		data.Body as Readable,
 		destinationPath,
-		extension: data.Metadata?.['extension'],
-	};
+		key,
+		data.ContentLength,
+	);
+	return data.Metadata?.['extension'];
 };
 
 const downloadS3Data = async (
 	data: Readable,
 	destinationPath: string,
 	key: string,
+	contentLength?: number,
 ) => {
 	const stream = data.pipe(createWriteStream(destinationPath));
-
+	let downloadedBytes = 0;
+	data.on('data', (chunk) => {
+		downloadedBytes += chunk.length;
+		logger.info(
+			`Downloaded ${downloadedBytes} of ${contentLength} bytes so far for ${key}`,
+		);
+	});
 	await new Promise<void>((resolve, reject) => {
 		stream
 			.on('finish', () => {