deekchat_renachan/client.js

1063 lines
22 KiB
JavaScript
Executable File

const fs = require("fs");
const websocket = require("ws");
const fetch = require("node-fetch");
const formdata = require("form-data");
const he = require("he");
const cheerio = require("cheerio");
const ddg = require("duckduckgo-images-api");
var mmm = require("mmmagic");
var Magic = mmm.Magic;
var http = require("http");
const emitter = require("events");
const deek = new emitter();
const name = "rena_chan";
const password = "pass";
const mc_password = "pass";
const userid = 12;
var channels = [];
var ws = [];
var ddg_cache = [];
var ddg_mod = true; // dont show porn in .img
var global_page = 1; // .img page
var raid = false; // raid?
var img_headers = {
"User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64; rv:124.0) Gecko/20100101 Firefox/124.0",
"Accept": "text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,image/webp,*/*;q=0.8",
"Accept-Language": "en-US,en;q=0.5",
"Accept-Encoding": "gzip, deflate",
"DNT": "1",
"Connection": "keep-alive"
};
var headers = {
"User-Agent": "renabot",
"Origin": "https://deek.chat"
};
/*
Minecraft functions
*/
async function send_mc(username, message){
if(mc_logged_in){
var txt = message.split("\n");
var txt_out = "";
txt.forEach(function(a){
mc.chat('/tellraw @a ["<",{"text":"' + mc_escape(username) + '","color":"gold"},"> ' + mc_escape(a) + '"]');
});
}
}
function mc_escape(str){
return str.replace(
/[^-!\"#$%&'()*+,.\/0123456789:;<=>?@[\\\]^_'abcdefghijklmnopqrstuvwxyz{|}~⌂ÇüéâäàåçêëèïîìÄÅÉæÆôöòûùÿÖÜø£Ø׃áíóúñѪº¿®¬½¼¡«» ]/gi,
""
);
}
/*
Helper functions
*/
async function getmime(file){
return new Promise(function(resolve, reject){
var magic = new Magic(mmm.MAGIC_MIME_TYPE);
magic.detect(file, function(err, result){
if(err){
resolve([
"image/png",
"png",
false
]);
}else{
resolve([
result,
result.split("/")[1],
true
]);
}
});
});
}
function removehtml(html){
return he.decode(html.replace(/<[^>]+>/ig,""));
};
async function serveddg(msg, results, page){
page--;
try{
var res = await fetch(
results[page].image,
{
headers: img_headers,
signal: AbortSignal.timeout(3000)
}
);
var res_get = await res.buffer();
var m = await getmime(res_get);
if(
m[2] === false ||
m[0].split("/")[0] != "image"
){
var res = await fetch(
results[page].thumbnail,
{
headers: img_headers,
signal: AbortSignal.timeout(5000)
}
);
var res_get = await res.buffer();
}
}catch(err){
var res = await fetch(
results[page].thumbnail,
{
headers: img_headers,
signal: AbortSignal.timeout(5000)
}
);
var res_get = await res.buffer();
}
send(
msg,
"Page " + (page + 1) + "/" + (results.length) + "\n[" + results[page].width + "x" + results[page].height + "] " + results[page].title + "\n" + results[page].url,
res_get
);
}
/*
Websocket functions
*/
async function send(channel, text, file = null, forcemime = null){
if(typeof channel == "object"){
channel = channel.channel;
}
if(channel === 1){
send_mc(name, text);
}
if(channel === -1){
channel = 1;
}
if(file === null){
ws.send(JSON.stringify({
type: "messageEnd",
data: text,
roomId: channel
}));
return;
}
/*
Send file
*/
if(forcemime === null){
var mimetype = await getmime(file);
}else{
var mimetype = forcemime;
}
var form_data = new formdata();
form_data.append("text", text);
form_data.append(
"files[]",
file,
{
contentType: mimetype[0],
name: "file",
filename: "file." + mimetype[1]
}
);
var headers_copy = headers;
headers_copy["Content-Type"] = form_data.getHeaders()["content-type"];
fetch("https://deek.chat/message/send/" + channel, {
method: 'POST',
body: form_data,
headers: headers_copy
});
}
/*
Handshake
*/
async function handshake(name, password){
/*
Get cookie
*/
console.log("logging in as " + name);
const form = new formdata();
form.append("name", name);
form.append("password", password);
form.append("submit", "log+in");
try{
var login = await fetch(
"https://deek.chat/login/submit",
{
method: "POST",
redirect: "manual",
body: form,
headers: headers
}
);
}catch(err){
console.log("Could not login. Trying again in 10 seconds...");
setTimeout(function(){
fs.utimesSync(__filename, Date.now(), Date.now());
}, 10000);
return;
}
var cookie = await login.headers.get("set-cookie");
var api_token = cookie.match(/api_token=([^;]+)/);
var session_id = cookie.match(/session_id=([^;]+)/);
if(
api_token === null ||
typeof api_token[1] != "string" ||
typeof session_id[1] != "string"
){
deek.emit("error", "Could not get api_token or session_id !!");
return;
}
headers.cookie = "session_id=" + session_id[1] + "; api_token=" + api_token[1];
/*
Connect to websocket serber
*/
ws = new websocket(
"wss://deek.chat/ws",
{
protocolVersion: 13,
encoding: "utf8",
headers: headers
}
);
ws.once("open", function(){
deek.emit("login");
});
ws.once("close", function(){
deek.emit("close");
});
ws.on("message", function(message, isbin){
if(isbin){ return; }
var m = JSON.parse(message.toString("utf8"));
if(typeof m.type == "undefined"){
return;
}
switch(m.type){
case "message":
case "messageEnd":
for(var k=0; k<m.data.mentions.length; k++){
m.data.mentions[k].id = m.data.mentions[k].userId;
delete m.data.mentions[k].userId;
}
for(var k=0; k<m.data.replies.length; k++){
m.data.replies[k].id = m.data.replies[k].userId;
m.data.replies[k] = m.data.replies[k].replyMessageId;
delete m.data.replies[k].userId;
delete m.data.replies[k].replyMessageId;
}
m.data.files = m.data.files === null ? [] : m.data.files;
var files = [];
for(var k=0; k<m.data.files.length; k++){
files.push("https://deek.chat/storage/files/" + m.data.files[k].name);
}
deek.emit(
"message",
{
text: removehtml(m.data.text),
id: m.data.id,
files: files,
mentions: m.data.mentions,
replies: m.data.replies,
channel: m.roomId
},
{
name: m.data.name,
id: m.userId,
picture: m.data.profilePicture == "" ? null : "https://deek.chat/storage/profilePictures/" + m.data.profilePicture
}
);
break;
case "files":
var files = [];
if(m.data.files !== null){
for(var k=0; k<m.data.files.length; k++){
files.push("https://deek.chat/storage/files/" + m.data.files[k].name);
}
}
deek.emit(
"message",
{
text: removehtml(m.data.text),
id: m.data.id,
files: files,
mentions: m.data.mentions,
replies: m.data.replies,
channel: m.roomId
},
{
name: m.data.name,
id: m.data.userId,
picture: m.data.profilePicture == "" ? null : "https://deek.chat/storage/profilePictures/" + m.data.profilePicture
}
);
break;
default:
//console.warn(m);
break;
}
});
}
/*
Minecraft => Deekchat bridge
*/
const mineflayer = require('mineflayer');
var mc_logged_in = false;
const mc = mineflayer.createBot({
host: 'deek.chat',
username: name,
auth: 'offline',
port: 25565
});
mc.on("login", function(){
mc_logged_in = true;
mc.chat("/login " + mc_password);
console.log("Logged to minecraft server as " + mc.username);
});
mc.on("death", function(user){
mc.respawn();
});
/*
User defined FUN-ctions!!!
*/
deek.on("login", function(channel){
console.log("Connected to websocket xoxo");
mc.on("chat", function(username, message){
if(username === mc.username){
return;
}
send(-1, "<" + username + "> " + message);
deek.emit(
"message",
{
text: message,
id: 0,
files: [],
mentions: [],
replies: [],
channel: 1,
is_mc: true
},
{
name: username,
id: -1,
picture: null
}
);
});
mc.on("playerJoined", function(user){
send(-1, ">" + user.username + " joined deekcraft");
});
mc.on("playerLeft", function(user){
send(-1, ">" + user.username + " left deekcraft");
});
// Log errors and kick reasons:
mc.on("kicked", function(msg){
mc_logged_in = false;
console.log(msg);
});
mc.on("error", function(msg){
mc_logged_in = false;
console.log(msg);
});
});
deek.on("message", async function(msg, user){
if(
(
user.id === 13 || // me lol
user.id === 14 || // aves
user.id === 8 || // aves again
user.id === 30 || // eagle
user.id === 2 || // deek
raid === false
) === false
){
return;
}
if(
user.id === userid ||
user.name == name
){
return;
}
/*
if(user.id === 5311){
user.name = msg.text.split(">")[0].substr(1);
msg.text = msg.text.split(">").splice(1).join(">").trim();
}*/
if(
msg.channel === 1 &&
typeof msg.is_mc === "undefined"
){
send_mc(user.name, msg.text);
}
switch(msg.text.toLowerCase()){
case "hello rena":
case "hi rena":
case "what's up rena":
case "whats up rena":
send(msg, "hi " + user.name);
return;
case "/help":
send(msg, "lmao newfag");
return;
case "fuck you rena":
send(msg, "fuck you eagle");
return;
}
/*
shitty embed support
*/
if(link = msg.text.match(/https?:\/\/[^ \n\r'>]+/)){
link = link[0];
try{
if(tweet = link.match(/https?:\/\/(?:www\.)?twitter\.com\/[A-Za-z0-9_]+\/status\/([0-9]+)/i)){
tweet = tweet[1];
var res = await fetch("https://cdn.syndication.twimg.com/tweet-result?id=" + tweet + "&token=2rkokdcv41v");
var json = await res.json();
var title = json.user.name + " (@" + json.user.screen_name + ") " + " on twatter";
var description = json.text;
}else if(watch = link.match(/(?:youtube\.com\/(?:[^\/]+\/.+\/|(?:v|e(?:mbed)?)\/|.*[?&]v=)|youtu\.be\/)([^"&?\/\s]{11})/i)){
watch = watch[1];
var res = await fetch("https://youtube.com/oembed?url=/watch?v=" + watch);
var json = await res.json();
var title = json.title;
var description = "By " + json.author_name;
}else{
var res = await fetch(
link,
{
headers: img_headers,
signal: AbortSignal.timeout(5000)
}
);
var headers_arr = [...res.headers];
var headers = [];
for(i=0; i<headers_arr.length; i++){
headers[headers_arr[i][0]] = headers_arr[i][1];
}
if(
!headers["content-type"] ||
headers["content-type"].split(";")[0] != "text/html" ||
(
!headers["content-length"] &&
parseInt(headers["content-length"]) > 10485760 // 10MB
)
){
var text = "This thingy^ ";
if(headers["content-type"]){
var format = headers["content-type"].split("/");
format = format[format.length - 1].split(";")[0];
text += "is a " + format + " file ";
}else{
text += "is uhh... something.. err.. "
}
if(headers["content-length"]){
var filesize = Math.round(parseInt(headers["content-length"]) / 1048576);
text += "that weighs " + (Math.round(parseInt(headers["content-length"]) / 1048576)) + "MB!!";
}else{
text += "that uhh weighs something probably idk!!!";
}
text += " lol thats all i know fuck you";
send(msg, text);
return;
}
// cancerous code ahead
var buffer = await res.buffer();
const parser = cheerio.load(buffer);
// get title
var title = "Unknown title lol, shit website";
var tag_title = parser("title");
var tag_name_og_title = parser("meta[name='og:title']");
var tag_property_og_title = parser("meta[property='og:title']");
if(tag_title.length !== 0){ title = tag_title.text(); }
if(tag_name_og_title.length !== 0){ title = tag_name_og_title.attr("content"); }
if(tag_property_og_title.length !== 0){ title = tag_property_og_title.attr("content"); }
// get description
var description = "Unknown description lol, stupid website do not click";
var tag_name_description = parser("meta[name='description']");
var tag_name_og_description = parser("meta[name='og:description']");
var tag_property_description = parser("meta[property='description']");
var tag_property_og_description = parser("meta[property='og:description']");
if(typeof tag_name_description.attr("content") != "undefined"){description = tag_name_description.attr("content"); }
if(typeof tag_name_og_description.attr("content") != "undefined"){description = tag_name_og_description.attr("content"); }
if(typeof tag_property_description.attr("content") != "undefined"){description = tag_property_description.attr("content"); }
if(typeof tag_property_og_description.attr("content") != "undefined"){description = tag_property_og_description.attr("content"); }
if(typeof tag_name_description.attr("value") != "undefined"){description = tag_name_description.attr("value"); }
if(typeof tag_name_og_description.attr("value") != "undefined"){description = tag_name_og_description.attr("value"); }
if(typeof tag_property_description.attr("value") != "undefined"){description = tag_property_description.attr("value"); }
if(typeof tag_property_og_description.attr("value") != "undefined"){description = tag_property_og_description.attr("value"); }
}
var text = "";
description = description.split("\n");
for(var i=0; i<description.length; i++){
text += "\n>" + description[i];
}
send(msg, title + text);
}catch(err){
send(msg, "Stupid retarded website alert!!!! I got an error accessing this shit...\n>" + err);
}
return;
}
/*
Commands
*/
var regex = msg.text.match(/^\.([^ ]+)(?: (.*))?/);
if(
regex === null ||
typeof regex[1] == "undefined"
){
return;
}
var cmd = regex[1];
if(typeof regex[2] != "undefined"){
var value = regex[2];
}else{
var value = "";
}
switch(cmd.toLowerCase()){
case "raid":
if(
(
user.id === 13 || // me lol
user.id === 14 || // aves
user.id === 8 || // aves again
user.id === 30 || // eagle
user.id === 2 // deek
) === false
){
break;
}
if(raid === false){
raid = true;
send(msg, "Ignoring all messages from now on, fuck you lol!!");
}else{
raid = false;
send(msg, "Now listening to messages!!!");
}
break;
case "rc":
case "reconnect":
if(user.id !== 13){
break;
}
send(msg, "brb");
setTimeout(function(){
fs.utimesSync(__filename, Date.now(), Date.now());
}, 1000);
break;
case "ping":
send(msg, "Pong!!!!");
break;
case "dice":
case "roll":
case "d":
case "r":
value = parseInt(value);
if(isNaN(value)){
value = 6;
}
if(value <= 1){
send(
msg,
"Rolling a " + value + " faced dice...\nWait what?? " +
"You fucking shit, a black hole just appeared!!!!!! Oh my fucking shit!!!!!"
);
return;
}
send(
msg,
"Rolling a " + value + " faced dice...\nAnd you got " +
(
Math.floor(Math.random() * value + 1)
) + "!!!"
);
break;
case "mumble":
case "m":
var port = 64738;
if(value == ""){
var ip = "lolcat.ca";
}else{
var value = value.split(":");
if(value.length >= 2){
var port = value[1];
}
var ip = value[0];
}
try{
var res = await fetch("https://lolcat.ca/api/mumble/?ip=" + ip + "&port=" + port);
var res_get = await res.json();
if(res_get.status != "ok"){
send(msg, "An error occured... " + res_get.status);
return;
}
res_get = res_get.server;
var servername = res_get.name === null ? res_get.domains[0] : res_get.name;
var website = res_get.website === null ? "No website available" : res_get.website;
send(
msg,
">Server information for " + servername + ":\n" +
"Known domains => " + res_get.domains.join(", ") + "\n" +
"Ping => " + res_get.ping + "\n" +
"Users => " + res_get.online + "/" + res_get.max + "\n" +
"Bandwidth => " + res_get.bandwidth + "\n" +
"Country => " + res_get.country.name + " (" + res_get.country.code + ")\n" +
"Version => " + res_get.version + "\n" +
"Website => " + website
);
}catch(err){
send(msg, "lolcat.ca api sucks and is offline and dead");
}
break;
case "prop":
try{
var res = await fetch("https://www.hamqsl.com/solarn0nbh.php");
var res_get = await res.buffer();
send(msg, "Good news: the sun has not yet exploded", res_get);
}catch(err){
send(msg, "Could not fetch image!!! FUCK!!!!111\n" + err);
}
break;
case "img":
case "im":
case "i":
if(value.trim() == ""){
send(msg, "You need to search for something cum licker!!!");
return;
}
global_page = 1;
ddg.image_search(
{
query: value,
moderate: ddg_mod,
iterations: 1
}
).then(async results => {
ddg_cache = results;
if(results.length === 0){
send(msg, "No results found for " + value + "!!");
return;
}
await serveddg(msg, results, 1);
});
break;
case "boobs":
case "boob":
case "nsfw":
switch(value.toLowerCase()){
case "yes":
case "y":
case "1":
case "yea":
case "true":
case "yup":
send(msg, "I will now show boobs when using .img");
ddg_mod = false;
break;
case "no":
case "n":
case "nae":
case "false":
case "no":
case "off":
case "nope":
case "nah":
case "0":
send(msg, "I will now prevent eagle from jacking off in main chat");
ddg_mod = true;
break;
default:
var active = ddg_mod ? "NOT " : "";
send(msg, "I will " + active + "show boobs. Use .boobs <yes:no> to toggle");
break;
}
break;
case "page":
case "p":
value = parseInt(value);
if(
isNaN(value) ||
value == ""
){
send(msg, "You didn't enter a valid number you dumbass!!");
return;
}
if(ddg_cache.length === 0){
send(msg, "Search buffer doesn't contain any links you horse fucker!!");
return;
}
if(
value > ddg_cache.length ||
value <= 0
){
send(msg, "Page offset must be between 1 and " + ddg_cache.length + " you dumbass!!");
return;
}
global_page = value;
await serveddg(msg, ddg_cache, value);
break;
case "pp":
global_page++;
if(global_page > ddg_cache.length){
send(msg, "You reached the end of results stupid kike sucker!!");
return;
}
await serveddg(msg, ddg_cache, global_page);
break;
case "youtube":
case "jewtube":
case "yt":
if(value.trim() == ""){
send(msg, "You need to search for something cum licker!!!");
break;
}
var res = await fetch("https://4get.zzls.xyz/api/v1/videos?s=" + encodeURIComponent(value));
var res_get = await res.json();
if(res_get.status != "ok"){
send(msg, "Shit!!!!! 4get sucks balls and returned this error: " + res_get.status);
break;
}
if(res_get.video.length === 0){
send(msg, "No results found for " + value + "!!");
break;
}
if(res_get.status != "ok"){
send(msg, "4get sucks!!!!! It returned ERRRO!!RRRO!!O!O!O!11\n>" + res_get.status);
break;
}
var text = [];
for(var i=0; i<res_get.video.length; i++){
if(i === 3){
break;
}
text.push(
">Duration: " + (new Date(res_get.video[i].duration * 1000).toISOString().slice(11, 19)) +
" • Views: " + (new Intl.NumberFormat().format(res_get.video[i].views)) +
" • Author: " + res_get.video[i].author.name +
"\n" + res_get.video[i].title +
"\n▶ " + res_get.video[i].url
);
}
send(msg, "Search results for \"" + value + "\"\n\n" + text.join("\n\n"));
break;
case "x":
case "xeno":
if(value.trim() == ""){
send(
msg,
"You must give me a search term you autistic cocksucker with no legs!!\nExample: .x owl"
);
break;
}
var res = await fetch("https://xeno-canto.org/api/2/recordings?query=" + encodeURIComponent(value));
var res_get = await res.json();
if(res_get.recordings.length === 0){
send(
msg,
"No recordings found for \"" + value + "\"!!!!!"
);
break;
}
var filereq = await fetch(
res_get.recordings[0].file,
{headers: img_headers}
);
var file = await filereq.buffer();
send(
msg,
">" + res_get.recordings[0].en + " in " + res_get.recordings[0].cnt + " (" + res_get.recordings[0].loc + ")\n" +
res_get.recordings[0].rmk,
file,
[
"audio/mpeg",
"mp3"
]
);
break;
case "help":
case "h":
send(
msg,
"== help menu ==\n\n" +
".help => lol idk\n" +
".img/.im/.i => search duckduckgo for birds\n" +
".boobs <yes:no> => Boobs?\n" +
".page/.p => get page offset for image search\n" +
".pp => get next page\n" +
".yt/.youtube => search the jewish propaganda catalog (now powered by 4get)\n" +
".x/xeno => search for bird sounds\n" +
".roll/.r => Because deekchat was too slow\n" +
".mumble/.m <[optional]ip:port> => check if lolcat died\n" +
".prop => check if the sun has exploded or smth\n" +
".ping => spam deekchat"
);
break;
}
});
deek.on("close", function(channel){
console.log("It's over. Disconnected from websocket. Attempting reconnection in 10 seconds");
setTimeout(function(){
fs.utimesSync(__filename, Date.now(), Date.now());
}, 10000);
});
deek.on("error", function(message){
console.error("Serber error: " + message + ". Attempting reconnection in 10 seconds");
setTimeout(function(){
fs.utimesSync(__filename, Date.now(), Date.now());
}, 10000);
});
// connect to serber
handshake(name, password);