Skip to content

Commit cc05d16

Browse files
committed
client: update RefreshCAT to take a context
1 parent af1a723 commit cc05d16

2 files changed

Lines changed: 3 additions & 3 deletions

File tree

client.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -181,7 +181,7 @@ type Client struct {
181181
// separate library for all the non-e2ee-related stuff like logging in.
182182
// The library is currently embedded in mautrix-meta (https://github.com/mautrix/meta), but may be separated later.
183183
MessengerConfig *MessengerConfig
184-
RefreshCAT func() error
184+
RefreshCAT func(context.Context) error
185185
}
186186

187187
type groupMetaCache struct {

connectionevents.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -58,7 +58,7 @@ func (cli *Client) handleStreamError(node *waBinary.Node) {
5858
cli.Log.Infof("Got %s stream error, refreshing CAT before reconnecting...", code)
5959
cli.socketLock.RLock()
6060
defer cli.socketLock.RUnlock()
61-
err := cli.RefreshCAT()
61+
err := cli.RefreshCAT(ctx)
6262
if err != nil {
6363
cli.Log.Errorf("Failed to refresh CAT: %v", err)
6464
cli.expectDisconnect()
@@ -136,7 +136,7 @@ func (cli *Client) handleConnectFailure(node *waBinary.Node) {
136136
go cli.dispatchEvent(&events.ClientOutdated{})
137137
} else if reason == events.ConnectFailureCATInvalid || reason == events.ConnectFailureCATExpired {
138138
cli.Log.Infof("Got %d/%s connect failure, refreshing CAT before reconnecting...", int(reason), message)
139-
err := cli.RefreshCAT()
139+
err := cli.RefreshCAT(ctx)
140140
if err != nil {
141141
cli.Log.Errorf("Failed to refresh CAT: %v", err)
142142
cli.expectDisconnect()

0 commit comments

Comments
 (0)