update

.gitignore

@@ -1,2 +1,2 @@
-conf.js
+conf.js
 last_ts

.vscode/settings.json

@@ -1,3 +1,3 @@
-{
-	"deno.enable": true
+{
+	"deno.enable": true
 }

readme.md

@@ -6,6 +6,7 @@ create conf.js and paste values
 export const ACCESS_TOKEN = ""; // your access token you can get it from element settings
 export const SERVER_URL = ""; // your matrix server url without trailing slash i.e. https://matrix-client.matrix.org
 export const ROOM_ID = ""; // make a private room and put its id here
+export const INTERVAL = 30; // how often to check for new notifications
 ```
 
 run

wfp.js

@@ -1,87 +1,97 @@
-import { ACCESS_TOKEN, SERVER_URL, ROOM_ID } from "./conf.js";
-
-try {
-	var last_ts = Number(Deno.readTextFileSync("last_ts"));
-} catch (error) {
-	var last_ts = 0;
-}
-
-
-async function fetchMatrix(url, options = {}) {
-	options.headers ||= {};
-	options.headers.Authorization ||= `Bearer ${ACCESS_TOKEN}`;
-	url = SERVER_URL + url;
-	do {
-		console.debug("fetch", url);
-		try {
-			var res = await fetch(url, options);
-			if (res.ok) break;
-			console.warn("status:", res.status);
-			if (res.status == 429) {
-				var {retry_after_ms} = await res.json();
-			}
-		} catch (error) {
-			console.error(error);
-		}
-		await new Promise(r => setTimeout(r, retry_after_ms || 60000));
-	} while (true)
-	if (!res.ok) throw new Error(`HTTP ${res.status} ${await res.text()}`);
-	return res;
-}
-
-async function checkNotifications() {
-	var new_notifications = [];
-	var next_token;
-	var limit = 5;
-
-	l: do {
-		var data = await fetchMatrix(`/_matrix/client/v3/notifications?limit=${limit}${next_token ? `&from=${next_token}` : ''}`).then(res => res.json());
-		for (let n of data.notifications) {
-			if (n.ts <= last_ts) break l;
-			new_notifications.unshift(n);
-		}
-		next_token = data.next_token;
-		limit = 50;
-	} while (next_token !== null)
-
-	console.debug("new notifications:", new_notifications);
-	if (!new_notifications.length) return;
-	for (let n of new_notifications) {
-		try {
-			await addNotificationToRoom(n);
-			last_ts = n.ts;
-			Deno.writeTextFileSync("last_ts", String(last_ts));
-		} catch (error) {
-			console.error(error);
-		}
-	}
-}
-
-
-async function addNotificationToRoom(notification) {
-	var text = `https://matrix.to/#/${encodeURIComponent(notification.room_id)}/${encodeURIComponent(notification.event.event_id)} ${new Date(notification.ts).toLocaleString()}`;
-	await fetchMatrix(`/_matrix/client/v3/rooms/${encodeURIComponent(ROOM_ID)}/send/m.room.message/${Math.random()}`, {
-		method: "PUT",
-		headers: {
-			"Content-Type": "application/json"
-		},
-		body: JSON.stringify({
-			msgtype: "m.text",
-			format: "org.matrix.custom.html",
-			body: text,
-			formatted_body: `<p>${text}</p>\n<pre><code class=\"language-json\">${JSON.stringify(notification.event, null, '\t')}\n</code></pre>\n`
-		})
-	});
-}
-
-
-
-
-while (true) {
-	try {
-		await checkNotifications();
-	} catch (error) {
-		console.error(error);
-	}
-	await new Promise(r => setTimeout(r, 10000));
-}
+import { ACCESS_TOKEN, SERVER_URL, ROOM_ID, INTERVAL } from "./conf.js";
+
+try {
+	var last_ts = Number(Deno.readTextFileSync("last_ts"));
+} catch (error) {
+	var last_ts = 0;
+}
+
+
+async function fetchMatrix(url, options = {}) {
+	options.headers ||= {};
+	options.headers.Authorization ||= `Bearer ${ACCESS_TOKEN}`;
+	if (!(url instanceof URL)) url = new URL(url, SERVER_URL);
+	console.debug("fetch", url.toString());
+	var res = await fetch(url, options);
+	console.debug("status:", res.status);
+	if (res.status == 429) {
+		var {retry_after_ms} = await res.json();
+		await new Promise(r => setTimeout(r, retry_after_ms || 60000));
+		return await fetchMatrix(url, options);
+	}
+	if (!res.ok) throw new Error(`HTTP ${res.status} ${await res.text()}`);
+	return res;
+}
+
+async function checkNotifications() {
+	var new_notifications = [];
+	var next_token;
+	var limit = 5;
+
+	l: do {
+		var data = await fetchMatrix(`/_matrix/client/v3/notifications?limit=${limit}${next_token ? `&from=${next_token}` : ''}`).then(res => res.json());
+		for (let n of data.notifications) {
+			if (n.ts <= last_ts) break l;
+			new_notifications.unshift(n);
+		}
+		next_token = data.next_token;
+		limit = 50;
+	} while (next_token !== null)
+
+	if (new_notifications.length) console.debug("new notifications:", new_notifications);
+	if (!new_notifications.length) return;
+	for (let n of new_notifications) {
+		try {
+			await addNotificationToRoom(n);
+			last_ts = n.ts;
+			Deno.writeTextFileSync("last_ts", String(last_ts));
+		} catch (error) {
+			console.error(error);
+		}
+	}
+}
+
+
+async function addNotificationToRoom({room_id, event}) {
+	var url = `https://matrix.to/#/${encodeURIComponent(room_id)}/${encodeURIComponent(event.event_id)}`;
+	var text = `${new Date(event.origin_server_ts).toLocaleString()}
+${await getAlias(room_id)}
+${event.sender}
+${event.content?.body}
+${url}`;
+	await fetchMatrix(`/_matrix/client/v3/rooms/${encodeURIComponent(ROOM_ID)}/send/m.room.message/${Math.random()}`, {
+		method: "PUT",
+		headers: {
+			"Content-Type": "application/json"
+		},
+		body: JSON.stringify({
+			msgtype: "m.text",
+			body: text
+			//format: "org.matrix.custom.html",
+			//formatted_body: `<p>${text}</p>\n<pre><code class=\"language-json\">${JSON.stringify(event, null, '\t')}\n</code></pre>\n`
+		})
+	});
+}
+
+async function getAlias(room_id) {
+	try {
+		var data = await fetchMatrix(`/_matrix/client/v3/rooms/${encodeURIComponent(room_id)}/state/m.room.canonical_alias/`).then(res => res.json());
+		console.debug(data);
+		return data.alias || room_id;
+	} catch (error) {
+		console.error(error);
+		return room_id;
+	}
+}
+
+
+
+
+while (true) {
+	try {
+		await checkNotifications();
+	} catch (error) {
+		console.error(error);
+	}
+	await new Promise(r => setTimeout(r, (INTERVAL || 30) * 1000));
+}