docs: align HTTP API examples with current JanusQL syntax

Author: argahsuknesib

docs/HTTP_API.md

@@ -61,11 +61,11 @@ Register a new JanusQL query.
 ```json
 {
   "query_id": "sensor_query_1",
-  "janusql": "SELECT ?sensor ?temp FROM HISTORICAL FIXED WINDOW [2024-01-01T00:00:00Z, 2024-01-02T00:00:00Z] WHERE { ?sensor <http://example.org/temperature> ?temp . }"
+  "janusql": "PREFIX ex: <http://example.org/> SELECT ?sensor ?temp FROM NAMED WINDOW ex:histWindow ON STREAM ex:sensorStream [START 1704067200 END 1704153600] WHERE { WINDOW ex:histWindow { ?sensor ex:temperature ?temp . } }"
 }
 ```
 
-**Response (201 Created):**
+**Response (200 OK):**
 ```json
 {
   "query_id": "sensor_query_1",
@@ -375,7 +375,7 @@ curl -X POST http://localhost:8080/api/queries \
   -H "Content-Type: application/json" \
   -d '{
     "query_id": "temp_query",
-    "janusql": "SELECT ?sensor ?temp FROM HISTORICAL FIXED WINDOW [2024-01-01T00:00:00Z, 2024-01-02T00:00:00Z] WHERE { ?sensor <http://example.org/temperature> ?temp . }"
+    "janusql": "PREFIX ex: <http://example.org/> SELECT ?sensor ?temp FROM NAMED WINDOW ex:histWindow ON STREAM ex:sensorStream [START 1704067200 END 1704153600] WHERE { WINDOW ex:histWindow { ?sensor ex:temperature ?temp . } }"
   }'
 ```
 
@@ -439,7 +439,7 @@ response = requests.post(
     f"{BASE_URL}/api/queries",
     json={
         "query_id": "my_query",
-        "janusql": "SELECT ?s ?p ?o FROM HISTORICAL FIXED WINDOW [2024-01-01T00:00:00Z, 2024-01-02T00:00:00Z] WHERE { ?s ?p ?o }"
+        "janusql": "PREFIX ex: <http://example.org/> SELECT ?s ?p ?o FROM NAMED WINDOW ex:histWindow ON STREAM ex:sensorStream [START 1704067200 END 1704153600] WHERE { WINDOW ex:histWindow { ?s ?p ?o . } }"
     }
 )
 print(f"Register: {response.json()}")
@@ -477,7 +477,7 @@ async function demo() {
   // Register a query
   const registerResponse = await axios.post(`${BASE_URL}/api/queries`, {
     query_id: 'js_query',
-    janusql: 'SELECT ?s ?p ?o FROM HISTORICAL FIXED WINDOW [2024-01-01T00:00:00Z, 2024-01-02T00:00:00Z] WHERE { ?s ?p ?o }'
+    janusql: 'PREFIX ex: <http://example.org/> SELECT ?s ?p ?o FROM NAMED WINDOW ex:histWindow ON STREAM ex:sensorStream [START 1704067200 END 1704153600] WHERE { WINDOW ex:histWindow { ?s ?p ?o . } }'
   });
   console.log('Registered:', registerResponse.data);
 
@@ -606,7 +606,7 @@ For a simple demo dashboard with "Start Replay" and "Start Query" buttons:
           headers: { 'Content-Type': 'application/json' },
           body: JSON.stringify({
             query_id: QUERY_ID,
-            janusql: 'SELECT ?sensor ?temp FROM HISTORICAL FIXED WINDOW [2024-01-01T00:00:00Z, 2024-01-02T00:00:00Z] WHERE { ?sensor <http://example.org/temperature> ?temp . }'
+            janusql: 'PREFIX ex: <http://example.org/> SELECT ?sensor ?temp FROM NAMED WINDOW ex:histWindow ON STREAM ex:sensorStream [START 1704067200 END 1704153600] WHERE { WINDOW ex:histWindow { ?sensor ex:temperature ?temp . } }'
           })
         });
 
@@ -844,4 +844,4 @@ Options:
 
 For issues, feature requests, or questions:
 - GitHub Issues: https://github.com/SolidLabResearch/janus/issues
-- Documentation: https://github.com/SolidLabResearch/janus
+- Documentation: https://github.com/SolidLabResearch/janus

docs/HTTP_API_IMPLEMENTATION.md

@@ -76,11 +76,11 @@ Request:
 ```json
 {
   "query_id": "sensor_query_1",
-  "janusql": "SELECT ?sensor ?temp FROM HISTORICAL FIXED WINDOW [2024-01-01T00:00:00Z, 2024-01-02T00:00:00Z] WHERE { ?sensor <http://example.org/temperature> ?temp . }"
+  "janusql": "PREFIX ex: <http://example.org/> SELECT ?sensor ?temp FROM NAMED WINDOW ex:histWindow ON STREAM ex:sensorStream [START 1704067200 END 1704153600] WHERE { WINDOW ex:histWindow { ?sensor ex:temperature ?temp . } }"
 }
 ```
 
