|
@ -73,9 +73,6 @@ pub struct Actor<O, M, T> { |
|
|
oracle_actor: Address<O>, |
|
|
oracle_actor: Address<O>, |
|
|
// Maker needs to also store TakerId to be able to send a reply back
|
|
|
// Maker needs to also store TakerId to be able to send a reply back
|
|
|
current_pending_proposals: HashMap<OrderId, (UpdateCfdProposal, TakerId)>, |
|
|
current_pending_proposals: HashMap<OrderId, (UpdateCfdProposal, TakerId)>, |
|
|
// TODO: Persist instead of using an in-memory hashmap for resiliency?
|
|
|
|
|
|
// (not a huge deal, as in the worst case taker will fall back to
|
|
|
|
|
|
// noncollaborative settlement)
|
|
|
|
|
|
current_agreed_proposals: HashMap<OrderId, (SettlementProposal, TakerId)>, |
|
|
current_agreed_proposals: HashMap<OrderId, (SettlementProposal, TakerId)>, |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
@ -746,8 +743,6 @@ where |
|
|
|
|
|
|
|
|
let dlc = cfd.open_dlc().context("CFD was in wrong state")?; |
|
|
let dlc = cfd.open_dlc().context("CFD was in wrong state")?; |
|
|
|
|
|
|
|
|
// TODO: do we want to store in the db that we rolled over?
|
|
|
|
|
|
|
|
|
|
|
|
let oracle_event_id = |
|
|
let oracle_event_id = |
|
|
oracle::next_announcement_after(time::OffsetDateTime::now_utc() + Order::TERM)?; |
|
|
oracle::next_announcement_after(time::OffsetDateTime::now_utc() + Order::TERM)?; |
|
|
let announcement = self |
|
|
let announcement = self |
|
|