refactor: Use enum-only format for mock source dataType config

- Remove string format support and custom deserializer for dataType
- DataType now requires object format: { type: counter|sensor_reading|generic }
- sensor_reading supports sensor_count parameter (default: 5)
- Update all example configs to use enum format
- Update README documentation
- Update all tests

Author: agentofreality

README.md

@@ -351,17 +351,18 @@ sources:
 
 Generates synthetic test data for development and demonstrations. Supports three data types with configurable generation intervals.
 
-**Simple string format:**
+**Configuration format:**
 ```yaml
 sources:
   - kind: mock
     id: test-source
     autoStart: true
-    dataType: sensor_reading    # or "counter", "generic"
+    dataType:
+      type: generic    # or "counter", "sensor_reading"
     intervalMs: 2000
 ```
 
-**Object format with sensor count:**
+**Sensor reading with custom sensor count:**
 ```yaml
 sources:
   - kind: mock
@@ -375,16 +376,16 @@ sources:
 
 | Field | Type | Default | Description |
 |-------|------|---------|-------------|
-| `dataType` | string or object | `generic` | Type of mock data (see below) |
+| `dataType` | object | `{ type: generic }` | Type of mock data (see below) |
 | `intervalMs` | integer | `5000` | Data generation interval in milliseconds |
 
 **Data Types:**
 
-| Type | String Value | Generated Nodes | Properties |
-|------|--------------|-----------------|------------|
-| Counter | `counter` | `Counter` | `value` (sequential int), `timestamp` |
-| Sensor Reading | `sensor_reading` or `sensor` | `SensorReading` | `sensor_id`, `temperature` (20-30°C), `humidity` (40-60%), `timestamp` |
-| Generic | `generic` | `Generic` | `value` (random int), `message`, `timestamp` |
+| Type | Value | Generated Nodes | Properties |
+|------|-------|-----------------|------------|
+| Counter | `{ type: counter }` | `Counter` | `value` (sequential int), `timestamp` |
+| Sensor Reading | `{ type: sensor_reading, sensor_count: N }` | `SensorReading` | `sensor_id`, `temperature` (20-30°C), `humidity` (40-60%), `timestamp` |
+| Generic | `{ type: generic }` | `Generic` | `value` (random int), `message`, `timestamp` |
 
 **Sensor Reading Behavior:**
 - First reading for each sensor generates an **INSERT** event

config/server-docker.yaml

@@ -20,7 +20,8 @@ sources:
   - id: order-status-source
     autoStart: true
     kind: mock
-    dataType: generic
+    dataType:
+      type: generic
     intervalMs: 3000
 
 queries:

examples/configs/01-fundamentals/first-continuous-query.yaml

@@ -34,14 +34,16 @@ logLevel: info
 persistConfig: false
 
 sources:
-  # Mock source generates data with labels based on dataType:
-  #   - "sensor" → SensorReading nodes with temperature, humidity, sensor_id
-  #   - "counter" → Counter nodes with count value
-  #   - "generic" → Generic nodes with value and message
+  # Mock source generates data with labels based on dataType enum:
+  #   - { type: sensor_reading, sensor_count: N } → SensorReading nodes with temperature, humidity, sensor_id
+  #     First reading per sensor = INSERT, subsequent readings = UPDATE
+  #   - { type: counter } → Counter nodes with sequential count value (always INSERT)
+  #   - { type: generic } → Generic nodes with random value and message (always INSERT)
   - kind: mock
     id: sensor-data
     autoStart: true
-    dataType: "sensor"
+    dataType:
+      type: sensor_reading
     intervalMs: 2000
 
 queries:

examples/configs/01-fundamentals/hello-world.yaml

@@ -37,16 +37,21 @@ logLevel: info
 persistConfig: false
 
 # A simple mock source that generates test data
-# dataType options: "sensor" (Sensor), "counter" (Counter), "generic" (Generic)
+# dataType is an enum with the following options:
+#   - { type: sensor_reading, sensor_count: N } - SensorReading nodes with sensor_id, temperature, humidity
+#     (first reading per sensor = INSERT, subsequent = UPDATE, default sensor_count: 5)
+#   - { type: counter } - Counter nodes with sequential value
+#   - { type: generic } - Generic nodes with random value and message
 sources:
   - kind: mock
     id: test-source
     autoStart: true
-    dataType: "sensor"
+    dataType:
+      type: sensor_reading
     intervalMs: 3000
 
 # A query that matches all data from the source
-# Note: The mock source with dataType "sensor" generates SensorReading nodes
+# Note: The mock source with type: sensor_reading generates SensorReading nodes
 queries:
   - id: all-sensors
     autoStart: true

examples/configs/01-fundamentals/mock-with-logging.yaml

@@ -40,7 +40,8 @@ sources:
   - kind: mock
     id: data-generator
     autoStart: true
-    dataType: "generic"
+    dataType:
+      type: generic
     intervalMs: 3000
 
 queries:

examples/configs/03-reactions/grpc-streaming-reaction.yaml

@@ -45,7 +45,8 @@ sources:
   - kind: mock
     id: events
     autoStart: true
-    dataType: "generic"
+    dataType:
+      type: generic
     intervalMs: 500
 
 queries:

examples/configs/03-reactions/http-webhook-sender.yaml

@@ -49,7 +49,8 @@ sources:
   - kind: mock
     id: orders
     autoStart: true
-    dataType: "generic"
+    dataType:
+      type: generic
     intervalMs: 3000
 
 queries:

examples/configs/03-reactions/log-with-templates.yaml

@@ -44,7 +44,8 @@ sources:
   - kind: mock
     id: events
     autoStart: true
-    dataType: "generic"
+    dataType:
+      type: generic
     intervalMs: 2000
 
 queries:

examples/configs/03-reactions/profiler-performance.yaml

@@ -49,7 +49,8 @@ sources:
   - kind: mock
     id: high-volume
     autoStart: true
-    dataType: "generic"
+    dataType:
+      type: generic
     intervalMs: 100
 
 queries:

examples/configs/03-reactions/sse-browser-streaming.yaml

@@ -47,10 +47,12 @@ persistConfig: false
 
 sources:
   # Mock source generates SensorReading nodes with temperature, humidity, sensor_id
+  # First reading per sensor = INSERT, subsequent = UPDATE
   - kind: mock
     id: live-data
     autoStart: true
-    dataType: "sensor"
+    dataType:
+      type: sensor_reading
     intervalMs: 1000
 
 queries: