amico-mods 0.0.4

The plugins of the Amico AI Agent Framework
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118

use amico::{
    ai::tool::{Tool, ToolBuilder},
    environment::Effector,
    resource::{IntoResource, Resource},
};
use async_trait::async_trait;

use crate::web3::wallet::WalletResource;

use super::{client::SolanaClientResource, utils::swap::swap};

/// A effector that trades solana tokens on Raydium
#[derive(Clone)]
pub struct TradeEffector {
    client: SolanaClientResource,
    wallet: WalletResource,
}

impl TradeEffector {
    /// Create a new trade effector
    ///
    /// Arguments:
    ///    * `client` - The client resource.
    ///    * `wallet` - The wallet resource.
    ///
    /// Returns:
    ///    * `TradeEffector` - The new trade effector instance.
    pub fn new(client: SolanaClientResource, wallet: WalletResource) -> Self {
        Self { client, wallet }
    }

    /// Get a tool that can be used to trade solana tokens on Raydium
    ///
    /// Arguments:
    ///    * `effector` - The trade effector.
    ///
    /// Returns:
    ///    * `Tool` - The trade tool.
    ///
    /// **NOTE**: This is the temporary approach. Wait for `Environment` model to support effector
    /// in the future release.
    pub fn tool(&self) -> Tool {
        let effector = self.clone();
        ToolBuilder::new()
            .name("trade_solana_token")
            .description("Trade solana tokens on Raydium")
            .parameters(serde_json::json!({
                "type": "object",
                "properties": {
                    "input_mint": {
                        "type": "string",
                        "description": "The Solana pubkey of input token mint, 'sol' for native token."
                    },
                    "output_mint": {
                        "type": "string",
                        "description": "The Solana pubkey of output token mint, 'sol' for native token."
                    },
                    "amount": {
                        "type": "string",
                        "description": "The amount of token to trade."
                    }
                },
                "required": ["input_mint", "output_mint", "amount"],
            }))
            .build_async(move |args| {
                let effector = effector.clone();
                let effector_args = TradeEffectorArgs {
                    input_mint: args["input_mint"].to_string(),
                    output_mint: args["output_mint"].to_string(),
                    amount: args["amount"].to_string(),
                };

                async move {
                    effector
                        .effect(effector_args)
                        .await
                        .map(|_| serde_json::json!({"status": "success"}))
                }
            })
    }
}

impl IntoResource<TradeEffector> for TradeEffector {
    fn into_resource(self) -> Resource<TradeEffector> {
        Resource::new("trade_effector", self)
    }
}

/// Arguments for the trade effector
pub struct TradeEffectorArgs {
    pub input_mint: String,
    pub output_mint: String,
    pub amount: String,
}

/// Errors that can occur during trade
#[derive(Debug, thiserror::Error)]
pub enum TradeError {
    #[error("Client error")]
    ClientError,
}

#[async_trait]
impl Effector for TradeEffector {
    type Args = TradeEffectorArgs;
    type Output = ();

    async fn effect(&self, args: Self::Args) -> anyhow::Result<Self::Output> {
        swap(
            self.client.get().rpc_client(),
            self.wallet.get().solana(),
            &args.input_mint,
            &args.output_mint,
            &args.amount,
        )
        .map_err(|_| anyhow::anyhow!("Failed to trade solana tokens on Raydium"))
    }
}