1.0.9

.gitlab-ci.yml

@@ -38,22 +38,34 @@ snyk:
 # test stage
 # ====================
 
-testLTS:
+testStable:
   stage: test
   script:
   - npmci npm prepare
-  - npmci node install lts
+  - npmci node install stable
   - npmci npm install
   - npmci npm test
   coverage: /\d+.?\d+?\%\s*coverage/
   tags:
   - docker
+  - priv
+
+testBuild:
+  stage: test
+  script:
+  - npmci npm prepare
+  - npmci node install stable
+  - npmci npm install
+  - npmci command npm run build
+  coverage: /\d+.?\d+?\%\s*coverage/
+  tags:
+  - docker
   - notpriv
 
 release:
   stage: release
   script:
-  - npmci node install lts
+  - npmci node install stable
   - npmci npm publish
   only:
   - tags
@@ -69,6 +81,7 @@ codequality:
   allow_failure: true
   script:
     - npmci command npm install -g tslint typescript
+    - npmci npm prepare
     - npmci npm install
     - npmci command "tslint -c tslint.json ./ts/**/*.ts"
   tags:
@@ -86,9 +99,9 @@ trigger:
   - notpriv
 
 pages:
-  image: hosttoday/ht-docker-node:npmci
   stage: metadata
   script:
+    - npmci node install lts
     - npmci command npm install -g @gitzone/tsdoc
     - npmci npm prepare
     - npmci npm install

npmextra.json

