Aptos Network SDK

Implement most of the commonly used practical transaction-related functions of the Aptos network.

简体中文 | English

Depend

cargo add aptos-network-sdk

Quick Start

use aptos_sdk::{AptosClient, AptosClientType, Wallet, Contract};
// Create client and wallet
let client = Arc::new(AptosClient::new(AptosClientType::Devnet));
let wallet = Arc::new(Wallet::new().unwrap());

// Get account balance
let balance = client.get_apt_balance_by_account(&wallet.address().unwrap()).await?;
println!("Balance: {} APT", balance);

// Transfer APT
let recipient = "0x123...";
let result = Contract::transfer_apt(
    Arc::clone(&client),
    Arc::clone(&wallet),
    recipient,
    100_000_000, // 1 APT
).await?;
println!("Transfer hash: {}", result.transaction_hash);

// Read contract data
let call = ContractCall {
    module_address: "0x1".to_string(),
    module_name: "coin".to_string(),
    function_name: "balance".to_string(),
    type_arguments: vec!["0x1::aptos_coin::AptosCoin".to_string()],
    arguments: vec![json!(wallet.address().unwrap())],
};
let result = Contract::read(Arc::clone(&client), &call).await?;
println!("Contract result: {:?}", result.data);

Retrieve information about the hash of a specified transaction.

#[cfg(test)]
mod tests {
    use super::*;
    use std::sync::Arc;

    #[tokio::test]
    async fn test_get_specific_transaction() {
        let client = Aptos::new(AptosType::Mainnet);
        let known_tx_hash = "0xc4da6f117be28bdf63ee455dcb845fe2c4447c5b89a9fb20e3afa92d9b8f2f50";
        let result = client.get_transaction_info_by_hash(known_tx_hash).await;
        match result {
            Ok(tx) => {
                println!("✅Find Transaction: {:?}", tx);
                println!("Hash: {}", tx.hash);
                println!("Version: {}", tx.version);
            }
            Err(e) => {
                println!("❌ error: {}", e);
            }
        }
    }
}

Creating and registering new tokens

 use crate::token::{TokenManager, TokenUtils};
 use std::sync::Arc;
 use crate::{
    global::rpc::{APTOS_MAINNET_URL},
    types::*,
 };

 async fn create_new_token() -> Result<(), String> {
 let client = Arc::new(AptosClient::new(APTOS_MAINNET_URL));
 let wallet = Arc::new(Wallet::from_private_key("your_private_key"));
 let result = TokenManager::create_token(
     client.clone(),
     wallet.clone(),
     "My Token",
     "MYT",
     8,
     1_000_000_000,
 ).await?;

 let token_type = TokenUtils::build_standard_token_type(
     &wallet.address(),
     "my_token",
     "MYT"
 );
 let register_result = TokenManager::register_token(
     client.clone(),
     wallet.clone(),
     &token_type,
 ).await?;
 Ok(())
}

Token minting and balance inquiry

use crate::{
    global::rpc::{APTOS_MAINNET_URL},
};

async fn mint_and_check_balance() -> Result<(), String> {
let client = Arc::new(AptosClient::new(APTOS_MAINNET_URL));
let wallet = Arc::new(Wallet::from_private_key("your_private_key"));
    let token_type = "0x1::managed_coin::MYT";
    let recipient = "0x123...";
    let mint_result = TokenManager::mint_token(
        client.clone(),
        wallet.clone(),
        token_type,
        recipient,
        100_000_000,
    ).await?;
    let balance = TokenManager::get_token_balance(
        client.clone(),
        recipient,
        token_type,
    ).await?;
    Ok(())
}

Token search function

use crate::token::{TokenSearchManager, TokenSearchResult};
use crate::{
    global::rpc::{APTOS_MAINNET_URL},
    types::*,
};

