fix: get stream

package.json

@@ -1,6 +1,6 @@
 {
 	"name": "@filen/s3",
-	"version": "0.2.5",
+	"version": "0.2.6",
 	"description": "Filen S3",
 	"main": "dist/index.js",
 	"types": "dist/index.d.ts",
@@ -50,7 +50,7 @@
 		"typescript": "^5.3.3"
 	},
 	"dependencies": {
-		"@filen/sdk": "^0.1.120",
+		"@filen/sdk": "^0.1.122",
 		"aws-sdk": "^2.1636.0",
 		"body-parser": "^1.20.2",
 		"dayjs": "^1.11.11",

src/handlers/getObject.ts

@@ -64,7 +64,7 @@ export class GetObject {
 		res.set("Content-Type", mimeType)
 		res.set("Accept-Ranges", "bytes")
 
-		const stream = await this.server.sdk.cloud().downloadFileToReadableStream({
+		const stream = this.server.sdk.cloud().downloadFileToReadableStream({
 			uuid: object.stats.uuid,
 			bucket: object.stats.bucket,
 			region: object.stats.region,
@@ -78,7 +78,40 @@ export class GetObject {
 
 		const nodeStream = Readable.fromWeb(stream as unknown as ReadableStreamWebType<Buffer>)
 
-		nodeStream.once("error", next)
+		const cleanup = () => {
+			try {
+				if (!nodeStream.closed || !nodeStream.destroyed) {
+					nodeStream.destroy()
+				}
+			} catch {
+				// Noop
+			}
+		}
+
+		res.once("close", () => {
+			cleanup()
+		})
+
+		res.once("error", () => {
+			cleanup()
+		})
+
+		res.once("finish", () => {
+			cleanup()
+		})
+
+		req.once("close", () => {
+			cleanup()
+		})
+
+		req.once("error", () => {
+			cleanup()
+		})
+
+		nodeStream.once("error", err => {
+			cleanup()
+			next(err)
+		})
 
 		nodeStream.pipe(res)
 	}

src/semaphore.ts

@@ -49,6 +49,10 @@ export const Semaphore = function (this: ISemaphore, max: number) {
 	}
 
 	this.release = function (): void {
+		if (counter <= 0) {
+			return
+		}
+
 		counter--
 
 		take()