cosmic-cinder 0.1.21

Rust terminal UI for Phoenix perpetuals on Solana
Documentation 
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

//! Background task spawners grouped by stream or workload.

//! Background task spawners: blockhash refresh, wallet WSS, balance fetch,
//! trader orders WS, and the Phoenix L2 book RPC subscription.

use std::collections::HashMap;
use std::str::FromStr;
use std::sync::Arc;
use std::time::Duration;

use futures_util::StreamExt;
use phoenix_rise::accounts::owned::{
    ConditionalOrderCollection, ConditionalOrderTrigger, StopLossDirection, StopLossOrderKind,
    StopLossTradeSide,
};
use phoenix_rise::api::{PhoenixHttpClient, PhoenixWSClient, Trader, TraderKey};
use phoenix_rise::ix::constants::get_conditional_orders_address;
use phoenix_rise::ix::types::Direction;
use phoenix_rise::types::trader::{
    TraderStatePayload, TraderStateRowChangeKind, TraderStateStopLossTrigger,
};
use solana_account_decoder_client_types::UiAccountEncoding;
use solana_commitment_config::CommitmentConfig;
use solana_keypair::Keypair;
use solana_pubkey::Pubkey;
use solana_pubsub_client::nonblocking::pubsub_client::PubsubClient;
use solana_rpc_client::nonblocking::rpc_client::RpcClient;
use solana_rpc_client_api::config::RpcAccountInfoConfig;
use solana_signer::Signer;
use tokio::sync::mpsc::UnboundedSender;
use tokio::sync::watch;
use tracing::warn;

use super::super::config::{SplineConfig, rpc_http_url_from_env};
use super::super::data::GtiHandle;
use super::super::data::fetch_top_positions;
use super::super::data::{L2Level, parse_l2_book_from_market_account};
use super::super::format::pubkey_trader_prefix;
use super::super::state::{
    BalanceUpdate, ClobLevel, L2BookStreamMsg, SplineBootstrapMsg, TxStatusMsg,
};
use super::super::trading::{
    OrderInfo, TopPositionEntry, TradingSide, fetch_phoenix_balance_and_position,
};
use super::super::tx::TxContext;
use super::{L2_SNAPSHOT_DEPTH, TxCtxMsg, WSS_RETRY_CAP, WSS_RETRY_INIT};

mod balances;
mod connect_flow;
mod l2_book;
mod liquidations;
mod orders;
mod position_leaderboard;
mod spline_bootstrap;
mod tx_context;
mod wallet_stream;

pub(in crate::tui::runtime) use balances::*;
pub(in crate::tui::runtime) use connect_flow::*;
pub(in crate::tui::runtime) use l2_book::*;
pub(in crate::tui::runtime) use liquidations::*;
pub(in crate::tui::runtime) use orders::*;
pub(in crate::tui::runtime) use position_leaderboard::*;
pub(in crate::tui::runtime) use spline_bootstrap::*;
pub(in crate::tui::runtime) use tx_context::*;
pub(in crate::tui::runtime) use wallet_stream::*;