async fn search_tokens() -> Result<(), String> {
    let client = Arc::new(AptosClient::new(APTOS_MAINNET_URL));
    let results = TokenSearchManager::get_token_by_symbol(
        client.clone(),
        "USDC",
    ).await?;
    let top_tokens = TokenSearchManager::get_top_token_vec(client.clone()).await?;
    for token in top_tokens {
       //..
    }
    Ok(())
}

Token tool usage

fn token_utils_examples() {
    let token_type = TokenUtils::build_standard_token_type("0x1234567890abcdef","my_collection","MYT");
    if let Some((creator, collection, name)) = TokenUtils::parse_token_type(&token_type) {
    }
    let address = "0x1234567890abcdef1234567890abcdef1234567890abcdef1234567890abcdef";
}

Get token trading pair information

use crate::{
    global::rpc::{APTOS_MAINNET_URL},
    types::*,
};

async fn get_trading_pairs() -> Result<(), String> {
let client = Arc::new(AptosClient::new(APTOS_MAINNET_URL));
    let token_address = "0x1::aptos_coin::AptosCoin";
    let trading_pairs = TokenSearchManager::get_token_trading_pairs(
        client.clone(),
        token_address,
    ).await?;
    for pair in trading_pairs {
       // ...
    }
    Ok(())
}

Complete token management process

use crate::{
    global::rpc::{APTOS_MAINNET_URL},
    types::*,
};

async fn complete_token_lifecycle() -> Result<(), String> {
    let client = Arc::new(AptosClient::new(APTOS_MAINNET_URL));
    let wallet = Arc::new(Wallet::from_private_key("your_private_key"));
    TokenManager::create_token(
        client.clone(),
        wallet.clone(),
        "Test Token",
        "TEST",
        6,
        10_000_000,
    ).await?;
    let token_type = format!("{}::test_token::TEST", wallet.address());
    // Register token
    TokenManager::register_token(client.clone(), wallet.clone(), &token_type).await?;
    // mint token
    TokenManager::mint_token(
        client.clone(),
        wallet.clone(),
        &token_type,
        &wallet.address(),
        1_000_000,
    ).await?;
    // Query token metadata
    let metadata = TokenManager::get_token_metadata(client.clone(), &token_type).await?;
    // Check balance
    let balance = TokenManager::get_token_balance(
        client.clone(),
        &wallet.address(),
        &token_type,
    ).await?;
    Ok(())
}

Basic event listener

use aptos_sdk::{AptosClient, AptosClientType, Contract, event::{EventHandler, EventSubscriptionManager}};

let client = Arc::new(AptosClient::new(AptosClientType::Mainnet));

// listener coin transfer events
Contract::listen_events_all_info(
    Arc::clone(&client),
    "0x1",
    "0x1::coin::WithdrawEvent",
    |result| {
        match result {
            Ok(event) => {
                println!("New Withdraw Event:");
                println!("Type: {}", event.r#type);
                println!("Sequence: {}", event.sequence_number);
                println!("Data: {:?}", event.data);

                // Extract amount from event data
                if let Some(amount) = event.data.get("amount") {
                    println!("Amount: {}", amount);
                }
            }
            Err(e) => eprintln!("Event monitoring error: {}", e),
        }
    },
    3, // check interval
).await?;

Event Streaming

use tokio::sync::broadcast;

let mut event_manager = EventSubscriptionManager::new();
let receiver = event_manager.subscribe("coin_events".to_string());

// Start event stream in background
tokio::spawn(async move {
    let (sender, _) = broadcast::channel(100);
    if let Err(e) = EventHandler::start_event_stream(
        Arc::clone(&client),
        "0x1".to_string(),
        "0x1::coin::DepositEvent".to_string(),
        sender,
    ).await {
        eprintln!("Event stream failed: {}", e);
    }
});

// Process events from receiver
while let Ok(event_data) = receiver.recv().await {
    println!("Deposit detected!");
    println!("Block: {}", event_data.block_height);
    println!("TX Hash: {}", event_data.transaction_hash);

    if let Some(account) = event_data.event_data.get("account") {
        println!("Account: {}", account);
    }
}