Struct PositionManager

pub struct PositionManager {
    pub open_positions: RwLock<HashMap<Pubkey, Arc<Mutex<Position>>>>,
    pub wallet_configs: HashMap<Pubkey, PositionConfig>,
    pub tx_monitor_receiver: Receiver<SwapTx>,
    pub market_update_receiver: Receiver<MarketUpdate>,
    pub new_pool_receiver: Receiver<Arc<RwLock<dyn PoolTrait>>>,
    pub wallet: Arc<Keypair>,
    pub central_context: Arc<CentralContext>,
    pub execution_context: Arc<ExecutionContext>,
}

Central coordinator for managing copy trading positions and monitoring wallet activity. Monitors swap transactions, market updates, and new pool creations, automatically opening and closing positions based on tracked wallet behavior. It maintains active positions and wallet configurations for copy trading.

Fields

open_positions: RwLock<HashMap<Pubkey, Arc<Mutex<Position>>>>

wallet_configs: HashMap<Pubkey, PositionConfig>

tx_monitor_receiver: Receiver<SwapTx>

market_update_receiver: Receiver<MarketUpdate>

new_pool_receiver: Receiver<Arc<RwLock<dyn PoolTrait>>>

wallet: Arc<Keypair>

central_context: Arc<CentralContext>

execution_context: Arc<ExecutionContext>

Implementations

impl PositionManager

pub async fn market_update_loop(position_manager: Arc<PositionManager>)

Monitor market price updates and trigger stop-loss checks for open positions. Receives market updates from broadcast channel and forwards them to open positions for stop-loss processing.

impl PositionManager

pub async fn new_pool_loop(position_manager: Arc<PositionManager>)

Monitor new pool creations and handle Pumpfun bonding curve migrations. When a Pumpfun bonding curve completes and migrates to a Pumpswap pool, updates the position’s pool reference and lookup key to the new pool address.

impl PositionManager

pub fn start(position_manager: &Arc<PositionManager>)

Start all async monitoring loops for the position manager. Spawns three separate async tasks: market update loop, transaction monitor loop, and new pool loop to handle different event streams concurrently.

impl PositionManager

pub async fn tx_monitor_loop(position_manager: Arc<PositionManager>)

Monitor swap transactions and manage position lifecycle based on wallet activity. Processes swap transactions from broadcast channel, handling two cases: Our own wallet’s swaps: Confirms buy/sell transactions for existing positions and tracked wallets’ swaps: Opens new positions when they buy tokens

impl PositionManager

pub fn new( tx_monitor_receiver: Receiver<SwapTx>, market_update_receiver: Receiver<MarketUpdate>, new_pool_receiver: Receiver<Arc<RwLock<dyn PoolTrait>>>, wallet: Arc<Keypair>, central_context: Arc<CentralContext>, execution_context: Arc<ExecutionContext>, ) -> Self