Changeset 194 in code for trunk/downstream.go

Timestamp:

Mar 31, 2020, 5:50:31 PM (5 years ago)

Author:

contact

Message:

Add downstream support for server-time

File:

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

trunk/downstream.go

@@ -445 +445 @@
                 }
 
-                var caps []string
+                caps := []string{"message-tags", "server-time"}
+
                 if dc.capVersion >= 302 {
                         caps = append(caps, "sasl=PLAIN")
@@ -451 +452 @@
                         caps = append(caps, "sasl")
                 }
-
-                caps = append(caps, "message-tags")
 
                 // TODO: multi-line replies
@@ -499 +498 @@
 
                         switch name {
-                        case "sasl", "message-tags":
+                        case "sasl", "message-tags", "server-time":
                                 dc.caps[name] = enable
                         default:
@@ -734 +733 @@
         // TODO: can't be enabled/disabled on-the-fly
         msgTagsEnabled := dc.caps["message-tags"]
+        serverTimeEnabled := dc.caps["server-time"]
 
         consumer, ch := net.ring.NewConsumer(seqPtr)
@@ -774 +774 @@
 
                                         if !msgTagsEnabled {
-                                                msg.Tags = nil
+                                                for name := range msg.Tags {
+                                                        supported := false
+                                                        switch name {
+                                                        case "time":
+                                                                supported = serverTimeEnabled
+                                                        }
+                                                        if !supported {
+                                                                delete(msg.Tags, name)
+                                                        }
+                                                }
                                         }