-Response (201):
+Response (200):
 ```json
 {
   "query_id": "sensor_query_1",
@@ -322,7 +322,7 @@ const response = await fetch('http://localhost:8080/api/queries', {
   headers: { 'Content-Type': 'application/json' },
   body: JSON.stringify({
     query_id: 'my_query',
-    janusql: 'SELECT ?s ?p ?o FROM HISTORICAL FIXED WINDOW [2024-01-01T00:00:00Z, 2024-12-31T23:59:59Z] WHERE { ?s ?p ?o }'
+    janusql: 'PREFIX ex: <http://example.org/> SELECT ?s ?p ?o FROM NAMED WINDOW ex:histWindow ON STREAM ex:sensorStream [START 1704067200 END 1735689599] WHERE { WINDOW ex:histWindow { ?s ?p ?o . } }'
   })
 });
 
@@ -349,7 +349,7 @@ import json
 # Register query
 requests.post('http://localhost:8080/api/queries', json={
     'query_id': 'my_query',
-    'janusql': 'SELECT ?s ?p ?o FROM HISTORICAL FIXED WINDOW [2024-01-01T00:00:00Z, 2024-12-31T23:59:59Z] WHERE { ?s ?p ?o }'
+    'janusql': 'PREFIX ex: <http://example.org/> SELECT ?s ?p ?o FROM NAMED WINDOW ex:histWindow ON STREAM ex:sensorStream [START 1704067200 END 1735689599] WHERE { WINDOW ex:histWindow { ?s ?p ?o . } }'
 })
 
 # Start query
@@ -373,7 +373,7 @@ ws.run_forever()
 # Register
 curl -X POST http://localhost:8080/api/queries \
   -H "Content-Type: application/json" \
-  -d '{"query_id": "test", "janusql": "SELECT ?s ?p ?o FROM HISTORICAL FIXED WINDOW [2024-01-01T00:00:00Z, 2024-12-31T23:59:59Z] WHERE { ?s ?p ?o }"}'
+  -d '{"query_id": "test", "janusql": "PREFIX ex: <http://example.org/> SELECT ?s ?p ?o FROM NAMED WINDOW ex:histWindow ON STREAM ex:sensorStream [START 1704067200 END 1735689599] WHERE { WINDOW ex:histWindow { ?s ?p ?o . } }"}'
 
 # Start
 curl -X POST http://localhost:8080/api/queries/test/start
@@ -559,4 +559,4 @@ The Janus HTTP API is fully implemented and ready for use. It provides:
 
 The implementation follows Rust best practices, uses modern async patterns, and integrates seamlessly with the existing Janus architecture.
 
-**Ready for testing and integration with external dashboards and agents.**
+**Ready for testing and integration with external dashboards and agents.**

docs/MVP_TODO.md

@@ -836,7 +836,7 @@ async fn main() {
         .route("/api/queries", post(register_query))
         .route("/api/queries", get(list_queries))
         .route("/api/queries/:id/start", post(start_query))
-        .route("/api/queries/:id/stop", post(stop_query))
+        .route("/api/queries/:id", delete(stop_query))
         .route("/api/queries/:id/results", get(query_results_ws))
         .layer(CorsLayer::permissive())
         .with_state(state);

docs/QUICKSTART_HTTP_API.md

@@ -56,7 +56,7 @@ curl -X POST http://localhost:8080/api/queries \
   -H "Content-Type: application/json" \
   -d '{
     "query_id": "test_query",
-    "janusql": "SELECT ?s ?p ?o FROM HISTORICAL FIXED WINDOW [2024-01-01T00:00:00Z, 2024-12-31T23:59:59Z] WHERE { ?s ?p ?o }"
+    "janusql": "PREFIX ex: <http://example.org/> SELECT ?s ?p ?o FROM NAMED WINDOW ex:histWindow ON STREAM ex:sensorStream [START 1704067200 END 1735689599] WHERE { WINDOW ex:histWindow { ?s ?p ?o . } }"
   }'
 ```
 
@@ -187,7 +187,7 @@ curl http://localhost:8080/api/replay/status
 # 4. Register and start query
 curl -X POST http://localhost:8080/api/queries \
   -H "Content-Type: application/json" \
