get conversation: change limit parameter and retry for rate limit

bcicen · Jun 24, 2021 · 7dd9205 · 7dd9205
1 parent 6025ea4
commit 7dd9205
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/api.go b/api.go
@@ -2,6 +2,7 @@ package main
 
 import (
 	"fmt"
+	"time"
 
 	"github.com/slack-go/slack"
 )
@@ -91,9 +92,15 @@ func getConversations(types ...string) (list []slack.Channel, err error) {
 			Cursor:          cursor,
 			ExcludeArchived: "true",
 			Types:           types,
+			Limit:           1000,
 		}
 		channels, cur, err := api.GetConversations(param)
 		if err != nil {
+			if rateLimitedError, ok := err.(*slack.RateLimitedError); ok {
+				output(fmt.Sprintf("%v", rateLimitedError))
+				time.Sleep(rateLimitedError.RetryAfter)
+				continue
+			}
 			return list, err
 		}
 		list = append(list, channels...)