diri: add new event

artifacts/orderbook.abi.json

@@ -614,6 +614,18 @@
       }
     ]
   },
+  {
+    "type": "event",
+    "name": "ark_orderbook::orderbook::orderbook::OrderBackToOpen",
+    "kind": "struct",
+    "members": [
+      {
+        "name": "order_hash",
+        "type": "core::felt252",
+        "kind": "key"
+      }
+    ]
+  },
   {
     "type": "event",
     "name": "ark_orderbook::orderbook::orderbook::Event",
@@ -643,6 +655,11 @@
         "name": "Upgraded",
         "type": "ark_orderbook::orderbook::orderbook::Upgraded",
         "kind": "nested"
+      },
+      {
+        "name": "OrderBackToOpen",
+        "type": "ark_orderbook::orderbook::orderbook::OrderBackToOpen",
+        "kind": "nested"
       }
     ]
   }

crates/diri/README.md

@@ -17,6 +17,7 @@ which is the one state among the following: 0. The order is created and open (`O
 1. The order is cancelled (`OrderCancelled`).
 2. The order is fulfilled (`OrderFulfilled`).
 3. The order is executed (`OrderExecuted`).
+4. The order can be rollbacked and status back to placed (`OrderBackToOpen`).
 
 The concept of `expiry` does not apply to Diri logic. We only care about the
 lifecycle of an order through the events.

crates/diri/artifacts/orderbook.abi.json

@@ -610,6 +610,18 @@
       }
     ]
   },
+  {
+    "type": "event",
+    "name": "ark_orderbook::orderbook::orderbook::OrderBackToOpen",
+    "kind": "struct",
+    "members": [
+      {
+        "name": "order_hash",
+        "type": "core::felt252",
+        "kind": "key"
+      }
+    ]
+  },
   {
     "type": "event",
     "name": "ark_orderbook::orderbook::orderbook::Event",
@@ -639,6 +651,11 @@
         "name": "Upgraded",
         "type": "ark_orderbook::orderbook::orderbook::Upgraded",
         "kind": "nested"
+      },
+      {
+        "name": "OrderBackToOpen",
+        "type": "ark_orderbook::orderbook::orderbook::OrderBackToOpen",
+        "kind": "nested"
       }
     ]
   }

crates/diri/src/lib.rs

@@ -112,6 +112,12 @@ impl<S: Storage, E: EventHandler> Diri<S, E> {
                             .register_executed(block_number, block_timestamp, &ev.into())
                             .await?;
                     }
+                    Event::OrderBackToOpen(ev) => {
+                        trace!("OrderBackToOpen found: {:?}", ev);
+                        self.storage
+                            .order_back_to_open(block_number, block_timestamp, &ev.into())
+                            .await?;
+                    }
                     _ => warn!("Orderbook event not handled: {:?}", orderbook_event),
                 };
             }

crates/diri/src/storage/mod.rs

@@ -1,7 +1,7 @@
 use async_trait::async_trait;
 
 pub mod types;
-use types::{CancelledData, ExecutedData, FulfilledData, PlacedData};
+use types::{BackToOpenData, CancelledData, ExecutedData, FulfilledData, PlacedData};
 
 pub type StorageResult<T> = Result<T, StorageError>;
 
@@ -42,4 +42,11 @@ pub trait Storage {
         block_timestamp: u64,
         order: &ExecutedData,
     ) -> StorageResult<()>;
+
+    async fn order_back_to_open(
+        &self,
+        block_id: u64,
+        block_timestamp: u64,
+        order: &BackToOpenData,
+    ) -> StorageResult<()>;
 }

crates/diri/src/storage/types.rs

@@ -4,7 +4,9 @@ use starknet::core::types::FieldElement;
 use starknet::core::utils::parse_cairo_short_string;
 use std::fmt::LowerHex;
 
-use crate::orderbook::{OrderCancelled, OrderExecuted, OrderFulfilled, OrderPlaced, U256};
+use crate::orderbook::{
+    OrderBackToOpen, OrderCancelled, OrderExecuted, OrderFulfilled, OrderPlaced, U256,
+};
 
 #[derive(Debug, Clone)]
 pub struct PlacedData {
@@ -70,6 +72,19 @@ impl From<OrderCancelled> for CancelledData {
     }
 }
 
+#[derive(Debug, Clone)]
+pub struct BackToOpenData {
+    pub order_hash: String,
+}
+
+impl From<OrderBackToOpen> for BackToOpenData {
+    fn from(value: OrderBackToOpen) -> Self {
+        Self {
+            order_hash: to_hex_str(&value.order_hash),
+        }
+    }
+}
+
 #[derive(Debug, Clone)]
 pub struct FulfilledData {
     pub order_hash: String,