From c4bd1d6553ad70dd66cd75dd8b5652b196577d51 Mon Sep 17 00:00:00 2001 From: Flummi Date: Mon, 4 Jun 2018 13:20:44 +0000 Subject: [PATCH] api: add src --- src/websrv.js | 720 +++++++++++++++++++++++++------------------------- 1 file changed, 360 insertions(+), 360 deletions(-) diff --git a/src/websrv.js b/src/websrv.js index 4dfefca..08282e4 100644 --- a/src/websrv.js +++ b/src/websrv.js @@ -1,360 +1,360 @@ -var fs = require('fs-extra'); -var http = require('http'); -var path = require('path'); -var swig = require('swig'); -var urlm = require('url'); -var exec = require('child_process').exec; - -var templates = {}; -var lib; - -module.exports = Websrv; -function Websrv(tlib) { - this.lib = lib = tlib; - Websrv.prototype.getTpls(); - http.createServer((req, res) => { - if(lib.cfg.websrv.wlip.hasOwnProperty(req.connection.remoteAddress)) { - var filePath = '.' + req.url.split('?')[0]; - var url = req.url.split("/")[1]; - if(filePath == './') - filePath = './index.html'; - if(req.method == 'POST') { - if(filePath == './git' && req.headers['x-gitlab-token'] == lib.cfg.websrv.gittoken) { - var body = ''; - req.on('data', (data) => { - body += data; - if(body.length > 1e6) - req.connection.destroy(); - }); - req.on('end', () => { - body = JSON.parse(body); - var eventname = body.event_name; - var autor = body.user_name; - var branch = body.ref.split('/')[2]; - if(branch === "master") { - var commit = ""; - try { - commit = body.commits[body.commits.length-1].message.replace('\n','').trim(); - } - catch(ex) { - commit = body.commits[body.commits.length-2].message.replace('\n','').trim(); - } - lib.bot.send( lib.cfg.main.debugchannel, eventname + ' from ' + autor + ' ('+commit+') in branch '+branch, 'n0xy' ); - if( lib.cfg.main.debugchannel === '#f0ck' ) { - exec('cd ../ & git pull', (error, stdout) => { - if(error === null) { - if(!lib.debug) - lib.bot.send(lib.cfg.main.debugchannel, 'git pull suxxessfully.', 'n0xy'); - else - lib.log(stdout); - } - }); - } - } - }); - res.writeHead(200, { 'Content-Type': 'text/html' }); - res.end('muh', 'utf-8'); - } - else - res.writeHead(403); - } - else { - var extname = String(path.extname(filePath)).toLowerCase(); - var contentType = 'text/html'; - var mimeTypes = { - '.html': 'text/html', - '.js': 'text/javascript', - '.css': 'text/css', - '.png': 'image/png', - '.jpg': 'image/jpg', - '.gif': 'image/gif', - '.mp3': 'audio/mpeg', - '.flac': 'audio/x-flac', - '.mp4': 'video/mp4', - '.webm': 'video/webm', - '.ogg': 'audio/ogg', - '.mov': 'video/quicktime', - '.woff': 'application/font-woff', - '.woff2': 'font/woff2', - '.eot': 'application/vnd.ms-fontobject', - '.svg': 'image/svg+xml', - '.ttf': 'application/octet-stream' - }; // Todo: hat hier nichts zu suchen! - if(filePath == "./index.html") { // mainpage - var tpl = swig.compile(templates.index); - var data = { - items: [], - last: 10000 - }; - lib.sql.query("select `id`,`mime` from `f0ck`.`items` order by `id` desc limit 100", (err, rows, fields) => { - rows.forEach((e,i,a) => { - data.items.push({ "id": e.id, "mime": e.mime }); - data.last = e.id; - }); - res.writeHead(200, { 'Content-Type': 'text/html' }); - res.end(tpl(data), 'utf-8'); - }); - } - else if(Number.isInteger(parseInt(url))) { // itempage - var query = "select * from `f0ck`.`items` where `id` = ? limit 1; " // get item - + "select `id` from `f0ck`.`items` where `id` = (select min(`id`) from `f0ck`.`items` where `id` > ?); " // get previous item - + "select `id` from `f0ck`.`items` where `id` = (select max(`id`) from `f0ck`.`items` where `id` < ?)"; // get next item - lib.sql.query(query, [url, url, url], (err, rows, fields) => { - var tpl = swig.compile(templates.item); - var data = { - id: '', - username: '', - item: '', - src: '', - dest: '', - mime: '', - size: '', - userchannel: '', - usernetwork: '', - thumb: null, - thumbnail: null, - next: null, - prev: null - }; - if(rows[0].length) { - var e = rows[0][0]; - switch(e.mime) { - case "image/png": - case "image/jpeg": - case "image/gif": - data.item = 'image'; - break; - case "video/webm": - case "video/mp4": - case "video/quicktime": - data.item = 'video'; - break; - case "audio/mpeg": - case "audio/ogg": - case "audio/flac": - case "audio/x-flac": - data.item = 'audio'; - break; - } - data.id = e.id; - data.username = e.username; - data.srcurl = e.src; - data.src = urlm.parse(e.src).hostname; - data.thumb = (e.thumb != '' && e.thumb.match(/sndcdn\.com/i))?e.thumb:null; - data.thumbnail = `${lib.cfg.main.url}/t/${e.id}.png`; - data.dest = e.dest; - data.mime = e.mime; - data.size = lib.formatSize(e.size); - data.userchannel = e.userchannel; - data.usernetwork = e.usernetwork; - data.timestamp = new Date(e.stamp * 1000).toISOString(); - if(rows[1].length) - data.next = rows[1][0].id; - if(rows[2].length) - data.prev = rows[2][0].id; - } - res.writeHead(200, { 'Content-Type': 'text/html' }); - res.end(tpl(data), 'utf-8'); - }); - } - else if(filePath == "./random") { - lib.sql.query("select `id` from `f0ck`.`items` order by rand() limit 1", (err, rows, fields) => { - res.writeHead(301, { - 'Cache-Control': 'no-cache, public', - 'Location': '/' + rows[0].id - }); - res.end(); - }); - } - else if(filePath == "./how") { - var tpl = swig.compile(templates.how); - res.writeHead(200, { 'Content-Type': 'text/html' }); - res.end(tpl(), 'utf-8'); - } - else if(filePath == "./contact") { - var tpl = swig.compile(templates.contact); - res.writeHead(200, { 'Content-Type': 'text/html' }); - res.end(tpl(), 'utf-8'); - } - else if(filePath == "./scripts") { - var tpl = swig.compile(templates.scripts); - res.writeHead(200, { 'Content-Type': 'text/html' }); - res.end(tpl(), 'utf-8'); - } - else if(filePath.match(/^\.\/(b|s|t)\/.*/)) { // file - contentType = mimeTypes[extname]; - if(( contentType === "video/webm" - || contentType === "video/mp4" - || contentType === "video/quicktime" - || contentType === "audio/mpeg" - || contentType === "audio/flac" - || contentType === "audio/x-flac" - || contentType === "audio/ogg") && req.headers['range']) { - fs.readFile(filePath, "binary", function(err, file) { - if(typeof req.headers.range !== 'undefined') { - var range = req.headers.range; - var parts = range.replace(/bytes=/, "").split("-"); - var partialstart = parts[0]; - var partialend = parts[1]; - var total = file.length; - var start = parseInt(partialstart, 10); - var end = partialend ? parseInt(partialend, 10) : total-1; - res.writeHead(206, { - "Content-Range": "bytes " + start + "-" + end + "/" + (total), - "Accept-Ranges": "bytes", - "Content-Length": (end-start)+1, - "Transfer-Encoding": "chunked", - "Connection": "close" - }); - res.write(file.slice(start, end)+'0', "binary"); - } - else { - res.writeHead(200); - res.write(file, "binary"); - } - res.end(); - }); - } - else { - fs.readFile(filePath, (error, content) => { - if(error) { - if(error.code == 'ENOENT') { - res.writeHead(404); - res.end('404 - f0ck you', 'utf-8'); - } - else { - res.writeHead(500); - res.end('Sorry, check with the site admin for error: '+error.code+' ..\n'); - res.end(); - } - } - else { - //res.writeHead(200, { 'Content-Type': contentType, 'Content-Length': content.length, 'Cache-Control': 'max-age=2592000, public' }); - res.writeHead(200); - res.end(content, 'utf-8'); - } - }); - } - } - else if(filePath.match(/^\.\/api/i)) { // api - var url = filePath.split('/'); - if(url[2] === undefined) { // Mainpage - /*var query = "select * from `f0ck`.`items`"; - lib.sql.query(query, (err, rows, fields) => { - var items = []; - rows.forEach((e,i,a) => { - items.push({ - 'id': e.id, - 'mime': e.mime - }); - }); - res.writeHead(200, { 'Content-Type': 'text/html' }); - res.end(JSON.stringify(items), 'utf-8'); - });*/ - res.writeHead(200, { 'Content-Type': 'text/html' }); - res.end('nope', 'utf-8'); - } - else if(url[2] == "p" && Number.isInteger(parseInt(url[3]))) { // pagination - var eps = 50; - var id = url[3]; - lib.sql.query("select * from `f0ck`.`items` where `id` < ? order by `id` desc limit ?", [id, eps], (err, rows, fields) => { - var items = { - "items": [], - "last": id - }; - rows.forEach((e,i,a) => { - items.items.push({ - 'id': e.id, - 'mime': e.mime - }); - items.last = e.id; - }); - res.writeHead(200, { 'Content-Type': 'text/html' }); - res.end(JSON.stringify(items), 'utf-8'); - }); - } - else if(Number.isInteger(parseInt(url[2]))) { // Item - var query = "select * from `f0ck`.`items` where `id` = ? limit 1; " // get item - + "select `id` from `f0ck`.`items` where `id` = (select min(`id`) from `f0ck`.`items` where `id` > ?); " // get previous item - + "select `id` from `f0ck`.`items` where `id` = (select max(`id`) from `f0ck`.`items` where `id` < ?)"; // get next item - lib.sql.query(query, [url[2], url[2], url[2]], (err, rows, fields) => { - var data; - if(rows[0].length) { - var e = rows[0][0]; - data = { - id: e.id, - username: e.username, - src: e.src, - dest: e.dest, - mime: e.mime, - size: e.size, - userchannel: e.userchannel, - usernetwork: e.usernetwork, - thumb: lib.cfg.main.url + "/t/" + e.id + ".png", - next: null, - prev: null - }; - if(rows[1].length) - data.next = rows[1][0].id; - if(rows[2].length) - data.prev = rows[2][0].id; - } - else - data = { error: 'nope' }; - res.writeHead(200, { 'Content-Type': 'text/html' }); - res.end(JSON.stringify(data), 'utf-8'); - }); - } - else if(url[2] === "random") { - res.writeHead(200, { 'Content-Type': 'text/html' }); - let mimes = []; - let query = ""; - switch(url[3]) { - case "image": - mimes = ["image/png", "image/gif", "image/jpeg"]; - query = "where "+mimes.map(mime => "`mime` = '"+mime+"'").join(" or ")+" order by rand() limit 1"; - break; - case "video": - mimes = ["video/webm", "video/mp4", "video/quicktime"]; - query = "where "+mimes.map(mime => "`mime` = '"+mime+"'").join(" or ")+" order by rand() limit 1"; - break; - case "audio": - mimes = ["audio/mpeg", "audio/flac", "audio/x-flac", "audio/ogg"]; - query = "where "+mimes.map(mime => "`mime` = '"+mime+"'").join(" or ")+" order by rand() limit 1"; - break; - default: - query = "order by rand() limit 1"; - break; - } - if(query.length === 0) - return res.end('type not found', 'utf-8'); - - lib.sql.query("select `id`, `mime`, `size`, `username`, `userchannel`, `usernetwork`, `stamp`, `dest` from `f0ck`.`items` " + query, (err, rows, fields) => { - if(err || rows.length === 0) - return res.end('no results', 'utf-8'); - res.end(JSON.stringify( rows[0] ), 'utf-8'); - }); - } - } - else { // errorpage - res.writeHead(404); - res.end('404 - f0ck you', 'utf-8'); - } - } - } - else { - res.writeHead(403); - res.end('403 - forbidden'); - console.log(req.connection.remoteAddress); - } - }).listen(lib.cfg.websrv.port); -} - -Websrv.prototype.getTpls = () => { - templates = { - "index": fs.readFileSync("./s/index.tpl.html", "utf-8"), - "item": fs.readFileSync("./s/item.tpl.html", "utf-8"), - "how": fs.readFileSync("./s/how.tpl.html", "utf-8"), - "contact": fs.readFileSync("./s/contact.tpl.html", "utf-8") - }; -}; +var fs = require('fs-extra'); +var http = require('http'); +var path = require('path'); +var swig = require('swig'); +var urlm = require('url'); +var exec = require('child_process').exec; + +var templates = {}; +var lib; + +module.exports = Websrv; +function Websrv(tlib) { + this.lib = lib = tlib; + Websrv.prototype.getTpls(); + http.createServer((req, res) => { + if(lib.cfg.websrv.wlip.hasOwnProperty(req.connection.remoteAddress)) { + var filePath = '.' + req.url.split('?')[0]; + var url = req.url.split("/")[1]; + if(filePath == './') + filePath = './index.html'; + if(req.method == 'POST') { + if(filePath == './git' && req.headers['x-gitlab-token'] == lib.cfg.websrv.gittoken) { + var body = ''; + req.on('data', (data) => { + body += data; + if(body.length > 1e6) + req.connection.destroy(); + }); + req.on('end', () => { + body = JSON.parse(body); + var eventname = body.event_name; + var autor = body.user_name; + var branch = body.ref.split('/')[2]; + if(branch === "master") { + var commit = ""; + try { + commit = body.commits[body.commits.length-1].message.replace('\n','').trim(); + } + catch(ex) { + commit = body.commits[body.commits.length-2].message.replace('\n','').trim(); + } + lib.bot.send( lib.cfg.main.debugchannel, eventname + ' from ' + autor + ' ('+commit+') in branch '+branch, 'n0xy' ); + if( lib.cfg.main.debugchannel === '#f0ck' ) { + exec('cd ../ & git pull', (error, stdout) => { + if(error === null) { + if(!lib.debug) + lib.bot.send(lib.cfg.main.debugchannel, 'git pull suxxessfully.', 'n0xy'); + else + lib.log(stdout); + } + }); + } + } + }); + res.writeHead(200, { 'Content-Type': 'text/html' }); + res.end('muh', 'utf-8'); + } + else + res.writeHead(403); + } + else { + var extname = String(path.extname(filePath)).toLowerCase(); + var contentType = 'text/html'; + var mimeTypes = { + '.html': 'text/html', + '.js': 'text/javascript', + '.css': 'text/css', + '.png': 'image/png', + '.jpg': 'image/jpg', + '.gif': 'image/gif', + '.mp3': 'audio/mpeg', + '.flac': 'audio/x-flac', + '.mp4': 'video/mp4', + '.webm': 'video/webm', + '.ogg': 'audio/ogg', + '.mov': 'video/quicktime', + '.woff': 'application/font-woff', + '.woff2': 'font/woff2', + '.eot': 'application/vnd.ms-fontobject', + '.svg': 'image/svg+xml', + '.ttf': 'application/octet-stream' + }; // Todo: hat hier nichts zu suchen! + if(filePath == "./index.html") { // mainpage + var tpl = swig.compile(templates.index); + var data = { + items: [], + last: 10000 + }; + lib.sql.query("select `id`,`mime` from `f0ck`.`items` order by `id` desc limit 100", (err, rows, fields) => { + rows.forEach((e,i,a) => { + data.items.push({ "id": e.id, "mime": e.mime }); + data.last = e.id; + }); + res.writeHead(200, { 'Content-Type': 'text/html' }); + res.end(tpl(data), 'utf-8'); + }); + } + else if(Number.isInteger(parseInt(url))) { // itempage + var query = "select * from `f0ck`.`items` where `id` = ? limit 1; " // get item + + "select `id` from `f0ck`.`items` where `id` = (select min(`id`) from `f0ck`.`items` where `id` > ?); " // get previous item + + "select `id` from `f0ck`.`items` where `id` = (select max(`id`) from `f0ck`.`items` where `id` < ?)"; // get next item + lib.sql.query(query, [url, url, url], (err, rows, fields) => { + var tpl = swig.compile(templates.item); + var data = { + id: '', + username: '', + item: '', + src: '', + dest: '', + mime: '', + size: '', + userchannel: '', + usernetwork: '', + thumb: null, + thumbnail: null, + next: null, + prev: null + }; + if(rows[0].length) { + var e = rows[0][0]; + switch(e.mime) { + case "image/png": + case "image/jpeg": + case "image/gif": + data.item = 'image'; + break; + case "video/webm": + case "video/mp4": + case "video/quicktime": + data.item = 'video'; + break; + case "audio/mpeg": + case "audio/ogg": + case "audio/flac": + case "audio/x-flac": + data.item = 'audio'; + break; + } + data.id = e.id; + data.username = e.username; + data.srcurl = e.src; + data.src = urlm.parse(e.src).hostname; + data.thumb = (e.thumb != '' && e.thumb.match(/sndcdn\.com/i))?e.thumb:null; + data.thumbnail = `${lib.cfg.main.url}/t/${e.id}.png`; + data.dest = e.dest; + data.mime = e.mime; + data.size = lib.formatSize(e.size); + data.userchannel = e.userchannel; + data.usernetwork = e.usernetwork; + data.timestamp = new Date(e.stamp * 1000).toISOString(); + if(rows[1].length) + data.next = rows[1][0].id; + if(rows[2].length) + data.prev = rows[2][0].id; + } + res.writeHead(200, { 'Content-Type': 'text/html' }); + res.end(tpl(data), 'utf-8'); + }); + } + else if(filePath == "./random") { + lib.sql.query("select `id` from `f0ck`.`items` order by rand() limit 1", (err, rows, fields) => { + res.writeHead(301, { + 'Cache-Control': 'no-cache, public', + 'Location': '/' + rows[0].id + }); + res.end(); + }); + } + else if(filePath == "./how") { + var tpl = swig.compile(templates.how); + res.writeHead(200, { 'Content-Type': 'text/html' }); + res.end(tpl(), 'utf-8'); + } + else if(filePath == "./contact") { + var tpl = swig.compile(templates.contact); + res.writeHead(200, { 'Content-Type': 'text/html' }); + res.end(tpl(), 'utf-8'); + } + else if(filePath == "./scripts") { + var tpl = swig.compile(templates.scripts); + res.writeHead(200, { 'Content-Type': 'text/html' }); + res.end(tpl(), 'utf-8'); + } + else if(filePath.match(/^\.\/(b|s|t)\/.*/)) { // file + contentType = mimeTypes[extname]; + if(( contentType === "video/webm" + || contentType === "video/mp4" + || contentType === "video/quicktime" + || contentType === "audio/mpeg" + || contentType === "audio/flac" + || contentType === "audio/x-flac" + || contentType === "audio/ogg") && req.headers['range']) { + fs.readFile(filePath, "binary", function(err, file) { + if(typeof req.headers.range !== 'undefined') { + var range = req.headers.range; + var parts = range.replace(/bytes=/, "").split("-"); + var partialstart = parts[0]; + var partialend = parts[1]; + var total = file.length; + var start = parseInt(partialstart, 10); + var end = partialend ? parseInt(partialend, 10) : total-1; + res.writeHead(206, { + "Content-Range": "bytes " + start + "-" + end + "/" + (total), + "Accept-Ranges": "bytes", + "Content-Length": (end-start)+1, + "Transfer-Encoding": "chunked", + "Connection": "close" + }); + res.write(file.slice(start, end)+'0', "binary"); + } + else { + res.writeHead(200); + res.write(file, "binary"); + } + res.end(); + }); + } + else { + fs.readFile(filePath, (error, content) => { + if(error) { + if(error.code == 'ENOENT') { + res.writeHead(404); + res.end('404 - f0ck you', 'utf-8'); + } + else { + res.writeHead(500); + res.end('Sorry, check with the site admin for error: '+error.code+' ..\n'); + res.end(); + } + } + else { + //res.writeHead(200, { 'Content-Type': contentType, 'Content-Length': content.length, 'Cache-Control': 'max-age=2592000, public' }); + res.writeHead(200); + res.end(content, 'utf-8'); + } + }); + } + } + else if(filePath.match(/^\.\/api/i)) { // api + var url = filePath.split('/'); + if(url[2] === undefined) { // Mainpage + /*var query = "select * from `f0ck`.`items`"; + lib.sql.query(query, (err, rows, fields) => { + var items = []; + rows.forEach((e,i,a) => { + items.push({ + 'id': e.id, + 'mime': e.mime + }); + }); + res.writeHead(200, { 'Content-Type': 'text/html' }); + res.end(JSON.stringify(items), 'utf-8'); + });*/ + res.writeHead(200, { 'Content-Type': 'text/html' }); + res.end('nope', 'utf-8'); + } + else if(url[2] == "p" && Number.isInteger(parseInt(url[3]))) { // pagination + var eps = 50; + var id = url[3]; + lib.sql.query("select * from `f0ck`.`items` where `id` < ? order by `id` desc limit ?", [id, eps], (err, rows, fields) => { + var items = { + "items": [], + "last": id + }; + rows.forEach((e,i,a) => { + items.items.push({ + 'id': e.id, + 'mime': e.mime + }); + items.last = e.id; + }); + res.writeHead(200, { 'Content-Type': 'text/html' }); + res.end(JSON.stringify(items), 'utf-8'); + }); + } + else if(Number.isInteger(parseInt(url[2]))) { // Item + var query = "select * from `f0ck`.`items` where `id` = ? limit 1; " // get item + + "select `id` from `f0ck`.`items` where `id` = (select min(`id`) from `f0ck`.`items` where `id` > ?); " // get previous item + + "select `id` from `f0ck`.`items` where `id` = (select max(`id`) from `f0ck`.`items` where `id` < ?)"; // get next item + lib.sql.query(query, [url[2], url[2], url[2]], (err, rows, fields) => { + var data; + if(rows[0].length) { + var e = rows[0][0]; + data = { + id: e.id, + username: e.username, + src: e.src, + dest: e.dest, + mime: e.mime, + size: e.size, + userchannel: e.userchannel, + usernetwork: e.usernetwork, + thumb: lib.cfg.main.url + "/t/" + e.id + ".png", + next: null, + prev: null + }; + if(rows[1].length) + data.next = rows[1][0].id; + if(rows[2].length) + data.prev = rows[2][0].id; + } + else + data = { error: 'nope' }; + res.writeHead(200, { 'Content-Type': 'text/html' }); + res.end(JSON.stringify(data), 'utf-8'); + }); + } + else if(url[2] === "random") { + res.writeHead(200, { 'Content-Type': 'text/html' }); + let mimes = []; + let query = ""; + switch(url[3]) { + case "image": + mimes = ["image/png", "image/gif", "image/jpeg"]; + query = "where "+mimes.map(mime => "`mime` = '"+mime+"'").join(" or ")+" order by rand() limit 1"; + break; + case "video": + mimes = ["video/webm", "video/mp4", "video/quicktime"]; + query = "where "+mimes.map(mime => "`mime` = '"+mime+"'").join(" or ")+" order by rand() limit 1"; + break; + case "audio": + mimes = ["audio/mpeg", "audio/flac", "audio/x-flac", "audio/ogg"]; + query = "where "+mimes.map(mime => "`mime` = '"+mime+"'").join(" or ")+" order by rand() limit 1"; + break; + default: + query = "order by rand() limit 1"; + break; + } + if(query.length === 0) + return res.end('type not found', 'utf-8'); + + lib.sql.query("select `id`, `mime`, `size`, `username`, `userchannel`, `usernetwork`, `stamp`, `dest`, `src` from `f0ck`.`items` " + query, (err, rows, fields) => { + if(err || rows.length === 0) + return res.end('no results', 'utf-8'); + res.end(JSON.stringify( rows[0] ), 'utf-8'); + }); + } + } + else { // errorpage + res.writeHead(404); + res.end('404 - f0ck you', 'utf-8'); + } + } + } + else { + res.writeHead(403); + res.end('403 - forbidden'); + console.log(req.connection.remoteAddress); + } + }).listen(lib.cfg.websrv.port); +} + +Websrv.prototype.getTpls = () => { + templates = { + "index": fs.readFileSync("./s/index.tpl.html", "utf-8"), + "item": fs.readFileSync("./s/item.tpl.html", "utf-8"), + "how": fs.readFileSync("./s/how.tpl.html", "utf-8"), + "contact": fs.readFileSync("./s/contact.tpl.html", "utf-8") + }; +};