Fix: example code

Author: dgtony

src/bin/example.rs

@@ -30,65 +30,79 @@ fn main() {
     let order_asset = parse_asset("BTC").unwrap();
     let price_asset = parse_asset("USD").unwrap();
 
-    // orders to process
-    let order_list = vec![
-        orders::new_limit_order_request(
-            order_asset,
-            price_asset,
-            OrderSide::Bid,
-            0.98,
-            5.0,
-            SystemTime::now()
-        ),
-        orders::new_limit_order_request(
-            order_asset,
-            price_asset,
-            OrderSide::Ask,
-            1.02,
-            1.0,
-            SystemTime::now()
-        ),
-        orders::new_limit_order_request(
-            order_asset,
-            price_asset,
-            OrderSide::Bid,
-            1.01,
-            0.4,
-            SystemTime::now()
-        ),
-        orders::new_limit_order_request(
-            order_asset,
-            price_asset,
-            OrderSide::Ask,
-            1.03,
-            0.5,
-            SystemTime::now()
-        ),
-        orders::new_limit_order_request(
-            order_asset,
-            price_asset,
-            OrderSide::Ask,
-            1.05,
-            0.5,
-            SystemTime::now()
-        ),
-        orders::new_limit_order_request(
-            order_asset,
-            price_asset,
-            OrderSide::Bid,
-            1.06,
-            2.0,
-            SystemTime::now()
-        ),
-    ];
+    // create order requests
+    let order_list =
+        vec![
+            orders::new_limit_order_request(
+                order_asset,
+                price_asset,
+                OrderSide::Bid,
+                0.98,
+                5.0,
+                SystemTime::now()
+            ),
+
+            orders::new_limit_order_request(
+                order_asset,
+                price_asset,
+                OrderSide::Ask,
+                1.02,
+                1.0,
+                SystemTime::now()
+            ),
+
+            orders::amend_order_request(1, OrderSide::Bid, 0.99, 4.0, SystemTime::now()),
+
+            orders::new_limit_order_request(
+                order_asset,
+                price_asset,
+                OrderSide::Bid,
+                1.01,
+                0.4,
+                SystemTime::now()
+            ),
+
+            orders::new_limit_order_request(
+                order_asset,
+                price_asset,
+                OrderSide::Ask,
+                1.03,
+                0.5,
+                SystemTime::now()
+            ),
+
+            orders::new_market_order_request(order_asset, price_asset, OrderSide::Bid, 1.0, SystemTime::now()),
+
+            orders::new_limit_order_request(
+                order_asset,
+                price_asset,
+                OrderSide::Ask,
+                1.05,
+                0.5,
+                SystemTime::now()
+            ),
+
+            orders::limit_order_cancel_request(4, OrderSide::Ask),
+
+            orders::new_limit_order_request(
+                order_asset,
+                price_asset,
+                OrderSide::Bid,
+                1.06,
+                0.6,
+                SystemTime::now()
+            ),
+        ];
 
     // processing
     for order in order_list {
-        println!("\nOrder => {:?}", &order);
+        println!("Order => {:?}", &order);
         let res = orderbook.process_order(order);
         println!("Processing => {:?}", res);
         if let Some((bid, ask)) = orderbook.current_spread() {
             println!("Spread => bid: {}, ask: {}\n", bid, ask);
+        } else {
+            println!("Spread => not available\n");
         }
     }
 }

src/engine/orderbook.rs

@@ -16,7 +16,7 @@ const MAX_STALLED_INDICES_IN_QUEUE: u64 = 10;
 const ORDER_QUEUE_INIT_CAPACITY: usize = 500;
 
 
-type OrderProcessingResult = Vec<Result<Success, Failed>>;
+pub type OrderProcessingResult = Vec<Result<Success, Failed>>;
 
 
 #[derive(Debug)]

src/lib.rs

@@ -2,7 +2,7 @@
 mod engine;
 
 pub use engine::domain::OrderSide;
-pub use engine::orderbook::{Orderbook, Success, Failed};
+pub use engine::orderbook::{Orderbook, OrderProcessingResult, Success, Failed};
 pub use engine::orders;