Changeset 405 in code for trunk/upstream.go

Timestamp:

Aug 20, 2020, 9:12:54 AM (5 years ago)

Author:

hubert

Message:

Forward RPL_TOPICWHOTIME to downstreams

File:

• trunk/upstream.go (modified) (5 diffs)

trunk/upstream.go

@@ -43 +43 @@
         conn         *upstreamConn
         Topic        string
-        TopicWho     string
+        TopicWho     *irc.Prefix
         TopicTime    time.Time
         Status       channelStatus
@@ -843 +843 @@
                 }
         case "TOPIC":
+                if msg.Prefix == nil {
+                        return fmt.Errorf("expected a prefix")
+                }
+
                 var name string
                 if err := parseMessageParams(msg, &name); err != nil {
@@ -853 +857 @@
                 if len(msg.Params) > 1 {
                         ch.Topic = msg.Params[1]
+                        ch.TopicWho = msg.Prefix.Copy()
+                        ch.TopicTime = time.Now() // TODO use msg.Tags["time"]
                 } else {
                         ch.Topic = ""
@@ -984 +990 @@
                         return err
                 }
-                ch.TopicWho = who
+                firstTopicWhoTime := ch.TopicWho == nil
+                ch.TopicWho = irc.ParsePrefix(who)
                 sec, err := strconv.ParseInt(timeStr, 10, 64)
                 if err != nil {
@@ -990 +997 @@
                 }
                 ch.TopicTime = time.Unix(sec, 0)
+                if firstTopicWhoTime {
+                        uc.forEachDownstream(func(dc *downstreamConn) {
+                                topicWho := dc.marshalUserPrefix(uc.network, ch.TopicWho)
+                                dc.SendMessage(&irc.Message{
+                                        Prefix:  dc.srv.prefix(),
+                                        Command: rpl_topicwhotime,
+                                        Params: []string{
+                                                dc.nick,
+                                                dc.marshalEntity(uc.network, ch.Name),
+                                                topicWho.String(),
+                                                timeStr,
+                                        },
+                                })
+                        })
+                }
         case irc.RPL_LIST:
                 var channel, clients, topic string