feat: add watch command to monitor files for changes and auto-deploy

Author: vobu

src/commands/help.ts

@@ -50,6 +50,7 @@ Commands:
   correlate msg <name>       Correlate message
   deploy    [path...]        Deploy BPMN/DMN/forms
   run       <path>           Deploy and start process
+  watch     [path...]        Watch files for changes and auto-deploy
   add       profile <name>   Add a profile
   remove    profile <name>   Remove a profile (alias: rm)
   load      plugin <name>    Load a c8ctl plugin from npm registry
@@ -77,6 +78,7 @@ Examples:
   c8ctl create pi --bpmnProcessId=myProcess
   c8ctl deploy ./my-process.bpmn     Deploy a BPMN file
   c8ctl run ./my-process.bpmn        Deploy and start process
+  c8ctl watch ./src                  Watch directory for changes
   c8ctl use profile prod             Set active profile
   c8ctl output json                  Switch to JSON output
   c8ctl load plugin my-plugin        Load plugin from npm registry

src/commands/watch.ts

@@ -0,0 +1,93 @@
+/**
+ * Watch command - monitor files for changes and auto-deploy
+ */
+
+import { watch } from 'node:fs';
+import { resolve, extname, basename } from 'node:path';
+import { existsSync, statSync } from 'node:fs';
+import { getLogger } from '../logger.ts';
+import { deploy } from './deployments.ts';
+
+const WATCHED_EXTENSIONS = ['.bpmn', '.dmn', '.form'];
+
+/**
+ * Watch for file changes and auto-deploy
+ */
+export async function watchFiles(paths: string[], options: {
+  profile?: string;
+}): Promise<void> {
+  const logger = getLogger();
+  
+  if (!paths || paths.length === 0) {
+    paths = ['.'];
+  }
+
+  // Resolve all paths
+  const resolvedPaths = paths.map(p => resolve(p));
+  
+  // Validate paths exist
+  for (const path of resolvedPaths) {
+    if (!existsSync(path)) {
+      logger.error(`Path does not exist: ${path}`);
+      process.exit(1);
+    }
+  }
+
+  logger.info(`👁️  Watching for changes in: ${resolvedPaths.join(', ')}`);
+  logger.info(`📋 Monitoring extensions: ${WATCHED_EXTENSIONS.join(', ')}`);
+  logger.info('Press Ctrl+C to stop watching\n');
+
+  // Keep track of recently deployed files to avoid duplicate deploys
+  const recentlyDeployed = new Map<string, number>();
+  const DEPLOY_COOLDOWN = 1000; // 1 second cooldown
+
+  // Watch each path
+  for (const path of resolvedPaths) {
+    const stats = statSync(path);
+    const isDirectory = stats.isDirectory();
+
+    const watcher = watch(path, { recursive: isDirectory }, async (eventType, filename) => {
+      if (!filename) return;
+
+      const ext = extname(filename);
+      if (!WATCHED_EXTENSIONS.includes(ext)) {
+        return;
+      }
+
+      const fullPath = isDirectory ? resolve(path, filename) : path;
+      
+      // Check cooldown to prevent duplicate deploys
+      const lastDeploy = recentlyDeployed.get(fullPath);
+      const now = Date.now();
+      if (lastDeploy && (now - lastDeploy) < DEPLOY_COOLDOWN) {
+        return;
+      }
+
+      // Check if file still exists (might have been deleted)
+      if (!existsSync(fullPath)) {
+        logger.info(`⚠️  File deleted, skipping: ${basename(filename)}`);
+        return;
+      }
+
+      logger.info(`\n🔄 Change detected: ${basename(filename)}`);
+      recentlyDeployed.set(fullPath, now);
+
+      try {
+        await deploy([fullPath], { profile: options.profile });
+      } catch (error) {
+        logger.error(`Failed to deploy ${basename(filename)}`, error as Error);
+      }
+    });
+
+    // Handle watcher errors
+    watcher.on('error', (error) => {
+      logger.error('Watcher error', error);
+    });
+  }
+
+  // Keep process alive
+  process.on('SIGINT', () => {
+    logger.info('\n\n🍹 - bottoms up.');
+    process.exit(0);
+  });
+}

src/index.ts

@@ -23,6 +23,7 @@ import { publishMessage, correlateMessage } from './commands/messages.ts';
 import { getTopology } from './commands/topology.ts';
 import { deploy } from './commands/deployments.ts';
 import { run } from './commands/run.ts';
