schema.ts•967 B
import { z } from 'zod'
import { zodToJsonSchema } from 'zod-to-json-schema'
export const zodInputSchema = z.object({
dataflowId: z.string()
.min(1, 'dataflowId is required')
.regex(/^\S+$/, 'dataflowId must not contain whitespace')
.describe('The ID of the data flow with a successful run'),
executionId: z.string()
.min(1, 'executionId is required')
.regex(/^\S+$/, 'executionId must be a non-empty string')
.describe('The ID of the last successful run (execution) of the data flow.'),
query: z.string()
.min(1, 'query is required')
.regex(/^SELECT.*?/, 'must start with "SELECT"')
.describe('The SQL query to run on the data flow sqlite file.'),
}).strict()
export const inputSchema = zodToJsonSchema(zodInputSchema)
const zodOutputSchema = z.object({
data: z.array(
z.record(z.unknown())
).describe('The data returned from the query.'),
}).strict()
export const outputSchema = zodToJsonSchema(zodOutputSchema)