Security: Sync from Public / sync-from-public (push) Has been cancelled
Test: Benchmark Nightly / build (push) Has been cancelled
Test: Benchmark Nightly / Notify Cats on failure (push) Has been cancelled
CI: Python / Checks (push) Has been cancelled
Test: Evals Python / Workflow Comparison Python (push) Has been cancelled
Util: Check Docs URLs / check-docs-urls (push) Has been cancelled
Test: Visual Storybook / Cloudflare Pages (push) Has been cancelled
Test: E2E Performance / build-and-test-performance (push) Has been cancelled
Test: Workflows Nightly / Run Workflow Tests (push) Has been cancelled
Util: Cleanup CI Docker Images / Delete stale CI images (push) Has been cancelled
Test: Benchmark Destroy Env / build (push) Has been cancelled
Util: Update Node Popularity / update-popularity (push) Has been cancelled
Test: E2E Coverage Weekly / Coverage Tests (push) Has been cancelled
64 lines
2.0 KiB
TypeScript
64 lines
2.0 KiB
TypeScript
import { jsonSchemaToZod } from '@n8n/json-schema-to-zod';
|
|
import { json as generateJsonSchema } from 'generate-schema';
|
|
import type { SchemaObject } from 'generate-schema';
|
|
import type { JSONSchema7 } from 'json-schema';
|
|
import type { IExecuteFunctions } from 'n8n-workflow';
|
|
import { NodeOperationError, jsonParse } from 'n8n-workflow';
|
|
import type { z } from 'zod';
|
|
|
|
function makeAllPropertiesRequired(schema: JSONSchema7): JSONSchema7 {
|
|
function isPropertySchema(property: unknown): property is JSONSchema7 {
|
|
return typeof property === 'object' && property !== null && 'type' in property;
|
|
}
|
|
|
|
// Handle object properties
|
|
if (schema.type === 'object' && schema.properties) {
|
|
const properties = Object.keys(schema.properties);
|
|
if (properties.length > 0) {
|
|
schema.required = properties;
|
|
}
|
|
|
|
for (const key of properties) {
|
|
if (isPropertySchema(schema.properties[key])) {
|
|
makeAllPropertiesRequired(schema.properties[key]);
|
|
}
|
|
}
|
|
}
|
|
|
|
// Handle arrays
|
|
if (schema.type === 'array' && schema.items && isPropertySchema(schema.items)) {
|
|
schema.items = makeAllPropertiesRequired(schema.items);
|
|
}
|
|
|
|
return schema;
|
|
}
|
|
|
|
export function generateSchemaFromExample(
|
|
exampleJsonString: string,
|
|
allFieldsRequired = false,
|
|
): JSONSchema7 {
|
|
const parsedExample = jsonParse<SchemaObject>(exampleJsonString);
|
|
|
|
const schema = generateJsonSchema(parsedExample) as JSONSchema7;
|
|
|
|
if (allFieldsRequired) {
|
|
return makeAllPropertiesRequired(schema);
|
|
}
|
|
|
|
return schema;
|
|
}
|
|
|
|
export function convertJsonSchemaToZod<T extends z.ZodTypeAny = z.ZodTypeAny>(schema: JSONSchema7) {
|
|
return jsonSchemaToZod<T>(schema);
|
|
}
|
|
|
|
export function throwIfToolSchema(ctx: IExecuteFunctions, error: Error) {
|
|
if (error?.message?.includes('tool input did not match expected schema')) {
|
|
throw new NodeOperationError(
|
|
ctx.getNode(),
|
|
`${error.message}.
|
|
This is most likely because some of your tools are configured to require a specific schema. This is not supported by Conversational Agent. Remove the schema from the tool configuration or use Tools agent instead.`,
|
|
);
|
|
}
|
|
}
|