Skip to content
Permalink

Comparing changes

This is a direct comparison between two commits made in this repository or its related repositories. View the default comparison for this range or learn more about diff comparisons.

Open a pull request

Create a new pull request by comparing changes across two branches. If you need to, you can also . Learn more about diff comparisons here.
base repository: ArkProjectNFTs/ark-project
Failed to load repositories. Confirm that selected base ref is valid, then try again.
Loading
base: 96ee53614e994a50b3374bd9f0364a5c99b77fec
Choose a base ref
..
head repository: ArkProjectNFTs/ark-project
Failed to load repositories. Confirm that selected head ref is valid, then try again.
Loading
compare: cced0e64b5eed8d178d5a12d7bca66be85425cd2
Choose a head ref
Showing with 35 additions and 10 deletions.
  1. +35 −10 crates/diri/src/lib.rs
45 changes: 35 additions & 10 deletions crates/diri/src/lib.rs
View file
Original file line number Diff line number Diff line change
@@ -95,33 +95,58 @@ impl<S: Storage, E: EventHandler> Diri<S, E> {
match orderbook_event {
Event::OrderPlaced(ev) => {
trace!("OrderPlaced found: {:?}", ev);
self.storage
match self
.storage
.register_placed(*block_number, block_timestamp, &ev.into())
.await?;
.await
{
Ok(_) => (),
Err(e) => error!("OrderPlaced event handler failed: {e}"),
}
}
Event::OrderCancelled(ev) => {
trace!("OrderCancelled found: {:?}", ev);
self.storage
match self
.storage
.register_cancelled(*block_number, block_timestamp, &ev.into())
.await?;
.await
{
Ok(_) => (),
Err(e) => error!("OrderCancelled event handler failed: {e}"),
}
}
Event::OrderFulfilled(ev) => {
trace!("OrderFulfilled found: {:?}", ev);
self.storage
match self
.storage
.register_fulfilled(*block_number, block_timestamp, &ev.into())
.await?;
.await
{
Ok(_) => (),
Err(e) => error!("OrderFulfilled event handler failed: {e}"),
}
}
Event::OrderExecuted(ev) => {
trace!("OrderExecuted found: {:?}", ev);
self.storage
match self
.storage
.register_executed(*block_number, block_timestamp, &ev.into())
.await?;
.await
{
Ok(_) => (),
Err(e) => error!("OrderExecuted event handler failed: {e}"),
}
}
Event::RollbackStatus(ev) => {
trace!("RollbackStatus found: {:?}", ev);
self.storage
match self
.storage
.status_back_to_open(*block_number, block_timestamp, &ev.into())
.await?;
.await
{
Ok(_) => (),
Err(e) => error!("RollbackStatus event handler failed: {e}"),
}
}
_ => warn!("Orderbook event not handled: {:?}", orderbook_event),
};