Feat: retry handle message

core/ic/src/tera/src/api/nonce.rs

@@ -9,3 +9,9 @@ use crate::{common::types::Nonce, tera::STATE};
 fn get_nonces() -> Vec<Nonce> {
     STATE.with(|s| s.get_nonces())
 }
+
+#[query(name = "nonce_exist")]
+#[candid_method(query, rename = "nonce_exist")]
+fn nonce_exist(nonce: Nonce) -> bool {
+    STATE.with(|s| s.nonce_exists(&nonce))
+}

core/ic/src/tera/tera.did

@@ -10,6 +10,7 @@ service : {
   get_messages : () -> (vec OutgoingMessagePair);
   get_messages_count : () -> (nat32) query;
   get_nonces : () -> (vec nat) query;
+  nonce_exist : (nat) -> (bool) query;
   remove_messages : (vec OutgoingMessagePair) -> (ConsumeMessageResponse);
   send_message : (principal, vec nat) -> (SendMessageResponse);
   store_message : (principal, principal, nat, vec nat) -> (

magic_bridge/ic/src/dip20_proxy/dip20_proxy.did

@@ -7,6 +7,7 @@ type ClaimableMessage = record {
   amount : nat;
   token_name : text;
 };
+type MessageStatus = variant { ConsumedNotMinted; Consuming };
 type OperationFailure = variant {
   SendMessage : opt TxError;
   Burn : opt TxError;
@@ -40,6 +41,7 @@ service : {
   get_all_token_balance : () -> (Result_1);
   get_balance : (principal, principal, nat) -> (opt nat);
   handle_message : (principal, nat, vec nat) -> (Result_2);
+  message_exist : (text) -> (opt MessageStatus) query;
   mint : (principal, nat, vec nat) -> (Result_2);
   perform_handshake : () -> (Result_3);
   remove_claimable : (principal, principal, nat) -> (Result_4);

magic_bridge/ic/src/dip20_proxy/src/api/burn.rs

@@ -92,7 +92,7 @@ async fn burn(
                             });
 
                             insert_claimable_asset(ClaimableMessage {
-                                from: caller,
+                                from: Some(caller),
                                 owner: eth_addr.clone(),
                                 msg_hash: outgoing_message.msg_hash.clone(),
                                 msg_key: Some(outgoing_message.msg_key.clone()),

magic_bridge/ic/src/dip20_proxy/src/api/messages.rs

@@ -0,0 +1,10 @@
+use candid::candid_method;
+use ic_cdk_macros::query;
+
+use crate::{common::types::MessageStatus, proxy::STATE};
+
+#[query(name = "message_exist")]
+#[candid_method(query, rename = "message_exist")]
+fn message_exist(msg_hash: String) -> Option<MessageStatus> {
+    STATE.with(|s| s.get_message(&msg_hash))
+}

magic_bridge/ic/src/dip20_proxy/src/api/mod.rs

@@ -5,6 +5,7 @@ mod claimable_assets;
 mod get_balance;
 mod handle_message;
 mod init;
+mod messages;
 mod mint;
 mod upgrade;
 mod withdraw;

magic_bridge/ic/src/dip20_proxy/src/api/withdraw.rs

@@ -77,7 +77,7 @@ pub async fn withdraw(
                 });
 
                 insert_claimable_asset(ClaimableMessage {
-                    from: caller,
+                    from: Some(caller),
                     owner: eth_addr.clone(),
                     msg_hash: outgoing_message.msg_hash.clone(),
                     msg_key: Some(outgoing_message.msg_key.clone()),

magic_bridge/ic/src/dip20_proxy/src/common/types.rs

@@ -75,7 +75,7 @@ pub struct ClaimableMessage {
     pub token_name: String,
     pub token: TokenId,
     pub amount: Nat,
-    pub from: Principal,
+    pub from: Option<Principal>,
 }
 
 #[derive(CandidType, Deserialize, Default)]

magic_bridge/ic/src/dip20_proxy/src/proxy.rs

@@ -288,14 +288,19 @@ impl ToCapEvent for ClaimableMessage {
         } else {
             [0; 32]
         };
+        let from = if self.from.is_some() {
+            self.from.unwrap()
+        } else {
+            Principal::anonymous()
+        };
         let details = DetailsBuilder::default()
             .insert("owner", self.owner)
             .insert("ethContractAddress", self.token)
             .insert("msgHash", self.msg_hash.clone())
             .insert("msgHashKey", hash_key.to_nat())
             .insert("amount", self.amount.clone())
             .insert("name", self.token_name.clone())
-            .insert("from", self.from.clone())
+            .insert("from", from)
             .build();
 
         IndefiniteEventBuilder::new()
@@ -317,7 +322,7 @@ impl From<IndefiniteEvent> for ClaimableMessage {
         let from: Principal = event.details[6].1.clone().try_into().unwrap();
 
         ClaimableMessage {
-            from: from,
+            from: Some(from),
             owner: event.caller,
             msg_key: Some(msg_key.to_nonce_bytes()),
             msg_hash: msg_hash,