-- Write logic once
DEFINE TABLE reading PERMISSIONS
  FOR create, select WHERE auth.device = $auth;
 
INSERT reading CONTENT {
  device: $auth,
  ts: time::now(),
  value: fn::get_device_input($auth)
};

-- Industrial IoT: Aggregate sensor data and run safety rules
LET $sensor_data = (
  SELECT value, ts 
  FROM sensors 
  WHERE device = $device 
  AND ts > time::now() - 1h
);

LET $anomaly_score = fn::edge_inference($sensor_data);

IF $anomaly_score > 0.8 THEN
  INSERT INTO alerts { 
    device: $device, 
    severity: "critical", 
    score: $anomaly_score 
  };
END;

-- Each register runs SurrealDB with SurrealKV
-- Transactions post locally, replicate to in-store peers

BEGIN TRANSACTION;

INSERT INTO transactions {
  register: $register_id,
  items: $cart_items,
  total: $total_amount,
  timestamp: time::now()
};

-- Sync to in-store peer for failsafe
SYNC "wss://store-gateway.local:8000";

COMMIT;

-- SurrealDB in WebAssembly stores forms, images, and graph links
INSERT INTO inspections {
  technician: $user_id,
  asset: $asset_id,
  photos: $photo_files,
  notes: $inspection_notes,
  location: $gps_coords,
  timestamp: time::now()
};

-- Graph links to assets for relationship queries
RELATE inspections:$inspection_id ->inspected-> assets:$asset_id;

-- App feels native offline; updates sent when phone reconnects
SYNC "wss://central.example.com:8000";

-- SurrealDB runs in the ECU, logs time-series data
INSERT INTO telemetry {
  vehicle: $vehicle_id,
  speed: $current_speed,
  engine_temp: $engine_temp,
  location: $gps_coords,
  timestamp: time::now()
};

-- Invoke Surrealism plugin with LLM for embedded inference
LET $classification = fn::vehicle_ai_analysis($telemetry_data);

-- Encrypt records with vehicle-bound keys
UPDATE telemetry SET 
  classification = $classification,
  encrypted = crypto::encrypt::aes($sensitive_data, $vehicle_key)
WHERE id = $telemetry_id;