weavegraph 0.3.0

Graph-driven, concurrent agent workflow framework with versioned state, deterministic barrier merges, and rich diagnostics.
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
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71

/*!
Helper utilities for SQLite checkpointer operations.

This module provides consistent JSON serialization/deserialization helpers
that standardize error handling and context reporting across the SQLite
checkpointer implementation. All functions convert serde errors to appropriate
`CheckpointerError` variants with contextual information.

## Usage

These helpers should be used for all JSON operations in the SQLite checkpointer
to ensure consistent error handling and debugging information.

```rust,ignore
// Serialization
let json_str = serialize_json(&data, "user_data")?;

// Deserialization
let data: MyType = deserialize_json(&json_str, "user_data")?;

// Value deserialization
let data: MyType = deserialize_json_value(json_value, "user_data")?;

// Field validation
let required_field = require_json_field(optional_field, "state_json")?;
```
*/

use crate::runtimes::checkpointer::CheckpointerError;
use crate::utils::json_ext::{deserialize_with_context, serialize_with_context};
use serde_json::Value;

/// Helper for JSON serialization with consistent error formatting.
pub(super) fn serialize_json<T: serde::Serialize>(
    value: &T,
    context: &'static str,
) -> Result<String, CheckpointerError> {
    serialize_with_context(value, context, |e, ctx| CheckpointerError::Other {
        message: format!("{ctx} serialize: {e}"),
    })
}

/// Helper for JSON deserialization with consistent error formatting.
pub(super) fn deserialize_json<T: serde::de::DeserializeOwned>(
    json: &str,
    context: &'static str,
) -> Result<T, CheckpointerError> {
    deserialize_with_context(json, context, |e, ctx| CheckpointerError::Other {
        message: format!("{ctx} parse: {e}"),
    })
}

/// Helper for JSON value deserialization with consistent error formatting.
pub(super) fn deserialize_json_value<T: serde::de::DeserializeOwned>(
    value: Value,
    context: &'static str,
) -> Result<T, CheckpointerError> {
    serde_json::from_value(value).map_err(|e| CheckpointerError::Other {
        message: format!("{context} parse (serde): {e}"),
    })
}

/// Helper for extracting required JSON fields with consistent error formatting.
pub(super) fn require_json_field(
    field: Option<String>,
    field_name: &'static str,
) -> Result<String, CheckpointerError> {
    field.ok_or_else(|| CheckpointerError::Other {
        message: format!("missing {field_name} for persisted checkpoint"),
    })
}