Merge branch 'main' of https://github.com/objectstack-ai/spec

Author: hotlong

examples/app-crm/src/flows/campaign-enrollment.flow.ts

@@ -1,63 +1,52 @@
+import type { Automation } from '@objectstack/spec';
+type Flow = Automation.Flow;
+
 /** Campaign Enrollment — scheduled flow to bulk enroll leads */
-export const CampaignEnrollmentFlow = {
+export const CampaignEnrollmentFlow: Flow = {
   name: 'campaign_enrollment',
   label: 'Enroll Leads in Campaign',
   description: 'Bulk enroll leads into marketing campaigns',
-  type: 'autolaunched',
-  triggerType: 'scheduled',
-  schedule: '0 9 * * 1', // Monday at 9am
+  type: 'schedule',
 
   variables: [
     { name: 'campaignId', type: 'text', isInput: true, isOutput: false },
     { name: 'leadStatus', type: 'text', isInput: true, isOutput: false },
   ],
 
-  steps: [
+  nodes: [
+    { id: 'start', type: 'start', label: 'Start (Monday 9 AM)', config: { schedule: '0 9 * * 1' } },
+    {
+      id: 'get_campaign', type: 'get_record', label: 'Get Campaign',
+      config: { objectName: 'campaign', filter: { id: '{campaignId}' }, outputVariable: 'campaignRecord' },
+    },
     {
-      id: 'get_campaign',
-      type: 'record_lookup',
-      label: 'Get Campaign',
-      objectName: 'campaign',
-      filter: { id: '{campaignId}' },
-      outputVariable: 'campaignRecord',
+      id: 'query_leads', type: 'get_record', label: 'Find Eligible Leads',
+      config: { objectName: 'lead', filter: { status: '{leadStatus}', is_converted: false, email: { $ne: null } }, limit: 1000, outputVariable: 'leadList' },
     },
     {
-      id: 'query_leads',
-      type: 'record_query',
-      label: 'Find Eligible Leads',
-      objectName: 'lead',
-      filter: { status: '{leadStatus}', is_converted: false, email: { $ne: null } },
-      limit: 1000,
-      outputVariable: 'leadList',
+      id: 'loop_leads', type: 'loop', label: 'Process Each Lead',
+      config: { collection: '{leadList}', iteratorVariable: 'currentLead' },
     },
     {
-      id: 'loop_leads',
-      type: 'loop',
-      label: 'Process Each Lead',
-      collection: '{leadList}',
-      itemVariable: 'currentLead',
-      steps: [
-        {
-          id: 'create_campaign_member',
-          type: 'record_create',
-          label: 'Add to Campaign',
-          objectName: 'campaign_member',
-          fields: {
-            campaign: '{campaignId}',
-            lead: '{currentLead.id}',
-            status: 'sent',
-            added_date: '{NOW()}',
-          },
-        },
-      ],
+      id: 'create_campaign_member', type: 'create_record', label: 'Add to Campaign',
+      config: {
+        objectName: 'campaign_member',
+        fields: { campaign: '{campaignId}', lead: '{currentLead.id}', status: 'sent', added_date: '{NOW()}' },
+      },
     },
     {
-      id: 'update_campaign_stats',
-      type: 'record_update',
-      label: 'Update Campaign Stats',
-      recordId: '{campaignId}',
-      objectName: 'campaign',
-      fields: { num_sent: '{leadList.length}' },
+      id: 'update_campaign_stats', type: 'update_record', label: 'Update Campaign Stats',
+      config: { objectName: 'campaign', filter: { id: '{campaignId}' }, fields: { num_sent: '{leadList.length}' } },
     },
+    { id: 'end', type: 'end', label: 'End' },
+  ],
+
+  edges: [
+    { id: 'e1', source: 'start', target: 'get_campaign', type: 'default' },
+    { id: 'e2', source: 'get_campaign', target: 'query_leads', type: 'default' },
+    { id: 'e3', source: 'query_leads', target: 'loop_leads', type: 'default' },
+    { id: 'e4', source: 'loop_leads', target: 'create_campaign_member', type: 'default' },
+    { id: 'e5', source: 'create_campaign_member', target: 'update_campaign_stats', type: 'default' },
+    { id: 'e6', source: 'update_campaign_stats', target: 'end', type: 'default' },
   ],
 };

examples/app-crm/src/flows/case-escalation.flow.ts

@@ -1,63 +1,65 @@
+import type { Automation } from '@objectstack/spec';
+type Flow = Automation.Flow;
+
 /** Case Escalation — auto-escalate high-priority cases */
-export const CaseEscalationFlow = {
+export const CaseEscalationFlow: Flow = {
   name: 'case_escalation',
   label: 'Case Escalation Process',
   description: 'Automatically escalate high-priority cases',
-  type: 'autolaunched',
-  triggerType: 'on_create',
-  objectName: 'case',
-  criteria: 'priority = "critical" OR (priority = "high" AND account.type = "customer")',
+  type: 'record_change',
 
   variables: [
     { name: 'caseId', type: 'text', isInput: true, isOutput: false },
   ],
 
-  steps: [
+  nodes: [
+    {
+      id: 'start', type: 'start', label: 'Start',
+      config: { objectName: 'case', criteria: 'priority = "critical" OR (priority = "high" AND account.type = "customer")' },
+    },
     {
-      id: 'get_case',
-      type: 'record_lookup',
-      label: 'Get Case Record',
-      objectName: 'case',
-      filter: { id: '{caseId}' },
-      outputVariable: 'caseRecord',
+      id: 'get_case', type: 'get_record', label: 'Get Case Record',
+      config: { objectName: 'case', filter: { id: '{caseId}' }, outputVariable: 'caseRecord' },
     },
     {
-      id: 'assign_senior_agent',
-      type: 'record_update',
-      label: 'Assign to Senior Agent',
-      recordId: '{caseId}',
-      objectName: 'case',
-      fields: {
-        owner: '{caseRecord.owner.manager}',
-        is_escalated: true,
-        escalated_date: '{NOW()}',
+      id: 'assign_senior_agent', type: 'update_record', label: 'Assign to Senior Agent',
+      config: {
+        objectName: 'case', filter: { id: '{caseId}' },
+        fields: { owner: '{caseRecord.owner.manager}', is_escalated: true, escalated_date: '{NOW()}' },
       },
     },
     {
-      id: 'create_task',
-      type: 'record_create',
-      label: 'Create Follow-up Task',
-      objectName: 'task',
-      fields: {
-        subject: 'Follow up on escalated case: {caseRecord.case_number}',
-        related_to: '{caseId}',
-        owner: '{caseRecord.owner}',
-        priority: 'high',
-        status: 'not_started',
-        due_date: '{TODAY() + 1}',
+      id: 'create_task', type: 'create_record', label: 'Create Follow-up Task',
+      config: {
+        objectName: 'task',
+        fields: {
+          subject: 'Follow up on escalated case: {caseRecord.case_number}',
+          related_to: '{caseId}', owner: '{caseRecord.owner}',
+          priority: 'high', status: 'not_started', due_date: '{TODAY() + 1}',
+        },
       },
     },
     {
-      id: 'notify_team',
-      type: 'email_alert',
-      label: 'Notify Support Team',
-      template: 'case_escalated',
-      recipients: ['{caseRecord.owner}', '{caseRecord.owner.manager}', 'support-team@example.com'],
-      variables: {
-        caseNumber: '{caseRecord.case_number}',
-        priority: '{caseRecord.priority}',
-        accountName: '{caseRecord.account.name}',
+      id: 'notify_team', type: 'script', label: 'Notify Support Team',
+      config: {
+        actionType: 'email',
+        template: 'case_escalated',
+        recipients: ['{caseRecord.owner}', '{caseRecord.owner.manager}', 'support-team@example.com'],
+        variables: {
+          caseNumber: '{caseRecord.case_number}',
+          priority: '{caseRecord.priority}',
+          accountName: '{caseRecord.account.name}',
+        },
       },
     },
+    { id: 'end', type: 'end', label: 'End' },
+  ],
+
+  edges: [
+    { id: 'e1', source: 'start', target: 'get_case', type: 'default' },
+    { id: 'e2', source: 'get_case', target: 'assign_senior_agent', type: 'default' },
+    { id: 'e3', source: 'assign_senior_agent', target: 'create_task', type: 'default' },
+    { id: 'e4', source: 'create_task', target: 'notify_team', type: 'default' },
+    { id: 'e5', source: 'notify_team', target: 'end', type: 'default' },
   ],
 };