Trading

client.wait_for_catalogs().await?;

use polyester::models::{CreateOrderParams, CreateOrderType, CreateSide, CreateTimeInForce};
use polyester::{Price, Quantity};

let quantity_scale = client
    .catalogs
    .base_quantity_scale_for_symbol("BTC-USDT")
    .ok_or_else(|| polyester::Error::validation("BTC-USDT quantity scale is unavailable"))?;

let result = client.orders.create(CreateOrderParams {
    symbol: "BTC-USDT".into(),
    side: CreateSide::Buy,
    order_type: CreateOrderType::Limit,
    quantity: Some(Quantity::from_decimal_str("0.25", quantity_scale, Some("BTC-USDT".into()), None)?),
    max_quote_debit_scaled: None,
    price: Some(Price::from_decimal_str("64250.5", Some("BTC-USDT".into()))?),
    time_in_force: Some(CreateTimeInForce::Gtc),
    client_order_id: Some("mm-bot-001".into()),
    subaccount_id: None,
    post_only: Some(true), // limit GTC only
    market_client_ref_price: None,
    fee_asset: None,
    self_trade_prevention: None,
    market_max_slippage: None,
    attached_risk: None,
}).await?;
// Create synthesizes status: "accepted" (admission ack). Lifecycle states come
// from list_open / get / subscribe, not create.
println!("{} {}", result.status, result.order_id);

client.orders.cancel_by_client_order_id("mm-bot-001", Some("BTC-USDT"), None).await?;

use polyester::models::{CancelAllOpts, ModifyOrderParams};
use polyester::Price;

let order_id = "order-id-from-create".to_owned();
client.orders.modify(ModifyOrderParams {
    symbol: "BTC-USDT".into(),
    order_id: Some(order_id),
    client_order_id: None,
    request_id: Some("mod-1".into()),
    new_price: Some(Price::from_decimal_str("64100", Some("BTC-USDT".into()))?),
    new_qty: None,
    new_attached_risk: None,
    behavior: None,
    new_client_order_id: None,
    subaccount_id: None,
}).await?;

let preview = client.orders.cancel_all_with(CancelAllOpts {
    symbol: Some("BTC-USDT".into()),
    dry_run: true,
    request_id: Some("cancel-all-preview-1".into()),
    ..Default::default()
}).await?;
client.orders.cancel_all_after(
    15,
    Some("BTC-USDT"),
    None,
    Some("cancel-after-arm-1".into()),
).await?;

let mut sub = client
    .orders
    .subscribe(client.default_account_id.as_deref())
    .await?;
while let Some(order) = sub.recv_result().await? {
    println!("{}", order.status);
    break;
}

use polyester::models::{
    CreateOrderType, CreateSide, CreateTimeInForce, CreateTriggerParams, CreateTriggerType,
    ModifyTriggerParams,
};
use polyester::{Price, Quantity};

let quantity_scale = client
    .catalogs
    .base_quantity_scale_for_symbol("BTC-USDT")
    .ok_or_else(|| polyester::Error::validation("BTC-USDT quantity scale is unavailable"))?;

let created = client.triggers.create(CreateTriggerParams {
    symbol: "BTC-USDT".into(),
    trigger_type: CreateTriggerType::StopLoss,
    side: CreateSide::Sell,
    order_type: CreateOrderType::Market,
    qty: Quantity::from_decimal_str("0.1", quantity_scale, Some("BTC-USDT".into()), None)?,
    trigger_price: Some(Price::from_decimal_str("60000", Some("BTC-USDT".into()))?),
    limit_price: None,
    trigger_price_source: None, // unsupported values fail instead of being discarded
    time_in_force: Some(CreateTimeInForce::Ioc),
    subaccount_id: None,
    client_trigger_id: "sl-1".into(),
    post_only: false,
    activation_price: None,
    trailing_distance_ticks: None,
    trailing_distance_bps: None,
    max_slippage_ticks: None,
    max_slippage_bps: None,
    twap_duration_ms: None,
    twap_slice_interval_ms: None,
    ladder_price_min: None,
    ladder_price_max: None,
    ladder_levels: None,
    ladder_distribution: None,
    fee_asset: None,
    self_trade_prevention_mode: None,
}).await?;
// Create returns status: "accepted" (admission).

client.triggers.modify(ModifyTriggerParams {
    trigger_id: created.trigger_id,
    subaccount_id: None,
    trigger_price: Some(Price::from_decimal_str("59500", Some("BTC-USDT".into()))?),
    limit_price: None,
    activation_price: None,
    trailing_distance_ticks: None,
    trailing_distance_bps: None,
    max_slippage_ticks: None,
    max_slippage_bps: None,
}).await?;