|
|
|
@ -2,7 +2,7 @@ var express = require('express'); |
|
|
|
var view = require('./view'); |
|
|
|
var view = require('./view'); |
|
|
|
var storage = require('./storage'); |
|
|
|
var storage = require('./storage'); |
|
|
|
var md5 = require('md5'); |
|
|
|
var md5 = require('md5'); |
|
|
|
var LRU = require("lru-cache") |
|
|
|
var LRU = require('lru-cache'); |
|
|
|
var bodyParser = require('body-parser'); |
|
|
|
var bodyParser = require('body-parser'); |
|
|
|
var fs = require('fs'); |
|
|
|
var fs = require('fs'); |
|
|
|
var blackList; |
|
|
|
var blackList; |
|
|
|
@ -13,8 +13,8 @@ app.use(bodyParser.urlencoded({ extended: true, limit: '200kb' })); |
|
|
|
app.use(express.static(__dirname + '/resources/public')); |
|
|
|
app.use(express.static(__dirname + '/resources/public')); |
|
|
|
app.use(function (error, req, res, next) { |
|
|
|
app.use(function (error, req, res, next) { |
|
|
|
if (error) { |
|
|
|
if (error) { |
|
|
|
sendResponse(res, 400, "Bad request", error.message); |
|
|
|
sendResponse(res, 400, 'Bad request', error.message); |
|
|
|
log("REQUEST ERROR:", error); |
|
|
|
log('REQUEST ERROR:', error); |
|
|
|
} else { |
|
|
|
} else { |
|
|
|
next(); |
|
|
|
next(); |
|
|
|
} |
|
|
|
} |
|
|
|
@ -24,28 +24,28 @@ var MODELS = {}; |
|
|
|
var CACHE = new LRU({ |
|
|
|
var CACHE = new LRU({ |
|
|
|
max: 50, |
|
|
|
max: 50, |
|
|
|
dispose: key => { |
|
|
|
dispose: key => { |
|
|
|
log("disposing", key, "from cache"); |
|
|
|
log('disposing', key, 'from cache'); |
|
|
|
var model = MODELS[key]; |
|
|
|
var model = MODELS[key]; |
|
|
|
model && model.save(); |
|
|
|
if (model) model.save(); |
|
|
|
delete MODELS[key]; |
|
|
|
delete MODELS[key]; |
|
|
|
} |
|
|
|
} |
|
|
|
}); |
|
|
|
}); |
|
|
|
|
|
|
|
|
|
|
|
var log = function() { |
|
|
|
var log = function() { |
|
|
|
var date = new Date(); |
|
|
|
var date = new Date(); |
|
|
|
var timestamp = date.getDate() + "/" + date.getMonth() + " " + date.getHours() + ":" + |
|
|
|
var timestamp = date.getDate() + '/' + date.getMonth() + ' ' + date.getHours() + ':' + |
|
|
|
date.getMinutes() + ":" + date.getSeconds() + "." + date.getMilliseconds(); |
|
|
|
date.getMinutes() + ':' + date.getSeconds() + '.' + date.getMilliseconds(); |
|
|
|
var message = Array.prototype.slice.call(arguments); |
|
|
|
var message = Array.prototype.slice.call(arguments); |
|
|
|
message.unshift("--"); |
|
|
|
message.unshift('--'); |
|
|
|
message.unshift(timestamp); |
|
|
|
message.unshift(timestamp); |
|
|
|
console.log.apply(console, message); |
|
|
|
console.log.apply(console, message); |
|
|
|
} |
|
|
|
}; |
|
|
|
|
|
|
|
|
|
|
|
app.get('/TOS', (req, res) => res.send(view.renderTOS())); |
|
|
|
app.get('/TOS', (req, res) => res.send(view.renderTOS())); |
|
|
|
|
|
|
|
|
|
|
|
app.get('/new', (req, res) => { |
|
|
|
app.get('/new', (req, res) => { |
|
|
|
log(req.ip, "opens /new"); |
|
|
|
log(req.ip, 'opens /new'); |
|
|
|
res.send(view.newNotePage(md5("new"))); |
|
|
|
res.send(view.newNotePage(md5('new'))); |
|
|
|
}); |
|
|
|
}); |
|
|
|
|
|
|
|
|
|
|
|
app.post('/note', (req, res) => { |
|
|
|
app.post('/note', (req, res) => { |
|
|
|
@ -55,43 +55,43 @@ app.post('/note', (req, res) => { |
|
|
|
password = body.password, |
|
|
|
password = body.password, |
|
|
|
action = body.action, |
|
|
|
action = body.action, |
|
|
|
id = body.id; |
|
|
|
id = body.id; |
|
|
|
log(req.ip, "calls /note to", action, id); |
|
|
|
log(req.ip, 'calls /note to', action, id); |
|
|
|
var goToNote = note => res.redirect("/" + note.id); |
|
|
|
var goToNote = note => res.redirect('/' + note.id); |
|
|
|
if (!note || !session || session.indexOf(md5('edit/' + id)) != 0 && session.indexOf(md5('new')) != 0) |
|
|
|
if (!note || !session || session.indexOf(md5('edit/' + id)) !== 0 && session.indexOf(md5('new')) !== 0) |
|
|
|
return sendResponse(res, 400, 'Bad request'); |
|
|
|
return sendResponse(res, 400, 'Bad request'); |
|
|
|
if (body.signature != md5(session + note.replace(/[\n\r]/g, ""))) |
|
|
|
if (body.signature != md5(session + note.replace(/[\n\r]/g, ''))) |
|
|
|
return sendResponse(res, 400, "Signature mismatch"); |
|
|
|
return sendResponse(res, 400, 'Signature mismatch'); |
|
|
|
if (action == "POST") |
|
|
|
if (action == 'POST') |
|
|
|
storage.addNote(note, password).then(goToNote); |
|
|
|
storage.addNote(note, password).then(goToNote); |
|
|
|
else { |
|
|
|
else { |
|
|
|
if (!id) return sendResponse(res, 400, "Wrong note ID"); |
|
|
|
if (!id) return sendResponse(res, 400, 'Wrong note ID'); |
|
|
|
CACHE.del(id); |
|
|
|
CACHE.del(id); |
|
|
|
if (body.button == "Delete") { |
|
|
|
if (body.button == 'Delete') { |
|
|
|
log("deleting note", id); |
|
|
|
log('deleting note', id); |
|
|
|
storage.deleteNote(id, password).then( |
|
|
|
storage.deleteNote(id, password).then( |
|
|
|
() => sendResponse(res, 200, "Note deleted"), |
|
|
|
() => sendResponse(res, 200, 'Note deleted'), |
|
|
|
error => sendResponse(res, 400, "Bad request", error.message)); |
|
|
|
error => sendResponse(res, 400, 'Bad request', error.message)); |
|
|
|
} else { |
|
|
|
} else { |
|
|
|
log("updating note", id); |
|
|
|
log('updating note', id); |
|
|
|
storage.updateNote(id, password, note).then(goToNote, |
|
|
|
storage.updateNote(id, password, note).then(goToNote, |
|
|
|
error => sendResponse(res, 400, "Bad request", error.message)); |
|
|
|
error => sendResponse(res, 400, 'Bad request', error.message)); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
}); |
|
|
|
}); |
|
|
|
|
|
|
|
|
|
|
|
app.get("/:year/:month/:day/:title", (req, res) => { |
|
|
|
app.get('/:year/:month/:day/:title', (req, res) => { |
|
|
|
var P = req.params, url = P.year + "/" + P.month + "/" + P.day + "/" + P.title; |
|
|
|
var P = req.params, url = P.year + '/' + P.month + '/' + P.day + '/' + P.title; |
|
|
|
log(req.ip, "resolves deprecated id", url); |
|
|
|
log(req.ip, 'resolves deprecated id', url); |
|
|
|
if (CACHE.has(url)) { |
|
|
|
if (CACHE.has(url)) { |
|
|
|
log(url, "is cached!"); |
|
|
|
log(url, 'is cached!'); |
|
|
|
var id = CACHE.get(url); |
|
|
|
var id = CACHE.get(url); |
|
|
|
if (id) res.redirect("/" + id); |
|
|
|
if (id) res.redirect('/' + id); |
|
|
|
else notFound(res); |
|
|
|
else notFound(res); |
|
|
|
} else storage.getNoteId(url).then(note => { |
|
|
|
} else storage.getNoteId(url).then(note => { |
|
|
|
log(url, "is not cached, resolving..."); |
|
|
|
log(url, 'is not cached, resolving...'); |
|
|
|
if (note) { |
|
|
|
if (note) { |
|
|
|
CACHE.set(url, note.id); |
|
|
|
CACHE.set(url, note.id); |
|
|
|
res.redirect("/" + note.id) |
|
|
|
res.redirect('/' + note.id); |
|
|
|
} else { |
|
|
|
} else { |
|
|
|
CACHE.set(url, null); |
|
|
|
CACHE.set(url, null); |
|
|
|
notFound(res); |
|
|
|
notFound(res); |
|
|
|
@ -100,44 +100,44 @@ app.get("/:year/:month/:day/:title", (req, res) => { |
|
|
|
}); |
|
|
|
}); |
|
|
|
|
|
|
|
|
|
|
|
app.get(/\/([a-z0-9]+)\/edit/, (req, res) => { |
|
|
|
app.get(/\/([a-z0-9]+)\/edit/, (req, res) => { |
|
|
|
var id = req.params["0"]; |
|
|
|
var id = req.params['0']; |
|
|
|
log(req.ip, "calls /edit on", id); |
|
|
|
log(req.ip, 'calls /edit on', id); |
|
|
|
storage.getNote(id).then(note => res.send(note |
|
|
|
storage.getNote(id).then(note => res.send(note ? |
|
|
|
? view.editNotePage(md5('edit/' + id), note) |
|
|
|
view.editNotePage(md5('edit/' + id), note) : |
|
|
|
: notFound(res))); |
|
|
|
notFound(res))); |
|
|
|
}); |
|
|
|
}); |
|
|
|
|
|
|
|
|
|
|
|
app.get(/\/([a-z0-9]+)\/export/, (req, res) => { |
|
|
|
app.get(/\/([a-z0-9]+)\/export/, (req, res) => { |
|
|
|
var id = req.params["0"]; |
|
|
|
var id = req.params['0']; |
|
|
|
log(req.ip, "calls /export on", id); |
|
|
|
log(req.ip, 'calls /export on', id); |
|
|
|
res.set({ 'Content-Type': 'text/plain', 'Charset': 'utf-8' }); |
|
|
|
res.set({ 'Content-Type': 'text/plain', 'Charset': 'utf-8' }); |
|
|
|
storage.getNote(id).then(note => note |
|
|
|
storage.getNote(id).then(note => note ? |
|
|
|
? res.send(note.text) |
|
|
|
res.send(note.text) : |
|
|
|
: notFound(res)); |
|
|
|
notFound(res)); |
|
|
|
}); |
|
|
|
}); |
|
|
|
|
|
|
|
|
|
|
|
app.get(/\/([a-z0-9]+)\/stats/, (req, res) => { |
|
|
|
app.get(/\/([a-z0-9]+)\/stats/, (req, res) => { |
|
|
|
var id = req.params["0"]; |
|
|
|
var id = req.params['0']; |
|
|
|
log(req.ip, "calls /stats on", id); |
|
|
|
log(req.ip, 'calls /stats on', id); |
|
|
|
var promise = id in MODELS |
|
|
|
var promise = id in MODELS ? |
|
|
|
? new Promise(resolve => resolve(MODELS[id])) |
|
|
|
new Promise(resolve => resolve(MODELS[id])) : |
|
|
|
: storage.getNote(id); |
|
|
|
storage.getNote(id); |
|
|
|
promise.then(note => note |
|
|
|
promise.then(note => note ? |
|
|
|
? res.send(view.renderStats(note)) |
|
|
|
res.send(view.renderStats(note)) : |
|
|
|
: notFound(res)); |
|
|
|
notFound(res)); |
|
|
|
}); |
|
|
|
}); |
|
|
|
|
|
|
|
|
|
|
|
app.get(/\/([a-z0-9]+)/, (req, res) => { |
|
|
|
app.get(/\/([a-z0-9]+)/, (req, res) => { |
|
|
|
var id = req.params["0"]; |
|
|
|
var id = req.params['0']; |
|
|
|
log(req.ip, "open note", id, "from", req.get("Referer")); |
|
|
|
log(req.ip, 'open note', id, 'from', req.get('Referer')); |
|
|
|
if (CACHE.has(id)) { |
|
|
|
if (CACHE.has(id)) { |
|
|
|
log(id, "is cached!"); |
|
|
|
log(id, 'is cached!'); |
|
|
|
var note = MODELS[id]; |
|
|
|
var obj = MODELS[id]; |
|
|
|
if (!note) return notFound(res); |
|
|
|
if (!obj) return notFound(res); |
|
|
|
note.views++; |
|
|
|
obj.views++; |
|
|
|
res.send(CACHE.get(id)); |
|
|
|
res.send(CACHE.get(id)); |
|
|
|
} else storage.getNote(id).then(note => { |
|
|
|
} else storage.getNote(id).then(note => { |
|
|
|
log(id, "is not cached, resolving..."); |
|
|
|
log(id, 'is not cached, resolving...'); |
|
|
|
if (!note) { |
|
|
|
if (!note) { |
|
|
|
CACHE.set(id, null); |
|
|
|
CACHE.set(id, null); |
|
|
|
return notFound(res); |
|
|
|
return notFound(res); |
|
|
|
@ -151,31 +151,31 @@ app.get(/\/([a-z0-9]+)/, (req, res) => { |
|
|
|
}); |
|
|
|
}); |
|
|
|
|
|
|
|
|
|
|
|
var sendResponse = (res, code, message, details) => { |
|
|
|
var sendResponse = (res, code, message, details) => { |
|
|
|
log("sending response", code, message); |
|
|
|
log('sending response', code, message); |
|
|
|
res.status(code).send(view.renderPage(null, message, |
|
|
|
res.status(code).send(view.renderPage(null, message, |
|
|
|
`<h1>${message}</h1><br/>` + |
|
|
|
`<h1>${message}</h1><br/>` + |
|
|
|
`<center>${details || "¯\\_(ツ)_/¯"}</center>`, "")); |
|
|
|
`<center>${details || '¯\\_(ツ)_/¯'}</center>`, '')); |
|
|
|
} |
|
|
|
}; |
|
|
|
|
|
|
|
|
|
|
|
var notFound = res => sendResponse(res, 404, "Not found"); |
|
|
|
var notFound = res => sendResponse(res, 404, 'Not found'); |
|
|
|
|
|
|
|
|
|
|
|
var server = app.listen(process.env.PORT || 3000, |
|
|
|
var server = app.listen(process.env.PORT || 3000, |
|
|
|
() => log('NoteHub server listening on port', server.address().port)); |
|
|
|
() => log('NoteHub server listening on port', server.address().port)); |
|
|
|
|
|
|
|
|
|
|
|
setInterval(() => { |
|
|
|
setInterval(() => { |
|
|
|
var keys = Object.keys(MODELS); |
|
|
|
var keys = Object.keys(MODELS); |
|
|
|
log("saving stats for", keys.length, "models..."); |
|
|
|
log('saving stats for', keys.length, 'models...'); |
|
|
|
keys.forEach(id => MODELS[id].save()) |
|
|
|
keys.forEach(id => MODELS[id].save()); |
|
|
|
}, 5 * 60 * 1000); |
|
|
|
}, 5 * 60 * 1000); |
|
|
|
|
|
|
|
|
|
|
|
var updateBlackList = () => { |
|
|
|
var updateBlackList = () => { |
|
|
|
var ids = fs.readFileSync(process.env.BLACK_LIST || "/dev/null", "utf-8").split(/\n+/).filter(Boolean); |
|
|
|
var ids = fs.readFileSync(process.env.BLACK_LIST || '/dev/null', 'utf-8').split(/\n+/).filter(Boolean); |
|
|
|
ids.forEach(id => CACHE.del(id)) |
|
|
|
ids.forEach(id => CACHE.del(id)); |
|
|
|
blackList = new Set(ids); |
|
|
|
blackList = new Set(ids); |
|
|
|
log("black list updated, entries:", blackList.size); |
|
|
|
log('black list updated, entries:', blackList.size); |
|
|
|
}; |
|
|
|
}; |
|
|
|
|
|
|
|
|
|
|
|
setInterval(updateBlackList, 60 * 60 * 1000) |
|
|
|
setInterval(updateBlackList, 60 * 60 * 1000); |
|
|
|
|
|
|
|
|
|
|
|
updateBlackList(); |
|
|
|
updateBlackList(); |
|
|
|
|
|
|
|
|
|
|
|
|
Christian Müller
9 years ago