Merge pull request #676 from betcode-org/release/2.4.2

Release/2.4.2

HISTORY.rst

@@ -3,6 +3,13 @@
 Release History
 ---------------
 
+2.4.2 (2023-08-03)
++++++++++++++++++++
+
+**Bug Fixes**
+
+- #674 Update marketCatalogue fix when recording data
+
 2.4.1 (2023-07-25)
 +++++++++++++++++++
 

flumine/__version__.py

@@ -1,6 +1,6 @@
 __title__ = "flumine"
 __description__ = "Betting trading framework"
 __url__ = "https://github.com/betcode-org/flumine"
-__version__ = "2.4.1"
+__version__ = "2.4.2"
 __author__ = "Liam Pauling"
 __license__ = "MIT"

flumine/baseflumine.py

@@ -222,16 +222,15 @@ def _process_raw_data(self, event: events.RawDataEvent) -> None:
                 market_id = datum["id"]
                 market = self.markets.markets.get(market_id)
                 if market is None:
-                    self._add_market(market_id, None)
+                    market = self._add_market(market_id, None)
                 elif market.closed:
                     self.markets.add_market(market_id, market)
 
-                if (
-                    "marketDefinition" in datum
-                    and datum["marketDefinition"]["status"] == "CLOSED"
-                ):
-                    datum["_stream_id"] = stream_id
-                    self.handler_queue.put(events.CloseMarketEvent(datum))
+                if "marketDefinition" in datum:
+                    market.update_market_catalogue = True
+                    if datum["marketDefinition"]["status"] == "CLOSED":
+                        datum["_stream_id"] = stream_id
+                        self.handler_queue.put(events.CloseMarketEvent(datum))
 
             for strategy in self.strategies:
                 if stream_id in strategy.stream_ids:

tests/test_baseflumine.py

@@ -252,6 +252,7 @@ def test__process_raw_data_closed(self, mock__add_market, mock_events):
         mock__add_market.assert_called_with("1.23", None)
         mock_queue.put.assert_called_with(mock_events.CloseMarketEvent())
         self.assertEqual(mock_event.event[3][0]["_stream_id"], mock_event.event[0])
+        self.assertTrue(mock__add_market.return_value.update_market_catalogue)
 
     @mock.patch("flumine.baseflumine.BaseFlumine._add_market")
     def test__process_raw_data_no_id(self, mock__add_market):