-  -d '{"query_id": "analysis", "janusql": "SELECT ?sensor ?temp FROM HISTORICAL FIXED WINDOW [2024-01-01T00:00:00Z, 2024-12-31T23:59:59Z] WHERE { ?sensor <http://example.org/temperature> ?temp . FILTER(?temp > 25.0) }"}'
+  -d '{"query_id": "analysis", "janusql": "PREFIX ex: <http://example.org/> SELECT ?sensor ?temp FROM NAMED WINDOW ex:histWindow ON STREAM ex:sensorStream [START 1704067200 END 1735689599] WHERE { WINDOW ex:histWindow { ?sensor ex:temperature ?temp . FILTER(?temp > 25.0) } }"}'
 
 curl -X POST http://localhost:8080/api/queries/analysis/start
 
@@ -200,7 +200,7 @@ curl -X POST http://localhost:8080/api/queries/analysis/start
 # 1. Register live query
 curl -X POST http://localhost:8080/api/queries \
   -H "Content-Type: application/json" \
-  -d '{"query_id": "live_monitor", "janusql": "SELECT ?sensor ?temp FROM LIVE SLIDING WINDOW sensors [RANGE PT10S, SLIDE PT5S] WHERE { ?sensor <http://example.org/temperature> ?temp . }"}'
+  -d '{"query_id": "live_monitor", "janusql": "PREFIX ex: <http://example.org/> SELECT ?sensor ?temp FROM NAMED WINDOW ex:liveWindow ON STREAM ex:sensorStream [RANGE 10000 STEP 5000] WHERE { WINDOW ex:liveWindow { ?sensor ex:temperature ?temp . } }"}'
 
 # 2. Start query (before replay to catch all events)
 curl -X POST http://localhost:8080/api/queries/live_monitor/start
@@ -218,7 +218,7 @@ curl -X POST http://localhost:8080/api/replay/start \
 # Register hybrid query
 curl -X POST http://localhost:8080/api/queries \
   -H "Content-Type: application/json" \
-  -d '{"query_id": "hybrid", "janusql": "SELECT ?s ?p ?o FROM HISTORICAL FIXED WINDOW [2024-01-01T00:00:00Z, 2024-01-02T00:00:00Z] FROM LIVE SLIDING WINDOW stream [RANGE PT30S, SLIDE PT10S] WHERE { ?s ?p ?o }"}'
+  -d '{"query_id": "hybrid", "janusql": "PREFIX ex: <http://example.org/> REGISTER RStream ex:output AS SELECT ?s ?p ?o FROM NAMED WINDOW ex:histWindow ON STREAM ex:sensorStream [START 1704067200 END 1704153600] FROM NAMED WINDOW ex:liveWindow ON STREAM ex:sensorStream [RANGE 30000 STEP 10000] WHERE { WINDOW ex:histWindow { ?s ?p ?o . } WINDOW ex:liveWindow { ?s ?p ?o . } }"}'
 
 # Start replay first to populate historical data
 curl -X POST http://localhost:8080/api/replay/start \
@@ -282,4 +282,4 @@ If you need test data, create `data/sensors.nq`:
 ## Support
 
 - GitHub Issues: https://github.com/SolidLabResearch/janus/issues
-- Documentation: See `HTTP_API.md` for complete API reference
+- Documentation: See `HTTP_API.md` for complete API reference

examples/http_client_example.rs

@@ -109,11 +109,14 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
     let query_request = RegisterQueryRequest {
         query_id: "sensor_query_1".to_string(),
         janusql: r#"
+            PREFIX ex: <http://example.org/>
             SELECT ?sensor ?temp ?time
-            FROM HISTORICAL FIXED WINDOW [2024-01-01T00:00:00Z, 2024-01-02T00:00:00Z]
+            FROM NAMED WINDOW ex:histWindow ON STREAM ex:sensorStream [START 1704067200 END 1704153600]
             WHERE {
-                ?sensor <http://example.org/temperature> ?temp .
-                ?sensor <http://example.org/timestamp> ?time .
+                WINDOW ex:histWindow {
+                    ?sensor ex:temperature ?temp .
+                    ?sensor ex:timestamp ?time .
+                }
             }
         "#
         .to_string(),
@@ -141,11 +144,14 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
     let live_query_request = RegisterQueryRequest {
         query_id: "live_sensor_query".to_string(),
         janusql: r#"
+            PREFIX ex: <http://example.org/>
             SELECT ?sensor ?temp
-            FROM LIVE SLIDING WINDOW sensors [RANGE PT10S, SLIDE PT5S]
+            FROM NAMED WINDOW ex:liveWindow ON STREAM ex:sensorStream [RANGE 10000 STEP 5000]
             WHERE {
-                ?sensor <http://example.org/temperature> ?temp .
-                FILTER(?temp > 25.0)
+                WINDOW ex:liveWindow {
+                    ?sensor ex:temperature ?temp .
+                    FILTER(?temp > 25.0)
+                }
             }
         "#
         .to_string(),