Changeset 684 in code for trunk/irc.go

Timestamp:

Nov 15, 2021, 1:34:04 PM (4 years ago)

Author:

contact

Message:

Add support for MONITOR

Add support for MONITOR in single-upstream mode.

Each downstream has its own set of monitored targets. These sets
are merged together to compute the MONITOR commands to send to
upstream.

Each upstream has a set of monitored targets accepted by the server
alongside with their status (online/offline). This is used to
directly send replies to downstreams adding a target another
downstream has already added, and send MONITOR S[TATUS] replies.

Co-authored-by: delthas <delthas@…>

File:

• trunk/irc.go (modified) (2 diffs)

trunk/irc.go

@@ -409 +409 @@
 }
 
+func generateMonitor(subcmd string, targets []string) []*irc.Message {
+        maxLength := maxMessageLength - len("MONITOR "+subcmd+" ")
+
+        var msgs []*irc.Message
+        var buf []string
+        n := 0
+        for _, target := range targets {
+                if n+len(target)+1 > maxLength {
+                        msgs = append(msgs, &irc.Message{
+                                Command: "MONITOR",
+                                Params:  []string{subcmd, strings.Join(buf, ",")},
+                        })
+                        buf = buf[:0]
+                        n = 0
+                }
+
+                buf = append(buf, target)
+                n += len(target) + 1
+        }
+
+        if len(buf) > 0 {
+                msgs = append(msgs, &irc.Message{
+                        Command: "MONITOR",
+                        Params:  []string{subcmd, strings.Join(buf, ",")},
+                })
+        }
+
+        return msgs
+}
+
 type joinSorter struct {
         channels []string
@@ -635 +665 @@
 }
 
+type monitorCasemapMap struct{ casemapMap }
+
+func (cm *monitorCasemapMap) Value(name string) (online bool) {
+        entry, ok := cm.innerMap[cm.casemap(name)]
+        if !ok {
+                return false
+        }
+        return entry.value.(bool)
+}
+
 func isWordBoundary(r rune) bool {
         switch r {