fix: change the tool result from NewToolResultStructured to NewToolResultText since there are a number of ai agents like opencode that does not support structured response

Author: thenodon

tools/parseable_info.go

@@ -2,6 +2,8 @@ package tools
 
 import (
 	"context"
+	"fmt"
+	"strings"
 
 	"github.com/mark3labs/mcp-go/mcp"
 	"github.com/mark3labs/mcp-go/server"
@@ -32,17 +34,13 @@ Returned fields:
 		if err != nil {
 			return mcp.NewToolResultError("failed to get info: " + err.Error()), nil
 		}
-		fieldDescriptions := map[string]interface{}{
-			"createdAt":     "When the data stream was created (ISO 8601)",
-			"firstEventAt":  "Timestamp of the first event (ISO 8601)",
-			"latestEventAt": "Timestamp of the latest event (ISO 8601)",
-			"streamType":    "Type of data stream (e.g. UserDefined)",
-			"logSource":     "Array of log source objects",
-			"telemetryType": "Type of telemetry - logs, metrics or traces",
+		// Default: return as text
+		var lines []string
+		for k, v := range info {
+			lines = append(lines, k+": "+fmt.Sprintf("%v", v))
 		}
-		return mcp.NewToolResultStructured(map[string]interface{}{
-			"info":              info,
-			"fieldDescriptions": fieldDescriptions,
-		}, "Info returned"), nil
+		return mcp.NewToolResultText(strings.Join(lines, "\n")), nil
+		// Optionally, for structured output:
+		// return mcp.NewToolResultStructured(map[string]interface{}{"info": info}, "Info returned"), nil
 	})
 }

tools/parseable_list_stats.go

@@ -2,6 +2,8 @@ package tools
 
 import (
 	"context"
+	"fmt"
+	"strings"
 
 	"github.com/mark3labs/mcp-go/mcp"
 	"github.com/mark3labs/mcp-go/server"
@@ -39,28 +41,13 @@ Returned fields:
 		if err != nil {
 			return mcp.NewToolResultError("failed to get stats: " + err.Error()), nil
 		}
-		fieldDescriptions := map[string]interface{}{
-			"stream": "Data stream name",
-			"time":   "Stats timestamp (ISO 8601)",
-			"ingestion": map[string]string{
-				"count":          "Number of ingested records",
-				"size":           "Total bytes ingested",
-				"format":         "Data format (e.g. json)",
-				"lifetime_count": "Cumulative ingested records",
-				"lifetime_size":  "Cumulative ingested bytes",
-				"deleted_count":  "Number of deleted records",
-				"deleted_size":   "Bytes deleted",
-			},
-			"storage": map[string]string{
-				"size":          "Total bytes stored",
-				"format":        "Storage format (e.g. parquet)",
-				"lifetime_size": "Cumulative stored bytes",
-				"deleted_size":  "Bytes deleted from storage",
-			},
+		// Default: return as text
+		var lines []string
+		for k, v := range stats {
+			lines = append(lines, k+": "+fmt.Sprintf("%v", v))
 		}
-		return mcp.NewToolResultStructured(map[string]interface{}{
-			"stats":             stats,
-			"fieldDescriptions": fieldDescriptions,
-		}, "Stats returned"), nil
+		return mcp.NewToolResultText(strings.Join(lines, "\n")), nil
+		// Optionally, for structured output:
+		// return mcp.NewToolResultStructured(map[string]interface{}{"stats": stats}, "Stats returned"), nil
 	})
 }

tools/parseable_list_streams.go

@@ -2,6 +2,7 @@ package tools
 
 import (
 	"context"
+	"strings"
 
 	"github.com/mark3labs/mcp-go/mcp"
 	"github.com/mark3labs/mcp-go/server"
@@ -16,6 +17,8 @@ func RegisterListDataStreamsTool(mcpServer *server.MCPServer) {
 		if err != nil {
 			return mcp.NewToolResultError(err.Error()), nil
 		}
-		return mcp.NewToolResultStructured(map[string]interface{}{"streams": streams}, "Streams listed"), nil
+		//return mcp.NewToolResultStructured(map[string]interface{}{"streams": streams}, "Streams listed"), nil
+		return mcp.NewToolResultText(strings.Join(streams, "\n")), nil
+
 	})
 }

tools/parseable_query.go

@@ -4,6 +4,7 @@ import (
 	"bytes"
 	"context"
 	"encoding/json"
+	"fmt"
 	"io"
 	"net/http"
 
@@ -51,6 +52,9 @@ func RegisterQueryDataStreamTool(mcpServer *server.MCPServer) {
 		if err := json.Unmarshal(body, &result); err != nil {
 			return mcp.NewToolResultError("failed to parse parseable response"), nil
 		}
-		return mcp.NewToolResultStructured(map[string]interface{}{"result": result}, "Query successful"), nil
+		// Default: return as text
+		return mcp.NewToolResultText(fmt.Sprintf("%v", result)), nil
+		// Optionally, for structured output:
+		// return mcp.NewToolResultStructured(map[string]interface{}{"result": result}, "Query successful"), nil
 	})
 }