feat: Implement AI Orchestration Protocol with comprehensive schemas and tests

- Added orchestration.zod.ts defining AI orchestration schemas including triggers, tasks, and post-processing actions.
- Created orchestration.test.ts to validate the functionality of the new orchestration schemas.
- Removed deprecated workflow-automation.zod.ts to streamline the codebase.

Author: hotlong

…/spec/src/ai/workflow-automation.test.ts …ckages/spec/src/ai/orchestration.test.tspackages/spec/src/ai/workflow-automation.test.ts renamed to packages/spec/src/ai/orchestration.test.ts packages/spec/src/ai/workflow-automation.test.ts renamed to packages/spec/src/ai/orchestration.test.ts

@@ -1,19 +1,19 @@
 import { describe, it, expect } from 'vitest';
 import {
-  AIWorkflowAutomationSchema,
-  AIWorkflowTriggerSchema,
+  AIOrchestrationSchema,
+  AIOrchestrationTriggerSchema,
   AITaskTypeSchema,
   AITaskSchema,
   WorkflowFieldConditionSchema,
   WorkflowScheduleSchema,
   PostProcessingActionSchema,
-  BatchAIWorkflowExecutionSchema,
-  AIWorkflowExecutionResultSchema,
-  type AIWorkflowAutomation,
+  BatchAIOrchestrationExecutionSchema,
+  AIOrchestrationExecutionResultSchema,
+  type AIOrchestration,
   type AITask,
-} from './workflow-automation.zod';
+} from './orchestration.zod';
 
