myko 4.7.0

myko in rust
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
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112

//! Command trait definitions.

use std::{fmt::Debug, sync::Arc};

use serde::{Serialize, de::DeserializeOwned};
use serde_json::Value;

use crate::{client::MykoClient, common::with_transaction::WithTransaction, wire::WrappedCommand};

// ─────────────────────────────────────────────────────────────────────────────
// Core Command Traits
// ─────────────────────────────────────────────────────────────────────────────

pub trait CommandId {
    fn command_id(&self) -> Arc<str>;
}

/// Static command ID for registration
pub trait CommandIdStatic {
    /// The command ID as a const string (usable in static contexts)
    const COMMAND_ID: &'static str;

    /// Get the command ID (convenience method, defaults to COMMAND_ID)
    fn command_id_static() -> &'static str {
        Self::COMMAND_ID
    }
}

/// Result type for a command
pub trait CommandResultType {
    type Result: Serialize + DeserializeOwned + Clone + Send + Sync + 'static;
}

/// Type-erased command trait for dynamic dispatch.
/// All commands implement this via the `#[myko_command]` macro.
pub trait AnyCommand: WithTransaction + CommandId + Debug + Send + Sync + 'static {
    /// Serialize this command to a JSON Value.
    fn to_value(&self) -> Value;
}

// A command that can be sent; implementors provide a response type via the macro.
pub trait MykoCommand<T: DeserializeOwned + Clone + Send + Sync + 'static> {
    fn handle(
        &self,
        client: &MykoClient,
    ) -> hyphae::Cell<Option<Result<T, String>>, hyphae::CellImmutable>;
}

// ─────────────────────────────────────────────────────────────────────────────
// CommandParams - Marker trait for command parameter structs (inner type)
// ─────────────────────────────────────────────────────────────────────────────

/// Marker trait for command parameter structs.
///
/// This is implemented by the user-defined command struct (e.g., `CreateTarget`).
/// It combines identity traits without requiring transaction metadata.
///
/// The full `Command` trait is implemented on `CommandRequest<C>` where `C: CommandParams`.
pub trait CommandParams:
    Serialize
    + DeserializeOwned
    + Clone
    + Send
    + Sync
    + CommandId
    + CommandIdStatic
    + CommandResultType
    + Debug
    + 'static
{
}

// Blanket impl for any type that satisfies the bounds
impl<T> CommandParams for T where
    T: Serialize
        + DeserializeOwned
        + Clone
        + Send
        + Sync
        + CommandId
        + CommandIdStatic
        + CommandResultType
        + Debug
        + 'static
{
}

// ─────────────────────────────────────────────────────────────────────────────
// Conversions
// ─────────────────────────────────────────────────────────────────────────────

// Conversion from Arc<dyn AnyCommand> to WrappedCommand
impl From<&dyn AnyCommand> for WrappedCommand {
    fn from(command: &dyn AnyCommand) -> Self {
        WrappedCommand {
            command: command.to_value(),
            command_id: command.command_id().to_string(),
        }
    }
}

impl From<Arc<dyn AnyCommand>> for WrappedCommand {
    fn from(command: Arc<dyn AnyCommand>) -> Self {
        WrappedCommand::from(command.as_ref())
    }
}

impl From<&Arc<dyn AnyCommand>> for WrappedCommand {
    fn from(command: &Arc<dyn AnyCommand>) -> Self {
        WrappedCommand::from(command.as_ref())
    }
}