From 8f35dac68eaeb154c553d9e3c55b0da36fd67d17 Mon Sep 17 00:00:00 2001
From: Bishal Prasad <bishal-pdmsft@github.com>
Date: Thu, 23 Mar 2023 22:26:57 +0530
Subject: [PATCH] streamToBuffer logging
---
dist/restore/index.js | 9 ++++++++-
1 file changed, 8 insertions(+), 1 deletion(-)
diff --git a/dist/restore/index.js b/dist/restore/index.js
index 98c210b..895a13f 100644
--- a/dist/restore/index.js
+++ b/dist/restore/index.js
@@ -28837,15 +28837,21 @@ async function streamToBuffer(stream, buffer, offset, end, encoding) {
let pos = 0; // Position in stream
const count = end - offset; // Total amount of data needed in stream
return new Promise((resolve, reject) => {
- const timeout = setTimeout(() => reject(new Error(`The operation cannot be completed in timeout.`)), REQUEST_TIMEOUT);
+ const timeout = setTimeout(() => {
+ console.log("Timeout triggered.");
+ return reject(new Error(`The operation cannot be completed in timeout.`));
+ }, REQUEST_TIMEOUT);
stream.on("readable", () => {
+ console.log("Entering readable");
if (pos >= count) {
clearTimeout(timeout);
+ console.log("Leaving readable");
resolve();
return;
}
let chunk = stream.read();
if (!chunk) {
+ console.log("Leaving readable");
return;
}
if (typeof chunk === "string") {
@@ -28855,6 +28861,7 @@ async function streamToBuffer(stream, buffer, offset, end, encoding) {
const chunkLength = pos + chunk.length > count ? count - pos : chunk.length;
buffer.fill(chunk.slice(0, chunkLength), offset + pos, offset + pos + chunkLength);
pos += chunkLength;
+ console.log("Leaving readable");
});
stream.on("end", () => {
clearTimeout(timeout);