package to code

Author: alexanderkirtzel

packages/cli/examples/flow.json

@@ -19,7 +19,7 @@
       },
       "destinations": {
         "ga4": {
-          "code": "destinationGtag",
+          "package": "@walkeros/web-destination-gtag",
           "config": {
             "consent": {
               "marketing": true
@@ -61,7 +61,7 @@
           }
         },
         "demo": {
-          "code": "destinationDemo",
+          "package": "@walkeros/destination-demo",
           "config": {
             "settings": {
               "name": "Order Complete Demo",

packages/cli/examples/server-collect.json

@@ -19,7 +19,7 @@
       },
       "sources": {
         "http": {
-          "code": "sourceExpress",
+          "package": "@walkeros/server-source-express",
           "config": {
             "settings": {
               "path": "/collect",
@@ -32,7 +32,7 @@
       },
       "destinations": {
         "demo": {
-          "code": "destinationDemo",
+          "package": "@walkeros/destination-demo",
           "config": {
             "settings": {
               "name": "Server Collection Demo",

packages/cli/examples/web-serve.json

@@ -22,7 +22,7 @@
       },
       "sources": {
         "demo": {
-          "code": "sourceDemo",
+          "package": "@walkeros/source-demo",
           "config": {
             "settings": {
               "events": [
@@ -48,15 +48,14 @@
       "destinations": {
         "demo": {
           "package": "@walkeros/destination-demo",
-          "code": "destinationDemo",
           "config": {
             "settings": {
               "name": "demo"
             }
           }
         },
         "api": {
-          "code": "destinationAPI",
+          "package": "@walkeros/web-destination-api",
           "config": {
             "settings": {
               "url": "http://localhost:8080/collect"

packages/cli/src/__tests__/config-loader.test.ts

@@ -269,7 +269,7 @@ describe('Config Loader', () => {
         loadBundleConfig(invalidConfig, {
           configPath: '/test/config.json',
         }),
-      ).toThrow(/Invalid configuration.*version/);
+      ).toThrow(/Invalid configuration[\s\S]*version/);
     });
 
     test('throws error for invalid config format (wrong version)', () => {
@@ -284,7 +284,7 @@ describe('Config Loader', () => {
         loadBundleConfig(invalidConfig, {
           configPath: '/test/config.json',
         }),
-      ).toThrow(/Invalid configuration.*version/);
+      ).toThrow(/Invalid configuration[\s\S]*version/);
     });
 
     test('throws error for invalid config format (missing flows)', () => {
@@ -296,7 +296,7 @@ describe('Config Loader', () => {
         loadBundleConfig(invalidConfig, {
           configPath: '/test/config.json',
         }),
-      ).toThrow(/Invalid configuration.*flows/);
+      ).toThrow(/Invalid configuration[\s\S]*flows/);
     });
 
     test('throws error for empty flows', () => {
@@ -309,7 +309,7 @@ describe('Config Loader', () => {
         loadBundleConfig(invalidConfig, {
           configPath: '/test/config.json',
         }),
-      ).toThrow(/must contain at least one flow/);
+      ).toThrow(/at least one flow/i);
     });
 
     test('throws error for flow without web/server key', () => {
@@ -326,7 +326,7 @@ describe('Config Loader', () => {
         loadBundleConfig(invalidConfig, {
           configPath: '/test/config.json',
         }),
-      ).toThrow(/must have a "web" or "server" key/);
+      ).toThrow(/web.*or.*server|Exactly one of/i);
     });
 
     test('returns empty array for non-Flow.Setup config', () => {

packages/cli/src/__tests__/simulate/server-simulate.integration.test.ts

@@ -32,7 +32,7 @@ describe('Server Simulation Integration', () => {
           },
           destinations: {
             demo: {
-              code: 'destinationDemo',
+              package: '@walkeros/destination-demo',
               config: { settings: { name: 'Test', values: ['name'] } },
             },
           },

packages/cli/src/commands/push/index.ts

@@ -2,6 +2,7 @@ import path from 'path';
 import { JSDOM, VirtualConsole } from 'jsdom';
 import fs from 'fs-extra';
 import { getPlatform, type Elb } from '@walkeros/core';
+import { schemas } from '@walkeros/core/dev';
 import {
   createCommandLogger,
   createLogger,
@@ -40,22 +41,34 @@ export async function pushCommand(options: PushCommandOptions): Promise<void> {
           name: 'event',
         });
 
-        // Validate event format
-        if (
-          !event ||
-          typeof event !== 'object' ||
-          !('name' in event) ||
-          typeof event.name !== 'string'
-        ) {
-          throw new Error(
-            'Event must be an object with a "name" property (string)',
-          );
+        // Validate event format using Zod schema
+        const eventResult = schemas.PartialEventSchema.safeParse(event);
+        if (!eventResult.success) {
+          const errors = eventResult.error.issues
+            .map((issue) => `${String(issue.path.join('.'))}: ${issue.message}`)
+            .join(', ');
+          throw new Error(`Invalid event: ${errors}`);
         }
 
-        // Warn about event naming format
-        if (!event.name.includes(' ')) {
+        const parsedEvent = eventResult.data as {
+          name?: string;
+          data?: Record<string, unknown>;
+        };
+        if (!parsedEvent.name) {
+          throw new Error('Invalid event: Missing required "name" property');
+        }
+
+        // Create typed event object for execution
+        const validatedEvent: { name: string; data: Record<string, unknown> } =
+          {
+            name: parsedEvent.name,
+            data: (parsedEvent.data || {}) as Record<string, unknown>,
+          };
+
+        // Warn about event naming format (walkerOS business logic)
+        if (!validatedEvent.name.includes(' ')) {
           logger.warn(
-            `Event name "${event.name}" should follow "ENTITY ACTION" format (e.g., "page view")`,
+            `Event name "${validatedEvent.name}" should follow "ENTITY ACTION" format (e.g., "page view")`,
           );
         }
 
@@ -108,10 +121,10 @@ export async function pushCommand(options: PushCommandOptions): Promise<void> {
 
         if (platform === 'web') {
           logger.info('🌐 Executing in web environment (JSDOM)...');
-          result = await executeWebPush(tempPath, event, logger);
+          result = await executeWebPush(tempPath, validatedEvent, logger);
         } else if (platform === 'server') {
           logger.info('🖥️  Executing in server environment (Node.js)...');
-          result = await executeServerPush(tempPath, event, logger);
+          result = await executeServerPush(tempPath, validatedEvent, logger);
         } else {
           throw new Error(`Unsupported platform: ${platform}`);
         }
@@ -199,12 +212,20 @@ export async function pushCommand(options: PushCommandOptions): Promise<void> {
   );
 }
 
+/**
+ * Typed event input for push command
+ */
+interface PushEventInput {
+  name: string;
+  data: Record<string, unknown>;
+}
+
 /**
  * Execute push for web platform using JSDOM with real APIs
  */
 async function executeWebPush(
   bundlePath: string,
-  event: Record<string, unknown>,
+  event: PushEventInput,
   logger: Logger,
 ): Promise<PushResult> {
   const startTime = Date.now();
@@ -244,8 +265,7 @@ async function executeWebPush(
 
     // Push event
     logger.info(`Pushing event: ${event.name}`);
-    const eventData = (event.data || {}) as Record<string, unknown>;
-    const elbResult = await elb(event.name as string, eventData);
+    const elbResult = await elb(event.name, event.data);
 
     return {
       success: true,
@@ -266,7 +286,7 @@ async function executeWebPush(
  */
 async function executeServerPush(
   bundlePath: string,
-  event: Record<string, unknown>,
+  event: PushEventInput,
   logger: Logger,
   timeout: number = 60000, // 60 second default timeout
 ): Promise<PushResult> {
@@ -305,13 +325,12 @@ async function executeServerPush(
 
       // Push event
       logger.info(`Pushing event: ${event.name}`);
-      const eventData = (event.data || {}) as Record<string, unknown>;
       const elbResult = await (
         elb as (
           name: string,
           data: Record<string, unknown>,
         ) => Promise<Elb.PushResult>
-      )(event.name as string, eventData);
+      )(event.name, event.data);
 
       return {
         success: true,

packages/cli/src/commands/run/validators.ts

@@ -1,36 +1,40 @@
 /**
  * Run Command Validators
  *
- * Validation logic for run command inputs
+ * Validation logic for run command inputs.
+ * Uses Zod schemas for type-safe validation.
  */
 
 import { existsSync } from 'fs';
 import { resolveAsset } from '../../core/asset-resolver.js';
-import type { RunMode } from './types.js';
+import {
+  RunModeSchema,
+  PortSchema,
+  type RunMode,
+} from '../../schemas/index.js';
 
 /**
- * Valid run modes
- */
-const VALID_MODES: RunMode[] = ['collect', 'serve'];
-
-/**
- * Validates run mode
+ * Validates run mode using Zod schema.
  *
  * @param mode - Mode to validate
  * @throws Error if mode is invalid
  */
 export function validateMode(mode: string): asserts mode is RunMode {
-  if (!VALID_MODES.includes(mode as RunMode)) {
+  const result = RunModeSchema.safeParse(mode);
+  if (!result.success) {
     throw new Error(
       `Invalid mode: "${mode}"\n` +
-        `   Valid modes: ${VALID_MODES.join(', ')}\n` +
+        `   Valid modes: collect, serve\n` +
         `   Example: walkeros run collect ./flow.json`,
     );
   }
 }
 
 /**
- * Validates flow file exists
+ * Validates flow file exists.
+ *
+ * @remarks
+ * File existence cannot be validated by Zod, so this remains a custom check.
  *
  * @param filePath - Path to flow configuration file (bare name, relative, or absolute)
  * @returns Absolute path to flow file
@@ -52,13 +56,14 @@ export function validateFlowFile(filePath: string): string {
 }
 
 /**
- * Validates port number
+ * Validates port number using Zod schema.
  *
  * @param port - Port number to validate
  * @throws Error if port is invalid
  */
 export function validatePort(port: number): void {
-  if (!Number.isInteger(port) || port < 1 || port > 65535) {
+  const result = PortSchema.safeParse(port);
+  if (!result.success) {
     throw new Error(
       `Invalid port: ${port}\n` +
         `   Port must be an integer between 1 and 65535\n` +

packages/cli/src/config/index.ts

@@ -9,7 +9,6 @@
 export {
   isObject,
   detectPlatform,
-  hasValidPlatform,
   isFlowSetup,
   validateFlowSetup,
   getAvailableFlows as getFlowNames,