FIX: T673 Fix printing of GatewayErrorMsg in ticktxt.c

Author: renan-databento

databento/common/bento.py

@@ -52,6 +52,7 @@ def _get_index_column(self) -> str:
                 Schema.OHLCV_1M,
                 Schema.OHLCV_1H,
                 Schema.OHLCV_1D,
+                Schema.GATEWAY_ERROR,
             )
             else "ts_recv"
         )

databento/common/data.py

@@ -172,6 +172,10 @@ def get_deriv_ba_types(level: int) -> List[Tuple[str, Union[type, str]]]:
         ("tick_rule", np.uint8),
         ("dummy", "S1"),  # 1 byte chararray
     ],
+    Schema.GATEWAY_ERROR: RECORD_HEADER
+    + [
+        ("error", "S64"),
+    ],
 }
 
 

databento/common/enums.py

@@ -50,6 +50,7 @@ class Schema(Enum):
     DEFINITION = "definition"
     STATISTICS = "statistics"
     STATUS = "status"
+    GATEWAY_ERROR = "gateway_error"
 
 
 @unique

databento/common/parsing.py

@@ -340,6 +340,8 @@ def schema_to_int(schema: Schema) -> int:
         return 10
     elif schema == Schema.STATUS:
         return 11
+    elif schema == Schema.GATEWAY_ERROR:
+        return 12
     else:
         raise NotImplementedError(
             f"The enum value '{schema.value}' "
@@ -372,6 +374,8 @@ def int_to_schema(value: int) -> Schema:
         return Schema.STATISTICS
     elif value == 11:
         return Schema.STATUS
+    elif value == 12:
+        return Schema.GATEWAY_ERROR
     else:
         raise NotImplementedError(
             f"The int value '{value}' " f"cannot be represented with the enum",

tests/test_historical_bento.py

@@ -225,6 +225,7 @@ def test_replay_with_stub_data_record_passes_to_callback(self) -> None:
                 Schema.STATUS,
                 Schema.STATISTICS,
                 Schema.DEFINITION,
+                Schema.GATEWAY_ERROR,
             )
         ],
     )