mirror of https://github.com/tycrek/ass
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
123 lines
3.7 KiB
123 lines
3.7 KiB
import fs from 'fs-extra';
|
|
import bb from 'express-busboy';
|
|
import { Router } from 'express';
|
|
import { log } from '../log';
|
|
import { UserConfig } from '../UserConfig';
|
|
import { random } from '../generators';
|
|
import { BusBoyFile, AssFile } from 'ass';
|
|
import { getFileS3, uploadFileS3 } from '../s3';
|
|
import { Readable } from 'stream';
|
|
import * as data from '../data';
|
|
|
|
const router = Router({ caseSensitive: true });
|
|
|
|
//@ts-ignore // Required since bb.extends expects express.Application, not a Router (but it still works)
|
|
bb.extend(router, {
|
|
upload: true,
|
|
restrictMultiple: true,
|
|
allowedPath: (url: string) => url === '/',
|
|
limits: {
|
|
fileSize: () => (UserConfig.ready ? UserConfig.config.maximumFileSize : 50) * 1000000 // MB
|
|
}
|
|
});
|
|
|
|
// Render or redirect
|
|
router.get('/', (req, res) => UserConfig.ready ? res.render('index') : res.redirect('/setup'));
|
|
|
|
// Upload flow
|
|
router.post('/', async (req, res) => {
|
|
|
|
// Check user config
|
|
if (!UserConfig.ready) return res.status(500).type('text').send('Configuration missing!');
|
|
|
|
// Does the file actually exist
|
|
if (!req.files || !req.files['file']) return res.status(400).type('text').send('No file was provided!');
|
|
else log.debug('Upload request received', `Using ${UserConfig.config.s3 != null ? 'S3' : 'local'} storage`);
|
|
|
|
// Type-check the file data
|
|
const bbFile: BusBoyFile = req.files['file'];
|
|
|
|
// Prepare file move
|
|
const uploads = UserConfig.config.uploadsDir;
|
|
const timestamp = Date.now().toString();
|
|
const fileKey = `${timestamp}_${bbFile.filename}`;
|
|
const destination = `${uploads}${uploads.endsWith('/') ? '' : '/'}${fileKey}`;
|
|
|
|
// S3 configuration
|
|
const s3 = UserConfig.config.s3 != null ? UserConfig.config.s3 : false;
|
|
|
|
try {
|
|
|
|
// * Move the file
|
|
if (!s3) await fs.move(bbFile.file, destination);
|
|
else await uploadFileS3(await fs.readFile(bbFile.file), bbFile.mimetype, fileKey);
|
|
|
|
// Build ass metadata
|
|
const assFile: AssFile = {
|
|
fakeid: random({ length: UserConfig.config.idSize }), // todo: more generators
|
|
fileKey,
|
|
mimetype: bbFile.mimetype,
|
|
filename: bbFile.filename,
|
|
timestamp,
|
|
uploader: '0', // todo: users
|
|
save: {},
|
|
sha256: '0' // todo: hashing
|
|
};
|
|
|
|
// Set the save location
|
|
if (!s3) assFile.save.local = destination;
|
|
else {
|
|
// Using S3 doesn't move temp file, delete it now
|
|
await fs.rm(bbFile.file);
|
|
assFile.save.s3 = true;
|
|
}
|
|
|
|
// * Save metadata
|
|
data.put('files', assFile.fakeid, assFile);
|
|
|
|
log.debug('File saved to', !s3 ? assFile.save.local! : 'S3');
|
|
return res.type('json').send({ resource: `${req.ass.host}/${assFile.fakeid}` });
|
|
} catch (err) {
|
|
log.error('Failed to upload file', bbFile.filename);
|
|
console.error(err);
|
|
return res.status(500).send(err);
|
|
}
|
|
});
|
|
|
|
router.get('/:fakeId', (req, res) => res.redirect(`/direct/${req.params.fakeId}`));
|
|
|
|
router.get('/direct/:fakeId', async (req, res) => {
|
|
if (!UserConfig.ready) res.redirect('/setup');
|
|
|
|
// Get the ID
|
|
const fakeId = req.params.fakeId;
|
|
|
|
if (!files.has(fakeId)) return res.status(404).send();
|
|
else {
|
|
|
|
// Get file metadata
|
|
const meta = files.get(fakeId)!;
|
|
|
|
// File data can come from either S3 or local filesystem
|
|
let output: Readable | NodeJS.ReadableStream;
|
|
|
|
// Try to retrieve the file
|
|
if (!!meta.save.s3) {
|
|
const file = await getFileS3(meta.fileKey);
|
|
if (!file.Body) return res.status(500).send('Unknown error');
|
|
output = file.Body as Readable;
|
|
} else output = fs.createReadStream(meta.save.local!);
|
|
|
|
// Configure response headers
|
|
res.type(meta.mimetype)
|
|
.header('Content-Disposition', `inline; filename="${meta.filename}"`)
|
|
.header('Cache-Control', 'public, max-age=31536000, immutable')
|
|
.header('Accept-Ranges', 'bytes');
|
|
|
|
// Send the file (thanks to https://stackoverflow.com/a/67373050)
|
|
output.pipe(res);
|
|
}
|
|
});
|
|
|
|
export { router };
|