diff options
author | Wim <wim@42.be> | 2019-04-20 23:06:06 +0200 |
---|---|---|
committer | Wim <wim@42.be> | 2019-04-23 23:28:28 +0200 |
commit | 1c3e764d572fdb0bc2a371028126a66b376e390e (patch) | |
tree | 046f0cf93afce00356c9f64da33b7b6ac9a32a87 /matterclient/users.go | |
parent | 0b03076a9dd411e567a06f231302f65d95e78c41 (diff) | |
download | matterbridge-msglm-1c3e764d572fdb0bc2a371028126a66b376e390e.tar.gz matterbridge-msglm-1c3e764d572fdb0bc2a371028126a66b376e390e.tar.bz2 matterbridge-msglm-1c3e764d572fdb0bc2a371028126a66b376e390e.zip |
Use paging in initUser and UpdateUsers (mattermost)
Diffstat (limited to 'matterclient/users.go')
-rw-r--r-- | matterclient/users.go | 21 |
1 files changed, 16 insertions, 5 deletions
diff --git a/matterclient/users.go b/matterclient/users.go index 11f22aa0..cf13e0df 100644 --- a/matterclient/users.go +++ b/matterclient/users.go @@ -2,6 +2,7 @@ package matterclient import ( "errors" + "time" "github.com/mattermost/mattermost-server/model" ) @@ -99,15 +100,25 @@ func (m *MMClient) GetUsers() map[string]*model.User { } func (m *MMClient) UpdateUsers() error { - mmusers, resp := m.Client.GetUsers(0, 50000, "") + idx := 0 + max := 200 + mmusers, resp := m.Client.GetUsers(idx, max, "") if resp.Error != nil { return errors.New(resp.Error.DetailedError) } - m.Lock() - for _, user := range mmusers { - m.Users[user.Id] = user + for len(mmusers) > 0 { + m.Lock() + for _, user := range mmusers { + m.Users[user.Id] = user + } + m.Unlock() + mmusers, resp = m.Client.GetUsers(idx, max, "") + time.Sleep(time.Millisecond * 300) + if resp.Error != nil { + return errors.New(resp.Error.DetailedError) + } + idx++ } - m.Unlock() return nil } |