lamp/who-fuck-ping
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Compare commits

base: lamp/who-fuck-ping:709ef9885be0642111cf02a54520778a8f029107
Branches Tags
lamp/who-fuck-ping:master
...
compare: lamp/who-fuck-ping:master
Branches Tags
lamp/who-fuck-ping:master

1 Commits
709ef9885b ... master

Author SHA1 Message Date
lamp 02354b3a7c update 2026-05-05 00:36:56 -07:00
1 changed files with 30 additions and 20 deletions
Expand all files Collapse all files
wfp.js
+30 -20
View File
@@ -10,21 +10,15 @@ try {
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);
}
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));
} while (true)
return await fetchMatrix(url, options);
}
if (!res.ok) throw new Error(`HTTP ${res.status} ${await res.text()}`);
return res;
}
@@ -44,7 +38,7 @@ async function checkNotifications() {
limit = 50;
} while (next_token !== null)
console.debug("new notifications:", new_notifications);
if (new_notifications.length) console.debug("new notifications:", new_notifications);
if (!new_notifications.length) return;
for (let n of new_notifications) {
try {
@@ -58,8 +52,13 @@ async function checkNotifications() {
}
async function addNotificationToRoom(notification) {
var text = `https://matrix.to/#/${encodeURIComponent(notification.room_id)}/${encodeURIComponent(notification.event.event_id)} ${new Date(notification.ts).toLocaleString()}`;
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: {
@@ -67,13 +66,24 @@ async function addNotificationToRoom(notification) {
},
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`
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;
}
}