Changeset 781 in code for trunk/upstream.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/upstream.go (modified) (2 diffs)

trunk/upstream.go

@@ -1338 +1338 @@
                 if c == nil || !c.Detached {
                         uc.forEachDownstream(func(dc *downstreamConn) {
-                                forwardChannel(dc, ch)
+                                forwardChannel(ctx, dc, ch)
                         })
                 }
@@ -1769 +1769 @@
         }
         if ch.ReattachOn == FilterMessage || (ch.ReattachOn == FilterHighlight && uc.network.isHighlight(msg)) {
-                uc.network.attach(ch)
+                uc.network.attach(ctx, ch)
                 if err := uc.srv.db.StoreChannel(ctx, uc.network.ID, ch); err != nil {
                         uc.logger.Printf("failed to update channel %q: %v", ch.Name, err)