Internals

impl ProtocolModule for ManaProtocol {
    fn protocol_name(&self) -> &'static str { "MANA" }
    fn version(&self) -> &'static str { "v1.0.0" }

    fn operations(&self) -> Vec<&'static str> {
        vec![
            "agent_profile",
            "service_advertisement",
            "task_advertisement",
            "bid_submission",
            "negotiation",
            "task_assignment",
            "reputation_update",
            "arbitration_open",
            "arbitration_close",
        ]
    }

    async fn invoke(&self, op: &str, payload: Value, ctx: &InvokeContext)
        -> Result<Response, ProtocolError>
    {
        match op {
            "agent_profile" => self.agent_profile(payload, ctx).await,
            "service_advertisement" => self.service_advertisement(payload, ctx).await,
            "task_advertisement" => self.task_advertisement(payload, ctx).await,
            "bid_submission" => self.bid_submission(payload, ctx).await,
            "negotiation" => self.negotiation(payload, ctx).await,
            "task_assignment" => self.task_assignment(payload, ctx).await,
            "reputation_update" => self.reputation_update(payload, ctx).await,
            "arbitration_open" => self.arbitration_open(payload, ctx).await,
            "arbitration_close" => self.arbitration_close(payload, ctx).await,
            _ => Err(ProtocolError::UnknownOperation(op.into())),
        }
    }
}

cargo test -p mana-lib --all-features