feat(world-aws): AWS World implementation for Workflow DevKit

.github/workflows/publish.yml

@@ -41,11 +41,11 @@ jobs:
           # cdk-v1.0.0, cdk-v1.0.0-beta.1
           # pulumi-v1.0.0, pulumi-v1.0.0-beta.1
           # core-v1.0.0, core-v1.0.0-beta.1
+          # world-aws-v0.1.0, world-aws-v0.1.0-beta.1
 
-          # Extract package name (everything before -v)
-          if [[ "$TAG" =~ ^([a-z]+)-v ]]; then
-            PACKAGE="${BASH_REMATCH[1]}"
-          else
+          # Extract package name (everything before last -v<number>)
+          PACKAGE="${TAG%-v*}"
+          if [[ "$PACKAGE" == "$TAG" || -z "$PACKAGE" ]]; then
             echo "Error: Tag must be in format <package>-v<version> (e.g., cli-v1.0.0)"
             exit 1
           fi
@@ -68,8 +68,12 @@ jobs:
               NPM_PACKAGE="@wraps/core"
               FILTER="@wraps/core"
               ;;
+            world-aws)
+              NPM_PACKAGE="@wraps.dev/world-aws"
+              FILTER="@wraps.dev/world-aws"
+              ;;
             *)
-              echo "Error: Unknown package '$PACKAGE'. Must be one of: cli, cdk, pulumi, core"
+              echo "Error: Unknown package '$PACKAGE'. Must be one of: cli, cdk, pulumi, core, world-aws"
               exit 1
               ;;
           esac

CLAUDE.md

@@ -103,7 +103,7 @@ wraps/                            # Monorepo root
 │   │       ├── actions/         # Server actions
 │   │       ├── components/
 │   │       │   ├── (ee)/        # Enterprise components
-│   │       │   │   └── workflow-builder/ # React Flow workflow canvas
+│   │       │   │   └── automation-builder/ # React Flow automation canvas
 │   │       │   ├── template-editor/     # TipTap email template editor
 │   │       │   └── ui/          # shadcn/ui components
 │   │       ├── hooks/           # Custom hooks
