generate idempotency key with x-forward-host

Author: shenao78

src/ic-solana/src/rpc_client.rs

@@ -14,15 +14,20 @@ use serde::{de::DeserializeOwned, Serialize};
 use serde_json::{json, Value};
 
 use crate::{
-    add_metric_entry, constants::*, eddsa::hash_with_sha256, request::RpcRequest, rpc_client::multi_call::{MultiCallError, MultiCallResults}, types::{
+    add_metric_entry,
+    constants::*,
+    eddsa::hash_with_sha256,
+    request::RpcRequest,
+    rpc_client::multi_call::{MultiCallError, MultiCallResults},
+    types::{
         CommitmentConfig, EncodedConfirmedTransactionWithStatusMeta, Epoch, EpochInfo, EpochSchedule, Pubkey,
         RpcAccountInfoConfig, RpcBlockConfig, RpcBlockProductionConfig, RpcContextConfig, RpcEpochConfig,
         RpcGetVoteAccountsConfig, RpcLargestAccountsConfig, RpcLeaderScheduleConfig, RpcProgramAccountsConfig,
         RpcSendTransactionConfig, RpcSignatureStatusConfig, RpcSignaturesForAddressConfig,
         RpcSimulateTransactionConfig, RpcSupplyConfig, RpcTokenAccountsFilter, RpcTransactionConfig, Signature, Slot,
         Transaction, TransactionStatus, UiAccount, UiConfirmedBlock, UiTokenAmount, UiTransactionEncoding,
         UnixTimestamp,
-    }
+    },
 };
 
 mod compression;
@@ -133,9 +138,14 @@ impl RpcClient {
             });
         }
 
-        let idempotency_key = hash_with_sha256(&format!("{}{}", provider.network, payload));
+        let forward_host = headers
+            .iter()
+            .find(|header| header.name == "x-forward-host")
+            .map_or(String::default(), |header| header.value.clone());
+
+        let idempotency_key = hash_with_sha256(&format!("{}{}", forward_host, payload));
         headers.push(HttpHeader {
-            name: "X-Idempotency".to_string(),
+            name: "idempotency-key".to_string(),
             value: idempotency_key,
         });