Added digital ocean spaces support

Author: 9trocode

README.md

@@ -49,6 +49,12 @@ Cloudinary Declaration
 export CLOUDINARY_URL=cloudinary://4737858435783453:3827489jksdhfjasfhjBB@nitrocode
 ```
 
+Digital Ocean Spaces
+```bash
+export DG_ACCESS_KEY=284893748923yuwfhsdkfjshkfjh
+export DG_SECRET_KEY=982u289432u48jsdfkjsr3894
+```
+
 Local NFS Declaration 
 ```bash
 export MOUNT_POINT=/Users/nitrocode/bucket/
@@ -154,6 +160,15 @@ node_storage_manager allows you to switch between clients easily without reconfi
 This contains a reference to the storage-pipe module. It is a valid use case to use
 both this module and all it's functions
 
+`Note to specify region on S3 and DigitalOcean Spaces you need to pass it parameter on getInstance `
+```javascript
+  // Imports the node_storage_manager library
+  const Storage = require('node_storage_manager');
+  let StorageInstance =  Storage.getInstance('NFS', 'Asia');
+  StorageInstance.upload()
+  }
+```
+
 ### StorageInstance.download() 
 Download file from S3, AWS & NFS using storage pipe
 

lib/DigitalOceanStorageSystem.js

@@ -0,0 +1,92 @@
+const StorageSystem = require('./storage-system');
+const AWS = require('aws-sdk');
+const fs = require('fs');
+
+class DigitalOceanStorageSystem extends StorageSystem {
+    constructor(Region) {
+        super();
+        this.Region = Region;
+        AWS.config.update({region: this.Region});
+        this.s3 = new AWS.S3({
+            endpoint: new AWS.Endpoint('https://'+this.Region + '.digitaloceanspaces.com'),
+            apiVersion: '2006-03-01'
+        });
+    }
+
+    async deleteBucket(bucketName) {
+        await this.s3.deleteBucket({Bucket: bucketName}, function (err, data) {
+            if (err) {
+                return err
+            } else {
+                return data
+            }
+        });
+    }
+
+    async listBuckets() {
+        // Call S3 to list the buckets
+        await  this.s3.listBuckets(function (err, data) {
+            if (err) {
+                return err
+            } else {
+                return data.Buckets;
+            }
+        });
+    }
+
+    async listFiles(bucketName) {
+        // Call S3 to obtain a list of the objects in the bucket
+        await this.s3.listObjects({Bucket: bucketName}, function (err, data) {
+            if (err) {
+                return err
+            } else {
+                return data
+            }
+        });
+    }
+
+    async createBucket(bucketName, ACL) {
+        // call S3 to create the bucket
+        await this.s3.createBucket({Bucket: bucketName, ACL: ACL}, function (err, data) {
+            if (err) {
+                return (err);
+            } else {
+                return (data.Location);
+            }
+        });
+    }
+
+    async upload(bucketName, filename, key) {
+        await fs.readFile(filename, (err, data) => {
+            if (err) return  err;
+            this.s3.upload({Bucket: bucketName, Key: key, Body: JSON.stringify(data, null, 2)}, function (s3Err, data) {
+                if (s3Err) return  s3Err;
+                return (`File uploaded successfully at ${data.Location}`)
+            });
+        });
+    }
+
+
+    /**
+     * @memberof GoogleCloudStorageSystem
+     * @name Download
+     * @params filename, destination
+     * @description Serves as General Download SDK for GCLOUD Storage
+     */
+    async download(bucketName, filename, destination) {
+        await  this.s3.getObject({Bucket: bucketName, Key: filename}, (err, data) => {
+            if (err) return (err);
+            fs.writeFileSync(destination, data.Body.toString());
+            return (`${filename} has been Downloaded!`);
+        });
+    }
+
+    async deleteFile(buckName, filename) {
+        await this.s3.deleteObject({Bucket: buckName, Key: filename}, function (err, data) {
+            if (err) return (err.stack); // an error occurred
+            else return (data);           // successful response
+        });
+    }
+}
+
+module.exports = DigitalOceanStorageSystem;