import z from "zod" import type { MessageV2 } from "../session/message-v2" export namespace Tool { interface Metadata { [key: string]: any } export type Context = { sessionID: string messageID: string agent: string abort: AbortSignal callID?: string extra?: { [key: string]: any } metadata(input: { title?: string; metadata?: M }): void } export interface Info { id: string init: () => Promise<{ description: string parameters: Parameters execute( args: z.infer, ctx: Context, ): Promise<{ title: string metadata: M output: string attachments?: MessageV2.FilePart[] }> formatValidationError?(error: z.ZodError): string }> } export type InferParameters = T extends Info ? z.infer

: never export type InferMetadata = T extends Info ? M : never export function define( id: string, init: Info["init"] | Awaited["init"]>>, ): Info { return { id, init: async () => { const toolInfo = init instanceof Function ? await init() : init const execute = toolInfo.execute toolInfo.execute = (args, ctx) => { try { toolInfo.parameters.parse(args) } catch (error) { if (error instanceof z.ZodError && toolInfo.formatValidationError) { throw new Error(toolInfo.formatValidationError(error), { cause: error }) } throw new Error( `The ${id} tool was called with invalid arguments: ${error}.\nPlease rewrite the input so it satisfies the expected schema.`, { cause: error }, ) } return execute(args, ctx) } return toolInfo }, } } }