Implemented stuff

src/executor/mod.rs

@@ -1,7 +1,6 @@
 pub mod pump_fun;
 
 use rust_decimal::Decimal;
-use tokio::sync::Mutex;
 
 use crate::account::Account;
 
@@ -32,9 +31,7 @@ pub trait Executor {
 impl Account {
     pub fn executor(self) -> impl Executor {
         match self {
-            Self::PumpDev(account) => pump_fun::PumpDev {
-                account: Mutex::new(account),
-            },
+            Self::PumpDev(account) => pump_fun::PumpDev::new(account),
         }
     }
 }

src/executor/pump_fun.rs

@@ -1,9 +1,13 @@
+use anyhow::{Context, anyhow};
+use reqwest::Client;
 use rust_decimal::Decimal;
 use serde::{Deserialize, Serialize};
 use tokio::sync::Mutex;
 
 use crate::executor::Executor;
 
+const TRADE_LIGHTNING_URL: &str = "https://pumpdev.io/api/trade-lightning";
+
 #[derive(Debug, Clone, Serialize, Deserialize)]
 pub struct PumpDevAccount {
     #[serde(rename = "apiKey")]
@@ -14,8 +18,70 @@ pub struct PumpDevAccount {
     pub private_key: String,
 }
 
+#[derive(Debug, Deserialize)]
+struct TradeResponse {
+    signature: String,
+}
+
 pub struct PumpDev {
     pub account: Mutex<PumpDevAccount>,
+    pub client: Client,
+}
+
+impl PumpDev {
+    pub fn new(account: PumpDevAccount) -> Self {
+        Self {
+            account: Mutex::new(account),
+            client: Client::new(),
+        }
+    }
+
+    async fn trade(
+        &self,
+        action: &str,
+        mint: String,
+        amount: Decimal,
+        priority: Decimal,
+        slippage: u16,
+        denominated_in_sol: bool,
+    ) -> anyhow::Result<()> {
+        let account = self.account.lock().await;
+
+        let response = self
+            .client
+            .post(format!("{TRADE_LIGHTNING_URL}?api-key={}", account.api_key))
+            .json(&serde_json::json!({
+                "action": action,
+                "mint": mint,
+                "amount": amount,
+                "denominatedInSol": if denominated_in_sol { "true" } else { "false" },
+                "slippage": slippage,
+                "priorityFee": priority,
+            }))
+            .send()
+            .await
+            .context("Failed to send trade request")?;
+
+        let status = response.status();
+        let body = response.text().await?;
+
+        if !status.is_success() {
+            let error = serde_json::from_str::<serde_json::Value>(&body)
+                .ok()
+                .and_then(|value| value.get("error").cloned())
+                .and_then(|value| value.as_str().map(str::to_string))
+                .unwrap_or_else(|| body.trim().to_string());
+
+            return Err(anyhow!("Trade failed ({status}): {error}"));
+        }
+
+        let data: TradeResponse =
+            serde_json::from_str(&body).context("Failed to parse trade response")?;
+
+        log::info!("{action} executed: {}", data.signature);
+
+        Ok(())
+    }
 }
 
 impl Executor for PumpDev {
@@ -26,7 +92,8 @@ impl Executor for PumpDev {
         priority: Decimal,
         slippage: u16,
     ) -> anyhow::Result<()> {
-        Ok(())
+        self.trade("buy", mint, amount, priority, slippage, true)
+            .await
     }
 
     async fn sell(
@@ -36,6 +103,7 @@ impl Executor for PumpDev {
         priority: Decimal,
         slippage: u16,
     ) -> anyhow::Result<()> {
-        Ok(())
+        self.trade("sell", mint, amount, priority, slippage, false)
+            .await
     }
 }