haystack_server/ops/
point_write.rs

1//! The `pointWrite` op — write a value to a writable point.
2
3use actix_web::{HttpRequest, HttpResponse, web};
4
5use haystack_core::data::{HDict, HGrid};
6use haystack_core::kinds::Kind;
7
8use crate::content;
9use crate::error::HaystackError;
10use crate::state::AppState;
11
12/// POST /api/pointWrite
13///
14/// Request grid has `id`, `level`, and `val` columns.
15/// Writes the value to the entity in the graph as a simple curVal update.
16pub async fn handle(
17    req: HttpRequest,
18    body: String,
19    state: web::Data<AppState>,
20) -> Result<HttpResponse, HaystackError> {
21    let content_type = req
22        .headers()
23        .get("Content-Type")
24        .and_then(|v| v.to_str().ok())
25        .unwrap_or("");
26    let accept = req
27        .headers()
28        .get("Accept")
29        .and_then(|v| v.to_str().ok())
30        .unwrap_or("");
31
32    let request_grid = content::decode_request_grid(&body, content_type)
33        .map_err(|e| HaystackError::bad_request(format!("failed to decode request: {e}")))?;
34
35    for row in request_grid.rows.iter() {
36        let ref_val = match row.get("id") {
37            Some(Kind::Ref(r)) => r.val.clone(),
38            _ => continue,
39        };
40
41        let level = match row.get("level") {
42            Some(Kind::Number(n)) => n.val as u32,
43            _ => 17, // Default level
44        };
45
46        if !(1..=17).contains(&level) {
47            return Err(HaystackError::bad_request(format!(
48                "level must be between 1 and 17, got {level}"
49            )));
50        }
51
52        // Check that the target entity has the `writable` marker tag
53        let entity = state
54            .graph
55            .get(&ref_val)
56            .ok_or_else(|| HaystackError::not_found(format!("entity not found: {ref_val}")))?;
57        if !entity.has("writable") {
58            return Err(HaystackError::bad_request(format!(
59                "entity '{ref_val}' is not writable"
60            )));
61        }
62
63        // Get the value to write
64        if let Some(val) = row.get("val") {
65            // Simple implementation: update the entity's curVal tag at the given level
66            let mut changes = HDict::new();
67            changes.set("curVal", val.clone());
68            changes.set(
69                "writeLevel",
70                Kind::Number(haystack_core::kinds::Number::unitless(level as f64)),
71            );
72            state
73                .graph
74                .update(&ref_val, changes)
75                .map_err(|e| HaystackError::bad_request(format!("write failed: {e}")))?;
76        }
77    }
78
79    // Return empty grid on success
80    let grid = HGrid::new();
81    let (encoded, ct) = content::encode_response_grid(&grid, accept)
82        .map_err(|e| HaystackError::internal(format!("encoding error: {e}")))?;
83
84    Ok(HttpResponse::Ok().content_type(ct).body(encoded))
85}
haystack_server/ops/point_write.rs

haystack_server/ops/
point_write.rs
