Channel pagination now uses provided value

Signed-off-by: Andrea Barberio <[email protected]>

pkg/ircslack/channels.go

@@ -11,14 +11,16 @@ import (
 
 // Channels wraps the channel list with convenient operations and cache.
 type Channels struct {
-	channels map[string]slack.Channel
-	mu       sync.Mutex
+	channels   map[string]slack.Channel
+	Pagination int
+	mu         sync.Mutex
 }
 
 // NewChannels creates a new Channels object.
-func NewChannels() *Channels {
+func NewChannels(pagination int) *Channels {
 	return &Channels{
-		channels: make(map[string]slack.Channel),
+		channels:   make(map[string]slack.Channel),
+		Pagination: pagination,
 	}
 }
 
@@ -45,7 +47,7 @@ func (c *Channels) Fetch(client *slack.Client) error {
 	)
 	start := time.Now()
 	params := slack.GetConversationsParameters{
-		Limit: 100,
+		Limit: c.Pagination,
 	}
 	for err == nil {
 		chans, nextCursor, err := client.GetConversationsContext(ctx, &params)

pkg/ircslack/channels_test.go

@@ -13,7 +13,7 @@ import (
 )
 
 func TestChannelsNewChannels(t *testing.T) {
-	u := NewChannels()
+	u := NewChannels(100)
 	require.NotNil(t, u)
 	assert.NotNil(t, u.channels)
 }
@@ -51,15 +51,15 @@ func (c fakeSlackHTTPClientChannels) Do(req *http.Request) (*http.Response, erro
 
 func TestChannelsFetch(t *testing.T) {
 	client := slack.New("test-token", slack.OptionHTTPClient(fakeSlackHTTPClientChannels{}))
-	channels := NewChannels()
+	channels := NewChannels(100)
 	err := channels.Fetch(client)
 	require.NoError(t, err)
 	assert.Equal(t, 1, channels.Count())
 }
 
 func TestChannelsById(t *testing.T) {
 	client := slack.New("test-token", slack.OptionHTTPClient(fakeSlackHTTPClientChannels{}))
-	channels := NewChannels()
+	channels := NewChannels(100)
 	err := channels.Fetch(client)
 	require.NoError(t, err)
 	u := channels.ByID("1234")
@@ -70,7 +70,7 @@ func TestChannelsById(t *testing.T) {
 
 func TestChannelsByName(t *testing.T) {
 	client := slack.New("test-token", slack.OptionHTTPClient(fakeSlackHTTPClientChannels{}))
-	channels := NewChannels()
+	channels := NewChannels(100)
 	err := channels.Fetch(client)
 	require.NoError(t, err)
 	u := channels.ByName("general")

pkg/ircslack/server.go

@@ -126,7 +126,7 @@ func (s *Server) HandleMsg(conn net.Conn, msg string) {
 				ProxyPrefix:          s.FileProxyPrefix,
 			},
 			Users:    NewUsers(s.Pagination),
-			Channels: NewChannels(),
+			Channels: NewChannels(s.Pagination),
 		}
 		go ctx.Start()
 		UserContexts[conn.RemoteAddr()] = ctx