seang96/gmessages
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages 1 Wiki Activity Actions

Refresh auth token in long polling loop

Browse source
This commit is contained in:
Tulir Asokan 2023-07-10 15:12:46 +03:00
parent 63effcbff6
commit fc0882f285
1 changed files with 9 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
libgm/rpc.go
View file

@ -31,6 +31,14 @@ func (r *RPC) ListenReceiveMessages(payload []byte) {
listenID := r.listenID listenID := r.listenID
errored := true errored := true
for r.listenID == listenID { for r.listenID == listenID {
if r.client.authData.DevicePair != nil && r.client.authData.AuthenticatedAt.Add(20*time.Hour).Before(time.Now()) {
r.client.Logger.Debug().Msg("Refreshing auth token before starting new long-polling request")
err := r.client.refreshAuthToken()
if err != nil {
r.client.Logger.Err(err).Msg("Error refreshing auth token")
return
}
}
r.client.Logger.Debug().Msg("Starting new long-polling request") r.client.Logger.Debug().Msg("Starting new long-polling request")
req, err := http.NewRequest("POST", util.RECEIVE_MESSAGES, bytes.NewReader(payload)) req, err := http.NewRequest("POST", util.RECEIVE_MESSAGES, bytes.NewReader(payload))
if err != nil { if err != nil {
@ -47,6 +55,7 @@ func (r *RPC) ListenReceiveMessages(payload []byte) {
continue continue
} }
if resp.StatusCode >= 400 && resp.StatusCode < 501 { if resp.StatusCode >= 400 && resp.StatusCode < 501 {
r.client.Logger.Error().Int("status_code", resp.StatusCode).Msg("Error making listen request")
r.client.triggerEvent(&events.ListenFatalError{Resp: resp}) r.client.triggerEvent(&events.ListenFatalError{Resp: resp})
return return
} else if resp.StatusCode >= 500 { } else if resp.StatusCode >= 500 {