Changeset 781 in code for trunk/bridge.go

Timestamp:

Feb 11, 2022, 6:41:46 PM (3 years ago)

Author:

delthas

Message:

Add support for the wip soju.im/read capability and READ command

READ lets downstream clients share information between each other about
what messages have been read by other downstreams.

Each target/entity has an optional corresponding read receipt, which is
stored as a timestamp.

• When a downstream sends: READ #chan timestamp=2020-01-01T01:23:45.000Z the read receipt for that target is set to that date
• soju sends READ to downstreams:
  • on JOIN, if the client uses the soju.im/read capability
  • when the read receipt timestamp is set by any downstream

The read receipt date is clamped by the previous receipt date and the
current time.

File:

• trunk/bridge.go (modified) (3 diffs)

trunk/bridge.go

@@ -2 +2 @@
 
 import (
+        "context"
+        "fmt"
         "strconv"
         "strings"
@@ -8 +10 @@
 )
 
-func forwardChannel(dc *downstreamConn, ch *upstreamChannel) {
+func forwardChannel(ctx context.Context, dc *downstreamConn, ch *upstreamChannel) {
         if !ch.complete {
                 panic("Tried to forward a partial channel")
@@ -17 +19 @@
                 sendTopic(dc, ch)
         }
+
+        if dc.caps["soju.im/read"] {
+                channelCM := ch.conn.network.casemap(ch.Name)
+                r, err := dc.srv.db.GetReadReceipt(ctx, ch.conn.network.ID, channelCM)
+                if err != nil {
+                        dc.logger.Printf("failed to get the read receipt for %q: %v", ch.Name, err)
+                } else {
+                        timestampStr := "*"
+                        if r != nil {
+                                timestampStr = fmt.Sprintf("timestamp=%s", r.Timestamp.UTC().Format(serverTimeLayout))
+                        }
+                        dc.SendMessage(&irc.Message{
+                                Prefix:  dc.prefix(),
+                                Command: "READ",
+                                Params:  []string{dc.marshalEntity(ch.conn.network, ch.Name), timestampStr},
+                        })
+                }
+        }
+
         sendNames(dc, ch)
 }