haystack_server/ops/
invoke.rs

1//! The `invokeAction` op — invoke an action on an entity.
2//!
3//! Parses `id` and `action` columns from the request grid, resolves
4//! the entity from the graph, and dispatches to the ActionRegistry.
5
6use actix_web::{HttpRequest, HttpResponse, web};
7
8use haystack_core::kinds::Kind;
9
10use crate::content;
11use crate::error::HaystackError;
12use crate::state::AppState;
13
14/// POST /api/invokeAction
15///
16/// Request grid must have `id` (Ref) and `action` (Str) columns in the
17/// first row.  Additional columns are passed as arguments to the handler.
18pub async fn handle(
19    req: HttpRequest,
20    body: String,
21    state: web::Data<AppState>,
22) -> Result<HttpResponse, HaystackError> {
23    let content_type = req
24        .headers()
25        .get("Content-Type")
26        .and_then(|v| v.to_str().ok())
27        .unwrap_or("");
28    let accept = req
29        .headers()
30        .get("Accept")
31        .and_then(|v| v.to_str().ok())
32        .unwrap_or("");
33
34    let request_grid = content::decode_request_grid(&body, content_type)
35        .map_err(|e| HaystackError::bad_request(format!("failed to decode request: {e}")))?;
36
37    // Extract id and action from the first row
38    let row = request_grid
39        .row(0)
40        .ok_or_else(|| HaystackError::bad_request("request grid has no rows"))?;
41
42    let ref_val = match row.get("id") {
43        Some(Kind::Ref(r)) => &r.val,
44        _ => {
45            return Err(HaystackError::bad_request(
46                "request row must have an 'id' column with a Ref value",
47            ));
48        }
49    };
50
51    let action = match row.get("action") {
52        Some(Kind::Str(s)) => s.as_str(),
53        _ => {
54            return Err(HaystackError::bad_request(
55                "request row must have an 'action' column with a Str value",
56            ));
57        }
58    };
59
60    // Resolve entity from the graph
61    let entity = state
62        .graph
63        .get(ref_val)
64        .ok_or_else(|| HaystackError::not_found(format!("entity not found: {ref_val}")))?;
65
66    // The remaining tags in the row serve as arguments (clone row as args dict)
67    let args = row.clone();
68
69    log::info!("invokeAction: id={ref_val} action={action}");
70
71    // Dispatch to the action registry
72    let result_grid = state
73        .actions
74        .invoke(&entity, action, &args)
75        .map_err(HaystackError::bad_request)?;
76
77    let (encoded, ct) = content::encode_response_grid(&result_grid, accept)
78        .map_err(|e| HaystackError::internal(format!("encoding error: {e}")))?;
79
80    Ok(HttpResponse::Ok().content_type(ct).body(encoded))
81}
haystack_server/ops/invoke.rs

haystack_server/ops/
invoke.rs
