From 7230b7c67deb7a15251e896163cc27b954c34066 Mon Sep 17 00:00:00 2001
From: Giulio De Pasquale <giulio@depasquale.eu>
Date: Tue, 26 Jan 2021 17:13:14 +0000
Subject: [PATCH] filter active orders based on pair

---
 rustybot/src/connectors.rs | 12 +++++++++---
 1 file changed, 9 insertions(+), 3 deletions(-)

diff --git a/rustybot/src/connectors.rs b/rustybot/src/connectors.rs
index 3e27ff1..24bd9b4 100644
--- a/rustybot/src/connectors.rs
+++ b/rustybot/src/connectors.rs
@@ -1,4 +1,5 @@
 use std::convert::{TryFrom, TryInto};
+use std::error::Error;
 use std::fmt::{Debug, Formatter};
 use std::str::FromStr;
 use std::sync::Arc;
@@ -10,6 +11,7 @@ use bitfinex::ticker::TradingPairTicker;
 use futures_retry::{FutureRetry, RetryPolicy, StreamRetryExt};
 use futures_util::task::FutureObj;
 use log::trace;
+use tokio::macros::support::Future;
 use tokio::time::Duration;
 
 use crate::currency::SymbolPair;
@@ -18,8 +20,6 @@ use crate::models::{
     PriceTicker, TradingPlatform,
 };
 use crate::BoxError;
-use std::error::Error;
-use tokio::macros::support::Future;
 
 #[derive(PartialEq, Eq, Clone, Copy, Debug)]
 pub enum Exchange {
@@ -83,7 +83,13 @@ impl Client {
     }
 
     pub async fn active_orders(&self, pair: &SymbolPair) -> Result<Vec<ActiveOrder>, BoxError> {
-        self.inner.active_orders(pair).await
+        Ok(self
+            .inner
+            .active_orders(pair)
+            .await?
+            .into_iter()
+            .filter(|x| &x.symbol == pair)
+            .collect())
     }
 
     pub async fn submit_order(&self, order: &OrderForm) -> Result<ActiveOrder, BoxError> {