Merge branch 'master' into 'f0ckdev'

Master



See merge request !5
This commit is contained in:
Flummi 2016-10-20 22:10:27 +00:00
commit d5bf271ee1

View File

@ -1,322 +1,323 @@
var fs = require('fs-extra'); var fs = require('fs-extra');
var http = require('http'); var http = require('http');
var path = require('path'); var path = require('path');
var swig = require('swig'); var swig = require('swig');
var urlm = require('url'); var urlm = require('url');
var cfg = require('../cfg/websrv.json'); var cfg = require('../cfg/websrv.json');
var exec = require('child_process').exec; var exec = require('child_process').exec;
var templates = {}; var templates = {};
var lib; var lib;
module.exports = Websrv; module.exports = Websrv;
function Websrv(tlib) { function Websrv(tlib) {
this.lib = lib = tlib; this.lib = lib = tlib;
Websrv.prototype.getTpls(); Websrv.prototype.getTpls();
http.createServer((req, res) => { http.createServer((req, res) => {
if(cfg.wlip.hasOwnProperty(req.connection.remoteAddress)) { if(cfg.wlip.hasOwnProperty(req.connection.remoteAddress)) {
var filePath = '.' + req.url; var filePath = '.' + req.url;
var url = req.url.split("/")[1]; var url = req.url.split("/")[1];
if(filePath == './') if(filePath == './')
filePath = './index.html'; filePath = './index.html';
if(req.method == 'POST') { if(req.method == 'POST') {
if(filePath == './git' && req.headers['x-gitlab-token'] == cfg.gittoken) { if(filePath == './git' && req.headers['x-gitlab-token'] == cfg.gittoken) {
var body = ''; var body = '';
req.on('data', (data) => { req.on('data', (data) => {
body += data; body += data;
if(body.length > 1e6) if(body.length > 1e6)
req.connection.destroy(); req.connection.destroy();
}); });
req.on('end', () => { req.on('end', () => {
body = JSON.parse(body); body = JSON.parse(body);
var eventname = body.event_name; var eventname = body.event_name;
var autor = body.user_name; var autor = body.user_name;
var branch = body.ref.split('/')[2];
var commit = "";
try { if(branch === "master") {
commit = body.commits[body.commits.length-1].message.replace('\n','').trim(); var commit = "";
} try {
catch(ex) { commit = body.commits[body.commits.length-1].message.replace('\n','').trim();
commit = body.commits[body.commits.length-2].message.replace('\n','').trim(); }
} catch(ex) {
lib.bot.send( lib.cfg.debugchannel, eventname + ' from ' + autor + ' ('+commit+')', 'n0xy' ); commit = body.commits[body.commits.length-2].message.replace('\n','').trim();
}
if( lib.cfg.debugchannel === '#f0ck' ) { lib.bot.send( lib.cfg.debugchannel, eventname + ' from ' + autor + ' ('+commit+') in branch '+branch, 'n0xy' );
exec('cd ../ & git pull', (error, stdout) => { if( lib.cfg.debugchannel === '#f0ck' ) {
if(error === null) exec('cd ../ & git pull', (error, stdout) => {
lib.bot.send( lib.cfg.debugchannel, stdout, 'n0xy' ); if(error === null)
}); lib.bot.send( lib.cfg.debugchannel, stdout, 'n0xy' );
} });
}); }
res.writeHead(200, { 'Content-Type': 'text/html' }); }
res.end('muh', 'utf-8'); });
} res.writeHead(200, { 'Content-Type': 'text/html' });
else { res.end('muh', 'utf-8');
res.writeHead(403); }
} else {
} res.writeHead(403);
else { }
var extname = String(path.extname(filePath)).toLowerCase(); }
var contentType = 'text/html'; else {
var mimeTypes = { var extname = String(path.extname(filePath)).toLowerCase();
'.html': 'text/html', var contentType = 'text/html';
'.js': 'text/javascript', var mimeTypes = {
'.css': 'text/css', '.html': 'text/html',
'.png': 'image/png', '.js': 'text/javascript',
'.jpg': 'image/jpg', '.css': 'text/css',
'.gif': 'image/gif', '.png': 'image/png',
'.mp3': 'audio/mpeg', '.jpg': 'image/jpg',
'.mp4': 'video/mp4', '.gif': 'image/gif',
'.webm': 'video/webm', '.mp3': 'audio/mpeg',
'.css': 'text/css', '.mp4': 'video/mp4',
'.ogg': 'audio/ogg' '.webm': 'video/webm',
}; '.ogg': 'audio/ogg'
if(filePath == "./index.html") { // mainpage };
var tpl = swig.compile(templates.index); if(filePath == "./index.html") { // mainpage
var data = { var tpl = swig.compile(templates.index);
items: [], var data = {
last: 10000 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) => { lib.sql.query("select `id`,`mime` from `f0ck`.`items` order by `id` desc limit 100", (err, rows, fields) => {
data.items.push({ "id": e.id, "mime": e.mime }); rows.forEach((e,i,a) => {
data.last = e.id; 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'); 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 else if(Number.isInteger(parseInt(url))) { // itempage
+ "select `id` from `f0ck`.`items` where `id` = (select min(`id`) from `f0ck`.`items` where `id` > ?); " // get previous item var query = "select * from `f0ck`.`items` where `id` = ? limit 1; " // get item
+ "select `id` from `f0ck`.`items` where `id` = (select max(`id`) from `f0ck`.`items` where `id` < ?)"; // get next item + "select `id` from `f0ck`.`items` where `id` = (select min(`id`) from `f0ck`.`items` where `id` > ?); " // get previous item
lib.sql.query(query, [url, url, url], (err, rows, fields) => { + "select `id` from `f0ck`.`items` where `id` = (select max(`id`) from `f0ck`.`items` where `id` < ?)"; // get next item
var tpl = swig.compile(templates.item); lib.sql.query(query, [url, url, url], (err, rows, fields) => {
var data = { var tpl = swig.compile(templates.item);
id: '', var data = {
username: '', id: '',
item: '', username: '',
src: '', item: '',
dest: '', src: '',
mime: '', dest: '',
size: '', mime: '',
userchannel: '', size: '',
usernetwork: '', userchannel: '',
thumb: null, usernetwork: '',
next: null, thumb: null,
prev: null next: null,
}; prev: null
if(rows[0].length) { };
var e = rows[0][0]; if(rows[0].length) {
switch(e.mime) { var e = rows[0][0];
case "image/png": switch(e.mime) {
case "image/jpeg": case "image/png":
case "image/gif": case "image/jpeg":
data.item = 'image'; case "image/gif":
break; data.item = 'image';
case "video/webm": break;
case "video/mp4": case "video/webm":
data.item = 'video'; case "video/mp4":
break; data.item = 'video';
case "audio/mpeg": break;
case "audio/ogg": case "audio/mpeg":
data.item = 'audio'; case "audio/ogg":
break; data.item = 'audio';
} break;
data.id = e.id; }
data.username = e.username; data.id = e.id;
data.username = e.username;
data.srcurl = e.src;
data.src = urlm.parse(e.src).hostname; data.srcurl = e.src;
data.thumb = (e.thumb != '' && e.thumb.match(/sndcdn\.com/i))?e.thumb:null; data.src = urlm.parse(e.src).hostname;
data.thumb = (e.thumb != '' && e.thumb.match(/sndcdn\.com/i))?e.thumb:null;
data.dest = e.dest;
data.mime = e.mime; data.dest = e.dest;
data.size = lib.formatSize(e.size); data.mime = e.mime;
data.userchannel = e.userchannel; data.size = lib.formatSize(e.size);
data.usernetwork = e.usernetwork; data.userchannel = e.userchannel;
if(rows[1].length) data.usernetwork = e.usernetwork;
data.next = rows[1][0].id; if(rows[1].length)
if(rows[2].length) data.next = rows[1][0].id;
data.prev = rows[2][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'); 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) => { else if(filePath == "./random") {
res.writeHead(301, { lib.sql.query("select `id` from `f0ck`.`items` order by rand() limit 1", (err, rows, fields) => {
'Cache-Control': 'no-cache, public', res.writeHead(301, {
'Location': '/' + rows[0].id 'Cache-Control': 'no-cache, public',
}); 'Location': '/' + rows[0].id
res.end(); });
}); res.end();
} });
else if(filePath == "./how") { }
var tpl = swig.compile(templates.how); else if(filePath == "./how") {
res.writeHead(200, { 'Content-Type': 'text/html' }); var tpl = swig.compile(templates.how);
res.end(tpl(), 'utf-8'); res.writeHead(200, { 'Content-Type': 'text/html' });
} res.end(tpl(), 'utf-8');
else if(filePath == "./contact") { }
var tpl = swig.compile(templates.contact); else if(filePath == "./contact") {
res.writeHead(200, { 'Content-Type': 'text/html' }); var tpl = swig.compile(templates.contact);
res.end(tpl(), 'utf-8'); res.writeHead(200, { 'Content-Type': 'text/html' });
} res.end(tpl(), 'utf-8');
else if(filePath == "./scripts") { }
var tpl = swig.compile(templates.scripts); else if(filePath == "./scripts") {
res.writeHead(200, { 'Content-Type': 'text/html' }); var tpl = swig.compile(templates.scripts);
res.end(tpl(), 'utf-8'); res.writeHead(200, { 'Content-Type': 'text/html' });
} res.end(tpl(), 'utf-8');
else if(filePath.match(/^\.\/(b|s|t)\/.*/)) { // file }
contentType = mimeTypes[extname]; else if(filePath.match(/^\.\/(b|s|t)\/.*/)) { // file
switch(contentType) { contentType = mimeTypes[extname];
case "video/webm": switch(contentType) {
case "video/mp4": case "video/webm":
case "audio/mpeg": case "video/mp4":
case "audio/ogg": case "audio/mpeg":
var start = 0; case "audio/ogg":
var end = 0; var start = 0;
var range = req.headers['range']; var end = 0;
var stat = fs.statSync(filePath); var range = req.headers['range'];
if(range != null) { var stat = fs.statSync(filePath);
start = parseInt(range.slice(range.indexOf('bytes=')+6, range.indexOf('-'))); if(range != null) {
end = parseInt(range.slice(range.indexOf('-')+1, range.length)); start = parseInt(range.slice(range.indexOf('bytes=')+6, range.indexOf('-')));
} end = parseInt(range.slice(range.indexOf('-')+1, range.length));
if(isNaN(end) || end == 0) end = stat.size-1; }
if(start > end) return; if(isNaN(end) || end == 0) end = stat.size-1;
res.writeHead(206, { if(start > end) return;
'Connection':'close', res.writeHead(206, {
'Content-Type':contentType, 'Connection':'close',
'Content-Length':end - start, 'Content-Type':contentType,
'Content-Range':'bytes '+start+'-'+end+'/'+stat.size, 'Content-Length':end - start,
'Transfer-Encoding':'chunked' 'Content-Range':'bytes '+start+'-'+end+'/'+stat.size,
}); 'Transfer-Encoding':'chunked'
var stream = fs.createReadStream(filePath, { flags: 'r', start: start, end: end}); });
stream.pipe(res); var stream = fs.createReadStream(filePath, { flags: 'r', start: start, end: end});
break; stream.pipe(res);
default: break;
fs.readFile(filePath, (error, content) => { default:
if(error) { fs.readFile(filePath, (error, content) => {
if(error.code == 'ENOENT') { if(error) {
res.writeHead(200, { 'Content-Type': contentType }); if(error.code == 'ENOENT') {
res.end('404 - f0ck you', 'utf-8'); res.writeHead(200, { 'Content-Type': contentType });
} res.end('404 - f0ck you', 'utf-8');
else { }
res.writeHead(500); else {
res.end('Sorry, check with the site admin for error: '+error.code+' ..\n'); res.writeHead(500);
res.end(); 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' }); else {
res.end(content, 'utf-8'); res.writeHead(200, { 'Content-Type': contentType, 'Content-Length': content.length, 'Cache-Control': 'max-age=2592000, public' });
} res.end(content, 'utf-8');
}); }
break; });
} break;
fs.readFile(filePath, (error, content) => { }
if(error) { fs.readFile(filePath, (error, content) => {
if(error.code == 'ENOENT') { if(error) {
res.writeHead(200, { 'Content-Type': contentType }); if(error.code == 'ENOENT') {
res.end('404 - f0ck you', 'utf-8'); res.writeHead(200, { 'Content-Type': contentType });
} res.end('404 - f0ck you', 'utf-8');
else { }
res.writeHead(500); else {
res.end('Sorry, check with the site admin for error: '+error.code+' ..\n'); res.writeHead(500);
res.end(); res.end('Sorry, check with the site admin for error: '+error.code+' ..\n');
} res.end();
} }
}); }
} });
else if(filePath.match(/^\.\/api/i)) { // api }
var url = filePath.split('/'); else if(filePath.match(/^\.\/api/i)) { // api
if(url[2] === undefined) { // Mainpage var url = filePath.split('/');
var query = "select * from `f0ck`.`items`"; if(url[2] === undefined) { // Mainpage
lib.sql.query(query, (err, rows, fields) => { var query = "select * from `f0ck`.`items`";
var items = []; lib.sql.query(query, (err, rows, fields) => {
rows.forEach((e,i,a) => { var items = [];
items.push({ rows.forEach((e,i,a) => {
'id': e.id, items.push({
'mime': e.mime '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(JSON.stringify(items), 'utf-8');
} });
else if(url[2] == "p" && Number.isInteger(parseInt(url[3]))) { // pagination }
var eps = 50; else if(url[2] == "p" && Number.isInteger(parseInt(url[3]))) { // pagination
var id = url[3]; 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 = { lib.sql.query("select * from `f0ck`.`items` where `id` < ? order by `id` desc limit ?", [id, eps], (err, rows, fields) => {
"items": [], var items = {
"last": id "items": [],
}; "last": id
rows.forEach((e,i,a) => { };
items.items.push({ rows.forEach((e,i,a) => {
'id': e.id, items.items.push({
'mime': e.mime 'id': e.id,
}); 'mime': e.mime
items.last = e.id; });
}); items.last = e.id;
res.writeHead(200, { 'Content-Type': 'text/html' }); });
res.end(JSON.stringify(items), 'utf-8'); 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 else if(Number.isInteger(parseInt(url[2]))) { // Item
+ "select `id` from `f0ck`.`items` where `id` = (select min(`id`) from `f0ck`.`items` where `id` > ?); " // get previous item var query = "select * from `f0ck`.`items` where `id` = ? limit 1; " // get item
+ "select `id` from `f0ck`.`items` where `id` = (select max(`id`) from `f0ck`.`items` where `id` < ?)"; // get next item + "select `id` from `f0ck`.`items` where `id` = (select min(`id`) from `f0ck`.`items` where `id` > ?); " // get previous item
lib.sql.query(query, [url[2], url[2], url[2]], (err, rows, fields) => { + "select `id` from `f0ck`.`items` where `id` = (select max(`id`) from `f0ck`.`items` where `id` < ?)"; // get next item
var data; lib.sql.query(query, [url[2], url[2], url[2]], (err, rows, fields) => {
if(rows[0].length) { var data;
var e = rows[0][0]; if(rows[0].length) {
data = { var e = rows[0][0];
id: e.id, data = {
username: e.username, id: e.id,
src: e.src, username: e.username,
dest: e.dest, src: e.src,
mime: e.mime, dest: e.dest,
size: e.size, mime: e.mime,
userchannel: e.userchannel, size: e.size,
usernetwork: e.usernetwork, userchannel: e.userchannel,
next: null, usernetwork: e.usernetwork,
prev: null next: null,
}; prev: null
if(rows[1].length) };
data.next = rows[1][0].id; if(rows[1].length)
if(rows[2].length) data.next = rows[1][0].id;
data.prev = rows[2][0].id; if(rows[2].length)
} data.prev = rows[2][0].id;
else }
data = { error: 'nope' }; else
res.writeHead(200, { 'Content-Type': 'text/html' }); data = { error: 'nope' };
res.end(JSON.stringify(data), 'utf-8'); res.writeHead(200, { 'Content-Type': 'text/html' });
}); res.end(JSON.stringify(data), 'utf-8');
} });
} }
else { // errorpage }
res.writeHead(404); else { // errorpage
res.end('404 - f0ck you', 'utf-8'); res.writeHead(404);
} res.end('404 - f0ck you', 'utf-8');
} }
} }
else { }
res.writeHead(403); else {
res.end('403 - forbidden'); res.writeHead(403);
} res.end('403 - forbidden');
}).listen(cfg.port); }
} }).listen(cfg.port);
}
Websrv.prototype.getTpls = () => {
templates = { Websrv.prototype.getTpls = () => {
"index": fs.readFileSync("./s/index.tpl.html", "utf-8"), templates = {
"item": fs.readFileSync("./s/item.tpl.html", "utf-8"), "index": fs.readFileSync("./s/index.tpl.html", "utf-8"),
"how": fs.readFileSync("./s/how.tpl.html", "utf-8"), "item": fs.readFileSync("./s/item.tpl.html", "utf-8"),
"contact": fs.readFileSync("./s/contact.tpl.html", "utf-8") "how": fs.readFileSync("./s/how.tpl.html", "utf-8"),
}; "contact": fs.readFileSync("./s/contact.tpl.html", "utf-8")
};
}; };