Move swapper out of gemstone (#726)

Author: 0xh3rman

.github/workflows/ci.yml

@@ -35,7 +35,6 @@ jobs:
 
       - name: Build all integration tests only
         run: |
-          just --unstable gemstone build-integration-tests
           just --unstable build-integration-tests
 
       - name: Check gemstone dependencies

AGENTS.md

@@ -20,7 +20,7 @@ Gem Wallet Core is a Rust-based cryptocurrency wallet backend engine supporting
 
 ### Cross-Platform Library (`gemstone/`)
 Shared Rust library compiled to iOS Swift Package and Android AAR using UniFFI bindings. Contains blockchain RPC clients, swap integrations, payment URI decoding, and message signing.
- - Key module: `gemstone::swapper` — swapper module for on-device swap integrations
+- Key module: `gemstone::gem_swapper` — swapper module for on-device swap integrations
 
 ### Blockchain Support
 Individual `gem_*` crates for each blockchain with unified RPC client patterns:

Cargo.lock

@@ -43,6 +43,7 @@ members = [
     "crates/number_formatter",
     "crates/pricer_dex",
     "crates/streamer",
+    "crates/swapper",
     "crates/tracing",
 ]
 

Cargo.toml

@@ -1,7 +1,7 @@
 use std::error::Error;
 
 use primitives::{Asset, AssetBasic, AssetFull, AssetId, ChainAddress, NFTCollection, Perpetual};
-use search_index::{ASSETS_INDEX_NAME, AssetDocument, NFTS_INDEX_NAME, NFTDocument, PERPETUALS_INDEX_NAME, PerpetualDocument, SearchIndexClient};
+use search_index::{ASSETS_INDEX_NAME, AssetDocument, NFTDocument, NFTS_INDEX_NAME, PERPETUALS_INDEX_NAME, PerpetualDocument, SearchIndexClient};
 use storage::DatabaseClient;
 
 pub struct AssetsClient {
@@ -84,7 +84,14 @@ impl SearchClient {
 
         let assets: Vec<AssetDocument> = self
             .client
-            .search(ASSETS_INDEX_NAME, &request.query, &build_filter(filters), [].as_ref(), request.limit, request.offset)
+            .search(
+                ASSETS_INDEX_NAME,
+                &request.query,
+                &build_filter(filters),
+                [].as_ref(),
+                request.limit,
+                request.offset,
+            )
             .await?;
 
         Ok(assets.into_iter().map(|x| AssetBasic::new(x.asset, x.properties, x.score)).collect())
@@ -93,7 +100,14 @@ impl SearchClient {
     pub async fn get_perpetuals_search(&self, request: &SearchRequest) -> Result<Vec<Perpetual>, Box<dyn Error + Send + Sync>> {
         let perpetuals: Vec<PerpetualDocument> = self
             .client
-            .search(PERPETUALS_INDEX_NAME, &request.query, &build_filter(vec![]), [].as_ref(), request.limit, request.offset)
+            .search(
+                PERPETUALS_INDEX_NAME,
+                &request.query,
+                &build_filter(vec![]),
+                [].as_ref(),
+                request.limit,
+                request.offset,
+            )
             .await?;
 
         Ok(perpetuals.into_iter().map(|x| x.perpetual).collect())
@@ -102,7 +116,14 @@ impl SearchClient {
     pub async fn get_nfts_search(&self, request: &SearchRequest) -> Result<Vec<NFTCollection>, Box<dyn Error + Send + Sync>> {
         let nfts: Vec<NFTDocument> = self
             .client
-            .search(NFTS_INDEX_NAME, &request.query, &build_filter(vec![]), [].as_ref(), request.limit, request.offset)
+            .search(
+                NFTS_INDEX_NAME,
+                &request.query,
+                &build_filter(vec![]),
+                [].as_ref(),
+                request.limit,
+                request.offset,
+            )
             .await?;
 
         Ok(nfts.into_iter().map(|x| x.collection).collect())

apps/api/src/assets/cilent.rs

@@ -146,7 +146,8 @@ pub async fn run_consumer_fetch_nft_associations(settings: Settings, database: A
     let nft_client = NFTClient::new(&settings.postgres.url, nft_config).await;
     let nft_client = Arc::new(Mutex::new(nft_client));
     let consumer = FetchNftAssetsAddressesConsumer::new(database.clone(), stream_producer, cacher, nft_client);
-    streamer::run_consumer::<ChainAddressPayload, FetchNftAssetsAddressesConsumer, usize>(&name, stream_reader, queue, consumer, ConsumerConfig::default()).await
+    streamer::run_consumer::<ChainAddressPayload, FetchNftAssetsAddressesConsumer, usize>(&name, stream_reader, queue, consumer, ConsumerConfig::default())
+        .await
 }
 
 pub async fn run_consumer_support(settings: Settings, _database: Arc<Mutex<DatabaseClient>>) -> Result<(), Box<dyn Error + Send + Sync>> {

apps/daemon/src/consumers/mod.rs

@@ -46,9 +46,5 @@ pub async fn jobs(settings: Settings) -> Vec<Pin<Box<dyn Future<Output = ()> + S
         }
     });
 
-    vec![
-        Box::pin(assets_index_updater),
-        Box::pin(perpetuals_index_updater),
-        Box::pin(nfts_index_updater),
-    ]
+    vec![Box::pin(assets_index_updater), Box::pin(perpetuals_index_updater), Box::pin(nfts_index_updater)]
 }

apps/daemon/src/worker/search/mod.rs

@@ -3,7 +3,8 @@ use std::error::Error;
 use gem_evm::fee_calculator::FeeCalculator;
 use gem_evm::models::fee::EthereumFeeHistory;
 use gem_evm::{ether_conv::EtherConv, jsonrpc::EthereumRpc};
-use gemstone::network::{alien_provider::NativeProvider, jsonrpc_client_with_chain};
+use gemstone::alien::reqwest_provider::NativeProvider;
+use gemstone::network::jsonrpc_client_with_chain;
 use num_bigint::BigInt;
 use primitives::{Chain, PriorityFeeValue, fee::FeePriority};
 use std::fmt::Display;

bin/gas-bench/src/client.rs

@@ -13,7 +13,7 @@ use crate::{
     etherscan::EtherscanClient,
     gasflow::GasflowClient,
 };
-use gemstone::network::alien_provider::NativeProvider;
+use gemstone::alien::reqwest_provider::NativeProvider;
 use primitives::fee::FeePriority;
 
 #[derive(Debug, Clone)]

bin/gas-bench/src/main.rs

@@ -14,4 +14,4 @@ serde_json = { workspace = true }
 serde_urlencoded = { workspace = true }
 reqwest = { workspace = true, optional = true }
 hex = { workspace = true }
-tokio = { workspace = true, features = ["time"], optional = true }
+tokio = { workspace = true, features = ["time"], optional = true }