Contract setup `Completed` is the same for taker and maker

Either of the roles has to record the outcome of the setup, which should be the same for them.
In order to handle this in our event model we need `Completed` in the model so it is not role specific.

daemon/src/model/cfd.rs

@@ -1661,6 +1661,22 @@ impl CollaborativeSettlement {
     }
 }
 
+/// Message sent from a setup actor to the
+/// cfd actor to notify that the contract setup has finished.
+pub enum Completed {
+    NewContract {
+        order_id: OrderId,
+        dlc: Dlc,
+    },
+    Rejected {
+        order_id: OrderId,
+    },
+    Failed {
+        order_id: OrderId,
+        error: anyhow::Error,
+    },
+}
+
 #[cfg(test)]
 mod tests {
     use super::*;

daemon/src/setup_taker.rs

@@ -1,4 +1,4 @@
-use crate::model::cfd::{Cfd, CfdState, Dlc, Order, OrderId, Role};
+use crate::model::cfd::{Cfd, CfdState, Completed, Dlc, Order, OrderId, Role};
 use crate::model::Usd;
 use crate::oracle::Announcement;
 use crate::setup_contract::{self, SetupParams};
@@ -206,22 +206,6 @@ pub struct SetupFailed {
     error: anyhow::Error,
 }
 
-/// Message sent from the `setup_taker::Actor` to the
-/// `taker_cfd::Actor` to notify that the contract setup has finished.
-pub enum Completed {
-    NewContract {
-        order_id: OrderId,
-        dlc: Dlc,
-    },
-    Rejected {
-        order_id: OrderId,
-    },
-    Failed {
-        order_id: OrderId,
-        error: anyhow::Error,
-    },
-}
-
 impl xtra::Message for Started {
     type Result = ();
 }

daemon/src/taker_cfd.rs

@@ -1,8 +1,9 @@
 use crate::cfd_actors::{self, append_cfd_state, insert_cfd_and_send_to_feed};
 use crate::db::{insert_order, load_cfd_by_order_id, load_order_by_id};
 use crate::model::cfd::{
-    Cfd, CfdState, CfdStateCommon, CollaborativeSettlement, Dlc, Order, OrderId, Origin, Role,
+    Cfd, CfdState, CfdStateCommon, CollaborativeSettlement, Completed, Dlc, Order, OrderId, Origin,
-    RollOverProposal, SettlementKind, SettlementProposal, UpdateCfdProposal, UpdateCfdProposals,
+    Role, RollOverProposal, SettlementKind, SettlementProposal, UpdateCfdProposal,
+    UpdateCfdProposals,
 };
 use crate::model::{BitMexPriceEventId, Price, Timestamp, Usd};
 use crate::monitor::{self, MonitorParams};
@@ -357,7 +358,7 @@ where
 
 impl<O, M, W> Actor<O, M, W>
 where
-    Self: xtra::Handler<setup_taker::Completed>,
+    Self: xtra::Handler<Completed>,
     O: xtra::Handler<oracle::GetAnnouncement> + xtra::Handler<oracle::MonitorAttestation>,
     W: xtra::Handler<wallet::BuildPartyParams> + xtra::Handler<wallet::Sign>,
 {
@@ -436,14 +437,14 @@ where
     M: xtra::Handler<monitor::StartMonitoring>,
     W: xtra::Handler<wallet::TryBroadcastTransaction>,
 {
-    async fn handle_setup_completed(&mut self, msg: setup_taker::Completed) -> Result<()> {
+    async fn handle_setup_completed(&mut self, msg: Completed) -> Result<()> {
         let (order_id, dlc) = match msg {
-            setup_taker::Completed::NewContract { order_id, dlc } => (order_id, dlc),
+            Completed::NewContract { order_id, dlc } => (order_id, dlc),
-            setup_taker::Completed::Rejected { order_id } => {
+            Completed::Rejected { order_id } => {
                 self.append_cfd_state_rejected(order_id).await?;
                 return Ok(());
             }
-            setup_taker::Completed::Failed { order_id, error } => {
+            Completed::Failed { order_id, error } => {
                 self.append_cfd_state_setup_failed(order_id, error).await?;
                 return Ok(());
             }
@@ -655,7 +656,7 @@ where
 #[async_trait]
 impl<O: 'static, M: 'static, W: 'static> Handler<TakeOffer> for Actor<O, M, W>
 where
-    Self: xtra::Handler<setup_taker::Completed>,
+    Self: xtra::Handler<Completed>,
     O: xtra::Handler<oracle::GetAnnouncement> + xtra::Handler<oracle::MonitorAttestation>,
     W: xtra::Handler<wallet::BuildPartyParams> + xtra::Handler<wallet::Sign>,
 {
@@ -742,13 +743,13 @@ where
 }
 
 #[async_trait]
-impl<O: 'static, M: 'static, W: 'static> Handler<setup_taker::Completed> for Actor<O, M, W>
+impl<O: 'static, M: 'static, W: 'static> Handler<Completed> for Actor<O, M, W>
 where
     O: xtra::Handler<oracle::MonitorAttestation>,
     M: xtra::Handler<monitor::StartMonitoring>,
     W: xtra::Handler<wallet::TryBroadcastTransaction>,
 {
-    async fn handle(&mut self, msg: setup_taker::Completed, _ctx: &mut Context<Self>) {
+    async fn handle(&mut self, msg: Completed, _ctx: &mut Context<Self>) {
         log_error!(self.handle_setup_completed(msg))
     }
 }