Changeset 256 in code for trunk/downstream.go

Timestamp:

Apr 15, 2020, 9:29:15 AM (5 years ago)

Author:

contact

Message:

Add support for downstream batch & chathistory

File:

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

trunk/downstream.go

@@ -428 +428 @@
                 }
 
-                caps := []string{"message-tags", "server-time", "echo-message"}
+                caps := []string{"message-tags", "server-time", "echo-message", "batch"}
 
                 if dc.capVersion >= 302 {
@@ -481 +481 @@
 
                         switch name {
-                        case "sasl", "message-tags", "server-time", "echo-message":
+                        case "sasl", "message-tags", "server-time", "echo-message", "batch":
                                 dc.caps[name] = enable
                         default:
@@ -717 +717 @@
                 }
 
+                batchRef := "history"
+                if dc.caps["batch"] {
+                        dc.SendMessage(&irc.Message{
+                                Prefix:  dc.srv.prefix(),
+                                Command: "BATCH",
+                                Params:  []string{"+" + batchRef, "chathistory", dc.marshalEntity(uc, target)},
+                        })
+                }
+
                 for {
                         msg := consumer.Consume()
@@ -735 +744 @@
                         }
 
+                        if dc.caps["batch"] {
+                                msg = msg.Copy()
+                                msg.Tags["batch"] = irc.TagValue(batchRef)
+                        }
+
                         dc.SendMessage(dc.marshalMessage(msg, uc))
+                }
+
+                if dc.caps["batch"] {
+                        dc.SendMessage(&irc.Message{
+                                Prefix:  dc.srv.prefix(),
+                                Command: "BATCH",
+                                Params:  []string{"-" + batchRef},
+                        })
                 }
         }