Use the config object.

This commit is contained in:
Mathieu Lecarme 2019-11-08 17:58:33 +01:00
parent 2d22573588
commit 97deb78de6
2 changed files with 22 additions and 14 deletions

View File

@ -9,6 +9,16 @@ const conf = convict({
default: '', default: '',
env: 'S3_BUCKET' env: 'S3_BUCKET'
}, },
s3_endpoint: {
format: String,
default: '',
env: 'S3_ENDPOINT'
},
s3_use_path_style_endpoint: {
format: Boolean,
default: false,
env: 'S3_USE_PATH_STYLE_ENDPOINT'
},
gcs_bucket: { gcs_bucket: {
format: String, format: String,
default: '', default: '',

View File

@ -1,33 +1,31 @@
const AWS = require('aws-sdk'); const AWS = require('aws-sdk');
const config = {};
if (typeof process.env.AWS_S3_ENDPOINT !== 'undefined') {
config['endpoint'] = process.env.AWS_S3_ENDPOINT;
}
if (typeof process.env.AWS_S3_USE_PATH_STYLE_ENDPOINT !== 'undefined') {
config['s3ForcePathStyle'] = process.env.AWS_S3_USE_PATH_STYLE_ENDPOINT == 'true' ? true : false;
}
AWS.config.update(config);
const s3 = new AWS.S3();
class S3Storage { class S3Storage {
constructor(config, log) { constructor(config, log) {
this.bucket = config.s3_bucket; this.bucket = config.s3_bucket;
this.log = log; this.log = log;
const cfg = {};
if (config.s3_endpoint != '') {
cfg['endpoint'] = config.s3_endpoint;
}
cfg['s3ForcePathStyle'] = config.s3_use_path_style_endpoint
AWS.config.update(cfg);
this.s3 = new AWS.S3();
} }
async length(id) { async length(id) {
const result = await s3 const result = await this.s3
.headObject({ Bucket: this.bucket, Key: id }) .headObject({ Bucket: this.bucket, Key: id })
.promise(); .promise();
return result.ContentLength; return result.ContentLength;
} }
getStream(id) { getStream(id) {
return s3.getObject({ Bucket: this.bucket, Key: id }).createReadStream(); return this.s3.getObject({ Bucket: this.bucket, Key: id }).createReadStream();
} }
set(id, file) { set(id, file) {
const upload = s3.upload({ const upload = this.s3.upload({
Bucket: this.bucket, Bucket: this.bucket,
Key: id, Key: id,
Body: file Body: file
@ -37,11 +35,11 @@ class S3Storage {
} }
del(id) { del(id) {
return s3.deleteObject({ Bucket: this.bucket, Key: id }).promise(); return this.s3.deleteObject({ Bucket: this.bucket, Key: id }).promise();
} }
ping() { ping() {
return s3.headBucket({ Bucket: this.bucket }).promise(); return this.s3.headBucket({ Bucket: this.bucket }).promise();
} }
} }