pub async fn get_affected_pools_from_logs( market: Arc<RwLock<Market>>, logs: &[Log], ) -> Result<BTreeMap<PoolWrapper, Vec<SwapDirection>>>