Skip to content

Commit

Permalink
update
Browse files Browse the repository at this point in the history
  • Loading branch information
haiyizxx committed Oct 18, 2024
1 parent 47ed652 commit c7c3fad
Show file tree
Hide file tree
Showing 2 changed files with 14 additions and 11 deletions.
5 changes: 2 additions & 3 deletions contracts/axelarnet-gateway/src/contract/execute.rs
Original file line number Diff line number Diff line change
Expand Up @@ -129,7 +129,7 @@ pub fn call_contract(
Response::new().add_messages(route_to_nexus(&client, &nexus, msg, token)?)
}
RoutingDestination::Router if token.is_none() => {
let (messages, events) = route_to_router(storage, &Router::new(router), vec![msg])?;
let (messages, events) = route_to_router(&Router::new(router), vec![msg])?;
Response::new().add_messages(messages).add_events(events)
}
_ => bail!(Error::InvalidRoutingDestination),
Expand Down Expand Up @@ -178,7 +178,7 @@ pub fn route_messages(
RoutingDestination::Nexus => {
route_messages_to_nexus(&client, &nexus, msgs.collect())
}
RoutingDestination::Router => route_to_router(storage, &router, msgs.collect()),
RoutingDestination::Router => route_to_router(&router, msgs.collect()),
}?;

Ok(acc.add_messages(messages).add_events(events))
Expand Down Expand Up @@ -280,7 +280,6 @@ fn prepare_msgs_for_execution(

/// Route messages to the router, ignore unknown messages.
fn route_to_router(
store: &mut dyn Storage,
router: &Router<nexus::execute::Message>,
msgs: Vec<Message>,
) -> Result<CosmosMsgWithEvent> {
Expand Down
20 changes: 12 additions & 8 deletions contracts/axelarnet-gateway/tests/query.rs
Original file line number Diff line number Diff line change
@@ -1,4 +1,5 @@
use assert_ok::assert_ok;
use axelar_core_std::nexus::test_utils::reply_with_is_chain_registered;
use axelar_core_std::query::AxelarQueryMsg;
use axelar_wasm_std::response::inspect_response_msg;
use axelarnet_gateway::msg::QueryMsg;
Expand Down Expand Up @@ -39,13 +40,16 @@ fn query_routable_messages_gets_expected_messages() {

#[test]
fn query_executable_messages_gets_expected_messages() {
let mut deps = mock_dependencies();
let mut deps = mock_axelar_dependencies();
deps.querier = deps
.querier
.with_custom_handler(reply_with_is_chain_registered(false));

utils::instantiate_contract(deps.as_mut()).unwrap();
utils::instantiate_contract(deps.as_default_mut()).unwrap();
let mut cc_ids = populate_executable_messages(&mut deps);
cc_ids.remove(3);

let executable_message = assert_ok!(query_executable_messages(deps.as_ref(), cc_ids));
let executable_message = assert_ok!(query_executable_messages(deps.as_default_deps(), cc_ids));
goldie::assert_json!(executable_message);
}

Expand Down Expand Up @@ -109,7 +113,7 @@ fn populate_routable_messages(
}

fn populate_executable_messages(
deps: &mut OwnedDeps<MockStorage, MockApi, MockQuerier>,
deps: &mut OwnedDeps<MockStorage, MockApi, MockQuerier<AxelarQueryMsg>, AxelarQueryMsg>,
) -> Vec<CrossChainId> {
let msgs: Vec<_> = (0..10)
.map(|i| Message {
Expand All @@ -121,11 +125,11 @@ fn populate_executable_messages(
})
.collect();

utils::route_from_router(deps.as_mut(), msgs.clone()).unwrap();
utils::route_from_router(deps.as_default_mut(), msgs.clone()).unwrap();

utils::execute_payload(deps.as_mut(), msgs[0].cc_id.clone(), vec![0].into()).unwrap();
utils::execute_payload(deps.as_mut(), msgs[5].cc_id.clone(), vec![5].into()).unwrap();
utils::execute_payload(deps.as_mut(), msgs[7].cc_id.clone(), vec![7].into()).unwrap();
utils::execute_payload(deps.as_default_mut(), msgs[0].cc_id.clone(), vec![0].into()).unwrap();
utils::execute_payload(deps.as_default_mut(), msgs[5].cc_id.clone(), vec![5].into()).unwrap();
utils::execute_payload(deps.as_default_mut(), msgs[7].cc_id.clone(), vec![7].into()).unwrap();

msgs.into_iter().map(|msg| msg.cc_id).collect()
}
Expand Down

0 comments on commit c7c3fad

Please sign in to comment.