Merge pull request #391 from autonomys/fix-stream-handling

fix: stream handling

Author: clostao

packages/utility/file-caching/src/models.ts

@@ -1,8 +1,8 @@
 import { Keyv } from 'keyv'
-import { Stream } from 'stream'
+import { Readable } from 'stream'
 
 export type FileResponse = {
-  data: Stream
+  data: Readable
   mimeType?: string
   filename?: string
   size?: bigint
@@ -16,7 +16,7 @@ export interface BaseCacheConfig {
 }
 
 export interface FileCache {
-  get: (cid: string) => Promise<Buffer | Stream | null>
-  set: (cid: string, data: Buffer | Stream) => Promise<void>
+  get: (cid: string) => Promise<Buffer | Readable | null>
+  set: (cid: string, data: Buffer | Readable) => Promise<void>
   remove: (cid: string) => Promise<void>
 }

packages/utility/file-caching/src/utils.ts

@@ -1,12 +1,12 @@
 import fs from 'fs'
 import fsPromises from 'fs/promises'
 import path from 'path'
-import { Stream } from 'stream'
+import { Readable } from 'stream'
 import { v4 } from 'uuid'
 
 export const writeFile = async (
   filepath: string,
-  data: Stream,
+  data: Readable,
   ensureDirectoryExistance: boolean = true,
 ) => {
   const tempFilePath = path.join(path.dirname(filepath), `${v4()}.tmp`)