Update pkg/mcp/internal/testutil/pulsar.go

freeznet · Copilot · web-flow · commit 15f9ced4dffe · 2026-01-05T14:59:09.000+08:00
Co-authored-by: Copilot &lt;175728472+Copilot@users.noreply.github.com&gt;
diff --git a/pkg/mcp/internal/testutil/pulsar.go b/pkg/mcp/internal/testutil/pulsar.go
@@ -141,12 +141,12 @@ func (h *PulsarTestHelper) CreateTopic(ctx context.Context, topic string, partit
 func (h *PulsarTestHelper) TopicExists(ctx context.Context, topic string) (bool, error) {
 	topicName, err := utils.GetTopicName(topic)
 	if err != nil {
-		return false, nil
+		return false, fmt.Errorf("invalid topic name %s: %w", topic, err)
 	}
 
 	_, err = h.adminClient.Topics().GetMetadata(*topicName)
 	if err != nil {
-		return false, nil // Assume doesn't exist
+		return false, fmt.Errorf("failed to get metadata for topic %s: %w", topic, err)
 	}
 	return true, nil
 }

Original file line number	Diff line number	Diff line change
`@@ -141,12 +141,12 @@ func (h *PulsarTestHelper) CreateTopic(ctx context.Context, topic string, partit`
`141`	`141`	`func (h *PulsarTestHelper) TopicExists(ctx context.Context, topic string) (bool, error) {`
`142`	`142`	`topicName, err := utils.GetTopicName(topic)`
`143`	`143`	`if err != nil {`
`144`		`- return false, nil`
	`144`	`+ return false, fmt.Errorf("invalid topic name %s: %w", topic, err)`
`145`	`145`	`}`
`146`	`146`
`147`	`147`	`_, err = h.adminClient.Topics().GetMetadata(*topicName)`
`148`	`148`	`if err != nil {`
`149`		`- return false, nil // Assume doesn't exist`
	`149`	`+ return false, fmt.Errorf("failed to get metadata for topic %s: %w", topic, err)`
`150`	`150`	`}`
`151`	`151`	`return true, nil`
`152`	`152`	`}`