Internals

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

    fn operations(&self) -> Vec<&'static str> {
        vec![
            "register_agent",
            "query_registry",
            "publish_manifest",
            "discovery",
        ]
    }

    async fn invoke(&self, op: &str, payload: Value, ctx: &InvokeContext)
        -> Result<Response, ProtocolError>
    {
        match op {
            "register_agent" => self.register_agent(payload, ctx).await,
            "query_registry" => self.query_registry(payload, ctx).await,
            "publish_manifest" => self.publish_manifest(payload, ctx).await,
            "discovery" => self.discovery(payload, ctx).await,
            _ => Err(ProtocolError::UnknownOperation(op.into())),
        }
    }
}

cargo test -p mars-lib --all-features