masto auto reconnect stream

config.js

@@ -10,7 +10,7 @@ module.exports = {
 	inactive_role: "892869309603389500",
 	verified_role: "949064806030254130",
 	view_archived_channels_role: "916056534402863125",
-	eval_undefined_emoji: "707729833601531935",
+	eval_undefined_emoji: "🅱️",
 	mi_emoji: "887931046086185060",
 	ki_emoji: "887935846710394910",
 	default_channel: "949831184957980722",
@@ -82,5 +82,7 @@ module.exports = {
 	masto: {
 		url: "https://mastodong.lol",
 		accessToken: process.env.MASTO_TOKEN
-	}
+	},
+	masto_account_id: "108643271047165149",
+	masto_webhook: process.env.DISCORD_WEBHOOK_FOR_MASTO
 }

eval-exec.js

@@ -9,7 +9,7 @@ client.on("messageCreate", async function (message) {
 	if (message.content.startsWith("!>")) {
 		with (message) {
 			try {
-				var x = await eval(message.content.substr(2).trim());
+				var x = await eval(message.content.substring(2).trim());
 			} catch(e) {
 				var x = e.message;
 			}

index.js

@@ -1,6 +1,6 @@
 process.title = "lamp discord bot";
 process.on("unhandledRejection", error => {
-	console.error("Unhandled Rejection:\n" + (error.stack || error));
+	console.error("Unhandled Rejection:\n", error.stack || error);
 });
 
 require("./util"); // global variables set in here

masto.js

@@ -1,14 +1,38 @@
 var {login} = require("masto");
 var config = require("./config");
 var client = require("./client");
+var {WebhookClient} = require("discord.js");
+
+var webhook = new WebhookClient({url: config.masto_webhook});
+module.exports.webhook = webhook;
 
 client.once("ready", async () => {
 	var donger = await login(config.masto);
-	module.exports = donger;
-	var stream = await donger.stream.streamUser();
-	stream.on("update", toot => {
-		console.debug("toot", toot); // testing
-	});
+	console.log("donger logged in");
+	module.exports.donger = donger;
+	(async function openStream() {
+		try {
+			var stream = await donger.stream.streamUser();
+			module.exports.stream = stream;
+			stream.on("update", toot => {
+				
+				if (toot.account.id != config.masto_account_id) return;
+				if (toot.visibility != "public") return;
+				if (toot.inReplyToAccountId && toot.inReplyToAccountId != toot.account.id) return;
+
+				webhook.send(toot.url || toot.reblog.url); //todo maybe custom embed
+
+				//todo maybe handle deletes
+			});
+			stream.ws.on("close", () => {
+				console.log("donger stream closed");
+				setTimeout(openStream, 10000);
+			});
+		} catch (error) {
+			console.error("donger stream", error.message);
+			setTimeout(openStream, 60000);
+		}
+	})();
 });