Refactor Pulsar Admin Tools to Remove Redundant Alias for Utils

- Removed the alias for the `utils` package in multiple files, simplifying imports and improving code clarity.
- Updated references to use the direct `utils` package instead of the alias, ensuring consistency across the codebase.
- Enhanced readability by streamlining the import statements and maintaining a clear structure.

Author: freeznet

pkg/mcp/pftools/invocation.go

@@ -27,7 +27,7 @@ import (
 	"time"
 
 	"github.com/apache/pulsar-client-go/pulsar"
-	cliutils "github.com/apache/pulsar-client-go/pulsaradmin/pkg/utils"
+	"github.com/apache/pulsar-client-go/pulsaradmin/pkg/utils"
 	"github.com/mark3labs/mcp-go/mcp"
 	"github.com/streamnative/streamnative-mcp-server/pkg/schema"
 )
@@ -259,20 +259,20 @@ func (fi *FunctionInvoker) unregisterResultChannel(messageID string) {
 
 func isCorrelationInputTopic(correlationInputTopic string, inputTopic string) bool {
 	// remove the partition index from the input topic
-	if strings.Contains(correlationInputTopic, cliutils.PARTITIONEDTOPICSUFFIX) {
-		correlationInputTopic = strings.Split(correlationInputTopic, cliutils.PARTITIONEDTOPICSUFFIX)[0]
+	if strings.Contains(correlationInputTopic, utils.PARTITIONEDTOPICSUFFIX) {
+		correlationInputTopic = strings.Split(correlationInputTopic, utils.PARTITIONEDTOPICSUFFIX)[0]
 	}
 
 	// remove the partition index from the input topic
-	if strings.Contains(inputTopic, cliutils.PARTITIONEDTOPICSUFFIX) {
-		inputTopic = strings.Split(inputTopic, cliutils.PARTITIONEDTOPICSUFFIX)[0]
+	if strings.Contains(inputTopic, utils.PARTITIONEDTOPICSUFFIX) {
+		inputTopic = strings.Split(inputTopic, utils.PARTITIONEDTOPICSUFFIX)[0]
 	}
 
-	correlationInputTopicName, err := cliutils.GetTopicName(correlationInputTopic)
+	correlationInputTopicName, err := utils.GetTopicName(correlationInputTopic)
 	if err != nil {
 		return false
 	}
-	inputTopicName, err := cliutils.GetTopicName(inputTopic)
+	inputTopicName, err := utils.GetTopicName(inputTopic)
 	if err != nil {
 		return false
 	}

pkg/mcp/pftools/manager.go

@@ -30,7 +30,6 @@ import (
 	"github.com/apache/pulsar-client-go/pulsaradmin/pkg/admin/config"
 	"github.com/apache/pulsar-client-go/pulsaradmin/pkg/rest"
 	"github.com/apache/pulsar-client-go/pulsaradmin/pkg/utils"
-	cliutils "github.com/apache/pulsar-client-go/pulsaradmin/pkg/utils"
 	"github.com/google/go-cmp/cmp"
 	"github.com/mark3labs/mcp-go/mcp"
 	"github.com/mark3labs/mcp-go/server"
@@ -50,7 +49,7 @@ var DefaultStringSchemaInfo = &SchemaInfo{
 	Definition: map[string]interface{}{
 		"type": "string",
 	},
-	PulsarSchemaInfo: &cliutils.SchemaInfo{
+	PulsarSchemaInfo: &utils.SchemaInfo{
 		Type: "STRING",
 	},
 }

pkg/mcp/pftools/schema.go

@@ -22,7 +22,7 @@ import (
 	"fmt"
 
 	"github.com/apache/pulsar-client-go/pulsar"
-	cliutils "github.com/apache/pulsar-client-go/pulsaradmin/pkg/utils"
+	"github.com/apache/pulsar-client-go/pulsaradmin/pkg/utils"
 	"github.com/mark3labs/mcp-go/mcp"
 	"github.com/streamnative/pulsarctl/pkg/cmdutils"
 )
@@ -42,7 +42,7 @@ func GetSchemaFromTopic(admin cmdutils.Client, topic string) (*SchemaInfo, error
 	if admin == nil {
 		return nil, fmt.Errorf("failed to get schema from topic '%s': mcp server is not initialized", topic)
 	}
-	topicName, err := cliutils.GetTopicName(topic)
+	topicName, err := utils.GetTopicName(topic)
 	if err != nil {
 		return nil, fmt.Errorf("failed to get topic name from topic '%s': %w", topic, err)
 	}