fix(parallel): use truncateUtf16Safe for MCP error JSON truncation

Pandah97 · Pandah97 · commit a8ca21b1414e · 2026-07-09T17:05:03.000+08:00
The extractMcpToolPayload function and error messages use naive
.slice(0, 500) on JSON-serialized errors and results which can split
surrogate pairs. Replace with truncateUtf16Safe().
diff --git a/extensions/parallel/src/parallel-mcp-search.runtime.ts b/extensions/parallel/src/parallel-mcp-search.runtime.ts
@@ -7,6 +7,7 @@ import {
 } from "openclaw/plugin-sdk/provider-http";
 import { withTrustedWebSearchEndpoint } from "openclaw/plugin-sdk/provider-web-search";
 import { isRecord } from "openclaw/plugin-sdk/string-coerce-runtime";
+import { truncateUtf16Safe } from "openclaw/plugin-sdk/text-utility-runtime";
 
 // Free hosted Search MCP. This keyless transport is used only after the user
 // explicitly selects the `parallel-free` web_search provider. Docs:
@@ -154,11 +155,13 @@ export function selectMcpEnvelope(text: string, requestId: string): JsonRpcMessa
  */
 export function extractMcpToolPayload(envelope: JsonRpcMessage): McpToolPayload {
   if ("error" in envelope) {
-    throw new Error(`Parallel MCP error: ${JSON.stringify(envelope.error).slice(0, 500)}`);
+    throw new Error(
+      `Parallel MCP error: ${truncateUtf16Safe(JSON.stringify(envelope.error), 500)}`,
+    );
   }
   const result = isRecord(envelope.result) ? envelope.result : {};
   if (result.isError) {
-    throw new Error(`Parallel MCP tool error: ${JSON.stringify(result).slice(0, 500)}`);
+    throw new Error(`Parallel MCP tool error: ${truncateUtf16Safe(JSON.stringify(result), 500)}`);
   }
   if (isRecord(result.structuredContent)) {
     return result.structuredContent;
@@ -177,7 +180,7 @@ export function extractMcpToolPayload(envelope: JsonRpcMessage): McpToolPayload
     }
   }
   throw new Error(
-    `Parallel MCP returned no parseable content: ${JSON.stringify(result).slice(0, 500)}`,
+    `Parallel MCP returned no parseable content: ${truncateUtf16Safe(JSON.stringify(result), 500)}`,
   );
 }
 

Original file line number	Diff line number	Diff line change
`@@ -7,6 +7,7 @@ import {`
`7`	`7`	`} from "openclaw/plugin-sdk/provider-http";`
`8`	`8`	`import { withTrustedWebSearchEndpoint } from "openclaw/plugin-sdk/provider-web-search";`
`9`	`9`	`import { isRecord } from "openclaw/plugin-sdk/string-coerce-runtime";`
	`10`	`+import { truncateUtf16Safe } from "openclaw/plugin-sdk/text-utility-runtime";`
`10`	`11`
`11`	`12`	`// Free hosted Search MCP. This keyless transport is used only after the user`
`12`	`13`	// explicitly selects the `parallel-free` web_search provider. Docs:
`@@ -154,11 +155,13 @@ export function selectMcpEnvelope(text: string, requestId: string): JsonRpcMessa`
`154`	`155`	`*/`
`155`	`156`	`export function extractMcpToolPayload(envelope: JsonRpcMessage): McpToolPayload {`
`156`	`157`	`if ("error" in envelope) {`
`157`		- throw new Error(`Parallel MCP error: ${JSON.stringify(envelope.error).slice(0, 500)}`);
	`158`	`+ throw new Error(`
	`159`	+ `Parallel MCP error: ${truncateUtf16Safe(JSON.stringify(envelope.error), 500)}`,
	`160`	`+ );`
`158`	`161`	`}`
`159`	`162`	`const result = isRecord(envelope.result) ? envelope.result : {};`
`160`	`163`	`if (result.isError) {`
`161`		- throw new Error(`Parallel MCP tool error: ${JSON.stringify(result).slice(0, 500)}`);
	`164`	+ throw new Error(`Parallel MCP tool error: ${truncateUtf16Safe(JSON.stringify(result), 500)}`);
`162`	`165`	`}`
`163`	`166`	`if (isRecord(result.structuredContent)) {`
`164`	`167`	`return result.structuredContent;`
`@@ -177,7 +180,7 @@ export function extractMcpToolPayload(envelope: JsonRpcMessage): McpToolPayload`
`177`	`180`	`}`
`178`	`181`	`}`
`179`	`182`	`throw new Error(`
`180`		- `Parallel MCP returned no parseable content: ${JSON.stringify(result).slice(0, 500)}`,
	`183`	+ `Parallel MCP returned no parseable content: ${truncateUtf16Safe(JSON.stringify(result), 500)}`,
`181`	`184`	`);`
`182`	`185`	`}`
`183`	`186`