Added NFS support

Author: 9trocode

README.md

@@ -44,7 +44,7 @@ export AWS_SECRET_ACCESS_KEY=982u289432u48jsdfkjsr3894
 export AWS_SESSION_TOKEN (optional)
 ```
 
-Local NFS Declaration **NOTE NFS still under development i.e it won't function appropriately
+Local NFS Declaration 
 ```bash
 export MOUNT_POINT=/Users/nitrocode/bucket/
 ```

lib/GoogleCloudStorageSystem.js

@@ -48,7 +48,7 @@ class GoogleCloudStorageSystem extends StorageSystem {
         }
     }
 
-    async deleteFile(buckName, filename, destination){
+    async deleteFile(buckName, filename){
         try{
             await storage
                 .bucket(buckName)

lib/NFSStorageSystem.js

@@ -1,5 +1,6 @@
 const StorageSystem = require ('./storage-system');
 const fse = require('fs-extra');
+const fs = require('fs');
 
 class NFSStorageSystem extends StorageSystem {
     /**
@@ -10,14 +11,13 @@ class NFSStorageSystem extends StorageSystem {
      */
     constructor() {
         super();
-        this.nfsMount = '';
-        this.nfsBucket = '';
+        this._nfsMount = process.env.NFS_MOUNT_POINT;
     }
 
-    async upload(source, destination) {
+    async upload(bucketName, filename, destination) {
         try {
-            const finalDest = `${this.nfsMount}${this.nfsBucket}/${destination}`;
-            return fse.copy(source, finalDest);
+            const finalDest = `${this._nfsMount}${bucketName}/${filename}`;
+            return fse.copy(destination, finalDest);
         } catch (e) {
             throw new Error(e);
         }
@@ -29,13 +29,70 @@ class NFSStorageSystem extends StorageSystem {
      * @params filename, destination
      * @description Serves as General Download SDK for NFS Storage
      */
-    async download(filename, destination) {
+    async download(bucketName, filename, destination) {
         try {
-            return fse.copy(`${this.nfsMount}${this.nfsBucket}/${filename}`, destination);
+            return fse.copy(`${this._nfsMount}${bucketName}/${filename}`, destination);
         } catch (e) {
             throw new Error(e);
         }
     }
+
+    async createBucket(bucketName){
+        try {
+            if (!fs.existsSync(this._nfsMount+bucketName)){
+                return fs.mkdirSync(this._nfsMount+bucketName);
+            }else {
+                return new Error('Bucket Already Exist')
+            }
+        }catch (err) {
+            throw new Error(err)
+        }
+    }
+
+    async deleteBucket(bucketName){
+        try {
+            if (fs.existsSync(this._nfsMount+bucketName) === true){
+                return fs.rmdirSync(this._nfsMount+bucketName, { recursive: true });
+            }else {
+                return new Error('Bucket Does Not Exist')
+            }
+        }catch (err) {
+            throw new Error(err)
+        }
+    }
+
+    async listFiles(bucketName){
+        let files = [];
+        try {
+            fs.readdirSync(this._nfsMount+bucketName).forEach(file => {
+                files.push(file);
+            });
+            return files
+        }catch (err) {
+            throw new Error(err)
+        }
+    }
+
+    async listBuckets(){
+        let files = [];
+        try {
+            fs.readdirSync(this._nfsMount).forEach(file => {
+                files.push(file);
+            });
+            return files
+        }catch (err) {
+            throw new Error(err)
+        }
+    }
+
+    async deleteFile(buckName, filename){
+        try{
+           return fs.unlinkSync(this._nfsMount+buckName+filename)
+        }catch (err) {
+            throw new Error(err)
+        }
+    }
+
 }
 
 module.exports = NFSStorageSystem;

lib/storage-system.js

@@ -2,7 +2,6 @@ class StorageSystem {
     upload() {
         throw new Error('concrete implementation should be used');
     }
-
     download() {
         throw new Error('concrete implementation should be used');
     }

package.json

@@ -1,6 +1,6 @@
 {
   "name": "node_storage_manager",
-  "version": "1.1.6",
+  "version": "1.1.7",
   "description": "A storage manager for nodejs",
   "main": "index.js",
   "scripts": {

test/sdk.test.js

@@ -6,9 +6,9 @@ describe('Simple Storage Test', () => {
 
     //First stage Unit Test
     it('should run', () => {
-      let StorageInstance =  storageSystem.getInstance('AWS', '');
-          StorageInstance.download('smc-v1-dev', 'dev_key.key', '/Users/nitrocode/tmp/');
-          console.log(StorageInstance);
+      let StorageInstance =  storageSystem.getInstance('GCLOUD');
+        const data =  StorageInstance.download('media', 'dev_key.key', '/Users/nitrocode/tmp/');
+          console.log(data);
     });
 
 });