natsim

commit d541a4747e328e09c841fb277dab31c6cd415d27
parent 2eff215f97581e6de9d61848782e47b3710f32a2
Author: Natasha Kerensikova <natgh@instinctive.eu>
Date:   Wed, 18 Jun 2025 18:40:59 +0000

NATS subscriptions are streamlined
Diffstat:
M
main.go
 | 
13
+++++--------

1 file changed, 5 insertions(+), 8 deletions(-)
diff --git a/main.go b/main.go
@@ -193,13 +193,6 @@ func (natsim *NatsIM) doCommands() {
 			natsim.irc.QuitMessage = cmd.arg
 			natsim.Close()
 
-		case "subscribeAll":
-			for _, subject := range natsim.Nats.Subjects {
-				if _, err := natsim.nc.Subscribe(subject, natsim.natsReceive); err != nil {
-					natsim.ircSendError("Subscribe", err)
-				}
-			}
-
 		case "version":
 			natsim.ircSendf("natsim %s", version)
 
@@ -233,7 +226,11 @@ func (natsim *NatsIM) ircJoined(e *irc.Event) {
 		return
 	}
 
-	natsim.cmdQueue <- command{name: "subscribeAll", arg: ""}
+	for _, subject := range natsim.Nats.Subjects {
+		if _, err := natsim.nc.Subscribe(subject, natsim.natsReceive); err != nil {
+			natsim.ircSendError("Subscribe", err)
+		}
+	}
 }
 
 func (natsim *NatsIM) ircReceive(e *irc.Event) {