|
@ -441,7 +441,7 @@ where |
|
|
tracing::info!("Lock transaction published with txid {}", txid); |
|
|
tracing::info!("Lock transaction published with txid {}", txid); |
|
|
|
|
|
|
|
|
self.monitor_actor |
|
|
self.monitor_actor |
|
|
.do_send_async(monitor::StartMonitoring { |
|
|
.send(monitor::StartMonitoring { |
|
|
id: order_id, |
|
|
id: order_id, |
|
|
params: MonitorParams::new( |
|
|
params: MonitorParams::new( |
|
|
dlc, |
|
|
dlc, |
|
@ -452,7 +452,7 @@ where |
|
|
.await?; |
|
|
.await?; |
|
|
|
|
|
|
|
|
self.oracle_actor |
|
|
self.oracle_actor |
|
|
.do_send_async(oracle::MonitorAttestation { |
|
|
.send(oracle::MonitorAttestation { |
|
|
event_id: cfd.order.oracle_event_id, |
|
|
event_id: cfd.order.oracle_event_id, |
|
|
}) |
|
|
}) |
|
|
.await?; |
|
|
.await?; |
|
@ -493,7 +493,7 @@ where |
|
|
.with_context(|| format!("Announcement {} not found", cfd.order.oracle_event_id))?; |
|
|
.with_context(|| format!("Announcement {} not found", cfd.order.oracle_event_id))?; |
|
|
|
|
|
|
|
|
self.oracle_actor |
|
|
self.oracle_actor |
|
|
.do_send_async(oracle::MonitorAttestation { |
|
|
.send(oracle::MonitorAttestation { |
|
|
event_id: offer_announcement.id, |
|
|
event_id: offer_announcement.id, |
|
|
}) |
|
|
}) |
|
|
.await?; |
|
|
.await?; |
|
@ -618,7 +618,7 @@ where |
|
|
append_cfd_state(&cfd, &mut conn, &self.cfd_feed_actor_inbox).await?; |
|
|
append_cfd_state(&cfd, &mut conn, &self.cfd_feed_actor_inbox).await?; |
|
|
|
|
|
|
|
|
self.monitor_actor |
|
|
self.monitor_actor |
|
|
.do_send_async(monitor::StartMonitoring { |
|
|
.send(monitor::StartMonitoring { |
|
|
id: order_id, |
|
|
id: order_id, |
|
|
params: MonitorParams::new( |
|
|
params: MonitorParams::new( |
|
|
dlc, |
|
|
dlc, |
|
@ -672,7 +672,7 @@ where |
|
|
self.remove_pending_proposal(&order_id)?; |
|
|
self.remove_pending_proposal(&order_id)?; |
|
|
|
|
|
|
|
|
self.monitor_actor |
|
|
self.monitor_actor |
|
|
.do_send_async(monitor::CollaborativeSettlement { |
|
|
.send(monitor::CollaborativeSettlement { |
|
|
order_id, |
|
|
order_id, |
|
|
tx: (tx.txid(), dlc.script_pubkey_for(Role::Taker)), |
|
|
tx: (tx.txid(), dlc.script_pubkey_for(Role::Taker)), |
|
|
}) |
|
|
}) |
|
|