import {z} from 'zod' export type IToolTypeEnum = 'system' | 'user'; export type IChannelProviderEnum = 'leadconnector' | 'hubspot' | 'google_calendar' | 'google_sheets' | 'zoho' | 'freshdesk' | 'insighto' | 'modmed' | 'twilio' | 'custom' | 'fb_messenger' | 'instagram' | 'paypal' | 'postgres' | 'plivo' | 'telnyx' | 'telegram' | 'calendar_pool'; export type IToolCategoryEnum = 'Calendar' | 'CRM' | 'EHR' | 'Support' | 'Communication' | 'System' | 'HRMS' | 'Social' | 'Others' | 'Payment' | 'Database' | 'MCP'; export type IToolCreate = {name: string | null, description: string | null, org_id?: (string | null) | undefined, tool_type: IToolTypeEnum | null, authentication: {[key: string]: unknown}, sdk: {[key: string]: unknown}, base_url?: (string | null) | undefined, logo_url?: (string | null) | undefined, tool_provider: IChannelProviderEnum | null, enabled?: (boolean | null) | undefined, attributes?: ({[key: string]: unknown} | null) | undefined, category: IToolCategoryEnum | null, requires_feature?: (string | null) | undefined}; export type CreateApiApiV1ToolArgs = {body: IToolCreate}; export type CreateApiApiV1ToolOptions = {baseUrl: string, YourAPIKey?: string | undefined, fetch?: typeof fetch | undefined}; export const iToolTypeEnum = z.enum(["system", "user"]); export const iChannelProviderEnum = z.enum(["leadconnector", "hubspot", "google_calendar", "google_sheets", "zoho", "freshdesk", "insighto", "modmed", "twilio", "custom", "fb_messenger", "instagram", "paypal", "postgres", "plivo", "telnyx", "telegram", "calendar_pool"]); export const iToolCategoryEnum = z.enum(["Calendar", "CRM", "EHR", "Support", "Communication", "System", "HRMS", "Social", "Others", "Payment", "Database", "MCP"]); export const iToolCreate = z.object({name: z.string().nullable(), description: z.string().nullable(), org_id: z.string().nullable().optional(), tool_type: iToolTypeEnum.nullable(), authentication: z.record(z.string(), z.unknown()), sdk: z.record(z.string(), z.unknown()), base_url: z.string().nullable().optional(), logo_url: z.string().nullable().optional(), tool_provider: iChannelProviderEnum.nullable(), enabled: z.boolean().nullable().optional(), attributes: z.record(z.string(), z.unknown()).nullable().optional(), category: iToolCategoryEnum.nullable(), requires_feature: z.string().nullable().optional()}); export const iPostResponseBaseIToolCreate = z.object({message: z.string().nullable().optional(), meta: z.union([z.record(z.string(), z.unknown()), z.unknown()]).nullable().optional(), data: iToolCreate.nullable().optional()}); export const validateResponse = async ( schema: { readonly '~standard': { readonly validate: (value: unknown) => ({ readonly value: Output; readonly issues?: undefined } | { readonly issues: ReadonlyArray<{ readonly message: string; readonly path?: ReadonlyArray | undefined }> }) | Promise<{ readonly value: Output; readonly issues?: undefined } | { readonly issues: ReadonlyArray<{ readonly message: string; readonly path?: ReadonlyArray | undefined }> }> } }, value: unknown ): Promise => { const result = await schema['~standard'].validate(value) if (result.issues !== undefined) { const detail = result.issues .map(({ message, path }) => path?.length ? `${path.map((segment) => String(typeof segment === 'object' ? segment.key : segment)).join('.')}: ${message}` : message ) .join('; ') throw new Error(`Response does not match the schema: ${detail}`, { cause: { issues: result.issues } }) } return result.value }; /** * Create Tool * * POST /api/v1/tool * * Also accepts auth: HTTPBearer */ export const createApiApiV1Tool = async (args: CreateApiApiV1ToolArgs, options: CreateApiApiV1ToolOptions) => { const {baseUrl, fetch: fetchFn = fetch, YourAPIKey} = options ?? {} const query = new URLSearchParams() const headers = new Headers() headers.set('content-type', "application/json") headers.set('accept', "application/json") if (YourAPIKey !== undefined) query.set("api_key", YourAPIKey) const url = `${baseUrl.replace(/\/+$/, '')}/api/v1/tool${query.size > 0 ? `?${query}` : ''}` const res = await fetchFn(url, {method: "POST", headers, body: JSON.stringify(args.body)}) if (!res.ok) throw new Error(`Request failed with status ${res.status}`, {cause: {status: res.status, body: await res.text()}}) return validateResponse(iPostResponseBaseIToolCreate, await res.json()) };