Changeset 284 in code for trunk/upstream.go

Timestamp:

May 1, 2020, 1:18:14 PM (5 years ago)

Author:

contact

Message:

Add support for detached channels

Channels can now be detached by leaving them with the reason "detach",
and re-attached by joining them again. Upon detaching the channel is
no longer forwarded to downstream connections. Upon re-attaching the
history buffer is sent.

File:

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

trunk/upstream.go

@@ -1406 +1406 @@
 // appendHistory appends a message to the history. entity can be empty.
 func (uc *upstreamConn) appendHistory(entity string, msg *irc.Message) {
+        detached := false
+        if ch, ok := uc.network.channels[entity]; ok {
+                detached = ch.Detached
+        }
+
         // If no client is offline, no need to append the message to the buffer
-        if len(uc.network.offlineClients) == 0 {
+        if len(uc.network.offlineClients) == 0 && !detached {
                 return
         }
@@ -1421 +1426 @@
                 for clientName, _ := range uc.network.offlineClients {
                         history.offlineClients[clientName] = 0
+                }
+
+                if detached {
+                        // If the channel is detached, online clients act as offline
+                        // clients too
+                        uc.forEachDownstream(func(dc *downstreamConn) {
+                                history.offlineClients[dc.clientName] = 0
+                        })
                 }
         }
@@ -1439 +1452 @@
         uc.appendHistory(target, msg)
 
+        // Don't forward messages if it's a detached channel
+        if ch, ok := uc.network.channels[target]; ok && ch.Detached {
+                return
+        }
+
         uc.forEachDownstream(func(dc *downstreamConn) {
                 if dc != origin || dc.caps["echo-message"] {