From b9d1a70b9a0e9035d2ca4afa37f7fea5e3c02a55 Mon Sep 17 00:00:00 2001
From: Baobhan Sith <80159437+Heavrnl@users.noreply.github.com>
Date: Thu, 15 May 2025 19:28:53 +0800
Subject: [PATCH] Update sftp.service.ts

---
 packages/backend/src/services/sftp.service.ts | 18 ------------------
 1 file changed, 18 deletions(-)

diff --git a/packages/backend/src/services/sftp.service.ts b/packages/backend/src/services/sftp.service.ts
index 40bb1a5..372771e 100644
--- a/packages/backend/src/services/sftp.service.ts
+++ b/packages/backend/src/services/sftp.service.ts
@@ -1574,24 +1574,6 @@ export class SftpService {
                  }
             });
 
-            if (!writeSuccess) {
-                console.warn(`[SFTP Upload ${uploadId}] Write stream buffer full after chunk ${chunkIndex}. Waiting for drain is recommended for large files/slow connections.`);
-            }
-
-
-            if (!writeSuccess) {
-                // console.warn(`[SFTP Upload ${uploadId}] Write stream buffer full after chunk ${chunkIndex}. Pausing chunk processing until 'drain'.`);
-                try {
-                    await new Promise<void>(resolve => uploadState.stream.once('drain', resolve));
-                    // console.log(`[SFTP Upload ${uploadId}] Write stream drained after chunk ${chunkIndex}. Resuming chunk processing.`);
-                } catch (drainError) {
-                     // Should not happen with .once, but handle defensively
-                     console.error(`[SFTP Upload ${uploadId}] Error waiting for drain event:`, drainError);
-                     // Consider cancelling upload if waiting for drain fails critically
-                     this.cancelUploadInternal(uploadId, 'Error waiting for drain');
-                     throw drainError; // Re-throw to stop further processing in this chunk handler
-                }
-            }
 
 
             if (!writeSuccess) {