khive-runtime 0.12.0

Composable Service API: entity/note CRUD, graph traversal, hybrid search, curation.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31

use async_trait::async_trait;
use serde_json::Value;

use crate::{KhiveRuntime, KindHook, RuntimeError};

#[derive(Debug)]
struct SharedCreateRefusal {
    kind: &'static str,
    own_verb: &'static str,
}

/// Refuse shared creation of a kind whose specialized writer owns its creation contract.
/// Delegate only `prepare_create` when the owning hook also guards updates or proposals.
pub fn refuse_shared_create(kind: &'static str, own_verb: &'static str) -> impl KindHook {
    SharedCreateRefusal { kind, own_verb }
}

#[async_trait]
impl KindHook for SharedCreateRefusal {
    async fn prepare_create(
        &self,
        _runtime: &KhiveRuntime,
        _args: &mut Value,
    ) -> Result<(), RuntimeError> {
        Err(RuntimeError::InvalidInput(format!(
            "kind={} is not creatable through shared `create`, `stream.batch`, or standalone \
             `stream.append`; only `{}` applies this kind's creation contract; use `{}` instead",
            self.kind, self.own_verb, self.own_verb
        )))
    }
}