From ebb5e2c0f3772edc4bb9750220e3fcbd8fb0ba44 Mon Sep 17 00:00:00 2001
From: mleku <me@mleku.dev>
Date: Sun, 7 Sep 2025 23:35:01 +0100
Subject: [PATCH] Refactor `publisher` to clean up dead code, streamline event
 filtering, and optimize subscriber removal logic.

---
 app/publisher.go | 13 ++++---------
 1 file changed, 4 insertions(+), 9 deletions(-)

diff --git a/app/publisher.go b/app/publisher.go
index 1845cc1..daf692c 100644
--- a/app/publisher.go
+++ b/app/publisher.go
@@ -8,6 +8,7 @@ import (
 	"encoders.orly/envelopes/eventenvelope"
 	"encoders.orly/event"
 	"encoders.orly/filter"
+	"encoders.orly/kind"
 	"github.com/coder/websocket"
 	"interfaces.orly/publisher"
 	"interfaces.orly/typer"
@@ -165,11 +166,9 @@ func (p *P) Deliver(ev *event.E) {
 			if !subscriber.Match(ev) {
 				continue
 			}
-			// if p.Server.AuthRequired() {
-			// 	if !auth.CheckPrivilege(w.AuthedPubkey(), ev) {
-			// 		continue
-			// 	}
-			// }
+			if kind.IsPrivileged(ev.Kind) {
+
+			}
 			var res *eventenvelope.Result
 			if res, err = eventenvelope.NewResultWith(id, ev); chk.E(err) {
 				continue
@@ -198,7 +197,6 @@ func (p *P) Deliver(ev *event.E) {
 // removeSubscriberId removes a specific subscription from a subscriber
 // websocket.
 func (p *P) removeSubscriberId(ws *websocket.Conn, id string) {
-	p.Mx.Lock()
 	var subs map[string]Subscription
 	var ok bool
 	if subs, ok = p.Map[ws]; ok {
@@ -208,13 +206,10 @@ func (p *P) removeSubscriberId(ws *websocket.Conn, id string) {
 			delete(p.Map, ws)
 		}
 	}
-	p.Mx.Unlock()
 }
 
 // removeSubscriber removes a websocket from the P collection.
 func (p *P) removeSubscriber(ws *websocket.Conn) {
-	p.Mx.Lock()
 	clear(p.Map[ws])
 	delete(p.Map, ws)
-	p.Mx.Unlock()
 }