add pubsub integration test for PubSub channels

Signed-off-by: jbrinkman <joe.brinkman@improving.com>

Author: jbrinkman

go/api/pubsub_commands.go

@@ -6,7 +6,10 @@ package api
 type PubSubCommands interface {
 	// Publish publishes a message to a channel. Returns the number of clients that received the message.
 	Publish(channel string, message string) (int64, error)
+	// PubSubChannels returns a list of all channels in the database.
 	PubSubChannels() ([]string, error)
+	// PubSubChannelsWithPattern returns a list of all channels that match the given pattern.
+	PubSubChannelsWithPattern(pattern string) ([]string, error)
 }
 
 // PubSubClusterCommands defines additional Pub/Sub operations available only in cluster mode.

go/integTest/pubsub_commands_test.go

@@ -0,0 +1,104 @@
+// Copyright Valkey GLIDE Project Contributors - SPDX Identifier: Apache-2.0
+
+package integTest
+
+import (
+	"sort"
+	"testing"
+	"time"
+
+	"github.com/stretchr/testify/assert"
+)
+
+// TestPubSubChannels tests the PubSubChannels command for standalone client
+func (suite *GlideTestSuite) TestPubSubChannels() {
+	tests := []struct {
+		name          string
+		clientType    ClientType
+		channelNames  []string
+		pattern       string
+		expectedNames []string
+	}{
+		{
+			name:          "Standalone Empty Pattern",
+			clientType:    GlideClient,
+			channelNames:  []string{"news.sports", "news.weather", "events.local"},
+			pattern:       "",
+			expectedNames: []string{"news.sports", "news.weather", "events.local"},
+		},
+		{
+			name:          "Standalone Exact Match",
+			clientType:    GlideClient,
+			channelNames:  []string{"news.sports", "news.weather", "events.local"},
+			pattern:       "news.sports",
+			expectedNames: []string{"news.sports"},
+		},
+		{
+			name:          "Standalone Glob Pattern",
+			clientType:    GlideClient,
+			channelNames:  []string{"news.sports", "news.weather", "events.local"},
+			pattern:       "news.*",
+			expectedNames: []string{"news.sports", "news.weather"},
+		},
+		{
+			name:          "Cluster Empty Pattern",
+			clientType:    GlideClusterClient,
+			channelNames:  []string{"cluster.news.sports", "cluster.news.weather", "cluster.events.local"},
+			pattern:       "",
+			expectedNames: []string{"cluster.news.sports", "cluster.news.weather", "cluster.events.local"},
+		},
+		{
+			name:          "Cluster Exact Match",
+			clientType:    GlideClusterClient,
+			channelNames:  []string{"cluster.news.sports", "cluster.news.weather", "cluster.events.local"},
+			pattern:       "cluster.news.sports",
+			expectedNames: []string{"cluster.news.sports"},
+		},
+		{
+			name:          "Cluster Glob Pattern",
+			clientType:    GlideClusterClient,
+			channelNames:  []string{"cluster.news.sports", "cluster.news.weather", "cluster.events.local"},
+			pattern:       "cluster.news.*",
+			expectedNames: []string{"cluster.news.sports", "cluster.news.weather"},
+		},
+	}
+
+	for _, tt := range tests {
+		suite.T().Run(tt.name, func(t *testing.T) {
+			// Skip cluster tests if cluster hosts are not available
+			if tt.clientType == 1 && len(suite.clusterHosts) == 0 {
+				t.Skip("Cluster not available")
+			}
+
+			// Create channel definitions for all channels
+			channels := make([]ChannelDefn, len(tt.channelNames))
+			for i, channelName := range tt.channelNames {
+				channels[i] = ChannelDefn{Channel: channelName, Mode: 0} // ExactMode
+			}
+
+			// Create a client with subscriptions
+			receiver := suite.CreatePubSubReceiver(tt.clientType, channels, 1, false)
+			defer receiver.Close()
+
+			// Allow subscription to establish
+			time.Sleep(MESSAGE_PROCESSING_DELAY * time.Millisecond)
+
+			// Get active channels
+			var activeChannels []string
+			var err error
+			if tt.pattern == "" {
+				activeChannels, err = receiver.PubSubChannels()
+			} else {
+				activeChannels, err = receiver.PubSubChannelsWithPattern(tt.pattern)
+			}
+			assert.NoError(t, err)
+
+			// Sort both slices for consistent comparison
+			sort.Strings(activeChannels)
+			sort.Strings(tt.expectedNames)
+
+			// Verify using the verification function
+			assert.Equal(t, tt.expectedNames, activeChannels)
+		})
+	}
+}