diff options
| author | Mohamed Bassem <me@mbassem.com> | 2025-07-04 23:58:42 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2025-07-04 23:58:42 +0100 |
| commit | d66b3b8619e8fff36c0243f7cc67eef864c5009b (patch) | |
| tree | 6f555ad31cfc44aebffab1db3edb6134c10878d0 /packages/api/utils/assets.ts | |
| parent | 53b6b3c24d9669ba240c1f9c5fb58672b6cf8666 (diff) | |
| download | karakeep-d66b3b8619e8fff36c0243f7cc67eef864c5009b.tar.zst | |
feat: Add support for S3 as an asset storage layer (#1703)
* feat: Add support for S3 as an asset storage layer. Fixes #305
* some minor fixes
* use bulk deletion api
* stream the file to s3
Diffstat (limited to 'packages/api/utils/assets.ts')
| -rw-r--r-- | packages/api/utils/assets.ts | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/packages/api/utils/assets.ts b/packages/api/utils/assets.ts index d8a726a6..205e1a76 100644 --- a/packages/api/utils/assets.ts +++ b/packages/api/utils/assets.ts @@ -28,7 +28,7 @@ export async function serveAsset(c: Context, assetId: string, userId: string) { const start = parseInt(parts[0], 10); const end = parts[1] ? parseInt(parts[1], 10) : size - 1; - const fStream = createAssetReadStream({ + const fStream = await createAssetReadStream({ userId, assetId, start, @@ -43,7 +43,7 @@ export async function serveAsset(c: Context, assetId: string, userId: string) { await stream.pipe(toWebReadableStream(fStream)); }); } else { - const fStream = createAssetReadStream({ + const fStream = await createAssetReadStream({ userId, assetId, }); |
