connector: properly send bridge states

Author: slice

pkg/connector/client.go

@@ -41,8 +41,18 @@ func NewClient(userLogin *bridgev2.UserLogin, client *gchatmeow.Client) *GChatCl
 }
 
 func (c *GChatClient) Connect(ctx context.Context) {
-	c.client.OnConnect.AddObserver(func(interface{}) { c.onConnect(ctx) })
-	c.client.OnStreamEvent.AddObserver(func(evt interface{}) { c.onStreamEvent(ctx, evt) })
+	c.client.OnConnect.AddObserver(func(any) {
+		c.userLogin.BridgeState.Send(status.BridgeState{
+			StateEvent: status.StateConnected,
+		})
+		c.onConnect(ctx)
+	})
+	c.client.OnDisconnect.AddObserver(func(any) {
+		c.userLogin.BridgeState.Send(status.BridgeState{
+			StateEvent: status.StateTransientDisconnect,
+		})
+	})
+	c.client.OnStreamEvent.AddObserver(func(evt any) { c.onStreamEvent(ctx, evt) })
 
 	err := c.client.Connect(ctx, time.Duration(90)*time.Minute)
 	if err != nil {

pkg/gchatmeow/channel.go

@@ -51,7 +51,9 @@ type Channel struct {
 	ofs              int
 	rid              int
 
-	OnConnect      *Event
+	// Fired when receiving data from the channel for the first time. This is only ever fired once.
+	OnConnect *Event
+	// Fired when a connection is re-established. This can be fired multiple times.
 	OnReconnect    *Event
 	OnDisconnect   *Event
 	OnReceiveArray *Event