Compare commits
8 Commits
Author | SHA1 | Date | |
---|---|---|---|
c333533c63 | |||
2317562e87 | |||
9f0b1dab55 | |||
9b84cf8bc0 | |||
d966e29b8c | |||
ec9551a772 | |||
8462536b6a | |||
2250f9f1cc |
@ -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
|
||||
|
@ -1,8 +1,6 @@
|
||||
{
|
||||
"npmci": {
|
||||
"npmGlobalTools": [
|
||||
"npmts"
|
||||
]
|
||||
"npmGlobalTools": []
|
||||
},
|
||||
"gitzone": {
|
||||
"module": {
|
||||
|
1839
package-lock.json
generated
1839
package-lock.json
generated
File diff suppressed because it is too large
Load Diff
29
package.json
29
package.json
@ -1,34 +1,37 @@
|
||||
{
|
||||
"name": "@pushrocks/smartbucket",
|
||||
"version": "1.0.4",
|
||||
"version": "1.0.8",
|
||||
"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"
|
||||
|
@ -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)
|
||||
|
||||
[](https://maintainedby.lossless.com)
|
||||
[](https://maintainedby.lossless.com)
|
||||
|
22
test/test.ts
22
test/test.ts
@ -1,8 +1,26 @@
|
||||
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;
|
||||
|
||||
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 a bucket', async () => {
|
||||
await testSmartbucket.createBucket('smartbucket');
|
||||
});
|
||||
|
||||
tap.skip.test('should remove testbucket', async () => {
|
||||
await testSmartbucket.removeBucket('pushrocks-smartbucket');
|
||||
});
|
||||
|
||||
tap.start();
|
||||
|
@ -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';
|
||||
|
24
ts/smartbucket.classes.bucket.ts
Normal file
24
ts/smartbucket.classes.bucket.ts
Normal file
@ -0,0 +1,24 @@
|
||||
import * as plugins from './smartbucket.plugins';
|
||||
import { SmartBucket } from './smartbucket.classes.smartbucket';
|
||||
|
||||
export class Bucket {
|
||||
public static async createFromName(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);
|
||||
}
|
||||
}
|
||||
|
||||
public smartbucketRef: SmartBucket;
|
||||
public name: string;
|
||||
constructor(smartbucketRef: SmartBucket, bucketName: string) {
|
||||
this.smartbucketRef = smartbucketRef;
|
||||
this.name = bucketName;
|
||||
}
|
||||
}
|
3
ts/smartbucket.classes.directory.ts
Normal file
3
ts/smartbucket.classes.directory.ts
Normal file
@ -0,0 +1,3 @@
|
||||
import * as plugins from './smartbucket.plugins';
|
||||
|
||||
export class Directory {}
|
3
ts/smartbucket.classes.file.ts
Normal file
3
ts/smartbucket.classes.file.ts
Normal file
@ -0,0 +1,3 @@
|
||||
import * as plugins from './smartbucket.plugins';
|
||||
|
||||
export class File {}
|
@ -1,30 +1,40 @@
|
||||
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(bucketName: string) {
|
||||
await this.minioClient.makeBucket(bucketName, 'ams3').catch(e => console.log(e));
|
||||
}
|
||||
|
||||
public async removeBucket(bucketName: string) {
|
||||
await this.minioClient.removeBucket(bucketName).catch(e => console.log(e));
|
||||
}
|
||||
|
||||
public async getBucket(bucketName: string) {
|
||||
return Bucket.getFromName(this, bucketName);
|
||||
}
|
||||
}
|
||||
|
@ -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
|
||||
};
|
||||
|
Reference in New Issue
Block a user