Changeset 198 in code for trunk

Timestamp:

Apr 1, 2020, 10:16:32 AM (5 years ago)

Author:

contact

Message:

Auto away

Closes: ​https://todo.sr.ht/~emersion/soju/13

Location:

trunk

Files:

• upstream.go (modified) (3 diffs)
• user.go (modified) (3 diffs)

trunk/upstream.go

@@ -55 +55 @@
         caps       map[string]string
         batches    map[string]batch
+        away       bool
 
         tagsSupported   bool
@@ -1270 +1271 @@
         case "ACK":
                 // Ignore
+        case irc.RPL_NOWAWAY, irc.RPL_UNAWAY:
+                // Ignore
         case irc.RPL_YOURHOST, irc.RPL_CREATED:
                 // Ignore
@@ -1484 +1487 @@
         }
 }
+
+func (uc *upstreamConn) updateAway() {
+        away := true
+        uc.forEachDownstream(func(*downstreamConn) {
+                away = false
+        })
+        if away == uc.away {
+                return
+        }
+        if away {
+                uc.SendMessage(&irc.Message{
+                        Command: "AWAY",
+                        Params:  []string{"Auto away"},
+                })
+        } else {
+                uc.SendMessage(&irc.Message{
+                        Command: "AWAY",
+                })
+        }
+        uc.away = away
+}

trunk/user.go

@@ -176 +176 @@
                 switch e := e.(type) {
                 case eventUpstreamConnected:
-                        // Nothing to do
+                        uc := e.uc
+                        uc.updateAway()
                 case eventUpstreamDisconnected:
                         uc := e.uc
@@ -201 +202 @@
 
                         u.downstreamConns = append(u.downstreamConns, dc)
+
+                        u.forEachUpstream(func(uc *upstreamConn) {
+                                uc.updateAway()
+                        })
                 case eventDownstreamDisconnected:
                         dc := e.dc
@@ -209 +214 @@
                                 }
                         }
+
+                        u.forEachUpstream(func(uc *upstreamConn) {
+                                uc.updateAway()
+                        })
                 case eventDownstreamMessage:
                         msg, dc := e.msg, e.dc