Crate kiteconnect_async_wasm

kiteconnect-async-wasm

A modern, async Rust implementation of the Zerodha KiteConnect API with WASM support. This library provides comprehensive access to KiteConnect’s REST APIs for trading, portfolio management, and market data.

Features

• 🚀 Async/Await: Built with modern Rust async patterns using tokio
• 🌐 WASM Compatible: Run in browsers with WebAssembly support
• 🔄 Cross-Platform: Native (Linux, macOS, Windows) and Web targets
• 📦 Modern Dependencies: Updated to latest Rust ecosystem libraries
• 🧪 Well Tested: Comprehensive test coverage with mocked responses
• ⚡ High Performance: Efficient HTTP client with connection pooling
• 🛡️ Type Safe: Leverages Rust’s type system for safer API interactions

Feature Flags

This crate supports multiple feature flags to enable platform-specific functionality:

• native (default): Enables native platform support with tokio, file I/O, and CSV parsing

  • Includes: tokio, sha2, csv dependencies
  • Best for: Desktop applications, servers, CLI tools

• wasm: Enables WebAssembly support with browser APIs and CSV parsing

  • Includes: wasm-bindgen, web-sys, js-sys, gloo-utils, csv-core dependencies
  • Features: Browser-compatible CSV parsing using csv-core
  • Best for: Browser applications, web workers

• debug: Enables additional logging and debugging features

  • Includes: Enhanced log output
  • Best for: Development and troubleshooting

Quick Start

Add to your Cargo.toml:

# For native applications (default)
[dependencies]
kiteconnect-async-wasm = "0.1.0"
 
# For WASM/browser applications
[dependencies]
kiteconnect-async-wasm = { version = "0.1.0", default-features = false, features = ["wasm"] }
 
# For development with debugging
[dependencies]
kiteconnect-async-wasm = { version = "0.1.0", features = ["native", "debug"] }

Basic Usage

use kiteconnect_async_wasm::connect::KiteConnect;
use serde_json::Value as JsonValue;
 
#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    // Initialize KiteConnect client
    let mut kiteconnect = KiteConnect::new("<YOUR-API-KEY>", "");
 
    // Step 1: Get login URL
    let login_url = kiteconnect.login_url();
    println!("Login URL: {}", login_url);
     
    // Step 2: After user login, generate session with request token
    let session_response = kiteconnect
        .generate_session("<REQUEST-TOKEN>", "<API-SECRET>")
        .await?;
    println!("Session: {:?}", session_response);
 
    // Step 3: Use the API (access token is automatically set)
    let holdings: JsonValue = kiteconnect.holdings().await?;
    println!("Holdings: {:?}", holdings);
 
    Ok(())
}

Available APIs

The library provides access to all KiteConnect REST APIs:

Authentication

• login_url() - Generate login URL
• generate_session() - Create session with request token
• invalidate_session() - Logout user

Portfolio

• holdings() - Get user holdings
• positions() - Get user positions
• margins() - Get account margins

Orders

• orders() - Get all orders
• order_trades() - Get trades for specific order
• trades() - Get all trades

Market Data

• instruments() - Get instrument list
• trigger_range() - Get trigger range for instruments

Mutual Funds

• mf_orders() - Get mutual fund orders
• mf_instruments() - Get mutual fund instruments

Error Handling

The library uses anyhow::Result for comprehensive error handling:

match kiteconnect.holdings().await {
    Ok(holdings) => println!("Holdings: {:?}", holdings),
    Err(e) => eprintln!("Error fetching holdings: {}", e),
}

Platform-Specific Features

Native (Tokio)

• Full CSV parsing for instruments
• Complete async/await support
• High-performance HTTP client

WASM (Browser)

• All APIs supported with full CSV parsing
• CSV parsing using csv-core for browser compatibility
• Returns structured JSON data (same as native)
• Compatible with web frameworks

Examples

See the examples/ directory for comprehensive usage examples:

• connect_sample.rs - Basic API usage
• async_connect_example.rs - Advanced async patterns

Thread Safety

The KiteConnect struct is Clone + Send + Sync, making it safe to use across multiple threads and async tasks. The underlying HTTP client uses connection pooling for optimal performance.

let kiteconnect = KiteConnect::new("<API-KEY>", "<ACCESS-TOKEN>");
 
// Clone for use in different tasks
let kc1 = kiteconnect.clone();
let kc2 = kiteconnect.clone();
 
// Use in concurrent tasks
let (holdings, positions) = tokio::try_join!(
    kc1.holdings(),
    kc2.positions()
)?;

Modules

connect

KiteConnect API Client Module

models

KiteConnect v1.0.0 Data Models