status-im/status-console-client
2
0
Fork 0
mirror of https://github.com/status-im/status-console-client.git synced 2025-02-23 16:18:23 +00:00
Code Issues Projects Releases Wiki Activity

Check if response returned cursor when making paginated request (#41)

Browse Source
This commit is contained in:
Dmitry Shulyak 2019-05-17 11:21:56 +03:00 committed by GitHub
parent a17396e618
commit a8314adb0b
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
protocol/adapters/whisper_service.go
View File

@ -329,27 +329,31 @@ func (a *WhisperServiceAdapter) requestMessages(ctx context.Context, req shhext.
shhextAPI := shhext.NewPublicAPI(shhextService)
log.Printf("[WhisperServiceAdapter::requestMessages] request for a chunk with %d messages\n", req.Limit)
start := time.Now()
resp, err = shhextAPI.RequestMessagesSync(shhext.RetryConfig{
BaseTimeout: time.Second * 10,
StepTimeout: time.Second,
MaxRetries: 3,
}, req)
if err != nil {
log.Printf("[WhisperServiceAdapter::requestMessages] timed out. err %v\n", err)
return
}
log.Printf("[WhisperServiceAdapter::requestMessages] delivery for %d message took %v\n", req.Limit, time.Since(start))
log.Printf("[WhisperServiceAdapter::requestMessages] response = %+v, err = %v", resp, err)
log.Printf("[WhisperServiceAdapter::requestMessages] response = %+v, err = %v\n", resp, err)
if resp.Error != nil {
err = resp.Error
return
}
if !followCursor || req.Cursor == "" {
if !followCursor || resp.Cursor == "" {
return
}
req.Cursor = resp.Cursor
log.Printf("[WhisperServiceAdapter::requestMessages] request messages with cursor %v\n", req.Cursor)
return a.requestMessages(ctx, req, true)
}