Skip to content

Commit

Permalink
add events in TransferRewards
Browse files Browse the repository at this point in the history
  • Loading branch information
vuong177 committed Sep 6, 2024
1 parent a42acbe commit ab73677
Showing 1 changed file with 8 additions and 14 deletions.
22 changes: 8 additions & 14 deletions contracts/consumer/converter/src/ibc.rs
Original file line number Diff line number Diff line change
Expand Up @@ -192,19 +192,8 @@ pub fn ibc_channel_close(
_env: Env,
msg: IbcChannelCloseMsg,
) -> Result<IbcBasicResponse, ContractError> {
match msg {
IbcChannelCloseMsg::CloseInit { .. } => {
return Err(ContractError::IbcChannelCloseInitDisallowed)
}
IbcChannelCloseMsg::CloseConfirm { channel } => {
if channel.ne(&IBC_CHANNEL.load(deps.storage)?) {
return Err(ContractError::IbcChannelNotMatch);
}
}
};

let contract = ConverterContract::new();
let msg = virtual_staking_api::sv::ExecMsg::HandleCloseChannel {};
let msg = virtual_staking_api::sv::ExecMsg::HandleCloseChannel{};
let msg = WasmMsg::Execute {
contract_addr: contract.virtual_stake.load(deps.storage)?.into(),
msg: to_json_binary(&msg)?,
Expand Down Expand Up @@ -246,7 +235,7 @@ pub fn ibc_packet_receive(
tx_id: _,
} => {
let response = contract.unstake(deps, delegator, validator, unstake)?;
let ack = ack_success(&UnstakeAck {})?;
let ack: cosmwasm_std::Binary = ack_success(&UnstakeAck {})?;
IbcReceiveResponse::new()
.set_ack(ack)
.add_submessages(response.messages)
Expand All @@ -266,8 +255,13 @@ pub fn ibc_packet_receive(
rewards, recipient, ..
} => {
let msg = contract.transfer_rewards(deps.as_ref(), recipient, rewards)?;
let event = Event::new("mesh-transfer-rewards")
.add_attribute("recipient", &recipient)
.add_attribute("rewards", &rewards.amount.to_string());
let ack = ack_success(&TransferRewardsAck {})?;
IbcReceiveResponse::new().set_ack(ack).add_message(msg)
IbcReceiveResponse::new()
.set_ack(ack).add_message(msg)
.add_event(event)
}
};
Ok(res)
Expand Down

0 comments on commit ab73677

Please sign in to comment.