@@ -1,8 +1,6 @@
 {
   "npmci": {
-    "npmGlobalTools": [
-      "npmts"
-    ]
+    "npmGlobalTools": []
   },
   "gitzone": {
     "module": {

package.json

@@ -1,34 +1,37 @@
 {
   "name": "@pushrocks/smartbucket",
-  "version": "1.0.4",
+  "version": "1.0.9",
   "description": "simple cloud independent object storage",
   "main": "dist/index.js",
   "typings": "dist/index.d.ts",
   "author": "Lossless GmbH",
   "license": "UNLICENSED",
   "scripts": {
-    "test": "(npmts)",
+    "test": "tstest test/",
     "format": "(gitzone format)",
     "build": "echo \"Not needed for now\""
   },
   "devDependencies": {
-    "@pushrocks/tapbundle": "^3.0.11",
-    "tslint": "^5.18.0",
+    "@gitzone/tsbuild": "^2.1.17",
+    "@gitzone/tstest": "^1.0.28",
+    "@pushrocks/tapbundle": "^3.0.13",
+    "tslint": "^5.20.0",
     "tslint-config-prettier": "^1.18.0"
   },
   "dependencies": {
-    "@google-cloud/storage": "^3.0.2",
-    "@pushrocks/smartpromise": "^3.0.2",
-    "@types/minio": "^7.0.2",
-    "minio": "^7.0.10"
+    "@pushrocks/qenv": "^4.0.6",
+    "@pushrocks/smartpromise": "^3.0.6",
+    "@types/minio": "^7.0.3",
+    "minio": "^7.0.12"
   },
   "private": true,
   "files": [
-    "ts/*",
-    "ts_web/*",
-    "dist/*",
-    "dist_web/*",
-    "assets/*",
+    "ts/**/*",
+    "ts_web/**/*",
+    "dist/**/*",
+    "dist_web/**/*",
+    "dist_ts_web/**/*",
+    "assets/**/*",
     "cli.js",
     "npmextra.json",
     "readme.md"

qenv.yml

@@ -0,0 +1,3 @@
+required:
+  - S3_KEY
+  - S3_SECRET

readme.md

@@ -21,6 +21,6 @@ simple cloud independent object storage
 For further information read the linked docs at the top of this readme.
 
 > MIT licensed | **©** [Lossless GmbH](https://lossless.gmbh)
-| By using this npm module you agree to our [privacy policy](https://lossless.gmbH/privacy.html)
+| By using this npm module you agree to our [privacy policy](https://lossless.gmbH/privacy)
 
-[![repo-footer](https://pushrocks.gitlab.io/assets/repo-footer.svg)](https://maintainedby.lossless.com)
+[![repo-footer](https://lossless.gitlab.io/publicrelations/repofooter.svg)](https://maintainedby.lossless.com)

test/test.ts

@@ -1,8 +1,37 @@
 import { expect, tap } from '@pushrocks/tapbundle';
+import { Qenv } from '@pushrocks/qenv';
+
 import * as smartbucket from '../ts/index';
 
-tap.test('first test', async () => {
-  console.log('hi');
+const testQenv = new Qenv('./', './.nogit/');
+
+let testSmartbucket: smartbucket.SmartBucket;
+let myBucket: smartbucket.Bucket;
+
+tap.test('should create a valid smartbucket', async () => {
+  testSmartbucket = new smartbucket.SmartBucket({
+    accessKey: testQenv.getEnvVarOnDemand('S3_KEY'),
+    accessSecret: testQenv.getEnvVarOnDemand('S3_SECRET'),
+    endpoint: 'ams3.digitaloceanspaces.com'
+  });
+});
+
+tap.skip.test('should create testbucket', async () => {
+  await testSmartbucket.createBucket('smartbucket');
+});
+
+tap.skip.test('should remove testbucket', async () => {
+  await testSmartbucket.removeBucket('pushrocks-smartbucket');
+});
+
+tap.test('should get a bucket', async () => {
+  myBucket = await testSmartbucket.getBucketByName('smartbucket');
+  expect(myBucket).to.be.instanceOf(smartbucket.Bucket);
+  expect(myBucket.name).to.equal('smartbucket');
+});
+
+tap.test('should store data in bucket', async () => {
+  
 });
 
 tap.start();

ts/index.ts

@@ -1 +1,4 @@
-import * as plugins from './smartbucket.plugins';
+export * from './smartbucket.classes.smartbucket';
+export * from './smartbucket.classes.bucket';
+export * from './smartbucket.classes.directory';
+export * from './smartbucket.classes.file';

ts/smartbucket.classes.bucket.ts

@@ -0,0 +1,43 @@
+import * as plugins from './smartbucket.plugins';
+import { SmartBucket } from './smartbucket.classes.smartbucket';
+
+export class Bucket {
+  public static async getBucketByName(smartbucketRef: SmartBucket, bucketNameArg: string) {
+    const buckets = await smartbucketRef.minioClient.listBuckets();
+    const foundBucket = buckets.find(bucket => {
+      return bucket.name === bucketNameArg;
+    });
+
+    if (foundBucket) {
+      console.log(`bucket with name ${bucketNameArg} exists.`)
+      console.log(`Taking this as base for new Bucket instance`);
+      return new this(smartbucketRef, bucketNameArg);
+    } else {
+      return null;
+    }
+  }
+
+  public static async createBucketByName(smartbucketRef: SmartBucket, bucketName: string) {
+    await smartbucketRef.minioClient.makeBucket(bucketName, 'ams3').catch(e => console.log(e));
+    return new Bucket(smartbucketRef, bucketName);
+  }
+
+  public static async removeBucketByName(smartbucketRef: SmartBucket, bucketName: string) {
+    await smartbucketRef.minioClient.removeBucket(bucketName).catch(e => console.log(e));
+  }
+
+  public smartbucketRef: SmartBucket;
+  public name: string;
+
+  constructor(smartbucketRef: SmartBucket, bucketName: string) {
+    this.smartbucketRef = smartbucketRef;
+    this.name = bucketName;
+  }
+
+  /**
+   * store file
+   */
+  public store(fileName:) {
+
+  }
+}

ts/smartbucket.classes.directory.ts

@@ -0,0 +1,3 @@
+import * as plugins from './smartbucket.plugins';
+
+export class Directory {}

ts/smartbucket.classes.file.ts

@@ -0,0 +1,3 @@
+import * as plugins from './smartbucket.plugins';
+
+export class File {}

ts/smartbucket.classes.smartbucket.ts

@@ -1,30 +1,41 @@
 import * as plugins from './smartbucket.plugins';
+import { Bucket } from './smartbucket.classes.bucket';
 
 export interface ISmartBucketConfig {
-  provider: 'google';
-  projectId: string;
-  bucketName: string;
+  endpoint: string;
+  accessKey: string;
+  accessSecret: string;
 }
 
 export class SmartBucket {
-  config: ISmartBucketConfig;
-  private _googleBucket;
+  public config: ISmartBucketConfig;
+
+  public minioClient: plugins.minio.Client;
+
   /**
    * the constructor of SmartBucket
    */
   constructor(configArg: ISmartBucketConfig) {
     this.config = configArg;
+    this.minioClient = new plugins.minio.Client({
+      endPoint: this.config.endpoint,
+      port: 443,
+      useSSL: true,
+      accessKey: this.config.accessKey,
+      secretKey: this.config.accessSecret
+    });
   }
 
-  /**
-   * initializes the Smartbucket
-   */
-  async init() {
-    if (this.config.provider === 'google') {
-      const storage = new plugins.googleCloudStorage.Storage({
-        projectId: this.config.projectId
-      });
-      storage.createBucket(this.config.bucketName, () => {});
-    }
+  public async createBucket(bucketNameArg: string) {
+    const bucket = await Bucket.createBucketByName(this, bucketNameArg);
+    return bucket;
+  }
+
+  public async removeBucket(bucketName: string) {
+    await Bucket.removeBucketByName(this, bucketName);
+  }
+
+  public async getBucketByName(bucketName: string) {
+    return Bucket.getBucketByName(this, bucketName);
   }
 }

ts/smartbucket.plugins.ts

@@ -3,7 +3,8 @@ import * as smartpromise from '@pushrocks/smartpromise';
 export { smartpromise };
 
 // third party scope
-import * as googleCloudStorage from '@google-cloud/storage';
 import * as minio from 'minio';
 
-export { googleCloudStorage };
+export {
+  minio
+};