@@ -543,9 +543,9 @@ These are enforced by `baseline.toml` and will fail CI:
 - **packages/cli/src/utils/shared/config.ts**: Centralized API/app URL helpers
 - **packages/db/src/schema/**: All database table definitions
 - **apps/api/src/routes/**: API route handlers
-- **apps/api/src/services/workflow-events.ts**: Workflow event emission
+- **apps/api/src/services/automation-events.ts**: Automation event emission
 - **apps/web/src/actions/**: Next.js server actions
-- **apps/web/src/components/(ee)/workflow-builder/**: Workflow builder (React Flow)
+- **apps/web/src/components/(ee)/automation-builder/**: Automation builder (React Flow)
 - **apps/web/src/components/template-editor/**: Email template editor (TipTap)
 
 ## Common Tasks

apps/api/CLAUDE.md

@@ -69,5 +69,5 @@ pnpm --filter @wraps/api test:coverage src/__tests__/my-test.test.ts
 ## Key Files
 
 - `src/routes/` - API route handlers
-- `src/services/workflow-events.ts` - Event emission helpers
+- `src/services/automation-events.ts` - Event emission helpers
 - `src/middleware/auth.ts` - Authentication middleware

apps/api/src/(ee)/__tests__/workflow-definition-drift.test.ts

@@ -302,15 +302,19 @@ vi.mock("../../services/credentials", () => ({
   }),
 }));
 
-vi.mock("../../services/workflow-queue", () => ({
+vi.mock("../../services/automation-queue", () => ({
+  enqueueAutomationStep: mockEnqueueWorkflowStep,
   enqueueWorkflowStep: mockEnqueueWorkflowStep,
+  enqueueAutomationStepBatch: mockEnqueueWorkflowStepBatch,
   enqueueWorkflowStepBatch: mockEnqueueWorkflowStepBatch,
   scheduleWaitTimeout: mockScheduleWaitTimeout,
+  scheduleAutomationStep: mockScheduleWorkflowStep,
   scheduleWorkflowStep: mockScheduleWorkflowStep,
   deleteScheduledStep: mockDeleteScheduledStep,
 }));
 
-vi.mock("../../services/workflow-scheduler", () => ({
+vi.mock("../../services/automation-scheduler", () => ({
+  createNextAutomationSchedule: mockCreateNextWorkflowSchedule,
   createNextWorkflowSchedule: mockCreateNextWorkflowSchedule,
 }));
 

apps/api/src/(ee)/__tests__/workflow-dlq-consumer.test.ts

@@ -72,7 +72,8 @@ const mockDbSelect = vi.fn();
 const mockDbUpdate = vi.fn();
 const mockCreateNextWorkflowSchedule = vi.fn();
 
-vi.mock("../../services/workflow-scheduler", () => ({
+vi.mock("../../services/automation-scheduler", () => ({
+  createNextAutomationSchedule: mockCreateNextWorkflowSchedule,
   createNextWorkflowSchedule: mockCreateNextWorkflowSchedule,
 }));
 

apps/api/src/(ee)/__tests__/workflow-events-cancel.test.ts → apps/api/src/(ee)/__tests__/workflow-events-cancel.integration.test.ts

@@ -28,7 +28,8 @@ import {
 } from "vitest";
 
 // Mock the workflow-queue module to avoid actual AWS calls
-vi.mock("../../services/workflow-queue", () => ({
+vi.mock("../../services/automation-queue", () => ({
+  enqueueAutomationStep: vi.fn().mockResolvedValue(undefined),
   enqueueWorkflowStep: vi.fn().mockResolvedValue(undefined),
   deleteScheduledStep: vi.fn().mockResolvedValue(undefined),
 }));

apps/api/src/(ee)/__tests__/workflow-processor-core.test.ts

@@ -276,15 +276,19 @@ vi.mock("../../services/credentials", () => ({
   }),
 }));
 
-vi.mock("../../services/workflow-queue", () => ({
+vi.mock("../../services/automation-queue", () => ({
+  enqueueAutomationStep: mockEnqueueWorkflowStep,
   enqueueWorkflowStep: mockEnqueueWorkflowStep,
+  enqueueAutomationStepBatch: mockEnqueueWorkflowStepBatch,
   enqueueWorkflowStepBatch: mockEnqueueWorkflowStepBatch,
   scheduleWaitTimeout: mockScheduleWaitTimeout,
+  scheduleAutomationStep: mockScheduleWorkflowStep,
   scheduleWorkflowStep: mockScheduleWorkflowStep,
   deleteScheduledStep: mockDeleteScheduledStep,
 }));
 
-vi.mock("../../services/workflow-scheduler", () => ({
+vi.mock("../../services/automation-scheduler", () => ({
+  createNextAutomationSchedule: mockCreateNextWorkflowSchedule,
   createNextWorkflowSchedule: mockCreateNextWorkflowSchedule,
 }));
 

apps/api/src/(ee)/__tests__/workflow-processor-steps.test.ts

@@ -228,15 +228,19 @@ vi.mock("../../services/credentials", () => ({
   }),
 }));
 
-vi.mock("../../services/workflow-queue", () => ({
+vi.mock("../../services/automation-queue", () => ({
+  enqueueAutomationStep: mockEnqueueWorkflowStep,
   enqueueWorkflowStep: mockEnqueueWorkflowStep,
+  enqueueAutomationStepBatch: mockEnqueueWorkflowStepBatch,
   enqueueWorkflowStepBatch: mockEnqueueWorkflowStepBatch,
   scheduleWaitTimeout: mockScheduleWaitTimeout,
+  scheduleAutomationStep: mockScheduleWorkflowStep,
   scheduleWorkflowStep: mockScheduleWorkflowStep,
   deleteScheduledStep: mockDeleteScheduledStep,
 }));
 
-vi.mock("../../services/workflow-scheduler", () => ({
+vi.mock("../../services/automation-scheduler", () => ({
+  createNextAutomationSchedule: mockCreateNextWorkflowSchedule,
   createNextWorkflowSchedule: mockCreateNextWorkflowSchedule,
 }));
 

apps/api/src/(ee)/__tests__/workflow-processor-trigger.test.ts

@@ -158,15 +158,19 @@ vi.mock("../../services/credentials", () => ({
   }),
 }));
 
-vi.mock("../../services/workflow-queue", () => ({
+vi.mock("../../services/automation-queue", () => ({
+  enqueueAutomationStep: mockEnqueueWorkflowStep,
   enqueueWorkflowStep: mockEnqueueWorkflowStep,
+  enqueueAutomationStepBatch: mockEnqueueWorkflowStepBatch,
   enqueueWorkflowStepBatch: mockEnqueueWorkflowStepBatch,
   scheduleWaitTimeout: mockScheduleWaitTimeout,
+  scheduleAutomationStep: mockScheduleWorkflowStep,
   scheduleWorkflowStep: mockScheduleWorkflowStep,
   deleteScheduledStep: mockDeleteScheduledStep,
 }));
 
-vi.mock("../../services/workflow-scheduler", () => ({
+vi.mock("../../services/automation-scheduler", () => ({
+  createNextAutomationSchedule: mockCreateNextWorkflowSchedule,
   createNextWorkflowSchedule: mockCreateNextWorkflowSchedule,
 }));