+import { watchFiles } from './commands/watch.ts';
 import { loadPlugin, unloadPlugin, listPlugins } from './commands/plugins.ts';
 import { 
   loadInstalledPlugins, 
@@ -425,6 +426,15 @@ async function main() {
     return;
   }
 
+  // Handle watch command
+  if (verb === 'watch' || verb === 'w') {
+    const paths = resource ? [resource, ...args] : (args.length > 0 ? args : ['.']);
+    await watchFiles(paths, {
+      profile: values.profile as string | undefined,
+    });
+    return;
+  }
+
   // Try to execute plugin command (before verb-only check)
   if (await executePluginCommand(verb, resource ? [resource, ...args] : args)) {
     return;

tests/fixtures/list-pis/.process-application

@@ -0,0 +1,44 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<bpmn:definitions xmlns:bpmn="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:dc="http://www.omg.org/spec/DD/20100524/DC" xmlns:zeebe="http://camunda.org/schema/zeebe/1.0" xmlns:di="http://www.omg.org/spec/DD/20100524/DI" xmlns:modeler="http://camunda.org/schema/modeler/1.0" id="Definitions_015jdpz" targetNamespace="http://bpmn.io/schema/bpmn" exporter="Camunda Modeler" exporterVersion="5.43.1" modeler:executionPlatform="Camunda Cloud" modeler:executionPlatformVersion="8.8.0">
+  <bpmn:process id="Process_0t60ay7" isExecutable="true">
+    <bpmn:startEvent id="StartEvent_1">
+      <bpmn:outgoing>Flow_1khnnfz</bpmn:outgoing>
+    </bpmn:startEvent>
+    <bpmn:sequenceFlow id="Flow_1khnnfz" sourceRef="StartEvent_1" targetRef="Activity_13vzxt6" />
+    <bpmn:endEvent id="Event_135jrp7">
+      <bpmn:incoming>Flow_0iusive</bpmn:incoming>
+    </bpmn:endEvent>
+    <bpmn:sequenceFlow id="Flow_0iusive" sourceRef="Activity_13vzxt6" targetRef="Event_135jrp7" />
+    <bpmn:userTask id="Activity_13vzxt6">
+      <bpmn:extensionElements>
+        <zeebe:userTask />
+        <zeebe:formDefinition formId="some-form" />
+      </bpmn:extensionElements>
+      <bpmn:incoming>Flow_1khnnfz</bpmn:incoming>
+      <bpmn:outgoing>Flow_0iusive</bpmn:outgoing>
+    </bpmn:userTask>
+  </bpmn:process>
+  <bpmndi:BPMNDiagram id="BPMNDiagram_1">
+    <bpmndi:BPMNPlane id="BPMNPlane_1" bpmnElement="Process_0t60ay7">
+      <bpmndi:BPMNShape id="Event_135jrp7_di" bpmnElement="Event_135jrp7">
+        <dc:Bounds x="422" y="102" width="36" height="36" />
+      </bpmndi:BPMNShape>
+      <bpmndi:BPMNShape id="Activity_0pfgzk4_di" bpmnElement="Activity_13vzxt6">
+        <dc:Bounds x="270" y="80" width="100" height="80" />
+      </bpmndi:BPMNShape>
+      <bpmndi:BPMNShape id="StartEvent_1_di" bpmnElement="StartEvent_1">
+        <dc:Bounds x="182" y="132" width="36" height="36" />
+      </bpmndi:BPMNShape>
+      <bpmndi:BPMNEdge id="Flow_1khnnfz_di" bpmnElement="Flow_1khnnfz">
+        <di:waypoint x="218" y="150" />
+        <di:waypoint x="244" y="150" />
+        <di:waypoint x="244" y="120" />
+        <di:waypoint x="270" y="120" />
+      </bpmndi:BPMNEdge>
+      <bpmndi:BPMNEdge id="Flow_0iusive_di" bpmnElement="Flow_0iusive">
+        <di:waypoint x="370" y="120" />
+        <di:waypoint x="422" y="120" />
+      </bpmndi:BPMNEdge>
+    </bpmndi:BPMNPlane>
+  </bpmndi:BPMNDiagram>
+</bpmn:definitions>

tests/fixtures/list-pis/min-usertask.bpmn

@@ -0,0 +1,23 @@
+{
+  "components": [
+    {
+      "label": "Text field 1",
+      "type": "textfield",
+      "layout": {
+        "row": "Row_0ooayjp",
+        "columns": null
+      },
+      "id": "Field_1vt56r5",
+      "key": "textfield_c9fwqc"
+    }
+  ],
+  "type": "default",
+  "id": "some-form",
+  "executionPlatform": "Camunda Cloud",
+  "executionPlatformVersion": "8.8.0",
+  "exporter": {
+    "name": "Camunda Modeler",
+    "version": "5.43.1"
+  },
+  "schemaVersion": 19
+}