Library Client for Coinbase Pro

Async only support

Documentation

Usage

Add this in your Cargo.toml: toml [dependencies] cbpro = "0.10.0" futures = "0.3.4" serde_json = "^1.0.47" tokio = { version = "^1.2.0", features = ["macros", "time"] }

Async Client

```rust use cbpro::client::{PublicClient, SANDBOX_URL};

[tokio::main]

async fn main() -> Result<(), Box> { let client = PublicClient::new(SANDBOXURL); let products = client.getproducts().json::().await?; println!("{}", serdejson::tostring_pretty(&products).unwrap()); Ok(()) } ```

Async Pagination

```rust use cbpro::client::{PublicClient, SANDBOX_URL}; use futures::TryStreamExt;

[tokio::main]

async fn main() -> Result<(), Box> { let client = PublicClient::new(SANDBOXURL); let mut pages = client.gettrades("BTC-USD").paginate::()?;

while let Some(json) = pages.try_next().await? {
    println!("{}", serde_json::to_string_pretty(&json).unwrap());
    tokio::time::sleep(core::time::Duration::new(1, 0)).await;
}
Ok(())

} ```

Async Websocket

```rust use cbpro::websocket::{Channels, WebSocketFeed, SANDBOXFEEDURL};

[tokio::main]

async fn main() -> Result<(), Box> { let mut feed = WebSocketFeed::connect(SANDBOXFEEDURL).await?; feed.subscribe(&["BTC-USD"], &[Channels::LEVEL2]).await?;

while let Some(value) = feed.json::<serde_json::Value>().await? {
    println!("{}", serde_json::to_string_pretty(&value).unwrap());
}
Ok(())

} ```

Endpoints

• [x] Private
  • [x] Authentication
  • [x] Accounts
  • [x] Orders
  • [x] Fills
  • [x] Deposits
  • [x] Withdrawals
  • [x] Payment Methods
  • [x] Coinbase Accounts
  • [x] Reports
  • [x] User Account
• [x] Market Data
  • [x] Products
  • [x] Currencies
  • [x] Time
• [x] Websocket Feed
  • [x] heartbeat
  • [x] ticker
  • [x] level2
  • [x] user
  • [x] matches
  • [x] full

FIX API

by request

License

Licensed under

• MIT license (LICENSE-MIT or http://opensource.org/licenses/MIT)