fox-send/server/storage.js

293 lines
5.9 KiB
JavaScript
Raw Normal View History

const AWS = require('aws-sdk');
const s3 = new AWS.S3();
const conf = require('./config.js');
const fs = require('fs');
const path = require('path');
2017-06-08 20:45:28 +00:00
const mozlog = require('./log.js');
2017-07-11 19:34:49 +00:00
const log = mozlog('send.storage');
2017-06-08 20:45:28 +00:00
const redis = require('redis');
2017-06-07 23:46:48 +00:00
const redis_client = redis.createClient({
2017-06-23 18:14:33 +00:00
host: conf.redis_host,
connect_timeout: 10000
2017-06-07 23:46:48 +00:00
});
redis_client.on('error', err => {
log.info('Redis:', err);
});
2017-06-24 03:01:32 +00:00
if (conf.s3_bucket) {
module.exports = {
filename: filename,
exists: exists,
2017-07-20 22:16:00 +00:00
ttl: ttl,
length: awsLength,
get: awsGet,
set: awsSet,
2017-06-20 21:33:28 +00:00
aad: aad,
setField: setField,
delete: awsDelete,
2017-06-23 18:14:33 +00:00
forceDelete: awsForceDelete,
2017-06-29 17:27:36 +00:00
ping: awsPing,
2017-07-11 19:47:40 +00:00
flushall: flushall,
quit: quit,
2017-06-29 17:27:36 +00:00
metadata
};
} else {
module.exports = {
filename: filename,
exists: exists,
2017-07-20 22:16:00 +00:00
ttl: ttl,
length: localLength,
get: localGet,
set: localSet,
2017-06-20 21:33:28 +00:00
aad: aad,
setField: setField,
delete: localDelete,
2017-06-23 18:14:33 +00:00
forceDelete: localForceDelete,
2017-06-29 17:27:36 +00:00
ping: localPing,
2017-07-11 19:47:40 +00:00
flushall: flushall,
quit: quit,
2017-06-29 17:27:36 +00:00
metadata
};
}
2017-07-11 19:47:40 +00:00
function flushall() {
redis_client.flushdb();
}
function quit() {
redis_client.quit();
}
2017-06-29 17:27:36 +00:00
function metadata(id) {
return new Promise((resolve, reject) => {
redis_client.hgetall(id, (err, reply) => {
if (!err) {
resolve(reply);
} else {
reject(err);
}
2017-06-29 17:30:08 +00:00
});
});
2017-06-29 17:27:36 +00:00
}
2017-07-20 22:16:00 +00:00
function ttl(id) {
return new Promise((resolve, reject) => {
redis_client.ttl(id, (err, reply) => {
if (!err) {
resolve(reply * 1000);
} else {
reject(err);
}
2017-07-22 00:01:26 +00:00
});
});
2017-07-20 22:16:00 +00:00
}
function filename(id) {
return new Promise((resolve, reject) => {
redis_client.hget(id, 'filename', (err, reply) => {
if (!err) {
resolve(reply);
} else {
2017-06-23 17:53:11 +00:00
reject(err);
}
});
});
}
function exists(id) {
2017-06-08 20:45:28 +00:00
return new Promise((resolve, reject) => {
redis_client.exists(id, (rediserr, reply) => {
2017-06-23 18:42:51 +00:00
if (reply === 1 && !rediserr) {
resolve();
} else {
reject(rediserr);
}
2017-06-08 20:45:28 +00:00
});
});
}
2017-06-20 21:33:28 +00:00
function setField(id, key, value) {
redis_client.hset(id, key, value);
}
function aad(id) {
return new Promise((resolve, reject) => {
redis_client.hget(id, 'aad', (err, reply) => {
if (!err) {
resolve(reply);
} else {
reject();
}
2017-06-29 17:30:08 +00:00
});
});
2017-06-20 21:33:28 +00:00
}
function localLength(id) {
return new Promise((resolve, reject) => {
try {
2017-06-09 17:44:12 +00:00
resolve(fs.statSync(path.join(__dirname, '../static', id)).size);
} catch (err) {
reject();
}
});
}
function localGet(id) {
2017-06-09 17:44:12 +00:00
return fs.createReadStream(path.join(__dirname, '../static', id));
}
2017-07-10 19:45:20 +00:00
function localSet(newId, file, filename, meta) {
return new Promise((resolve, reject) => {
2017-07-20 19:50:20 +00:00
const filepath = path.join(__dirname, '../static', newId);
const fstream = fs.createWriteStream(filepath);
file.pipe(fstream);
2017-07-20 19:50:20 +00:00
file.on('limit', () => {
file.unpipe(fstream);
fstream.destroy(new Error('limit'));
});
fstream.on('finish', () => {
redis_client.hmset(newId, meta);
2017-07-10 19:45:20 +00:00
redis_client.expire(newId, 86400000);
log.info('localSet:', 'Upload Finished of ' + newId);
resolve(meta.delete);
});
2017-07-20 19:50:20 +00:00
fstream.on('error', err => {
log.error('localSet:', 'Failed upload of ' + newId);
2017-07-20 19:50:20 +00:00
fs.unlinkSync(filepath);
reject(err);
});
});
}
function localDelete(id, delete_token) {
return new Promise((resolve, reject) => {
redis_client.hget(id, 'delete', (err, reply) => {
if (!reply || delete_token !== reply) {
reject();
} else {
redis_client.del(id);
2017-06-09 17:44:12 +00:00
resolve(fs.unlinkSync(path.join(__dirname, '../static', id)));
}
});
});
}
function localForceDelete(id) {
return new Promise((resolve, reject) => {
redis_client.del(id);
2017-06-09 17:44:12 +00:00
resolve(fs.unlinkSync(path.join(__dirname, '../static', id)));
});
}
2017-06-23 18:14:33 +00:00
function localPing() {
return new Promise((resolve, reject) => {
redis_client.ping(err => {
return err ? reject() : resolve();
});
});
}
function awsLength(id) {
2017-06-09 17:44:12 +00:00
const params = {
Bucket: conf.s3_bucket,
Key: id
};
return new Promise((resolve, reject) => {
s3.headObject(params, function(err, data) {
if (!err) {
resolve(data.ContentLength);
} else {
reject();
}
});
});
}
function awsGet(id) {
2017-06-09 17:44:12 +00:00
const params = {
Bucket: conf.s3_bucket,
Key: id
};
2017-06-20 17:21:11 +00:00
try {
return s3.getObject(params).createReadStream();
2017-06-20 19:52:01 +00:00
} catch (err) {
2017-06-20 17:21:11 +00:00
log.info('GetFailed', 'Get Object from s3 failed.');
return null;
}
}
2017-07-10 19:45:20 +00:00
function awsSet(newId, file, filename, meta) {
2017-06-09 17:44:12 +00:00
const params = {
Bucket: conf.s3_bucket,
Key: newId,
Body: file
};
2017-07-20 19:50:20 +00:00
let hitLimit = false;
const upload = s3.upload(params);
file.on('limit', () => {
hitLimit = true;
upload.abort();
});
2017-07-22 00:01:26 +00:00
return upload.promise().then(
() => {
2017-07-20 19:50:20 +00:00
redis_client.hmset(newId, meta);
redis_client.expire(newId, 86400000);
log.info('awsUploadFinish', 'Upload Finished of ' + filename);
},
err => {
if (hitLimit) {
throw new Error('limit');
} else {
2017-07-20 19:50:20 +00:00
throw err;
}
2017-07-22 00:01:26 +00:00
}
);
}
function awsDelete(id, delete_token) {
return new Promise((resolve, reject) => {
redis_client.hget(id, 'delete', (err, reply) => {
if (!reply || delete_token !== reply) {
reject();
} else {
2017-06-09 17:44:12 +00:00
const params = {
Bucket: conf.s3_bucket,
Key: id
};
2017-06-09 17:44:12 +00:00
s3.deleteObject(params, function(err, _data) {
2017-07-18 17:52:32 +00:00
redis_client.del(id);
2017-06-19 20:37:56 +00:00
err ? reject(err) : resolve(err);
});
}
});
});
}
function awsForceDelete(id) {
return new Promise((resolve, reject) => {
2017-06-09 17:44:12 +00:00
const params = {
Bucket: conf.s3_bucket,
Key: id
};
2017-06-09 17:44:12 +00:00
s3.deleteObject(params, function(err, _data) {
2017-07-18 17:52:32 +00:00
redis_client.del(id);
2017-06-19 20:37:56 +00:00
err ? reject(err) : resolve(err);
});
});
}
2017-06-23 18:14:33 +00:00
function awsPing() {
return localPing().then(() =>
s3.headBucket({ Bucket: conf.s3_bucket }).promise()
);
}