Send event when ditto ping stops failing

mautrix · Sep 27, 2023 · e6f9c36 · e6f9c36
1 parent 6c98afb
commit e6f9c36
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/libgm/longpoll.go b/libgm/longpoll.go
@@ -25,12 +25,18 @@ const phoneNotRespondingTimeout = 30 * time.Second
 
 func (c *Client) doDittoPinger(log *zerolog.Logger, dittoPing <-chan struct{}, stopPinger <-chan struct{}) {
 	notResponding := false
+	pingFailed := false
 	exit := false
 	onRespond := func() {
 		if notResponding {
 			log.Debug().Msg("Ditto ping succeeded, phone is back online")
 			c.triggerEvent(&events.PhoneRespondingAgain{})
 			notResponding = false
+			pingFailed = false
+		} else if pingFailed {
+			// TODO separate event?
+			c.triggerEvent(&events.PhoneRespondingAgain{})
+			pingFailed = false
 		}
 	}
 	doPing := func() {
@@ -40,6 +46,7 @@ func (c *Client) doDittoPinger(log *zerolog.Logger, dittoPing <-chan struct{}, s
 			c.triggerEvent(&events.PingFailed{
 				Error: fmt.Errorf("failed to notify ditto activity: %w", err),
 			})
+			pingFailed = true
 			return
 		}
 		select {