added default policies for the search commands

Author: htemelski-redis

command_policy_manager.go

@@ -1,12 +1,114 @@
 package redis
 
 import (
+	"strings"
 	"sync"
 
 	"github.com/redis/go-redis/v9/internal/routing"
 )
 
-var defaultPolicies = map[string]*routing.CommandPolicy{}
+var defaultPolicies = map[string]*routing.CommandPolicy{
+	"ft.create": {
+		Request:  routing.ReqDefault,
+		Response: routing.RespDefaultKeyless,
+	},
+	"ft.search": {
+		Request:  routing.ReqDefault,
+		Response: routing.RespDefaultKeyless,
+	},
+	"ft.aggregate": {
+		Request:  routing.ReqDefault,
+		Response: routing.RespDefaultKeyless,
+	},
+	"ft.dictadd": {
+		Request:  routing.ReqDefault,
+		Response: routing.RespDefaultKeyless,
+	},
+	"ft.dictdump": {
+		Request:  routing.ReqDefault,
+		Response: routing.RespDefaultKeyless,
+	},
+	"ft.dictdel": {
+		Request:  routing.ReqDefault,
+		Response: routing.RespDefaultKeyless,
+	},
+	"ft.suglen": {
+		Request:  routing.ReqDefault,
+		Response: routing.RespDefaultHashSlot,
+	},
+	"ft.cursor": {
+		Request:  routing.ReqSpecial,
+		Response: routing.RespDefaultKeyless,
+	},
+	"ft.sugadd": {
+		Request:  routing.ReqDefault,
+		Response: routing.RespDefaultHashSlot,
+	},
+	"ft.sugget": {
+		Request:  routing.ReqDefault,
+		Response: routing.RespDefaultHashSlot,
+	},
+	"ft.sugdel": {
+		Request:  routing.ReqDefault,
+		Response: routing.RespDefaultHashSlot,
+	},
+	"ft.spellcheck": {
+		Request:  routing.ReqDefault,
+		Response: routing.RespDefaultKeyless,
+	},
+	"ft.explain": {
+		Request:  routing.ReqDefault,
+		Response: routing.RespDefaultKeyless,
+	},
+	"ft.explaincli": {
+		Request:  routing.ReqDefault,
+		Response: routing.RespDefaultKeyless,
+	},
+	"ft.aliasadd": {
+		Request:  routing.ReqDefault,
+		Response: routing.RespDefaultKeyless,
+	},
+	"ft.aliasupdate": {
+		Request:  routing.ReqDefault,
+		Response: routing.RespDefaultKeyless,
+	},
+	"ft.aliasdel": {
+		Request:  routing.ReqDefault,
+		Response: routing.RespDefaultKeyless,
+	},
+	"ft.info": {
+		Request:  routing.ReqDefault,
+		Response: routing.RespDefaultKeyless,
+	},
+	"ft.tagvals": {
+		Request:  routing.ReqDefault,
+		Response: routing.RespDefaultKeyless,
+	},
+	"ft.syndump": {
+		Request:  routing.ReqDefault,
+		Response: routing.RespDefaultKeyless,
+	},
+	"ft.synupdate": {
+		Request:  routing.ReqDefault,
+		Response: routing.RespDefaultKeyless,
+	},
+	"ft.profile": {
+		Request:  routing.ReqDefault,
+		Response: routing.RespDefaultKeyless,
+	},
+	"ft.alter": {
+		Request:  routing.ReqDefault,
+		Response: routing.RespDefaultKeyless,
+	},
+	"ft.dropindex": {
+		Request:  routing.ReqDefault,
+		Response: routing.RespDefaultKeyless,
+	},
+	"ft.drop": {
+		Request:  routing.ReqDefault,
+		Response: routing.RespDefaultKeyless,
+	},
+}
 
 type commandPolicyManager struct {
 	rwmutex             *sync.RWMutex
@@ -15,10 +117,12 @@ type commandPolicyManager struct {
 }
 
 func newCommandPolicyManager(overwrites interface{}) *commandPolicyManager {
+	// TODO: To be implemented in the next req-resp development stage
 	return &commandPolicyManager{}
 }
 
 func (cpm *commandPolicyManager) updateClientPolicies(policies interface{}) {
+	// TODO: To be implemented in the next req-resp development stage
 	cpm.rwmutex.Lock()
 	defer cpm.rwmutex.Unlock()
 }
@@ -27,8 +131,7 @@ func (cpm *commandPolicyManager) getCmdPolicy(cmd Cmder) *routing.CommandPolicy
 	cpm.rwmutex.RLock()
 	defer cpm.rwmutex.RUnlock()
 
-	cmdName := cmd.Name()
-
+	cmdName := strings.ToLower(cmd.Name())
 	if policy, ok := cpm.overwrittenPolicies[cmdName]; ok {
 		return policy
 	}

osscluster_router.go

@@ -37,16 +37,6 @@ func (c *ClusterClient) routeAndRun(ctx context.Context, cmd Cmder, node *cluste
 	}
 }
 
-// getCommandPolicy retrieves the routing policy for a command
-func (c *ClusterClient) getCommandPolicy(cmd Cmder) *routing.CommandPolicy {
-
-	return c.cmdPolicyManager.getCmdPolicy(cmd)
-	// if cmdInfo := c.cmdInfo(ctx, cmd.Name()); cmdInfo != nil && cmdInfo.Tips != nil {
-	// 	return cmdInfo.Tips
-	// }
-	// return nil
-}
-
 // executeDefault handles standard command routing based on keys
 func (c *ClusterClient) executeDefault(ctx context.Context, cmd Cmder, node *clusterNode) error {
 	if c.hasKeys(cmd) {