3.0.13

package-lock.json

@@ -1,12 +1,12 @@
 {
   "name": "@push.rocks/smartbucket",
-  "version": "3.0.11",
+  "version": "3.0.13",
   "lockfileVersion": 3,
   "requires": true,
   "packages": {
     "": {
       "name": "@push.rocks/smartbucket",
-      "version": "3.0.11",
+      "version": "3.0.13",
       "license": "UNLICENSED",
       "dependencies": {
         "@push.rocks/smartpath": "^5.0.18",

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@push.rocks/smartbucket",
-  "version": "3.0.11",
+  "version": "3.0.13",
   "description": "A TypeScript library offering simple and cloud-agnostic object storage with advanced features like bucket creation, file and directory management, and data streaming.",
   "main": "dist_ts/index.js",
   "typings": "dist_ts/index.d.ts",

ts/00_commitinfo_data.ts

@@ -3,6 +3,6 @@
  */
 export const commitinfo = {
   name: '@push.rocks/smartbucket',
-  version: '3.0.11',
+  version: '3.0.13',
   description: 'A TypeScript library offering simple and cloud-agnostic object storage with advanced features like bucket creation, file and directory management, and data streaming.'
 }

ts/classes.bucket.ts

@@ -216,7 +216,7 @@ export class Bucket {
    */
   public async fastPutStream(optionsArg: {
     path: string;
-    dataStream: plugins.stream.Readable | ReadableStream;
+    readableStream: plugins.stream.Readable | ReadableStream;
     nativeMetadata?: { [key: string]: string };
     overwrite?: boolean;
   }): Promise<void> {
@@ -233,7 +233,7 @@ export class Bucket {
         console.log(`Creating new object at path '${optionsArg.path}' in bucket '${this.name}'.`);
       }
 
-      const streamIntake = await plugins.smartstream.StreamIntake.fromStream<Uint8Array>(optionsArg.dataStream);
+      const streamIntake = await plugins.smartstream.StreamIntake.fromStream<Uint8Array>(optionsArg.readableStream);
   
       // Proceed with putting the object
       await this.smartbucketRef.minioClient.putObject(
@@ -241,12 +241,7 @@ export class Bucket {
         optionsArg.path,
         streamIntake,
         null,
-        ...(optionsArg.nativeMetadata
+        null, // TODO: Add support for custom metadata once proper support is in minio.
-          ? (() => {
-              const returnObject: any = {};
-              return returnObject;
-            })()
-          : {})
       );
   
       console.log(`Object '${optionsArg.path}' has been successfully stored in bucket '${this.name}'.`);

ts/classes.directory.ts

@@ -74,8 +74,9 @@ export class Directory {
       return null;
     }
     if (!exists && optionsArg.createWithContents) {
-      await this.fastPut({
+      await File.create({
-        path: optionsArg.name,
+        directory: this,
+        name: optionsArg.name,
         contents: optionsArg.createWithContents,
       });
     }
@@ -254,6 +255,20 @@ export class Directory {
     return result;
   }
 
+  /**
+   * fast put stream
+   */
+  public async fastPutStream(optionsArg: {
+    path: string;
+    stream: plugins.stream.Readable;
+  }): Promise<void> {
+    const path = plugins.path.join(this.getBasePath(), optionsArg.path);
+    await this.bucketRef.fastPutStream({
+      path,
+      readableStream: optionsArg.stream,
+    });
+  }
+
   /**
    * removes a file within the directory
    * @param optionsArg

ts/classes.file.ts

@@ -33,6 +33,10 @@ export class File {
       fileName: optionsArg.name,
     });
     if (contents instanceof plugins.stream.Readable) {
+      await optionsArg.directory.fastPutStream({
+        path: optionsArg.name,
+        stream: contents,
+      });
     } else {
       await optionsArg.directory.fastPut({
         path: optionsArg.name,
@@ -160,7 +164,7 @@ export class File {
     ) {
       await this.parentDirectoryRef.bucketRef.fastPutStream({
         path: this.getBasePath(),
-        dataStream: optionsArg.contents,
+        readableStream: optionsArg.contents,
       });
     } else if (Buffer.isBuffer(optionsArg.contents)) {
       await this.parentDirectoryRef.bucketRef.fastPut({