VER: Release 0.42.0

Author: threecgreen

CHANGELOG.md

@@ -1,5 +1,13 @@
 # Changelog
 
+## 0.42.0 - 2025-08-19
+
+### Enhancements
+- Added `EndOfInterval` variant to `SystemCode`
+
+### Breaking changes
+- Removed `bill_id` field from `BatchJob` struct
+
 ## 0.41.0 - 2025-08-12
 
 ### Enhancements

CMakeLists.txt

@@ -6,7 +6,7 @@ cmake_minimum_required(VERSION 3.24..4.0)
 
 project(
   databento
-  VERSION 0.41.0
+  VERSION 0.42.0
   LANGUAGES CXX
   DESCRIPTION "Official Databento client library"
 )

examples/live/live_smoke_test.cpp

@@ -53,7 +53,7 @@ void ProcessRecords(db::LiveBlocking& client, db::Schema schema,
 
   while (auto record = client.NextRecord(timeout)) {
     if (record->RType() == expected_rtype) {
-      std::cout << "Received expected record type " << expected_rtype << '\n';
+      std::cout << "Received expected record type \n";
       break;
     } else if (auto* msg = record->GetIf<db::ErrorMsg>()) {
       std::stringstream ss;
@@ -66,13 +66,11 @@ void ProcessRecords(db::LiveBlocking& client, db::Schema schema,
   std::cout << "Finished client\n";
 }
 
-void ProcessSnapshotRecords(db::LiveBlocking& client, db::Schema schema) {
+void ProcessSnapshotRecords(db::LiveBlocking& client) {
   client.Start();
 
   std::cout << "Starting client...\n";
 
-  const auto expected_rtype = db::Record::RTypeFromSchema(schema);
-
   constexpr auto timeout = std::chrono::seconds{30};
 
   auto received_snapshot_record = false;
@@ -82,7 +80,7 @@ void ProcessSnapshotRecords(db::LiveBlocking& client, db::Schema schema) {
       if (mbo_msg->flags.IsSnapshot()) {
         received_snapshot_record = true;
       } else {
-        std::cout << "Received expected record type " << expected_rtype << '\n';
+        std::cout << "Received expected record type\n";
         break;
       }
     } else if (auto* error_msg = record->GetIf<db::ErrorMsg>()) {
@@ -195,7 +193,7 @@ int main(int argc, char* argv[]) {
   }
 
   if (use_snapshot) {
-    ProcessSnapshotRecords(client, schema);
+    ProcessSnapshotRecords(client);
   } else {
     ProcessRecords(client, schema, start_from_epoch);
   }

include/databento/batch.hpp

@@ -12,7 +12,6 @@ namespace databento {
 struct BatchJob {
   std::string id;
   std::string user_id;
-  std::string bill_id;
   // Cost in US dollars
   double cost_usd;
   std::string dataset;

include/databento/enums.hpp

@@ -627,6 +627,9 @@ enum SystemCode : std::uint8_t {
   SlowReaderWarning = 2,
   // Indicates a replay subscription has caught up with real-time data.
   ReplayCompleted = 3,
+  // Signals that all records for interval-based schemas have been published for the
+  // given timestamp.
+  EndOfInterval = 4,
   Unset = 255,
 };
 }  // namespace system_code

pkg/PKGBUILD

@@ -1,7 +1,7 @@
 # Maintainer: Databento <support@databento.com>
 _pkgname=databento-cpp
 pkgname=databento-cpp-git
-pkgver=0.41.0
+pkgver=0.42.0
 pkgrel=1
 pkgdesc="Official C++ client for Databento"
 arch=('any')

src/batch.cpp

@@ -19,7 +19,6 @@ std::ostream& operator<<(std::ostream& stream, const BatchJob& batch_job) {
       .Build()
       .AddField("id", batch_job.id)
       .AddField("user_id", batch_job.user_id)
-      .AddField("bill_id", batch_job.bill_id)
       .AddField("cost_usd", batch_job.cost_usd)
       .AddField("dataset", batch_job.dataset)
       .AddField("symbols", static_cast<std::ostringstream&>(symbol_helper.Finish()))

src/enums.cpp

@@ -795,6 +795,9 @@ const char* ToString(SystemCode system_code) {
     case SystemCode::ReplayCompleted: {
       return "replay_completed";
     }
+    case SystemCode::EndOfInterval: {
+      return "end_of_interval";
+    }
     default: {
       return "Unknown";
     }
@@ -1233,6 +1236,9 @@ SystemCode FromString(const std::string& str) {
   if (str == "replay_completed") {
     return SystemCode::ReplayCompleted;
   }
+  if (str == "end_of_interval") {
+    return SystemCode::EndOfInterval;
+  }
   throw InvalidArgumentError{"FromString<SystemCode>", "str",
                              "unknown value '" + str + '\''};
 }

src/historical.cpp

@@ -72,7 +72,6 @@ databento::BatchJob Parse(const std::string& endpoint, const nlohmann::json& jso
   databento::BatchJob res;
   res.id = CheckedAt(endpoint, json, "id");
   res.user_id = ParseAt<std::string>(endpoint, json, "user_id");
-  res.bill_id = ParseAt<std::string>(endpoint, json, "bill_id");
   res.cost_usd = ParseAt<double>(endpoint, json, "cost_usd");
   res.dataset = ParseAt<std::string>(endpoint, json, "dataset");
   res.symbols = ParseAt<std::vector<std::string>>(endpoint, json, "symbols");

tests/src/batch_tests.cpp

@@ -8,7 +8,6 @@ namespace databento::tests {
 TEST(BatchTests, TestBatchJobToString) {
   const BatchJob target{"aNiD",
                         "USER",
-                        "57db",
                         12.39,
                         dataset::kXnasItch,
                         {"CL.FUT"},
@@ -41,7 +40,6 @@ TEST(BatchTests, TestBatchJobToString) {
   ASSERT_EQ(res, R"(BatchJob {
     id = "aNiD",
     user_id = "USER",
-    bill_id = "57db",
     cost_usd = 12.39,
     dataset = "XNAS.ITCH",
     symbols = { "CL.FUT" },