From d6aed063fc2d047dcd01cab3952b0222232fc63d Mon Sep 17 00:00:00 2001 From: Daniel Karzel Date: Mon, 11 Oct 2021 10:13:51 +1100 Subject: [PATCH] Missing CFD feed updates --- daemon/src/maker_cfd.rs | 5 +++++ daemon/src/taker_cfd.rs | 5 +++++ 2 files changed, 10 insertions(+) diff --git a/daemon/src/maker_cfd.rs b/daemon/src/maker_cfd.rs index f4a138e..b91e0a6 100644 --- a/daemon/src/maker_cfd.rs +++ b/daemon/src/maker_cfd.rs @@ -836,6 +836,8 @@ impl Actor { } insert_new_cfd_state_by_order_id(cfd.order.id, cfd.state.clone(), &mut conn).await?; + self.cfd_feed_actor_inbox + .send(load_all_cfds(&mut conn).await?)?; if let Err(e) = self.try_cet_publication(cfd).await { tracing::error!("Error when trying to publish CET: {:#}", e); @@ -861,6 +863,9 @@ impl Actor { insert_new_cfd_state_by_order_id(cfd.order.id, cfd.state.clone(), &mut conn) .await?; + + self.cfd_feed_actor_inbox + .send(load_all_cfds(&mut conn).await?)?; } Err(not_ready_yet) => { tracing::debug!("{:#}", not_ready_yet); diff --git a/daemon/src/taker_cfd.rs b/daemon/src/taker_cfd.rs index 783ecaa..5a7dd7a 100644 --- a/daemon/src/taker_cfd.rs +++ b/daemon/src/taker_cfd.rs @@ -616,6 +616,8 @@ impl Actor { } insert_new_cfd_state_by_order_id(cfd.order.id, cfd.state.clone(), &mut conn).await?; + self.cfd_feed_actor_inbox + .send(load_all_cfds(&mut conn).await?)?; if let Err(e) = self.try_cet_publication(cfd).await { tracing::error!("Error when trying to publish CET: {:#}", e); @@ -641,6 +643,9 @@ impl Actor { insert_new_cfd_state_by_order_id(cfd.order.id, cfd.state.clone(), &mut conn) .await?; + + self.cfd_feed_actor_inbox + .send(load_all_cfds(&mut conn).await?)?; } Err(not_ready_yet) => { tracing::debug!("{:#}", not_ready_yet);