|
| 1 | +const express = require('express'); |
| 2 | +const _ = require('lodash'); |
| 3 | +const fs = require('fs'); |
| 4 | +const router = express.Router(); |
| 5 | +const settings = require('../settings.json'); |
| 6 | +const logger = require('../utils').logger; |
| 7 | +const missingProps = require('../utils').missingProps; |
| 8 | +const multer = require('multer'); |
| 9 | +const crypto = require('crypto'); |
| 10 | +const storage = multer.diskStorage({ |
| 11 | + destination(req, file, cb) { |
| 12 | + cb(null, './uploads/') |
| 13 | + }, |
| 14 | + filename(req, file, cb) { |
| 15 | + crypto.pseudoRandomBytes(16, (err, raw) => { |
| 16 | + cb(null, raw.toString('hex') + Date.now()); |
| 17 | + }); |
| 18 | + } |
| 19 | +}); |
| 20 | +const upload = multer({ |
| 21 | + storage: storage, |
| 22 | + limits: { |
| 23 | + fileSize: 5*1024*1024 |
| 24 | + } |
| 25 | +}).single('file'); |
| 26 | + |
| 27 | +const API = require('../models/API'); |
| 28 | +const User = require('../models/User'); |
| 29 | +const List = require('../models/List'); |
| 30 | +const Snippet = require('../models/Snippet'); |
| 31 | + |
| 32 | +// Setup defaultVars and baseURL for all routes |
| 33 | +let defaultVars, baseURL; |
| 34 | +router.all('*', (req, res, next) => { |
| 35 | + defaultVars = req.app.get('defaultVars'); |
| 36 | + baseURL = req.app.get('baseURL'); |
| 37 | + |
| 38 | + if (!req.session.loggedin) { |
| 39 | + res.redirect(baseURL + '/'); |
| 40 | + |
| 41 | + } else if (req.session.subscription.status === 3) { |
| 42 | + res.redirect(baseURL + '/settings/subscription/paymentOverdue'); |
| 43 | + |
| 44 | + } else if (req.session.subscription.status === 4) { |
| 45 | + req.flash('warning', 'Your account is currently soft-locked until you fix your account quotas.'); |
| 46 | + res.redirect(baseURL + '/'); |
| 47 | + |
| 48 | + } else { |
| 49 | + next(); |
| 50 | + } |
| 51 | +}); |
| 52 | + |
| 53 | +router.get('/api/:ref?', (req, res, next) => { |
| 54 | + API.getCond({ref: req.params.ref}).then(doc => { |
| 55 | + if (doc.owner !== req.session.user.id) { |
| 56 | + res.redirect(baseURL + '/view/api'); |
| 57 | + } else { |
| 58 | + doc.code = fs.readFileSync('./data/apis/' + doc.id + '.api'); // Read api src into this... |
| 59 | + res.render('code/api', _.merge(defaultVars, {api: doc, socket: ':' + settings.general.socket, title: `Edit API ${doc.name} [${doc.ref}]`})); |
| 60 | + } |
| 61 | + }).catch(err => { |
| 62 | + res.redirect(baseURL + '/view/api'); |
| 63 | + }); |
| 64 | +}); |
| 65 | + |
| 66 | +router.post('/api/:ref', (req, res, next) => { |
| 67 | + if (missingProps(req.body, ['rename', 'code'])) { |
| 68 | + req.flash('warning', 'Missing expected form properties'); |
| 69 | + res.send(baseURL + '/edit/api/' + req.params.ref); |
| 70 | + return; |
| 71 | + } |
| 72 | + |
| 73 | + API.getCond({ref: req.params.ref}).then(doc => { |
| 74 | + if (doc.owner !== req.session.user.id) { |
| 75 | + res.send(baseURL + '/view/api'); |
| 76 | + } else { |
| 77 | + let name = req.body.rename; |
| 78 | + if (name === undefined || name === "") name = doc.name; |
| 79 | + if (name.match(/^[a-zA-Z0-9 _\-\.+\[\]\{\}\(\)]{1,32}$/) === null) { |
| 80 | + req.flash('warning', 'Only 32 chars max please! Accepted chars: a-Z0-9 _-.+[]{}()'); |
| 81 | + res.send(baseURL + '/edit/api/' + req.params.ref); |
| 82 | + } else { |
| 83 | + API.update({name}, doc.ref).then(() => { |
| 84 | + fs.writeFile('./data/apis/' + doc.id + '.api', req.body.code.replace(/\r\n/g, '\n').slice(0, 8192), 'utf8', err => { |
| 85 | + req.flash('info', `API ${name} [${doc.ref}] was updated successfully!`); |
| 86 | + res.send(baseURL + '/view/api'); |
| 87 | + }); |
| 88 | + }); |
| 89 | + } |
| 90 | + } |
| 91 | + }); |
| 92 | +}); |
| 93 | + |
| 94 | +// Snippets |
| 95 | +router.get('/snippet/:ref?', (req, res, next) => { |
| 96 | + Snippet.getCond({ref: req.params.ref}).then(doc => { |
| 97 | + if (doc.owner !== req.session.user.id) { |
| 98 | + res.redirect(baseURL + '/view/snippet'); |
| 99 | + } else { |
| 100 | + doc.code = fs.readFileSync('./data/snippets/' + doc.id + '.snippet'); // Read snippet src into this... |
| 101 | + res.render('code/snippet', _.merge(defaultVars, {snippet: doc, socket: ':' + settings.general.socket, title: `Edit Snippet ${doc.name}`})); |
| 102 | + } |
| 103 | + }).catch(err => { |
| 104 | + res.redirect(baseURL + '/view/snippet'); |
| 105 | + }); |
| 106 | +}); |
| 107 | + |
| 108 | +router.post('/snippet/:ref', (req, res, next) => { |
| 109 | + if (missingProps(req.body, ['name', 'tags'])) { |
| 110 | + req.flash('warning', 'Missing expected form properties'); |
| 111 | + res.send(baseURL + '/edit/snippet/' + req.params.ref); |
| 112 | + return; |
| 113 | + } |
| 114 | + Snippet.getCond({ref: req.params.ref}).then(doc => { |
| 115 | + if (doc.owner !== req.session.user.id) { |
| 116 | + res.send(baseURL + '/view/snippet'); |
| 117 | + } else { |
| 118 | + let name = req.body.rename; |
| 119 | + if (name === undefined || name === "") name = doc.name; |
| 120 | + if (name.match(/^[a-zA-Z0-9 _\-\.+\[\]\{\}\(\)]{1,32}$/) === null) { |
| 121 | + req.flash('warning', 'Only 32 chars max please! Accepted chars: a-Z0-9 _-.+[]{}()'); |
| 122 | + res.send(baseURL + '/edit/snippet/' + req.params.ref); |
| 123 | + } else { |
| 124 | + Snippet.getCond({name: req.body.rename, owner: req.session.user.id}).then(dup => { |
| 125 | + |
| 126 | + if ((req.body.rename !== doc.name && dup === null) || (req.body.rename === doc.name)) { |
| 127 | + Snippet.update({name}, doc.ref).then(() => { |
| 128 | + fs.writeFile('./data/snippets/' + doc.id + '.snippet', req.body.code.replace(/\r\n/g, '\n').slice(0, 8192), 'utf8', err => { |
| 129 | + req.app.get('removeSnippet')(`${req.session.user.username}/${doc.name}`); |
| 130 | + req.flash('info', `Snippet ${name} was updated successfully!`); |
| 131 | + res.send(baseURL + '/view/snippet'); |
| 132 | + }); |
| 133 | + }); |
| 134 | + |
| 135 | + // Duplicate name - still update the file contents though |
| 136 | + } else { |
| 137 | + fs.writeFile('./data/snippets/' + doc.id + '.snippet', req.body.code.replace(/\r\n/g, '\n').slice(0, 8192), 'utf8', err => { |
| 138 | + req.app.get('removeSnippet')(`${req.session.user.username}/${doc.name}`); |
| 139 | + req.flash('warning', `You already have another snippet named ${req.body.rename}`); |
| 140 | + res.send(baseURL + '/edit/snippet/' + req.params.ref); |
| 141 | + }); |
| 142 | + } |
| 143 | + }); |
| 144 | + } |
| 145 | + } |
| 146 | + }); |
| 147 | +}); |
| 148 | + |
| 149 | +module.exports = router; |
0 commit comments