so many bugs

[whalebotdev]

error: future cannot be sent between threads safely
--> src/engine/copy_trading.rs:2025:5
|
2025 | / tokio::spawn(async move {
2026 | | let _ = monitor_token_for_selling(
2027 | | token_mint_cloned,
2028 | | app_state_cloned,
... |
2033 | | ).await;
2034 | | });
| |______^ future created by async block is not Send
|
= help: within {async block@src/engine/copy_trading.rs:2025:18: 2025:28}, the trait std::marker::Send is not implemented for Rc<solana_sdk::signature::Keypair>
note: future is not Send as this value is used across an await
--> src/dex/pump_fun.rs:425:100
|
406 | let sandwich_client = SandwichProgramClient::new(
| --------------- has type SandwichProgramClient which is not Send
...
425 | let token_amount = match self.rpc_nonblocking_client.get_token_account(&token_ata).await {
| ^^^^^ await occurs here, with sandwich_client maybe used later
note: required by a bound in tokio::spawn
--> /root/.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.46.1/src/task/spawn.rs:168:21
|
166 | pub fn spawn(future: F) -> JoinHandle<F::Output>
| ----- required by a bound in this function
167 | where
168 | F: Future + Send + 'static,
| ^^^^ required by this bound in spawn

error: future cannot be sent between threads safely
--> src/engine/copy_trading.rs:2025:5
|
2025 | / tokio::spawn(async move {
2026 | | let _ = monitor_token_for_selling(
2027 | | token_mint_cloned,
2028 | | app_state_cloned,
... |
2033 | | ).await;
2034 | | });
| |______^ future created by async block is not Send
|
= help: within SandwichProgramClient, the trait Sync is not implemented for Rc<solana_sdk::signature::Keypair>
note: future is not Send as this value is used across an await
--> src/engine/solana_program_client.rs:215:74
|
135 | &self,
| ----- has type &SandwichProgramClient which is not Send
...
215 | let recent_blockhash = self.program.rpc().get_latest_blockhash().await?;
| ^^^^^ await occurs here, with &self maybe used later
note: required by a bound in tokio::spawn
--> /root/.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.46.1/src/task/spawn.rs:168:21
|
166 | pub fn spawn(future: F) -> JoinHandle<F::Output>
| ----- required by a bound in this function
167 | where
168 | F: Future + Send + 'static,
| ^^^^ required by this bound in spawn

error: future cannot be sent between threads safely
--> src/engine/selling_strategy.rs:557:29
|
557 | / ... tokio::spawn(async move {
558 | | ... // Create trade info for emergency sell
559 | | ... match engine_clone.metrics_to_trade_info(&token_mint_clone).await {
560 | | ... Ok(trade_info) => {
... |
571 | | ... });
| |________________________^ future created by async block is not Send
|
= help: within {async block@src/engine/selling_strategy.rs:557:42: 557:52}, the trait std::marker::Send is not implemented for Rc<solana_sdk::signature::Keypair>
note: future is not Send as this value is used across an await
--> src/dex/pump_fun.rs:425:100
|
406 | let sandwich_client = SandwichProgramClient::new(
| --------------- has type SandwichProgramClient which is not Send
...
425 | let token_amount = match self.rpc_nonblocking_client.get_token_account(&token_ata).await {
| ^^^^^ await occurs here, with sandwich_client maybe used later
note: required by a bound in tokio::spawn
--> /root/.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.46.1/src/task/spawn.rs:168:21
|
166 | pub fn spawn(future: F) -> JoinHandle<F::Output>
| ----- required by a bound in this function
167 | where
168 | F: Future + Send + 'static,
| ^^^^ required by this bound in spawn

error: future cannot be sent between threads safely
--> src/engine/selling_strategy.rs:557:29
|
557 | / ... tokio::spawn(async move {
558 | | ... // Create trade info for emergency sell
559 | | ... match engine_clone.metrics_to_trade_info(&token_mint_clone).await {
560 | | ... Ok(trade_info) => {
... |
571 | | ... });
| |________________________^ future created by async block is not Send
|
= help: within SandwichProgramClient, the trait Sync is not implemented for Rc<solana_sdk::signature::Keypair>
note: future is not Send as this value is used across an await
--> src/engine/solana_program_client.rs:215:74
|
135 | &self,
| ----- has type &SandwichProgramClient which is not Send
...
215 | let recent_blockhash = self.program.rpc().get_latest_blockhash().await?;
| ^^^^^ await occurs here, with &self maybe used later
note: required by a bound in tokio::spawn
--> /root/.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.46.1/src/task/spawn.rs:168:21
|
166 | pub fn spawn(future: F) -> JoinHandle<F::Output>
| ----- required by a bound in this function
167 | where
168 | F: Future + Send + 'static,
| ^^^^ required by this bound in spawn

error: future cannot be sent between threads safely
--> src/engine/selling_strategy.rs:2161:29
|
2161 | / ... tokio::spawn(async move {
2162 | | ... // Create trade info for emergency sell
2163 | | ... if let Ok(trade_info) = engine_clone.metrics_to_trade_info(&token_mint_clone).await {
2164 | | ... if let Err(e) = engine_clone.emergency_sell_all(&token_mint_clone, &trade_info, SwapProtocol::PumpFun).await {
... |
2175 | | ... });
| |________________________^ future created by async block is not Send
|
= help: within {async block@src/engine/selling_strategy.rs:2161:42: 2161:52}, the trait std::marker::Send is not implemented for Rc<solana_sdk::signature::Keypair>
note: future is not Send as this value is used across an await
--> src/dex/pump_fun.rs:425:100
|
406 | let sandwich_client = SandwichProgramClient::new(
| --------------- has type SandwichProgramClient which is not Send
...
425 | let token_amount = match self.rpc_nonblocking_client.get_token_account(&token_ata).await {
| ^^^^^ await occurs here, with sandwich_client maybe used later
note: required by a bound in tokio::spawn
--> /root/.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.46.1/src/task/spawn.rs:168:21
|
166 | pub fn spawn(future: F) -> JoinHandle<F::Output>
| ----- required by a bound in this function
167 | where
168 | F: Future + Send + 'static,
| ^^^^ required by this bound in spawn

error: future cannot be sent between threads safely
--> src/engine/selling_strategy.rs:2161:29
|
2161 | / ... tokio::spawn(async move {
2162 | | ... // Create trade info for emergency sell
2163 | | ... if let Ok(trade_info) = engine_clone.metrics_to_trade_info(&token_mint_clone).await {
2164 | | ... if let Err(e) = engine_clone.emergency_sell_all(&token_mint_clone, &trade_info, SwapProtocol::PumpFun).await {
... |
2175 | | ... });
| |________________________^ future created by async block is not Send
|
= help: within SandwichProgramClient, the trait Sync is not implemented for Rc<solana_sdk::signature::Keypair>
note: future is not Send as this value is used across an await
--> src/engine/solana_program_client.rs:215:74
|
135 | &self,
| ----- has type &SandwichProgramClient which is not Send
...
215 | let recent_blockhash = self.program.rpc().get_latest_blockhash().await?;
| ^^^^^ await occurs here, with &self maybe used later
note: required by a bound in tokio::spawn
--> /root/.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.46.1/src/task/spawn.rs:168:21
|
166 | pub fn spawn(future: F) -> JoinHandle<F::Output>
| ----- required by a bound in this function
167 | where
168 | F: Future + Send + 'static,
| ^^^^ required by this bound in spawn

[coffellas-cto]

Replace Rc with Arc to make it thread-safe and satisfy Tokio's spawn requirements.