f0ck/f0ckv2
3
4
Fork 1
Code Issues 11 Pull Requests Actions Packages Projects Releases Wiki Activity

init oder so

Browse Source
This commit is contained in:
Flummi
2019-04-23 15:58:25 +00:00
parent 0d39f68990
commit b8b23c8ea8
9 changed files with 39 additions and 562 deletions
Download Patch File Download Diff File Expand all files Collapse all files

53
src/inc/trigger/debug.mjs
View File

@ -1,39 +1,36 @@
import { admins, getLevel } from "../admin";
import vm from "vm";
const maxoutput = 750;
const maxoutput = 1000;
let context = vm.createContext({
e: null,
bot: null,
admins: null,
});
export default bot => {
bot._trigger.set("sandbox_debug", new bot.trigger({
call: /^\!debug (.*)/i,
level: 100,
active: true,
f: e => {
const args = e.message.trim().substring(7);
if(args === "true" || args === "false")
return e.self.debug = !e.self.debug;
try {
context.admins = admins;
context.e = e;
context.bot = bot;
context.level = getLevel;
let output = vm.runInContext(args, vm.createContext(context));
if (typeof output !== undefined && output) {
output = JSON.stringify(output);
if (output.length > maxoutput)
return e.reply(`holy fuck, Ausgabe wäre viel zu lang! (${output.length} Zeichen :DDDDDD)`);
else
return e.reply(output);
}
}
catch (err) {
e.reply(err.message);
export default bot => bot._trigger.set("sandbox_debug", new bot.trigger({
call: /^\!debug (.*)/i,
level: 100,
active: true,
f: e => {
const args = e.message.trim().substring(7);
if(args === "true" || args === "false")
return e.self.debug = !e.self.debug;
try {
context.admins = admins;
context.e = e;
context.bot = bot;
context.level = getLevel;
let output = vm.runInContext(args, vm.createContext(context));
if (typeof output !== undefined && output) {
output = JSON.stringify(output);
if (output.length > maxoutput)
return e.reply(`holy fuck, Ausgabe wäre viel zu lang! (${output.length} Zeichen :DDDDDD)`);
else
return e.reply(output);
}
}
catch (err) {
e.reply(err.message);
}
}
}));
};

3
src/inc/trigger/index.mjs
View File

@ -1,4 +1,3 @@
import debug from "./debug";
import parser from "./parser_new";
export default [ debug, parser ];
export default [ debug ];

241
src/inc/trigger/parser.mjs
View File

@ -1,241 +0,0 @@
import { cfg } from "../cfg";
import sql from "../sql";
import fs from "fs";
import path from "path";
import crypto from "crypto";
import uuid from "uuid";
import cloudscraper from "cloudscraper";
import readChunk from "read-chunk";
import ytdl from "ytdl-core";
import request from "request";
import fileType from "file-type";
import { Readable } from "stream";
const checkRepost = (url, cbcr) => {
sql.exec("select count(id) as count, id from `f0ck`.`items` where `src` = ?", url).then(rows => {
cbcr((rows[0].count == 0)?true:rows[0].id);
});
};
const checkRepostCheckSum = (cs, cbcrcs) => {
sql.exec("select count(id) as count, id from `f0ck`.`items` where `checksum` = ?", cs).then(rows => {
cbcrcs((rows[0].count == 0)?true:rows[0].id);
});
};
const formatSize = size => {
const i = ~~(Math.log(size) / Math.log(1024));
return (size / Math.pow(1024, i)).toFixed(2) * 1 + ' ' + ['B', 'kB', 'MB', 'GB', 'TB'][i];
};
const getCheckSum = (file, cbcs) => {
var sha256sum = crypto.createHash('sha256');
fs.ReadStream(file)
.on('data', d => sha256sum.update(d))
.on('end', () => cbcs(sha256sum.digest('hex')));
};
export default bot => {
bot._trigger.set("parser", new bot.trigger({
call: /https?:\/\/[\w-]+(\.[\w-]+)+\.?(:\d+)?(\/\S*)?/gi,
f: e => {
if(e.channel === "#kbot-dev" || e.message.match(/(!|-)f0ck/i)) {
if(!e.message.match(/(!|-)ignore/)) {
const tmp = e.message.match(/https?:\/\/[\w-]+(\.[\w-]+)+\.?(:\d+)?(\/\S*)?/gi); // get links
tmp.forEach((entry,i,a) => {
if(!entry.match(/f0ck\.me/i) && !entry.match(/\.onion/i)) {
getLink(entry, ((e.message.match(/(!|-)force/i) && e.user.level.level >= 100)?true:false), e.user.level.level, cb => {
if(cb.success === true) {
fs.rename(cb.file, cb.file + '.' + cb.info.ext, (err) => {
if(!err) {
sql.exec("insert into `f0ck`.`items` (`src`,`dest`,`mime`,`size`,`checksum`,`username`,`userchannel`,`usernetwork`,`stamp`,`active`,`thumb`) values (?,?,?,?,?,?,?,?,?,?,?)", [
entry,
cb.file + '.' + cb.info.ext,
cb.info.mime,
cb.size,
cb.checksum,
e.user.nick,
e.channel,
e.network,
~~(new Date() / 1000),
0,
cb.info.thumb ? cb.info.thumb : ''
]).then(result => {
//lib.generateThumbs();
e.reply(cfg.main.url.val+"/"+result.insertId+" - "+cb.info.title+" ("+cb.info.mime+", ~"+formatSize(cb.size)+") by "+e.user.nick+" ("+e.user.prefix+")");
}).catch(msg => {
e.reply("ups", msg);
});
}
else {
e.reply("Datei konnte nicht verschoben werden D:");
e.reply(`${cb.file} -> ${cb.file}.${cb.info.ext}`);
}
});
}
else {
e.reply(JSON.stringify(cb));
fs.stat(process.cwd() + '/b/' + cb.file, (err, stat) => {
if(cb.msg !== '')
e.reply(cb.msg);
if(!err && stat.isFile())
fs.unlinkSync(process.cwd() + '/b/' + cb.file);
});
}
});
}
});
}
else
e.reply("ignored");
}
else
e.reply("ignore");
}
}));
};
const getLink = (url, force, userlevel, cb) => {
const yt = /https?:\/\/(www\.)?youtu(\.be\/|be\.com\/)((.+\/)?(watch(\?v=|.+&v=))?(v=)?)([\w_-]{11})(&.+)?/gi;
const sc = /https?:\/\/(www\.)?(soundcloud\.com|snd\.sc)(\/\S*)(\/\S*)/gi;
checkRepost(url, cbcr => {
var tmpdest = uuid.v1().split('-')[0];
if(cbcr === true) {
var dat = fs.createWriteStream(process.cwd() + '/b/' + tmpdest);
var info;
if(url.match(yt)) { // ytdl
ytdl.getInfo(url, (err, inf) => {
if(!err) {
var title = inf.title;
var iurl = inf.thumbnail_url; //JSON.parse(inf.player_response).videoDetails.thumbnail.thumbnails[0].url.split('?')[0];
try {
dlformat = { filter: (format) => { return format.container === 'webm'; } };
ytdl.downloadFromInfo(inf, dlformat)
.on('response', (res) => {
if( ( res.headers['content-length'] <= cfg.main.maxFileSize.val ) || force || ( userlevel >= 60 && res.headers['content-length'] <= (cfg.main.maxFileSize.val * 2) ) ) {
info = {
type: 'youtube',
title: title,
mime: 'video/webm',
ext: 'webm',
thumb: iurl
};
}
else {
res.destroy();
dat.end();
return cb({ success: false, file: tmpdest, msg: 'f0ck! your file is too big (~'+formatSize(res.headers['content-length'])+'), max '+formatSize( ( userlevel >= 60?(cfg.main.maxFileSize.val*2):cfg.main.maxFileSize.val ) )+' allowed' });
}
})
.on('error', (err) => {
dat.end();
return cb({ success: false, file: tmpdest, msg: err.message });
})
.pipe(dat);
}
catch(ex) {
dat.end();
return cb({ success: false, file: tmpdest, msg: ex.message });
}
}
});
}
else if(url.match(sc)) { // scdl
request('https://api.soundcloud.com/resolve.json?client_id=' + cfg.main.scclientid.val + '&url=' + url, (err, res, body) => {
if(!err && res.statusCode === 200) {
var data = JSON.parse(body);
request(data.stream_url + ((data.stream_url.indexOf('?') === -1)?'?':'&') + 'client_id=' + cfg.main.scclientid.val)
.pipe(dat);
info = {
type: 'soundcloud',
title: data.title,
mime: 'audio/mpeg',
ext: 'mp3',
thumb: (data.artwork_url !== null)?data.artwork_url.replace('large.jpg', 't300x300.jpg'):null
};
}
else {
dat.end();
return cb({ success: false, file: tmpdest, msg: 'f0ck sc-api' });
}
});
}
else { // various
cloudscraper.request({
method: 'GET',
url: url,
encoding: null,
},
(err, res, data) => {
if(!err) {
var type = res.headers['content-type'].split(";")[0];
if(cfg.main.allowedMimes.val.hasOwnProperty(type)) {
if( ( data.length <= cfg.main.maxFileSize.val ) || force || ( userlevel >= 60 && data.length <= (cfg.main.maxFileSize.val * 2) ) ) {
var s = new Readable;
s.push(data);
s.push(null);
s.pipe(dat);
info = {
type: 'other',
title: path.parse(url).base,
mime: type,
ext: cfg.main.allowedMimes[type],
thumb: null
};
}
else {
dat.end();
return cb({ success: false, file: tmpdest, msg: 'f0ck! your file is too big (~'+formatSize(data.length)+'), max '+formatSize( ( userlevel >= 60?(cfg.main.maxFileSize.val*2):cfg.main.maxFileSize.val ) )+' allowed' });
}
}
else {
dat.end();
return cb({ success: false, file: tmpdest, msg: 'irgendwas mit mime oder so.' });
}
}
else {
dat.end();
return cb({ success: false, file: tmpdest, msg: 'nope.' });
}
});
}
dat
.on('finish', () => {
var size = dat.bytesWritten;
dat.end();
if( ( size <= cfg.main.maxFileSize.val ) || force || ( userlevel >= 60 && size <= (cfg.main.maxFileSize.val * 2) ) ) {
fs.stat(process.cwd() + '/b/' + tmpdest, (err, stat) => {
if(!err && stat.isFile() && stat.size > 300) {
getCheckSum(process.cwd() + '/b/' + tmpdest, (cbcs) => {
checkRepostCheckSum(cbcs, (cbcrcs) => {
if(cbcrcs === true) {
var mime = fileType(readChunk.sync(process.cwd() + '/b/' + tmpdest, 0, 262));
info.ext = mime.ext;
info.mime = mime.mime;
if(cfg.main.allowedMimes.val.hasOwnProperty(mime.mime) || info.type === 'soundcloud')
return cb({ success: true, info: info, size: size, file: process.cwd() + '/b/' + tmpdest, checksum: cbcs });
else
return cb({ success: false, file: tmpdest, msg: 'lol, go f0ck yourself ('+mime.mime+')' });
}
else
return cb({ success: false, file: tmpdest, msg: 'repost motherf0cker: '+cfg.main.url.val+'/'+cbcrcs });
});
});
}
else
return cb({ success: false, file: tmpdest, msg: 'nope' });
});
}
else
return cb({ success: false, file: tmpdest, msg: 'f0ck! your file is too big (~'+formatSize(size)+'), max '+formatSize( ( userlevel >= 60?(cfg.main.maxFileSize.val*2):cfg.main.maxFileSize.val ) )+' allowed' });
})
.on('error', err => {
return cb({ success: false, file: tmpdest, msg: err });
});
}
else
return cb({ success: false, file: tmpdest, msg: 'repost motherf0cker: '+cfg.main.url.val+'/'+cbcr });
});
};

119
src/inc/trigger/parser_new.mjs
View File

@ -1,119 +0,0 @@
import { cfg } from "../cfg";
import sql from "../sql";
import * as lib from "./inc/parser";
import fs from "fs";
//import fetch from "node-fetch";
import fetch from "../fetch";
import { promisify } from "util";
import { execFile as ef } from "child_process";
const execFile = promisify(ef)
, bin = process.cwd() + "/bin/youtube-dl"
, b = process.cwd() + "/b"
, _args = [ "--dump-json" ]
, regex = /https?:\/\/[\w-]+(\.[\w-]+)+\.?(:\d+)?(\/\S*)?/gi;
export default bot => {
bot._trigger.set("parser", new bot.trigger({
call: regex,
f: e => {
if(e.channel !== "#kbot-dev" && !e.message.match(/(!|-)f0ck/i))
return;
if(e.message.match(/(!|-)ignore/))
return e.reply("ignored");
const tmp = e.message.match(regex); // get links
Promise.all(tmp.map(link => execFile(bin, [...[link], ..._args])))
.then(data => data.map(d => JSON.parse(d.stdout)))
.then(d => d.map(data => data.direct ? {
thumbnail: "",
link: data.url,
file: data.title,
format: [{
ext: data.ext,
note: "direct",
url: data.url,
size: 0,
rsize: 0
}]
} : {
thumbnail: data.thumbnail,
link: data.webpage_url,
file: data.id,
format: data.formats
.filter(f => {
if(f.hasOwnProperty("fragments"))
return false;
if(!["webm", "mp4", "mp3"].includes(f.ext))
return false;
if(f.filesize > cfg.main.maxFileSize.val && f.ext !== "mp3")
return false;
if(/playlist/i.test(f.url))
return false;
if(e.self.debug)
e.reply(`${f.ext} - ${f.url} - ${f.format}`);
return f;
})
.splice(-1, 1)
.map(f => ({
ext: f.ext,
note: f.format_note,
url: f.url,
size: lib.formatSize(f.filesize),
rsize: f.filesize
}))
}))
.then(d => d.map(data => {
if(data.format.length === 0)
return e.reply("no filters found, f0ck! D:");
fetch(data.format[0].url, { size: cfg.main.maxFileSize.val })
.then(res => {
if(res.headers["content-length"] >= cfg.main.maxFileSize.val)
return e.reply(`file too large soos! D; (~${lib.formatSize(res.headers["content-length"])} / ~${lib.formatSize(cfg.main.maxFileSize.val)})`);
const uuid = lib.getUUID();
const file = `${b}/${uuid}.${data.format[0].ext}`;
const dest = fs.createWriteStream(file);
const start = new Date();
res.body.pipe(dest);
let t;
dest.on("open", () => {
e.reply(`downloading ${data.file}...`);
t = setInterval(() => {
const size = fs.statSync(file).size;
if(size >= cfg.main.maxFileSize.val) {
e.reply(`file too large lol! D: (${lib.formatSize(size)})`);
res.body.unpipe(dest);
dest.destroy();
fs.unlinkSync(file);
clearInterval(t);
t = false;
}
else {
if(e.self.debug)
e.reply(`${data.file}: ${lib.formatSize(size)}`);
}
}, 2000);
});
dest.on("close", blah => {
if(t) {
clearInterval(t);
const size = fs.statSync(file).size;
const time = ~~((new Date() - start) / 1000);
e.reply(`gef0ckt lol: ${data.file} -> ${uuid}.${data.format[0].ext}, ~${lib.formatSize(size)}, speed: ${lib.calcSpeed(size, time)}`);
}
else {
// recursive
}
});
})
.catch(err => {
console.error(err);
});
}))
.catch(err => e.reply(JSON.stringify(err))
);
}
}));
};