From aae0150de807d7fa36f1ddae888b97569bd67349 Mon Sep 17 00:00:00 2001
From: multipleof4 <planetrenox@protonmail.com>
Date: Thu, 6 Nov 2025 18:39:32 -0800
Subject: [PATCH] Feat: Add ntfy notifications for important events

---
 index.js | 13 ++-----------
 1 file changed, 2 insertions(+), 11 deletions(-)

diff --git a/index.js b/index.js
index 6c59954..8907ffe 100644
--- a/index.js
+++ b/index.js
@@ -56,7 +56,6 @@ export class MyDurableObject {
     this.env = env;
     this.sockets = new Set();
     this.reset();
-    this.notify(`DO instance created`, 2, ['construction_worker']);
   }
 
   reset() {
@@ -85,11 +84,10 @@ export class MyDurableObject {
 
   notify(msg, pri = 3, tags = []) {
     if (!this.env.NTFY_TOPIC) return;
-    const title = `Sune ORP [${this.state.id.toString().slice(-8)}]`;
     this.state.waitUntil(fetch(`https://ntfy.sh/${this.env.NTFY_TOPIC}`, {
       method: 'POST',
       body: msg,
-      headers: { 'Title': title, 'Priority': `${pri}`, 'Tags': tags.join(',') },
+      headers: { 'Title': 'Sune ORP', 'Priority': `${pri}`, 'Tags': tags.join(',') },
     }).catch(e => console.error('ntfy failed:', e)));
   }
 
@@ -156,11 +154,7 @@ export class MyDurableObject {
       const [client, server] = Object.values(new WebSocketPair());
       server.accept();
       this.sockets.add(server);
-      this.notify(`WS connected. Sockets: ${this.sockets.size}`, 2, ['wave']);
-      server.addEventListener('close', () => {
-        this.sockets.delete(server);
-        this.notify(`WS disconnected. Sockets: ${this.sockets.size}`, 2, ['end']);
-      });
+      server.addEventListener('close', () => this.sockets.delete(server));
       server.addEventListener('message', e => this.state.waitUntil(this.onMessage(server, e)));
       return new Response(null, { status: 101, webSocket: client });
     }
@@ -342,7 +336,6 @@ export class MyDurableObject {
     try { this.oaStream?.controller?.abort(); } catch {}
     this.saveSnapshot();
     this.bcast({ type: 'done' });
-    this.notify(`Run ${this.rid} finished successfully`, 3, ['tada']);
     this.state.waitUntil(this.stopHeartbeat());
   }
 
@@ -366,9 +359,7 @@ export class MyDurableObject {
   }
 
   async stopHeartbeat() {
-    if (!this.hbActive) return;
     this.hbActive = false;
-    this.notify(`Heartbeat stopped`, 2, ['stop_sign']);
     await this.state.storage.setAlarm(null).catch(() => {});
   }