amico-mods 0.0.3

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

use base64::{Engine, engine::general_purpose::STANDARD};
use sodiumoxide::crypto::{
    sealedbox,
    sign::{
        ed25519::{PublicKey as EdPublicKey, SecretKey as EdSecretKey, to_curve25519_pk},
        to_curve25519_sk,
    },
};
use solana_sdk::{pubkey::Pubkey, signature::Keypair};

#[derive(Debug, thiserror::Error)]
pub enum CryptoError {
    #[error("Failed to init sodiumoxide")]
    SodiumoxideInitError,

    #[error("Base64 decode error: {0}")]
    Base64DecodeError(#[from] base64::DecodeError),

    #[error("sodiumoxide sealedbox open error")]
    SealedBoxOpenError,

    #[error("UTF-8 decode error")]
    UTF8DecodeError(#[from] std::string::FromUtf8Error),

    #[error("Invalid public key")]
    InvalidPublicKey,

    #[error("Invalid private key")]
    InvalidPrivateKey,

    #[error("Failed to convert ed25519 key to curve25519")]
    ConvertToCurve25519Error,
}

/// Encrypt a message using a Solana public key
pub fn encrypt_message(plaintext: &str, pubkey: &Pubkey) -> Result<String, CryptoError> {
    // Initialize sodiumoxide for encryption
    sodiumoxide::init().map_err(|_| CryptoError::SodiumoxideInitError)?;
    // Convert receiver Solana pubkey to Curve25519 public key
    let receiver_pubkey_bytes = pubkey.to_bytes();
    let ed_pk =
        EdPublicKey::from_slice(&receiver_pubkey_bytes).ok_or(CryptoError::InvalidPublicKey)?;
    let receiver_curve_pk =
        to_curve25519_pk(&ed_pk).map_err(|_| CryptoError::ConvertToCurve25519Error)?;
    // Encrypt message content
    let ciphertext = sealedbox::seal(plaintext.as_bytes(), &receiver_curve_pk);
    let encrypted_content = STANDARD.encode(&ciphertext);
    Ok(encrypted_content)
}

/// Decrypt a message using a Solana keypair
pub fn decrypt_message(ciphertext: &str, keypair: &Keypair) -> Result<String, CryptoError> {
    // Initialize sodiumoxide and derive Curve25519 keys for decryption
    sodiumoxide::init().map_err(|_| CryptoError::SodiumoxideInitError)?;

    // Conv
    let sk_bytes = keypair.to_bytes();
    let ed_sk = EdSecretKey::from_slice(&sk_bytes).ok_or(CryptoError::InvalidPrivateKey)?;
    let ed_pk = ed_sk.public_key();
    let my_curve_sk =
        to_curve25519_sk(&ed_sk).map_err(|_| CryptoError::ConvertToCurve25519Error)?;
    let my_curve_pk =
        to_curve25519_pk(&ed_pk).map_err(|_| CryptoError::ConvertToCurve25519Error)?;

    // Decode and decrypt the ciphertext
    let decoded = STANDARD
        .decode(ciphertext)
        .map_err(CryptoError::Base64DecodeError)?;
    let plaintext_bytes = sealedbox::open(&decoded, &my_curve_pk, &my_curve_sk)
        .map_err(|_| CryptoError::SealedBoxOpenError)?;
    let plaintext = String::from_utf8(plaintext_bytes).map_err(CryptoError::UTF8DecodeError)?;
    Ok(plaintext)
}

#[cfg(test)]
mod tests {
    use super::*;
    use solana_sdk::signer::Signer;

    #[test]
    fn test_encrypt_decrypt() {
        let keypair = Keypair::new();
        let pubkey = keypair.pubkey();
        let message = "test";
        let encrypted = encrypt_message(message, &pubkey).unwrap();
        let decrypted = decrypt_message(&encrypted, &keypair).unwrap();
        assert_eq!(decrypted, message);
    }
}