refactor(core): rename getStream to getAsStream and implement S3 stre…

packages/core/lib/storage/drivers/local.ts

@@ -122,7 +122,7 @@ export class Local implements StorageDriver {
     return false;
   }
 
-  getStream(filePath: string): ReadStream {
+  getAsStream(filePath: string): ReadStream {
     return createReadStream(join(this.config.basePath || '', filePath));
   }
 

packages/core/lib/storage/drivers/s3Storage.ts

@@ -28,8 +28,25 @@ export class S3Storage implements StorageDriver {
     this.initialiseModules();
   }
 
-  getStream(filePath: string): ReadStream {
-    throw new Error('Method not implemented.');
+  getAsStream(filePath: string): ReadStream {
+    this.initialiseModules();
+
+    try {
+      const command = new this.AWS.GetObjectCommand({
+        Bucket: this.config.bucket,
+        Key: this.getPath(filePath),
+      });
+
+      const response = this.client.send(command);
+      return response.Body as ReadStream;
+    } catch (error) {
+      if (this.shouldThrowError()) {
+        throw new CannotPerformFileOpException(
+          `Cannot get stream for file ${filePath}: ${error['message']}`,
+        );
+      }
+      return null;
+    }
   }
 
   listDir(path: string): Promise<Record<string, any>> {

packages/core/lib/storage/interfaces/storageDriver.ts

@@ -1,3 +1,4 @@
+import { ReadStream } from 'fs-extra';
 import {
   StorageDriver$GetFileResponse,
   StorageDriver$FileMetadataResponse,
@@ -136,6 +137,11 @@ export interface StorageDriver {
    */
   getAsJson(path: string, throwError: boolean): Promise<Record<string, any>>;
 
+  /**
+   * Read file as stream
+   */
+  getAsStream(path: string): ReadStream;
+
   temporaryUrl(
     path: string,
     ttlInMins: number,

packages/core/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@intentjs/core",
-  "version": "0.1.60",
+  "version": "0.1.61",
   "description": "Core module for Intent",
   "repository": {
     "type": "git",