Internals

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

    fn operations(&self) -> Vec<&'static str> {
        vec![
            "submit_manifest",
            "execute_workflow",
            "workflow_status",
            "agent_deployment_status",
            "scale_deployment",
            "update_manifest",
        ]
    }

    async fn invoke(&self, op: &str, payload: Value, ctx: &InvokeContext)
        -> Result<Response, ProtocolError>
    {
        match op {
            "submit_manifest" => self.submit_manifest(payload, ctx).await,
            "execute_workflow" => self.execute_workflow(payload, ctx).await,
            "workflow_status" => self.workflow_status(payload, ctx).await,
            "agent_deployment_status" => self.agent_deployment_status(payload, ctx).await,
            "scale_deployment" => self.scale_deployment(payload, ctx).await,
            "update_manifest" => self.update_manifest(payload, ctx).await,
            _ => Err(ProtocolError::UnknownOperation(op.into())),
        }
    }
}

cargo test -p moon-lib --all-features