From 6003ad0bc72f0cb483be4f841289b2d5311fbb05 Mon Sep 17 00:00:00 2001 From: Daniel Karzel Date: Thu, 18 Nov 2021 14:46:06 +1100 Subject: [PATCH] Cleanup impl blocks --- daemon/src/taker_cfd.rs | 55 +++++++++++++++++------------------------ 1 file changed, 22 insertions(+), 33 deletions(-) diff --git a/daemon/src/taker_cfd.rs b/daemon/src/taker_cfd.rs index ea3920f..bcbe12b 100644 --- a/daemon/src/taker_cfd.rs +++ b/daemon/src/taker_cfd.rs @@ -319,36 +319,7 @@ impl Actor { } Ok(()) } -} -impl Actor -where - W: xtra::Handler, -{ - async fn handle_oracle_attestation(&mut self, attestation: oracle::Attestation) -> Result<()> { - let mut conn = self.db.acquire().await?; - cfd_actors::handle_oracle_attestation( - attestation, - &mut conn, - &self.wallet, - &self.projection_actor, - ) - .await?; - Ok(()) - } - - async fn handle_monitoring_event(&mut self, event: monitor::Event) -> Result<()> { - let mut conn = self.db.acquire().await?; - cfd_actors::handle_monitoring_event(event, &mut conn, &self.wallet, &self.projection_actor) - .await?; - Ok(()) - } -} - -impl Actor -where - W: xtra::Handler, -{ async fn handle_propose_roll_over(&mut self, order_id: OrderId) -> Result<()> { if self.current_pending_proposals.contains_key(&order_id) { anyhow::bail!("An update for order id {} is already in progress", order_id) @@ -377,11 +348,29 @@ where Ok(()) } } -impl Actor where - W: xtra::Handler - + xtra::Handler - + xtra::Handler + +impl Actor +where + W: xtra::Handler, { + async fn handle_oracle_attestation(&mut self, attestation: oracle::Attestation) -> Result<()> { + let mut conn = self.db.acquire().await?; + cfd_actors::handle_oracle_attestation( + attestation, + &mut conn, + &self.wallet, + &self.projection_actor, + ) + .await?; + Ok(()) + } + + async fn handle_monitoring_event(&mut self, event: monitor::Event) -> Result<()> { + let mut conn = self.db.acquire().await?; + cfd_actors::handle_monitoring_event(event, &mut conn, &self.wallet, &self.projection_actor) + .await?; + Ok(()) + } } impl Actor