Changeset 140 in code for trunk/downstream.go

Timestamp:

Mar 25, 2020, 8:47:26 AM (5 years ago)

Author:

delthas

Message:

Add downstream NAMES support

NAMES reply for channels currently joined will be returned from cache;
requests for channels not joined will be forwarded from upstream.

File:

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

trunk/downstream.go

@@ -914 +914 @@
                         })
                 }
+        case "NAMES":
+                if len(msg.Params) == 0 {
+                        dc.SendMessage(&irc.Message{
+                                Prefix:  dc.srv.prefix(),
+                                Command: irc.RPL_ENDOFNAMES,
+                                Params:  []string{dc.nick, "*", "End of /NAMES list"},
+                        })
+                        return nil
+                }
+
+                channels := strings.Split(msg.Params[0], ",")
+                for _, channel := range channels {
+                        uc, upstreamChannel, err := dc.unmarshalEntity(channel)
+                        if err != nil {
+                                return err
+                        }
+
+                        ch, ok := uc.channels[upstreamChannel]
+                        if ok {
+                                sendNames(dc, ch)
+                        } else {
+                                // NAMES on a channel we have not joined, ask upstream
+                                uc.SendMessage(&irc.Message{
+                                        Command: "NAMES",
+                                        Params:  []string{upstreamChannel},
+                                })
+                        }
+                }
         case "WHO":
                 if len(msg.Params) == 0 {
@@ -920 +948 @@
                                 Prefix:  dc.srv.prefix(),
                                 Command: irc.RPL_ENDOFWHO,
-                                Params:  []string{dc.nick, "*", "End of /WHO list."},
+                                Params:  []string{dc.nick, "*", "End of /WHO list"},
                         })
                         return nil