From c98722c4781379c680d9ec9efc066e555bad318c Mon Sep 17 00:00:00 2001
From: "Mohamed Bassem (aider)" <me@mbassem.com>
Date: Sun, 5 Jan 2025 14:01:40 +0000
Subject: refactor: Implement file streaming for asset route. Fixes #818

---
 packages/shared/assetdb.ts | 19 +++++++++++++++++++
 1 file changed, 19 insertions(+)

(limited to 'packages/shared/assetdb.ts')

diff --git a/packages/shared/assetdb.ts b/packages/shared/assetdb.ts
index fb7d2461..2ef69279 100644
--- a/packages/shared/assetdb.ts
+++ b/packages/shared/assetdb.ts
@@ -123,6 +123,25 @@ export async function readAsset({
   return { asset, metadata };
 }
 
+export function createAssetReadStream({
+  userId,
+  assetId,
+  start,
+  end,
+}: {
+  userId: string;
+  assetId: string;
+  start?: number;
+  end?: number;
+}) {
+  const assetDir = getAssetDir(userId, assetId);
+
+  return fs.createReadStream(path.join(assetDir, "asset.bin"), {
+    start,
+    end,
+  });
+}
+
 export async function readAssetMetadata({
   userId,
   assetId,
-- 
cgit v1.2.3-70-g09d2