-describe('AIWorkflowTriggerSchema', () => {
+describe('AIOrchestrationTriggerSchema', () => {
   it('should accept all trigger types', () => {
     const triggers = [
       'record_created',
@@ -26,7 +26,7 @@ describe('AIWorkflowTriggerSchema', () => {
     ] as const;
 
     triggers.forEach(trigger => {
-      expect(() => AIWorkflowTriggerSchema.parse(trigger)).not.toThrow();
+      expect(() => AIOrchestrationTriggerSchema.parse(trigger)).not.toThrow();
     });
   });
 });
@@ -253,10 +253,10 @@ describe('PostProcessingActionSchema', () => {
   });
 });
 
-describe('AIWorkflowAutomationSchema', () => {
+describe('AIOrchestrationSchema', () => {
   describe('Basic Properties', () => {
     it('should accept minimal workflow', () => {
-      const workflow: AIWorkflowAutomation = {
+      const workflow: AIOrchestration = {
         name: 'auto_classify_tickets',
         label: 'Auto-classify Support Tickets',
         objectName: 'support_ticket',
@@ -272,7 +272,7 @@ describe('AIWorkflowAutomationSchema', () => {
         ],
       };
 
-      const result = AIWorkflowAutomationSchema.parse(workflow);
+      const result = AIOrchestrationSchema.parse(workflow);
       expect(result.active).toBe(true);
       expect(result.version).toBe('1.0.0');
       expect(result.executionMode).toBe('sequential');
@@ -283,7 +283,7 @@ describe('AIWorkflowAutomationSchema', () => {
     it('should enforce snake_case for workflow name', () => {
       const validNames = ['auto_classify', 'lead_scoring', '_internal_workflow'];
       validNames.forEach(name => {
-        expect(() => AIWorkflowAutomationSchema.parse({
+        expect(() => AIOrchestrationSchema.parse({
           name,
           label: 'Test',
           objectName: 'test_object',
@@ -299,7 +299,7 @@ describe('AIWorkflowAutomationSchema', () => {
 
       const invalidNames = ['autoClassify', 'Auto-Classify', '123workflow'];
       invalidNames.forEach(name => {
-        expect(() => AIWorkflowAutomationSchema.parse({
+        expect(() => AIOrchestrationSchema.parse({
           name,
           label: 'Test',
           objectName: 'test_object',
@@ -317,7 +317,7 @@ describe('AIWorkflowAutomationSchema', () => {
 
   describe('Field Change Trigger', () => {
     it('should accept field change workflow', () => {
-      const workflow: AIWorkflowAutomation = {
+      const workflow: AIOrchestration = {
         name: 'priority_change_handler',
         label: 'Handle Priority Changes',
         objectName: 'ticket',
@@ -339,13 +339,13 @@ describe('AIWorkflowAutomationSchema', () => {
         ],
       };
 
-      expect(() => AIWorkflowAutomationSchema.parse(workflow)).not.toThrow();
+      expect(() => AIOrchestrationSchema.parse(workflow)).not.toThrow();
     });
   });
 
   describe('Scheduled Workflow', () => {
     it('should accept scheduled workflow', () => {
-      const workflow: AIWorkflowAutomation = {
+      const workflow: AIOrchestration = {
         name: 'daily_lead_scoring',
         label: 'Daily Lead Scoring',
         objectName: 'lead',
@@ -366,13 +366,13 @@ describe('AIWorkflowAutomationSchema', () => {
         ],
       };
 
-      expect(() => AIWorkflowAutomationSchema.parse(workflow)).not.toThrow();
+      expect(() => AIOrchestrationSchema.parse(workflow)).not.toThrow();
     });
   });
 
   describe('Complex Workflows', () => {
     it('should accept workflow with multiple AI tasks', () => {
-      const workflow: AIWorkflowAutomation = {
+      const workflow: AIOrchestration = {
         name: 'comprehensive_ticket_handler',
         label: 'Comprehensive Ticket Handler',
         objectName: 'support_ticket',
@@ -421,11 +421,11 @@ describe('AIWorkflowAutomationSchema', () => {
         ],
       };
 
-      expect(() => AIWorkflowAutomationSchema.parse(workflow)).not.toThrow();
+      expect(() => AIOrchestrationSchema.parse(workflow)).not.toThrow();
     });
 
     it('should accept workflow with all features', () => {
-      const workflow: AIWorkflowAutomation = {
+      const workflow: AIOrchestration = {
         name: 'advanced_automation',
         label: 'Advanced Automation Workflow',
         description: 'Comprehensive AI-powered automation',
@@ -474,19 +474,19 @@ describe('AIWorkflowAutomationSchema', () => {
         owner: 'user_123',
       };
 
-      expect(() => AIWorkflowAutomationSchema.parse(workflow)).not.toThrow();
+      expect(() => AIOrchestrationSchema.parse(workflow)).not.toThrow();
     });
   });
 });
 
-describe('BatchAIWorkflowExecutionSchema', () => {
+describe('BatchAIOrchestrationExecutionSchema', () => {
   it('should accept batch execution request', () => {
     const request = {
       workflowName: 'auto_classify_tickets',
       recordIds: ['rec_1', 'rec_2', 'rec_3'],
     };
 
-    const result = BatchAIWorkflowExecutionSchema.parse(request);
+    const result = BatchAIOrchestrationExecutionSchema.parse(request);
     expect(result.batchSize).toBe(10);
     expect(result.parallelism).toBe(3);
     expect(result.priority).toBe('normal');
@@ -501,25 +501,25 @@ describe('BatchAIWorkflowExecutionSchema', () => {
       priority: 'high' as const,
     };
 
-    expect(() => BatchAIWorkflowExecutionSchema.parse(request)).not.toThrow();
+    expect(() => BatchAIOrchestrationExecutionSchema.parse(request)).not.toThrow();
   });
 
   it('should enforce batch size limits', () => {
-    expect(() => BatchAIWorkflowExecutionSchema.parse({
+    expect(() => BatchAIOrchestrationExecutionSchema.parse({
       workflowName: 'test',
       recordIds: ['rec_1'],
       batchSize: 0,
     })).toThrow();
 
-    expect(() => BatchAIWorkflowExecutionSchema.parse({
+    expect(() => BatchAIOrchestrationExecutionSchema.parse({
       workflowName: 'test',
       recordIds: ['rec_1'],
       batchSize: 1001,
     })).toThrow();
   });
 });
 
-describe('AIWorkflowExecutionResultSchema', () => {
+describe('AIOrchestrationExecutionResultSchema', () => {
   it('should accept successful execution result', () => {
     const result = {
       workflowName: 'auto_classify_tickets',
@@ -533,7 +533,7 @@ describe('AIWorkflowExecutionResultSchema', () => {
       completedAt: '2024-01-01T10:00:01Z',
     };
 
-    expect(() => AIWorkflowExecutionResultSchema.parse(result)).not.toThrow();
+    expect(() => AIOrchestrationExecutionResultSchema.parse(result)).not.toThrow();
   });
 
   it('should accept result with task details', () => {
@@ -571,7 +571,7 @@ describe('AIWorkflowExecutionResultSchema', () => {
       completedAt: '2024-01-01T10:00:02Z',
     };
 
-    expect(() => AIWorkflowExecutionResultSchema.parse(result)).not.toThrow();
+    expect(() => AIOrchestrationExecutionResultSchema.parse(result)).not.toThrow();
   });
 
   it('should accept failed execution result', () => {
@@ -587,13 +587,13 @@ describe('AIWorkflowExecutionResultSchema', () => {
       startedAt: '2024-01-01T10:00:00Z',
     };
 
-    expect(() => AIWorkflowExecutionResultSchema.parse(result)).not.toThrow();
+    expect(() => AIOrchestrationExecutionResultSchema.parse(result)).not.toThrow();
   });
 });
 
 describe('Real-World Workflow Examples', () => {
   it('should accept customer support ticket automation', () => {
-    const workflow: AIWorkflowAutomation = {
+    const workflow: AIOrchestration = {
       name: 'auto_triage_support_tickets',
       label: 'Auto-Triage Support Tickets',
       description: 'Automatically classify, prioritize, and route support tickets',
@@ -654,11 +654,11 @@ describe('Real-World Workflow Examples', () => {
       tags: ['automation', 'ai', 'support'],
     };
 
-    expect(() => AIWorkflowAutomationSchema.parse(workflow)).not.toThrow();
+    expect(() => AIOrchestrationSchema.parse(workflow)).not.toThrow();
   });
 
   it('should accept lead scoring automation', () => {
-    const workflow: AIWorkflowAutomation = {
+    const workflow: AIOrchestration = {
       name: 'ai_lead_scoring',
       label: 'AI-Powered Lead Scoring',
       objectName: 'lead',
@@ -715,11 +715,11 @@ describe('Real-World Workflow Examples', () => {
       tags: ['lead-scoring', 'ml', 'automation'],
     };
 
-    expect(() => AIWorkflowAutomationSchema.parse(workflow)).not.toThrow();
+    expect(() => AIOrchestrationSchema.parse(workflow)).not.toThrow();
   });
 
   it('should accept document processing workflow', () => {
-    const workflow: AIWorkflowAutomation = {
+    const workflow: AIOrchestration = {
       name: 'process_invoice_documents',
       label: 'Process Invoice Documents',
       objectName: 'invoice',
@@ -784,6 +784,6 @@ describe('Real-World Workflow Examples', () => {
       tags: ['document-processing', 'ocr', 'automation'],
     };
 
-    expect(() => AIWorkflowAutomationSchema.parse(workflow)).not.toThrow();
+    expect(() => AIOrchestrationSchema.parse(workflow)).not.toThrow();
   });
 });

…s/spec/src/ai/workflow-automation.zod.ts packages/spec/src/ai/orchestration.zod.tspackages/spec/src/ai/workflow-automation.zod.ts renamed to packages/spec/src/ai/orchestration.zod.ts packages/spec/src/ai/workflow-automation.zod.ts renamed to packages/spec/src/ai/orchestration.zod.ts

@@ -1,25 +1,26 @@
 import { z } from 'zod';
 
 /**
- * AI Workflow Automation Protocol
+ * AI Agentic Orchestration Protocol
  * 
- * Defines intelligent automation workflows that leverage AI/ML capabilities
- * to automate business processes with cognitive tasks like classification,
- * extraction, summarization, content generation, and prediction.
+ * Defines intelligent orchestration flows where AI Agents leverage cognitive skills
+ * to automate business processes with dynamic reasoning, planning, and execution.
+ * 
+ * Distinction from Standard Workflows:
+ * - Standard Workflow: Deterministic (If X then Y). defined in src/data/workflow.zod.ts
+ * - AI Orchestration: Probabilistic & Agentic (Goal -> Plan -> Execute).
  * 
  * Use Cases:
- * - Automatically classify support tickets by urgency and route to teams
- * - Extract key information from documents and populate fields
- * - Generate summaries of long text content
- * - Predict lead scores or customer churn risk
- * - Auto-fill forms based on natural language input
+ * - Complex Support Triage (Analyze sentiment + intent -> Draft response -> Route)
+ * - Intelligent Document Processing (OCR -> Extract Entities -> Validate -> Entry)
+ * - Research Agent (Search Web -> Summarize -> Generate Report)
  */
 
 /**
- * Workflow Trigger Types
- * Defines when an AI workflow should be initiated
+ * Orchestration Trigger Types
+ * Defines when an AI Agentic Flow should be initiated
  */
-export const AIWorkflowTriggerSchema = z.enum([
+export const AIOrchestrationTriggerSchema = z.enum([
   'record_created',      // When a new record is created
   'record_updated',      // When a record is updated
   'field_changed',       // When specific field(s) change
@@ -127,20 +128,20 @@ export const PostProcessingActionSchema = z.object({
 });
 
 /**
- * AI Workflow Automation Schema
+ * AI Agentic Orchestration Schema
  * Complete workflow definition with AI-powered tasks
  */
-export const AIWorkflowAutomationSchema = z.object({
+export const AIOrchestrationSchema = z.object({
   /** Identity */
-  name: z.string().regex(/^[a-z_][a-z0-9_]*$/).describe('Workflow unique identifier (snake_case)'),
-  label: z.string().describe('Workflow display name'),
+  name: z.string().regex(/^[a-z_][a-z0-9_]*$/).describe('Orchestration unique identifier (snake_case)'),
+  label: z.string().describe('Display name'),
   description: z.string().optional(),
 
   /** Target Object */
-  objectName: z.string().describe('Target object for this workflow'),
+  objectName: z.string().describe('Target object for this orchestration'),
 
   /** Trigger Configuration */
-  trigger: AIWorkflowTriggerSchema,
+  trigger: AIOrchestrationTriggerSchema,
 
   /** Trigger-specific configuration */
   fieldConditions: z.array(WorkflowFieldConditionSchema).optional().describe('Fields to monitor (for field_changed trigger)'),
@@ -185,22 +186,22 @@ export const AIWorkflowAutomationSchema = z.object({
 });
 
 /**
- * Batch AI Workflow Execution Request
+ * Batch AI Orchestration Execution Request
  * For processing multiple records at once
  */
-export const BatchAIWorkflowExecutionSchema = z.object({
-  workflowName: z.string().describe('Workflow to execute'),
+export const BatchAIOrchestrationExecutionSchema = z.object({
+  workflowName: z.string().describe('Orchestration to execute'),
   recordIds: z.array(z.string()).describe('Records to process'),
   batchSize: z.number().int().min(1).max(1000).optional().default(10),
   parallelism: z.number().int().min(1).max(10).optional().default(3),
   priority: z.enum(['low', 'normal', 'high']).optional().default('normal'),
 });
 
 /**
- * AI Workflow Execution Result
- * Result of a single workflow execution
+ * AI Orchestration Execution Result
+ * Result of a single execution
  */
-export const AIWorkflowExecutionResultSchema = z.object({
+export const AIOrchestrationExecutionResultSchema = z.object({
   workflowName: z.string(),
   recordId: z.string(),
   status: z.enum(['success', 'partial_success', 'failed', 'skipped']),
@@ -224,12 +225,12 @@ export const AIWorkflowExecutionResultSchema = z.object({
 });
 
 // Type exports
-export type AIWorkflowTrigger = z.infer<typeof AIWorkflowTriggerSchema>;
+export type AIOrchestrationTrigger = z.infer<typeof AIOrchestrationTriggerSchema>;
 export type AITaskType = z.infer<typeof AITaskTypeSchema>;
 export type AITask = z.infer<typeof AITaskSchema>;
 export type WorkflowFieldCondition = z.infer<typeof WorkflowFieldConditionSchema>;
 export type WorkflowSchedule = z.infer<typeof WorkflowScheduleSchema>;
 export type PostProcessingAction = z.infer<typeof PostProcessingActionSchema>;
-export type AIWorkflowAutomation = z.infer<typeof AIWorkflowAutomationSchema>;
-export type BatchAIWorkflowExecution = z.infer<typeof BatchAIWorkflowExecutionSchema>;
-export type AIWorkflowExecutionResult = z.infer<typeof AIWorkflowExecutionResultSchema>;
+export type AIOrchestration = z.infer<typeof AIOrchestrationSchema>;
+export type BatchAIOrchestrationExecution = z.infer<typeof BatchAIOrchestrationExecutionSchema>;
+export type AIOrchestrationExecutionResult = z.infer<typeof AIOrchestrationExecutionResultSchema>;