DEX-775 Starting issue when there is matching rules (#285)

wavesplatform · May 28, 2020 · a107f40 · a107f40
1 parent 0b57e17
commit a107f40
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 4 deletions.
diff --git a/dex/src/main/scala/com/wavesplatform/dex/market/OrderBookActor.scala b/dex/src/main/scala/com/wavesplatform/dex/market/OrderBookActor.scala
@@ -63,10 +63,15 @@ class OrderBookActor(settings: Settings,
       matchingRules = actualRules
       updateCurrentMatchingRules(matchingRules.head)
       actualRule = normalizeMatchingRule(matchingRules.head)
-      aggregatedRef ! AggregatedOrderBookActor.Command.ApplyChanges(LevelAmounts.empty,
-                                                                    None,
-                                                                    Some(matchingRules.head.tickSize.toDouble),
-                                                                    System.currentTimeMillis)
+      // Could be unset during the start
+      Option(aggregatedRef).foreach {
+        _ ! AggregatedOrderBookActor.Command.ApplyChanges(
+          LevelAmounts.empty,
+          None,
+          Some(matchingRules.head.tickSize.toDouble),
+          System.currentTimeMillis
+        )
+      }
     }
   }
 

diff --git a/dex/src/test/scala/com/wavesplatform/dex/market/OrderBookActorSpecification.scala b/dex/src/test/scala/com/wavesplatform/dex/market/OrderBookActorSpecification.scala
@@ -109,6 +109,13 @@ class OrderBookActorSpecification
       tp.expectMsg(OrderBookRecovered(pair, Some(50)))
     }
 
+    "recovery - if there is a matching rule - DEX-775" in obcTestWithPrepare(
+      prepare = (obsdb, p) => obsdb.update(p, 50, Some(OrderBookSnapshot.empty)),
+      matchingRules = NonEmptyList.of(DenormalizedMatchingRule(0, 0.00000001), DenormalizedMatchingRule(40, 0.0000001))
+    ) { (pair, _, tp) =>
+      tp.expectMsg(OrderBookRecovered(pair, Some(50)))
+    }
+
     "recovery - notify address actor about orders" in obcTestWithPrepare(
       { (obsdb, p) =>
         val ord               = buy(p, 10 * Order.PriceConstant, 100)