feat(minor-axelarnet-gateway): route messages from nexus to router

contracts/axelarnet-gateway/src/contract.rs

@@ -3,8 +3,10 @@
 use axelar_wasm_std::{address, FnExt, IntoContractError};
 #[cfg(not(feature = "library"))]
 use cosmwasm_std::entry_point;
-use cosmwasm_std::{to_json_binary, Binary, Deps, DepsMut, Empty, Env, MessageInfo, Response};
-use error_stack::ResultExt;
+use cosmwasm_std::{
+    to_json_binary, Addr, Binary, Deps, DepsMut, Empty, Env, MessageInfo, Response, Storage,
+};
+use error_stack::{Report, ResultExt};
 
 use crate::msg::{ExecuteMsg, InstantiateMsg, QueryMsg};
 use crate::state::{self, Config};
@@ -70,7 +72,7 @@
     info: MessageInfo,
     msg: ExecuteMsg,
 ) -> Result<Response<nexus::execute::Message>, ContractError> {
-    match msg.ensure_permissions(deps.storage, &info.sender)? {
+    match msg.ensure_permissions(deps.storage, &info.sender, match_nexus)? {
         ExecuteMsg::CallContract {
             destination_chain,
             destination_address,
@@ -91,6 +93,9 @@
         ExecuteMsg::Execute { cc_id, payload } => {
             execute::execute(deps, cc_id, payload).change_context(Error::Execute)
         }
+        ExecuteMsg::RouteMessagesFromNexus(msgs) => {
+            Ok(execute::route_messages_from_nexus(deps.storage, msgs)?)
+        }
     }?
     .then(Ok)
 }
@@ -111,6 +116,10 @@
     .then(Ok)
 }
 
+fn match_nexus(storage: &dyn Storage, _: &ExecuteMsg) -> Result<Addr, Report<Error>> {
+    Ok(state::load_config(storage).nexus)
+}
+
 #[cfg(test)]
 mod tests {
     use assert_ok::assert_ok;

contracts/axelarnet-gateway/src/contract/execute.rs

@@ -55,6 +55,8 @@
     InvalidToken,
     #[error("invalid routing destination")]
     InvalidRoutingDestination,
+    #[error("failed converting the nexus message for the router")]
+    InvalidNexusMessageForRouter,
 }
 
 #[cw_serde]
@@ -173,6 +175,21 @@
         .then(Ok)
 }
 
+pub fn route_messages_from_nexus(
+    storage: &dyn Storage,
+    msgs: Vec<nexus::execute::Message>,
+) -> Result<Response<nexus::execute::Message>> {
+    let msgs: Vec<_> = msgs
+        .into_iter()
+        .map(router_api::Message::try_from)
+        .collect::<error_stack::Result<Vec<_>, _>>()
+        .change_context(Error::InvalidNexusMessageForRouter)?;
+
+    let router = Router::new(state::load_config(storage).router);
+
+    Ok(Response::new().add_messages(router.route(msgs)))
+}
+
 fn ensure_same_payload_hash(
     payload_hash: &[u8; 32],
 ) -> impl FnOnce(&Message) -> core::result::Result<(), state::Error> + '_ {

contracts/axelarnet-gateway/src/msg.rs

@@ -1,3 +1,4 @@
+use axelar_core_std::nexus;
 use cosmwasm_schema::{cw_serde, QueryResponses};
 use cosmwasm_std::HexBinary;
 use msgs_derive::EnsurePermissions;
@@ -41,6 +42,10 @@ pub enum ExecuteMsg {
         destination_address: Address,
         payload: HexBinary,
     },
+
+    /// Forward the given nexus messages to the next step of the routing layer.
+    #[permission(Specific(nexus))]
+    RouteMessagesFromNexus(Vec<nexus::execute::Message>),
 }
 
 #[cw_serde]