Dexes MinSwap and SundaeSwap (#25)

* Dexes MinSwap and SundaeSwap

* Fix structure and some code loopes for DEXes

* Fix variable name colision

Author: miksax

Cargo.lock

@@ -27,3 +27,4 @@ serde_json = "1.0.86"
 tokio-tungstenite = "0.17.2"
 futures = "0.3.24"
 headers = "0.3.8"
+async-trait = "0.1.58"

Cargo.toml

@@ -3,4 +3,30 @@
 script_hash = "e6c90a5923713af5786963dee0fdffd830ca7e0c86a041d9e5833e91"
 request_hash = "86ae9eebd8b97944a45201e4aec1330a72291af2d071644bba015959"
 vesting_hash = "0a27b0fb1daeb27ff58a79adcefc784fe5cfb5399750d3552e8c54f9"
-address = "addr1wxr2a8htmzuhj39y2gq7ftkpxv98y2g67tg8zezthgq4jkg0a4ul4"
+address = "addr1wxr2a8htmzuhj39y2gq7ftkpxv98y2g67tg8zezthgq4jkg0a4ul4"
+type = "WingRidersV1"
+enable = true
+
+[[pools]]
+script_hash = "57c8e718c201fba10a9da1748d675b54281d3b1b983c5d1687fc7317"
+request_hash = "0ca50950adbb06c5c5f6833924a66ac873e43202588b6d338602d78d"
+vesting_hash = "73c3f85a23b2b81d7df84a9616b666b1e1c8c5fcfff6783d9c4a1a45"
+address = "addr1wyx22z2s4kasd3w976pnjf9xdty88epjqfvgkmfnscpd0rg3z8y6v"
+type = "MinSwapV1"
+enable = true
+
+[[pools]]
+script_hash = "e1317b152faac13426e6a83e06ff88a4d62cce3c1634ab0a5ec13309"
+request_hash = "a65ca58a4e9c755fa830173d2a5caed458ac0c73f97db7faae2e7e3b"
+vesting_hash = "73c3f85a23b2b81d7df84a9616b666b1e1c8c5fcfff6783d9c4a1a45"
+address = "addr1wxn9efv2f6w82hagxqtn62ju4m293tqvw0uhmdl64ch8uwc0h43gt"
+type = "MinSwapV1"
+enable = true
+
+[[pools]]
+script_hash = "4020e7fc2de75a0729c3cc3af715b34d98381e0cdbcfa99c950bc3ac"
+request_hash = "ba158766c1bae60e2117ee8987621441fac66a5e0fb9c7aca58cf20a"
+vesting_hash = "ba158766c1bae60e2117ee8987621441fac66a5e0fb9c7aca58cf20a"
+address = "addr1w9qzpelu9hn45pefc0xr4ac4kdxeswq7pndul2vuj59u8tqaxdznu"
+type = "SundaeSwapV1"
+enable = true

example.toml

@@ -1,14 +1,78 @@
+use crate::sink::common::Dex;
 use serde::Deserialize;
 
+use crate::types::{AssetAmount, Swap};
+use async_trait::async_trait;
+use oura::model::TransactionRecord;
+use sea_orm::DatabaseConnection;
+
+fn default_as_true() -> bool {
+    true
+}
+
 #[derive(Deserialize, Debug)]
 pub struct Config {
     pub pools: Vec<PoolConfig>,
 }
 
+#[derive(Deserialize, Debug, PartialEq, Eq)]
+pub struct WingRidersV1;
+#[derive(Deserialize, Debug, PartialEq, Eq)]
+pub struct MinSwapV1;
+#[derive(Deserialize, Debug, PartialEq, Eq)]
+pub struct MinSwapV2;
+#[derive(Deserialize, Debug, PartialEq, Eq)]
+pub struct SundaeSwapV1;
+#[derive(Deserialize, Debug, PartialEq, Eq)]
+pub struct Empty;
+
+#[derive(Debug, Deserialize, PartialEq, Eq)]
+pub enum PoolType {
+    WingRidersV1,
+    SundaeSwapV1,
+    MinSwapV1,
+    MinSwapV2,
+}
+
+#[async_trait]
+impl Dex for Empty {
+    async fn mean_value(
+        &self,
+        _pool: &PoolConfig,
+        _db: &DatabaseConnection,
+        _transaction: &TransactionRecord,
+    ) -> Option<(AssetAmount, AssetAmount)> {
+        unimplemented!();
+    }
+    async fn swaps(
+        &self,
+        _pool: &PoolConfig,
+        _db: &DatabaseConnection,
+        _transaction: &TransactionRecord,
+    ) -> anyhow::Result<Vec<Swap>> {
+        unimplemented!();
+    }
+}
+
 #[derive(Deserialize, Debug)]
 pub struct PoolConfig {
+    #[serde(default = "default_as_true")]
+    pub enable: bool,
     pub script_hash: String,
     pub request_hash: String,
     pub vesting_hash: String,
     pub address: String,
+    #[serde(rename = "type")]
+    pub pool_type: PoolType,
+}
+
+impl PoolConfig {
+    pub fn as_trait(&self) -> &dyn Dex {
+        match &self.pool_type {
+            PoolType::WingRidersV1 => &WingRidersV1 {},
+            PoolType::MinSwapV1 => &MinSwapV1 {},
+            PoolType::SundaeSwapV1 => &SundaeSwapV1 {},
+            _ => &Empty {},
+        }
+    }
 }

src/config.rs

@@ -483,7 +483,7 @@ pub async fn get_utxo_input(
                 }
                 let mut assets = Vec::new();
                 let mut out = TxOutputRecord {
-                    address: String::from("address"),
+                    address: o.payload.clone(),
                     amount: 0,
                     assets: None,
                     datum_hash: o.datum_hash.clone(),