refactor: share tavily tool helpers

extensions/tavily/src/tavily-client.ts

@@ -65,6 +65,27 @@ function resolveEndpoint(baseUrl: string, pathname: string): string {
   }
 }
 
+async function postTavilyJson(params: {
+  baseUrl: string;
+  pathname: "/extract" | "/search";
+  timeoutSeconds: number;
+  apiKey: string;
+  body: Record<string, unknown>;
+  errorLabel: string;
+}): Promise<Record<string, unknown>> {
+  return postTrustedWebToolsJson(
+    {
+      url: resolveEndpoint(params.baseUrl, params.pathname),
+      timeoutSeconds: params.timeoutSeconds,
+      apiKey: params.apiKey,
+      body: params.body,
+      errorLabel: params.errorLabel,
+      extraHeaders: { "X-Client-Source": "openclaw" },
+    },
+    async (response) => (await response.json()) as Record<string, unknown>,
+  );
+}
+
 export async function runTavilySearch(
   params: TavilySearchParams,
 ): Promise<Record<string, unknown>> {
@@ -124,17 +145,14 @@ export async function runTavilySearch(
   }
 
   const start = Date.now();
-  const payload = await postTrustedWebToolsJson(
-    {
-      url: resolveEndpoint(baseUrl, "/search"),
-      timeoutSeconds,
-      apiKey,
-      body,
-      errorLabel: "Tavily Search",
-      extraHeaders: { "X-Client-Source": "openclaw" },
-    },
-    async (response) => (await response.json()) as Record<string, unknown>,
-  );
+  const payload = await postTavilyJson({
+    baseUrl,
+    pathname: "/search",
+    timeoutSeconds,
+    apiKey,
+    body,
+    errorLabel: "Tavily Search",
+  });
 
   const rawResults = Array.isArray(payload.results) ? payload.results : [];
   const results = rawResults.map((r: Record<string, unknown>) =>
@@ -218,17 +236,14 @@ export async function runTavilyExtract(
   }
 
   const start = Date.now();
-  const payload = await postTrustedWebToolsJson(
-    {
-      url: resolveEndpoint(baseUrl, "/extract"),
-      timeoutSeconds,
-      apiKey,
-      body,
-      errorLabel: "Tavily Extract",
-      extraHeaders: { "X-Client-Source": "openclaw" },
-    },
-    async (response) => (await response.json()) as Record<string, unknown>,
-  );
+  const payload = await postTavilyJson({
+    baseUrl,
+    pathname: "/extract",
+    timeoutSeconds,
+    apiKey,
+    body,
+    errorLabel: "Tavily Extract",
+  });
 
   const rawResults = Array.isArray(payload.results) ? payload.results : [];
   const results = rawResults.map((r: Record<string, unknown>) =>

extensions/tavily/src/tavily-extract-tool.ts

@@ -6,19 +6,7 @@ import {
   readStringParam,
 } from "openclaw/plugin-sdk/provider-web-search";
 import { runTavilyExtract } from "./tavily-client.js";
-
-function optionalStringEnum<const T extends readonly string[]>(
-  values: T,
-  options: { description?: string } = {},
-) {
-  return Type.Optional(
-    Type.Unsafe<T[number]>({
-      type: "string",
-      enum: [...values],
-      ...options,
-    }),
-  );
-}
+import { optionalStringEnum } from "./tavily-tool-schema.js";
 
 const TavilyExtractToolSchema = Type.Object(
   {

extensions/tavily/src/tavily-search-tool.ts

@@ -6,19 +6,7 @@ import {
   readStringParam,
 } from "openclaw/plugin-sdk/provider-web-search";
 import { runTavilySearch } from "./tavily-client.js";
-
-function optionalStringEnum<const T extends readonly string[]>(
-  values: T,
-  options: { description?: string } = {},
-) {
-  return Type.Optional(
-    Type.Unsafe<T[number]>({
-      type: "string",
-      enum: [...values],
-      ...options,
-    }),
-  );
-}
+import { optionalStringEnum } from "./tavily-tool-schema.js";
 
 const TavilySearchToolSchema = Type.Object(
   {

extensions/tavily/src/tavily-tool-schema.ts

@@ -0,0 +1,14 @@
+import { Type } from "@sinclair/typebox";
+
+export function optionalStringEnum<const T extends readonly string[]>(
+  values: T,
+  options: { description?: string } = {},
+) {
+  return Type.Optional(
+    Type.Unsafe<T[number]>({
+      type: "string",
+      enum: [...values],
+      ...options,
+    }),
+  );
+}