{"version":3,"sources":["../src/server/schemas/processors.ts"],"names":["z"],"mappings":";;;;;AAGO,IAAM,qBAAA,GAAwBA,KAAE,MAAA,CAAO;AAAA,EAC5C,WAAA,EAAaA,IAAA,CAAE,MAAA,EAAO,CAAE,SAAS,qCAAqC;AACxE,CAAC;AAKM,IAAM,4BAAA,GAA+BA,KAAE,MAAA,CAAO;AAAA,EACnD,OAAA,EAASA,KAAE,MAAA,EAAO;AAAA,EAClB,SAAA,EAAWA,KAAE,MAAA,EAAO;AAAA,EACpB,MAAMA,IAAA,CAAE,IAAA,CAAK,CAAC,OAAA,EAAS,QAAQ,CAAC;AAClC,CAAC;AAKD,IAAM,gCAAA,GAAmCA,KAAE,MAAA,CAAO;AAAA,EAChD,OAAA,EAASA,KAAE,MAAA,EAAO;AAAA,EAClB,MAAMA,IAAA,CAAE,IAAA,CAAK,CAAC,OAAA,EAAS,QAAQ,CAAC;AAClC,CAAC,CAAA;AAKM,IAAM,yBAAA,GAA4BA,KAAE,MAAA,CAAO;AAAA,EAChD,EAAA,EAAIA,KAAE,MAAA,EAAO;AAAA,EACb,IAAA,EAAMA,IAAA,CAAE,MAAA,EAAO,CAAE,QAAA,EAAS;AAAA,EAC1B,WAAA,EAAaA,IAAA,CAAE,MAAA,EAAO,CAAE,QAAA,EAAS;AAAA,EACjC,MAAA,EAAQA,IAAA,CAAE,KAAA,CAAMA,IAAA,CAAE,IAAA,CAAK,CAAC,OAAA,EAAS,WAAA,EAAa,cAAA,EAAgB,cAAA,EAAgB,YAAY,CAAC,CAAC,CAAA;AAAA,EAC5F,QAAA,EAAUA,IAAA,CAAE,KAAA,CAAMA,IAAA,CAAE,QAAQ,CAAA;AAAA,EAC5B,cAAA,EAAgBA,IAAA,CAAE,KAAA,CAAM,gCAAgC,CAAA;AAAA,EACxD,UAAA,EAAYA,KAAE,OAAA;AAChB,CAAC;AAKM,IAAM,+BAAA,GAAkCA,KAAE,MAAA,CAAO;AAAA,EACtD,EAAA,EAAIA,KAAE,MAAA,EAAO;AAAA,EACb,IAAA,EAAMA,IAAA,CAAE,MAAA,EAAO,CAAE,QAAA,EAAS;AAAA,EAC1B,WAAA,EAAaA,IAAA,CAAE,MAAA,EAAO,CAAE,QAAA,EAAS;AAAA,EACjC,MAAA,EAAQA,IAAA,CAAE,KAAA,CAAMA,IAAA,CAAE,IAAA,CAAK,CAAC,OAAA,EAAS,WAAA,EAAa,cAAA,EAAgB,cAAA,EAAgB,YAAY,CAAC,CAAC,CAAA;AAAA,EAC5F,cAAA,EAAgBA,IAAA,CAAE,KAAA,CAAM,4BAA4B,CAAA;AAAA,EACpD,UAAA,EAAYA,KAAE,OAAA;AAChB,CAAC;AAKM,IAAM,+BAA+BA,IAAA,CAAE,MAAA,CAAOA,IAAA,CAAE,MAAA,IAAU,yBAAyB;AAK1F,IAAM,oBAAA,GAAuBA,KAC1B,MAAA,CAAO;AAAA,EACN,MAAA,EAAQA,IAAA,CAAE,OAAA,CAAQ,CAAC,EAAE,QAAA,EAAS;AAAA,EAC9B,OAAOA,IAAA,CAAE,KAAA,CAAMA,KAAE,GAAA,EAAK,EAAE,QAAA,EAAS;AAAA,EACjC,OAAA,EAASA,IAAA,CAAE,MAAA,EAAO,CAAE,QAAA;AACtB,CAAC,EACA,WAAA,EAAY;AAKf,IAAM,sBAAA,GAAyBA,KAC5B,MAAA,CAAO;AAAA,EACN,EAAA,EAAIA,KAAE,MAAA,EAAO;AAAA,EACb,IAAA,EAAMA,KAAE,IAAA,CAAK,CAAC,QAAQ,WAAA,EAAa,QAAA,EAAU,MAAA,EAAQ,QAAQ,CAAC,CAAA;AAAA,EAC9D,SAAA,EAAWA,IAAA,CAAE,MAAA,CAAO,IAAA,GAAO,QAAA,EAAS;AAAA,EACpC,OAAA,EAASA,KAAE,KAAA,CAAM,CAAC,sBAAsBA,IAAA,CAAE,MAAA,EAAQ,CAAC;AACrD,CAAC,EACA,WAAA,EAAY;AAKR,IAAM,0BAAA,GAA6BA,KAAE,MAAA,CAAO;AAAA,EACjD,KAAA,EAAOA,KAAE,IAAA,CAAK,CAAC,SAAS,WAAA,EAAa,cAAA,EAAgB,cAAA,EAAgB,YAAY,CAAC,CAAA;AAAA,EAClF,QAAA,EAAUA,IAAA,CAAE,KAAA,CAAM,sBAAsB,CAAA;AAAA,EACxC,OAAA,EAASA,IAAA,CAAE,MAAA,EAAO,CAAE,QAAA,EAAS;AAAA,EAC7B,cAAA,EAAgBA,IAAA,CAAE,MAAA,CAAOA,IAAA,CAAE,MAAA,IAAUA,IAAA,CAAE,GAAA,EAAK,CAAA,CAAE,QAAA;AAChD,CAAC;AAKD,IAAM,cAAA,GAAiBA,KAAE,MAAA,CAAO;AAAA,EAC9B,SAAA,EAAWA,KAAE,OAAA,EAAQ;AAAA,EACrB,MAAA,EAAQA,IAAA,CAAE,MAAA,EAAO,CAAE,QAAA,EAAS;AAAA,EAC5B,QAAA,EAAUA,IAAA,CAAE,GAAA,EAAI,CAAE,QAAA;AACpB,CAAC,CAAA;AAKM,IAAM,8BAAA,GAAiCA,KAAE,MAAA,CAAO;AAAA,EACrD,OAAA,EAASA,KAAE,OAAA,EAAQ;AAAA,EACnB,KAAA,EAAOA,KAAE,MAAA,EAAO;AAAA,EAChB,QAAA,EAAUA,IAAA,CAAE,KAAA,CAAM,sBAAsB,EAAE,QAAA,EAAS;AAAA,EACnD,WAAA,EAAaA,KACV,MAAA,CAAO;AAAA,IACN,QAAA,EAAUA,IAAA,CAAE,KAAA,CAAM,sBAAsB;AAAA,GACzC,EACA,QAAA,EAAS;AAAA,EACZ,QAAA,EAAU,eAAe,QAAA,EAAS;AAAA,EAClC,KAAA,EAAOA,IAAA,CAAE,MAAA,EAAO,CAAE,QAAA;AACpB,CAAC","file":"chunk-TMGV2NRM.cjs","sourcesContent":["import { z } from 'zod/v4';\n\n// Path parameter schemas\nexport const processorIdPathParams = z.object({\n  processorId: z.string().describe('Unique identifier for the processor'),\n});\n\n/**\n * Schema for processor configuration (how it's attached to an agent)\n */\nexport const processorConfigurationSchema = z.object({\n  agentId: z.string(),\n  agentName: z.string(),\n  type: z.enum(['input', 'output']),\n});\n\n/**\n * Schema for processor configuration in list response (simplified)\n */\nconst processorListConfigurationSchema = z.object({\n  agentId: z.string(),\n  type: z.enum(['input', 'output']),\n});\n\n/**\n * Schema for processor in list response\n */\nexport const serializedProcessorSchema = z.object({\n  id: z.string(),\n  name: z.string().optional(),\n  description: z.string().optional(),\n  phases: z.array(z.enum(['input', 'inputStep', 'outputStream', 'outputResult', 'outputStep'])),\n  agentIds: z.array(z.string()),\n  configurations: z.array(processorListConfigurationSchema),\n  isWorkflow: z.boolean(),\n});\n\n/**\n * Schema for detailed processor response\n */\nexport const serializedProcessorDetailSchema = z.object({\n  id: z.string(),\n  name: z.string().optional(),\n  description: z.string().optional(),\n  phases: z.array(z.enum(['input', 'inputStep', 'outputStream', 'outputResult', 'outputStep'])),\n  configurations: z.array(processorConfigurationSchema),\n  isWorkflow: z.boolean(),\n});\n\n/**\n * Schema for list processors endpoint response\n */\nexport const listProcessorsResponseSchema = z.record(z.string(), serializedProcessorSchema);\n\n/**\n * Schema for message content in processor execution\n */\nconst messageContentSchema = z\n  .object({\n    format: z.literal(2).optional(),\n    parts: z.array(z.any()).optional(),\n    content: z.string().optional(),\n  })\n  .passthrough();\n\n/**\n * Schema for a message in processor execution\n */\nconst processorMessageSchema = z\n  .object({\n    id: z.string(),\n    role: z.enum(['user', 'assistant', 'system', 'tool', 'signal']),\n    createdAt: z.coerce.date().optional(),\n    content: z.union([messageContentSchema, z.string()]),\n  })\n  .passthrough();\n\n/**\n * Body schema for executing a processor\n */\nexport const executeProcessorBodySchema = z.object({\n  phase: z.enum(['input', 'inputStep', 'outputStream', 'outputResult', 'outputStep']),\n  messages: z.array(processorMessageSchema),\n  agentId: z.string().optional(),\n  requestContext: z.record(z.string(), z.any()).optional(),\n});\n\n/**\n * Schema for tripwire result\n */\nconst tripwireSchema = z.object({\n  triggered: z.boolean(),\n  reason: z.string().optional(),\n  metadata: z.any().optional(),\n});\n\n/**\n * Response schema for processor execution\n */\nexport const executeProcessorResponseSchema = z.object({\n  success: z.boolean(),\n  phase: z.string(),\n  messages: z.array(processorMessageSchema).optional(),\n  messageList: z\n    .object({\n      messages: z.array(processorMessageSchema),\n    })\n    .optional(),\n  tripwire: tripwireSchema.optional(),\n  error: z.string().optional(),\n});\n"]}