mirror of https://github.com/tycrek/ass
Merge pull request #96 from tycrek/minor-things
Josh Moore
3 years ago
committed by
GitHub
commit
202e990888
@ -1,151 +0,0 @@
|
||||
// https://docs.digitalocean.com/products/spaces/resources/s3-sdk-examples/
|
||||
// https://www.digitalocean.com/community/tutorials/how-to-upload-a-file-to-object-storage-with-node-js
|
||||
|
||||
const fs = require('fs-extra');
|
||||
const aws = require('aws-sdk');
|
||||
const Thumbnail = require('./thumbnails').default;
|
||||
const Vibrant = require('./vibrant').default;
|
||||
const Hash = require('./hash').default;
|
||||
const { generateId, log } = require('./utils');
|
||||
const { s3enabled, s3endpoint, s3bucket, s3usePathStyle, s3accessKey, s3secretKey, diskFilePath, saveAsOriginal, saveWithDate, mediaStrict, maxUploadSize } = require('../config.json');
|
||||
const { CODE_UNSUPPORTED_MEDIA_TYPE } = require('../MagicNumbers.json');
|
||||
|
||||
const ID_GEN_LENGTH = 32;
|
||||
const ALLOWED_MIMETYPES = /(image)|(video)|(audio)\//;
|
||||
|
||||
const s3 = new aws.S3({
|
||||
s3ForcePathStyle: s3usePathStyle,
|
||||
endpoint: new aws.Endpoint(s3endpoint),
|
||||
credentials: new aws.Credentials({ accessKeyId: s3accessKey, secretAccessKey: s3secretKey })
|
||||
});
|
||||
|
||||
function getDatedDirname() {
|
||||
if (!saveWithDate) return diskFilePath;
|
||||
|
||||
// Get current month and year
|
||||
const [month, , year] = new Date().toLocaleDateString('en-US').split('/');
|
||||
|
||||
// Add 0 before single digit months (6 turns into 06)
|
||||
return `${diskFilePath}${diskFilePath.endsWith('/') ? '' : '/'}${year}-${`0${month}`.slice(-2)}`; // skipcq: JS-0074
|
||||
}
|
||||
|
||||
function getLocalFilename(req) {
|
||||
return `${getDatedDirname()}/${saveAsOriginal ? req.file.originalname : req.file.sha1}`;
|
||||
}
|
||||
|
||||
function processUploaded(req, res, next) { // skipcq: JS-0045
|
||||
// Fix file object
|
||||
req.file = req.files.file;
|
||||
|
||||
// Other fixes
|
||||
req.file.ext = '.'.concat(req.file.filename.split('.').pop());
|
||||
req.file.originalname = req.file.filename;
|
||||
req.file.path = req.file.file;
|
||||
req.file.randomId = generateId('random', ID_GEN_LENGTH, null, null);
|
||||
req.file.deleteId = generateId('random', ID_GEN_LENGTH, null, null);
|
||||
|
||||
// Set up types
|
||||
req.file.is = {
|
||||
image: false,
|
||||
video: false,
|
||||
audio: false,
|
||||
other: false
|
||||
};
|
||||
|
||||
// Specify correct type
|
||||
const isType = req.file.mimetype.includes('image') ? 'image' : req.file.mimetype.includes('video') ? 'video' : req.file.mimetype.includes('audio') ? 'audio' : 'other';
|
||||
req.file.is[isType] = true;
|
||||
|
||||
// Block the resource if the mimetype is not an image or video
|
||||
if (mediaStrict && !ALLOWED_MIMETYPES.test(req.file.mimetype))
|
||||
return log
|
||||
.warn('Upload blocked', req.file.originalname, req.file.mimetype)
|
||||
.warn('Strict media mode', 'only images, videos, & audio are file permitted')
|
||||
.callback(() =>
|
||||
fs.remove(req.file.path)
|
||||
.then(() => log
|
||||
.debug('Temp file', 'deleted')
|
||||
.callback(() => res.sendStatus(CODE_UNSUPPORTED_MEDIA_TYPE)))
|
||||
.catch((err) => log
|
||||
.error('Temp file could not be deleted', err)
|
||||
.callback(next, err)));
|
||||
|
||||
// Remove unwanted fields
|
||||
delete req.file.uuid;
|
||||
delete req.file.field;
|
||||
delete req.file.file;
|
||||
delete req.file.filename;
|
||||
delete req.file.truncated;
|
||||
delete req.file.done;
|
||||
|
||||
// Operations
|
||||
Promise.all([Thumbnail(req.file), Vibrant(req.file), Hash(req.file), fs.stat(req.file.path)])
|
||||
// skipcq: JS-0086
|
||||
.then(([thumbnail, vibrant, sha1, stat]) => (
|
||||
req.file.thumbnail = thumbnail, // skipcq: JS-0090
|
||||
req.file.vibrant = vibrant, // skipcq: JS-0090
|
||||
req.file.sha1 = sha1, // skipcq: JS-0090
|
||||
req.file.size = stat.size // skipcq: JS-0090
|
||||
))
|
||||
|
||||
// Check if file size is too big
|
||||
.then(() => { if (req.file.size / Math.pow(1024, 2) > maxUploadSize) throw new Error('LIMIT_FILE_SIZE'); })
|
||||
|
||||
// Save file
|
||||
.then(() => log.debug('Saving file', req.file.originalname, s3enabled ? 'in S3' : 'on disk'))
|
||||
.then(() =>
|
||||
// skipcq: JS-0229
|
||||
new Promise((resolve, reject) => s3enabled
|
||||
|
||||
// Upload to Amazon S3
|
||||
? s3.putObject({
|
||||
Bucket: s3bucket,
|
||||
Key: req.file.randomId.concat(req.file.ext),
|
||||
ACL: 'public-read',
|
||||
ContentType: req.file.mimetype,
|
||||
Body: fs.createReadStream(req.file.path)
|
||||
}).promise().then(resolve).catch(reject)
|
||||
|
||||
// Save to local storage
|
||||
: fs.ensureDir(getDatedDirname())
|
||||
.then(() => fs.copy(req.file.path, getLocalFilename(req), { preserveTimestamps: true }))
|
||||
.then(resolve)
|
||||
.catch(reject)
|
||||
))
|
||||
.then(() => log.debug('File saved', req.file.originalname, s3enabled ? 'in S3' : 'on disk'))
|
||||
.catch(next)
|
||||
|
||||
// Delete the file
|
||||
.then(() => fs.remove(req.file.path))
|
||||
.then(() => log.debug('Temp file', 'deleted'))
|
||||
|
||||
// Fix the file path
|
||||
.then(() => !s3enabled && (req.file.path = getLocalFilename(req))) // skipcq: JS-0090
|
||||
.then(() => next())
|
||||
.catch(next);
|
||||
}
|
||||
|
||||
function deleteS3(file) {
|
||||
return new Promise((resolve, reject) => s3
|
||||
.deleteObject({ Bucket: s3bucket, Key: file.randomId.concat(file.ext) })
|
||||
.promise()
|
||||
.then(resolve)
|
||||
.catch(reject));
|
||||
}
|
||||
|
||||
function listAllKeys(resolve, reject, token) {
|
||||
let allKeys = [];
|
||||
s3.listObjectsV2({ Bucket: s3bucket, ContinuationToken: token }).promise()
|
||||
.then((data) => (allKeys = allKeys.concat(data.Contents), data.IsTruncated ? listAllKeys(resolve, reject, data.NextContinuationToken) : resolve(allKeys.length))) // skipcq: JS-0086, JS-0090
|
||||
.catch(reject);
|
||||
}
|
||||
|
||||
function bucketSize() {
|
||||
return new Promise((resolve, reject) => (s3enabled ? listAllKeys(resolve, reject) : resolve(0)));
|
||||
}
|
||||
|
||||
module.exports = {
|
||||
processUploaded,
|
||||
deleteS3,
|
||||
bucketSize
|
||||
};
|
||||
@ -0,0 +1,147 @@
|
||||
// https://docs.digitalocean.com/products/spaces/resources/s3-sdk-examples/
|
||||
// https://www.digitalocean.com/community/tutorials/how-to-upload-a-file-to-object-storage-with-node-js
|
||||
import { AssRequest, AssResponse, FileData } from './definitions';
|
||||
|
||||
import fs, { Stats } from 'fs-extra';
|
||||
import aws from 'aws-sdk';
|
||||
import Thumbnail from './thumbnails';
|
||||
import Vibrant from './vibrant';
|
||||
import Hash from './hash';
|
||||
import { generateId, log } from './utils';
|
||||
const { s3enabled, s3endpoint, s3bucket, s3usePathStyle, s3accessKey, s3secretKey, diskFilePath, saveAsOriginal, saveWithDate, mediaStrict, maxUploadSize } = require('../config.json');
|
||||
const { CODE_UNSUPPORTED_MEDIA_TYPE } = require('../MagicNumbers.json');
|
||||
|
||||
const ID_GEN_LENGTH = 32;
|
||||
const ALLOWED_MIMETYPES = /(image)|(video)|(audio)\//;
|
||||
|
||||
const s3 = new aws.S3({
|
||||
s3ForcePathStyle: s3usePathStyle,
|
||||
endpoint: new aws.Endpoint(s3endpoint),
|
||||
credentials: new aws.Credentials({ accessKeyId: s3accessKey, secretAccessKey: s3secretKey })
|
||||
});
|
||||
|
||||
function getDatedDirname() {
|
||||
if (!saveWithDate) return diskFilePath;
|
||||
|
||||
// Get current month and year
|
||||
const [month, , year] = new Date().toLocaleDateString('en-US').split('/');
|
||||
|
||||
// Add 0 before single digit months (6 turns into 06)
|
||||
return `${diskFilePath}${diskFilePath.endsWith('/') ? '' : '/'}${year}-${`0${month}`.slice(-2)}`; // skipcq: JS-0074
|
||||
}
|
||||
|
||||
function getLocalFilename(req: AssRequest) {
|
||||
return `${getDatedDirname()}/${saveAsOriginal ? req.file!.originalname : req.file!.sha1}`;
|
||||
}
|
||||
|
||||
export function processUploaded(req: AssRequest, res: AssResponse, next: Function) { // skipcq: JS-0045
|
||||
// Fix file object
|
||||
req.file = req.files!.file;
|
||||
|
||||
// Other fixes
|
||||
req.file!.ext = '.'.concat((req.file!.filename ?? '').split('.').pop() ?? '');
|
||||
req.file!.originalname = req.file!.filename ?? '';
|
||||
req.file!.path = req.file!.file ?? '';
|
||||
req.file!.randomId = generateId('random', ID_GEN_LENGTH, 0, '');
|
||||
req.file!.deleteId = generateId('random', ID_GEN_LENGTH, 0, '');
|
||||
|
||||
// Set up types
|
||||
req.file!.is = {
|
||||
image: false,
|
||||
video: false,
|
||||
audio: false,
|
||||
other: false
|
||||
};
|
||||
|
||||
// Specify correct type
|
||||
const isType = req.file!.mimetype.includes('image') ? 'image' : req.file!.mimetype.includes('video') ? 'video' : req.file!.mimetype.includes('audio') ? 'audio' : 'other';
|
||||
req.file!.is[isType] = true;
|
||||
|
||||
// Block the resource if the mimetype is not an image or video
|
||||
if (mediaStrict && !ALLOWED_MIMETYPES.test(req.file!.mimetype))
|
||||
return log
|
||||
.warn('Upload blocked', req.file!.originalname, req.file!.mimetype)
|
||||
.warn('Strict media mode', 'only images, videos, & audio are file permitted')
|
||||
.callback(() =>
|
||||
fs.remove(req.file!.path)
|
||||
.then(() => log
|
||||
.debug('Temp file', 'deleted')
|
||||
.callback(() => res.sendStatus(CODE_UNSUPPORTED_MEDIA_TYPE)))
|
||||
.catch((err) => log
|
||||
.error('Temp file could not be deleted', err)
|
||||
.callback(next, err)));
|
||||
|
||||
// Remove unwanted fields
|
||||
delete req.file!.uuid;
|
||||
delete req.file!.field;
|
||||
delete req.file!.file;
|
||||
delete req.file!.filename;
|
||||
delete req.file!.truncated;
|
||||
delete req.file!.done;
|
||||
|
||||
// Operations
|
||||
// @ts-ignore
|
||||
Promise.all([Thumbnail(req.file), Vibrant(req.file), Hash(req.file), fs.stat(req.file!.path)])
|
||||
// skipcq: JS-0086
|
||||
.then(([thumbnail, vibrant, sha1, stat]: [string, string, string, Stats]) => (
|
||||
req.file!.thumbnail = thumbnail, // skipcq: JS-0090
|
||||
req.file!.vibrant = vibrant, // skipcq: JS-0090
|
||||
req.file!.sha1 = sha1, // skipcq: JS-0090
|
||||
req.file!.size = stat.size // skipcq: JS-0090
|
||||
))
|
||||
|
||||
// Check if file size is too big
|
||||
.then(() => { if (req.file!.size / Math.pow(1024, 2) > maxUploadSize) throw new Error('LIMIT_FILE_SIZE'); })
|
||||
|
||||
// Save file
|
||||
.then(() => log.debug('Saving file', req.file!.originalname, s3enabled ? 'in S3' : 'on disk'))
|
||||
.then(() =>
|
||||
// skipcq: JS-0229
|
||||
new Promise((resolve, reject) => s3enabled
|
||||
|
||||
// Upload to Amazon S3
|
||||
? s3.putObject({
|
||||
Bucket: s3bucket,
|
||||
Key: req.file!.randomId.concat(req.file!.ext),
|
||||
ACL: 'public-read',
|
||||
ContentType: req.file!.mimetype,
|
||||
Body: fs.createReadStream(req.file!.path)
|
||||
}).promise().then(resolve).catch(reject)
|
||||
|
||||
// Save to local storage
|
||||
: fs.ensureDir(getDatedDirname())
|
||||
.then(() => fs.copy(req.file!.path, getLocalFilename(req), { preserveTimestamps: true }))
|
||||
.then(resolve)
|
||||
.catch(reject)
|
||||
))
|
||||
.then(() => log.debug('File saved', req.file!.originalname, s3enabled ? 'in S3' : 'on disk'))
|
||||
.catch((err) => next(err))
|
||||
|
||||
// Delete the file
|
||||
.then(() => fs.remove(req.file!.path))
|
||||
.then(() => log.debug('Temp file', 'deleted'))
|
||||
|
||||
// Fix the file path
|
||||
.then(() => !s3enabled && (req.file!.path = getLocalFilename(req))) // skipcq: JS-0090
|
||||
.then(() => next())
|
||||
.catch((err) => next(err));
|
||||
}
|
||||
|
||||
export function deleteS3(file: FileData) {
|
||||
return new Promise((resolve, reject) => s3
|
||||
.deleteObject({ Bucket: s3bucket, Key: file.randomId.concat(file.ext) })
|
||||
.promise()
|
||||
.then(resolve)
|
||||
.catch(reject));
|
||||
}
|
||||
|
||||
function listAllKeys(resolve: Function, reject: Function, token?: string) {
|
||||
let allKeys: string[] = [];
|
||||
s3.listObjectsV2({ Bucket: s3bucket, ContinuationToken: token }).promise()
|
||||
.then((data: { [key: string]: any }) => (allKeys = allKeys.concat(data.Contents), data.IsTruncated ? listAllKeys(resolve, reject, data.NextContinuationToken) : resolve(allKeys.length))) // skipcq: JS-0086, JS-0090
|
||||
.catch((err) => reject(err));
|
||||
}
|
||||
|
||||
export function bucketSize() {
|
||||
return new Promise((resolve, reject) => (s3enabled ? listAllKeys(resolve, reject) : resolve(0)));
|
||||
}
|
||||
Loading…
Reference in new issue