http support

Author: alexanderkirtzel

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

@@ -8,11 +8,7 @@ import {
   getErrorMessage,
   type Logger,
 } from '../../core/index.js';
-import {
-  loadJsonConfig,
-  loadJsonFromSource,
-  loadBundleConfig,
-} from '../../config/index.js';
+import { loadFlowConfig, loadJsonFromSource } from '../../config/index.js';
 import { bundleCore } from '../bundle/bundler.js';
 import type { PushCommandOptions, PushResult } from './types.js';
 
@@ -62,20 +58,17 @@ export async function pushCommand(options: PushCommandOptions): Promise<void> {
 
     // Step 2: Load config
     logger.debug('Loading flow configuration');
-    const configPath = path.resolve(options.config);
-    const rawConfig = await loadJsonConfig(configPath);
-    const { flowConfig, buildOptions, flowName, isMultiFlow } =
-      loadBundleConfig(rawConfig, {
-        configPath: options.config,
-        flowName: options.flow,
-        logger,
-      });
+    const { flowConfig, buildOptions } = await loadFlowConfig(options.config, {
+      flowName: options.flow,
+      logger,
+    });
 
     const platform = getPlatform(flowConfig);
 
     // Step 3: Bundle to temp file in config directory (so Node.js can find node_modules)
     logger.debug('Bundling flow configuration');
-    const configDir = path.dirname(configPath);
+    // buildOptions.configDir already handles URLs (uses cwd) vs local paths
+    const configDir = buildOptions.configDir || process.cwd();
     const tempDir = path.join(
       configDir,
       '.tmp',

packages/cli/src/commands/simulate/simulator.ts

@@ -4,8 +4,7 @@ import type { Flow } from '@walkeros/core';
 import { getPlatform } from '@walkeros/core';
 import { createLogger, getErrorMessage } from '../../core/index.js';
 import {
-  loadJsonConfig,
-  loadBundleConfig,
+  loadFlowConfig,
   isObject,
   type BuildOptions,
 } from '../../config/index.js';
@@ -39,29 +38,17 @@ export async function simulateCore(
   });
 
   try {
-    logger.info('🎯 Starting walkerOS simulation...');
-
     // Load and validate configuration
-    logger.info('📦 Loading bundle configuration...');
-    const fullConfigPath = path.resolve(configPath);
-    const rawConfig = await loadJsonConfig(fullConfigPath);
-    loadBundleConfig(rawConfig, { configPath: fullConfigPath });
+    logger.debug('Loading configuration');
+    await loadFlowConfig(configPath);
 
     // Execute simulation
-    logger.info(`🚀 Executing simulation with event: ${JSON.stringify(event)}`);
-    const result = await executeSimulation(event, fullConfigPath);
-
-    // Report results
-    if (result.success) {
-      logger.info(`✅ Simulation completed successfully`);
-    } else {
-      logger.error(`❌ Simulation failed: ${result.error}`);
-    }
+    logger.debug(`Simulating event: ${JSON.stringify(event)}`);
+    const result = await executeSimulation(event, configPath);
 
     return result;
   } catch (error) {
     const errorMessage = getErrorMessage(error);
-    logger.error(`💥 Simulation error: ${errorMessage}`);
 
     return {
       success: false,
@@ -87,9 +74,9 @@ export function formatSimulationResult(
   }
 
   if (result.success) {
-    return '✅ Simulation completed successfully';
+    return 'Simulation completed';
   } else {
-    return `❌ Simulation failed: ${result.error}`;
+    return `Simulation failed: ${result.error}`;
   }
 }
 
@@ -122,10 +109,7 @@ export async function executeSimulation(
     await fs.ensureDir(tempDir);
 
     // 1. Load config
-    const rawConfig = await loadJsonConfig(configPath);
-    const { flowConfig, buildOptions } = loadBundleConfig(rawConfig, {
-      configPath,
-    });
+    const { flowConfig, buildOptions } = await loadFlowConfig(configPath);
 
     // Detect platform from flowConfig
     const platform = getPlatform(flowConfig);

packages/cli/src/config/index.ts

@@ -32,7 +32,12 @@ export {
 } from './utils.js';
 
 // Loader
-export { loadBundleConfig, loadAllFlows, getAvailableFlows } from './loader.js';
+export {
+  loadBundleConfig,
+  loadAllFlows,
+  getAvailableFlows,
+  loadFlowConfig,
+} from './loader.js';
 export type { LoadConfigResult, LoadConfigOptions } from './loader.js';
 
 // Type re-exports

packages/cli/src/config/loader.ts

@@ -15,7 +15,7 @@ import {
   getAvailableFlows as getFlowNames,
 } from './validators.js';
 import { getBuildDefaults, getDefaultOutput } from './build-defaults.js';
-import { isUrl } from './utils.js';
+import { isUrl, loadJsonConfig } from './utils.js';
 
 /** Default folder for includes if it exists */
 const DEFAULT_INCLUDE_FOLDER = './shared';
@@ -232,3 +232,27 @@ export function getAvailableFlows(rawConfig: unknown): string[] {
   }
   return [];
 }
+
+/**
+ * Load flow configuration from file or URL.
+ *
+ * Single entry point for all commands (bundle, simulate, push).
+ * Handles URL vs local path detection automatically.
+ *
+ * @param configPath - Path to config file or URL
+ * @param options - Loading options (flowName, logger, buildOverrides)
+ * @returns Parsed configuration with flow and build options
+ *
+ * @example
+ * ```typescript
+ * const { flowConfig, buildOptions } = await loadFlowConfig('./flow.json');
+ * const { flowConfig } = await loadFlowConfig('https://example.com/flow.json');
+ * ```
+ */
+export async function loadFlowConfig(
+  configPath: string,
+  options?: Omit<LoadConfigOptions, 'configPath'>,
+): Promise<LoadConfigResult> {
+  const rawConfig = await loadJsonConfig(configPath);
+  return loadBundleConfig(rawConfig, { configPath, ...options });
+}