aves 0.5.0

Typed async application runtime with domain messaging, RPC, and durable workflow automation
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

use serde::{Deserialize, Serialize};
use serde_json::Value;
use tokio::sync::oneshot;

use crate::bus::BusRpcContext;

use super::domain::ConfigDomain;
use super::types::{ConfigError, SectionRegistration};

/// Config actor request routed over the normal bus.
pub struct ConfigRequest {
    pub payload: ConfigRequestPayload,
    pub reply_to: oneshot::Sender<Result<ConfigResponse, ConfigError>>,
}

/// Section operations and privileged registration requests.
#[aves::bus_requests(marker = ConfigDomain, context = BusRpcContext, root_error = ConfigError, domain_error = ConfigError)]
#[derive(Debug, Clone, Serialize, Deserialize)]
pub enum ConfigRequestPayload {
    /// A Rust owner registers its section and validation behavior during setup.
    #[privileged(reason = "Config section registration is internal setup authority, not public RPC")]
    #[serde(skip)]
    RegisterSection { registration: SectionRegistration },

    /// The embedding application closes registration before runtime start.
    #[privileged(reason = "Closing Config registration is internal runtime control, not public RPC")]
    #[serde(skip)]
    SealRegistration,

    /// Returns one owner's effective section, including defaults without writing them.
    #[operation(name = "getConfigSection", kind = "query", response = ConfigSectionOutput, response_variant = "ConfigSection")]
    GetConfigSection { section: String },

    /// Merges an owner-scoped object, validates it, and saves the file.
    #[operation(name = "saveConfigSection", kind = "mutation", response = ConfigSectionSavedOutput, response_variant = "ConfigSectionSaved")]
    SaveConfigSection { section: String, value: Value },
}

/// Responses to Config actor requests.
#[aves::bus_responses]
#[derive(Debug, Clone, Serialize, Deserialize)]
pub enum ConfigResponse {
    /// One owner's effective configuration value.
    ConfigSection {
        /// The normalized value of the section.
        value: Value,
    },

    /// A section was saved successfully.
    ConfigSectionSaved {
        /// The name of the section that was saved.
        section: String,
    },

    /// Internal registration completed.
    Registered,
}

/// A successful change broadcasts only the affected owner's effective section.
#[derive(Debug, Clone, Serialize, Deserialize)]
pub enum ConfigBroadcast {
    /// Typed-owner section identifier and its complete effective value.
    ConfigChanged {
        /// The name of the section that was changed.
        section: String,
        /// The normalized value of the section.
        value: Value,
    },
}