VER: Release 0.36.0

threecgreen · web-flow · commit 44a0ffeae919 · 2025-11-19T11:30:08.000-06:00
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -1,13 +1,31 @@
 # Changelog
 
+## 0.36.0 - 2025-11-19
+
+### Enhancements
+- Added support for using built-in range syntax for specifying date and datetime ranges
+  in the historical API, e.g. `date!(2020-01-01)..=date!(2020-12-31)`
+- Changed `metadata().get_dataset_range()`, `metadata().list_schemas()`, and
+  `metadata().list_unit_prices()` to accept any `impl AsRef<str>` as the dataset
+  parameter
+- Upgraded DBN version to 0.44.0:
+  - Added logic to set `code` when upgrading version 1 `SystemMsg` to newer versions
+  - Added `Dataset::publishers()` method to retrieve all `Publisher` values for a
+    dataset
+
+### Breaking changes
+- Updated the minimum supported `tokio` version to 1.41, which was released one year ago
+- Made reference enums `Country`, `Currency`, and `EventSubType` non-exhaustive
+- Removed variants from `Country` and `Currency` that were not present in any data
+- Added more variants to `EventSubType`
+
 ## 0.35.0 - 2025-10-22
 
 ### Enhancements
 - Initial release with Reference API support
 - Upgraded DBN version to 0.43.0:
   - Added explicit `Unset` variant for `SystemCode` and `ErrorCode`
   - Added `Default` implementation for `SystemCode` and `ErrorCode`
-
 ## 0.34.1 - 2025-09-30
 
 ### Enhancements
diff --git a/Cargo.toml b/Cargo.toml
@@ -1,7 +1,7 @@
 [package]
 name = "databento"
 authors = ["Databento <support@databento.com>"]
-version = "0.35.0"
+version = "0.36.0"
 edition = "2021"
 repository = "https://github.com/databento/databento-rs"
 description = "Official Databento client library"
@@ -32,7 +32,7 @@ historical = [
 live = ["tokio/net"]
 
 [dependencies]
-dbn = { version = "0.43.0", features = ["async", "serde"] }
+dbn = { version = "0.44.0", features = ["async", "serde"] }
 
 async-compression = { version = "0.4", features = ["tokio", "zstd"], optional = true }
 # Async stream trait
@@ -46,19 +46,19 @@ serde_json = { version = "1.0", optional = true }
 sha2 = "0.10"
 thiserror = "2.0"
 time = { version = ">=0.3.35", features = ["macros", "parsing", "serde-human-readable"] }
-tokio = { version = ">=1.38", features = ["io-util", "macros"] }
+tokio = { version = ">=1.41", features = ["io-util", "macros"] }
 # Stream utils
 tokio-util = { version = "0.7", features = ["io"], optional = true }
 tracing = "0.1"
-typed-builder = "0.22"
+typed-builder = "0.23"
 zstd = { version = "0.13", optional = true }
 
 [dev-dependencies]
 anyhow = "1.0.100"
 async-compression = { version = "0.4", features = ["tokio", "zstd"] }
-clap = { version = "4.5.48", features = ["derive"] }
+clap = { version = "4.5.51", features = ["derive"] }
 rstest = "0.26.1"
 tempfile = "3.23.0"
-tokio = { version = "1.47", features = ["full"] }
+tokio = { version = "1.48", features = ["full"] }
 tracing-subscriber = "0.3.20"
 wiremock = "0.6"
diff --git a/README.md b/README.md
@@ -57,10 +57,7 @@ async fn main() -> Result<(), Box<dyn Error>> {
         .get_range(
             &GetRangeParams::builder()
                 .dataset(Dataset::GlbxMdp3)
-                .date_time_range((
-                    datetime!(2022-06-10 14:30 UTC),
-                    datetime!(2022-06-10 14:40 UTC),
-                ))
+                .date_time_range(datetime!(2022-06-10 14:30 UTC)..datetime!(2022-06-10 14:40 UTC))
                 .symbols("ES.FUT")
                 .stype_in(SType::Parent)
                 .schema(Schema::Trades)
diff --git a/examples/historical.rs b/examples/historical.rs
@@ -19,10 +19,7 @@ async fn main() -> Result<(), Box<dyn Error>> {
         .get_range(
             &GetRangeParams::builder()
                 .dataset(Dataset::GlbxMdp3)
-                .date_time_range((
-                    datetime!(2022-06-10 14:30 UTC),
-                    datetime!(2022-06-10 14:40 UTC),
-                ))
+                .date_time_range(datetime!(2022-06-10 14:30 UTC)..datetime!(2022-06-10 14:40 UTC))
                 .symbols("ES.FUT")
                 .stype_in(SType::Parent)
                 .schema(Schema::Trades)
diff --git a/examples/split_symbols.rs b/examples/split_symbols.rs
@@ -82,7 +82,7 @@ async fn fetch_symbols_to_parent(metadata: &Metadata) -> anyhow::Result<HashMap<
                 &GetRangeParams::builder()
                     .dataset(metadata.dataset.clone())
                     .schema(Schema::Definition)
-                    .date_time_range((metadata.start(), end))
+                    .date_time_range(metadata.start()..end)
                     .symbols(Vec::from(chunk))
                     .build(),
             )
diff --git a/src/historical.rs b/src/historical.rs
@@ -6,7 +6,10 @@ pub mod metadata;
 pub mod symbology;
 pub mod timeseries;
 
-use std::num::NonZeroU64;
+use std::{
+    num::NonZeroU64,
+    ops::{Range, RangeInclusive},
+};
 
 pub use client::*;
 use serde::Deserialize;
@@ -57,6 +60,24 @@ pub struct DateTimeRange {
     pub end: time::OffsetDateTime,
 }
 
+impl From<Range<time::Date>> for DateRange {
+    fn from(range: Range<time::Date>) -> Self {
+        Self {
+            start: range.start,
+            end: range.end,
+        }
+    }
+}
+
+impl From<RangeInclusive<time::Date>> for DateRange {
+    fn from(range: RangeInclusive<time::Date>) -> Self {
+        Self {
+            start: *range.start(),
+            end: range.end().next_day().unwrap(),
+        }
+    }
+}
+
 impl From<(time::Date, time::Date)> for DateRange {
     fn from(value: (time::Date, time::Date)) -> Self {
         Self {
@@ -75,6 +96,36 @@ impl From<(time::Date, time::Duration)> for DateRange {
     }
 }
 
+impl From<Range<time::Date>> for DateTimeRange {
+    fn from(range: Range<time::Date>) -> Self {
+        Self::from(DateRange::from(range))
+    }
+}
+
+impl From<RangeInclusive<time::Date>> for DateTimeRange {
+    fn from(range: RangeInclusive<time::Date>) -> Self {
+        Self::from(DateRange::from(range))
+    }
+}
+
+impl From<Range<time::OffsetDateTime>> for DateTimeRange {
+    fn from(range: Range<time::OffsetDateTime>) -> Self {
+        Self {
+            start: range.start,
+            end: range.end,
+        }
+    }
+}
+
+impl From<RangeInclusive<time::OffsetDateTime>> for DateTimeRange {
+    fn from(range: RangeInclusive<time::OffsetDateTime>) -> Self {
+        Self {
+            start: *range.start(),
+            end: *range.end() + time::Duration::NANOSECOND,
+        }
+    }
+}
+
 impl From<(time::Date, time::Duration)> for DateTimeRange {
     fn from(value: (time::Date, time::Duration)) -> Self {
         Self::from(DateRange::from(value))
@@ -266,6 +317,14 @@ mod tests {
             DateRange::from(date),
             DateRange::from((date!(2025 - 03 - 27), date!(2025 - 03 - 28)))
         );
+        assert_eq!(
+            DateRange::from(date),
+            DateRange::from(date!(2025 - 03 - 27)..date!(2025 - 03 - 28))
+        );
+        assert_eq!(
+            DateRange::from(date),
+            DateRange::from(date!(2025 - 03 - 27)..=date!(2025 - 03 - 27))
+        );
         assert_eq!(
             DateTimeRange::from(date),
             DateTimeRange::from((
diff --git a/src/historical/batch.rs b/src/historical/batch.rs
@@ -751,7 +751,7 @@ mod tests {
                     .dataset(dbn::Dataset::XnasItch)
                     .schema(SCHEMA)
                     .symbols("TSLA")
-                    .date_time_range((START, END))
+                    .date_time_range(START..END)
                     .build(),
             )
             .await?;
diff --git a/src/historical/metadata.rs b/src/historical/metadata.rs
@@ -53,10 +53,10 @@ impl MetadataClient<'_> {
     /// # Errors
     /// This function returns an error when it fails to communicate with the Databento API
     /// or the API indicates there's an issue with the request.
-    pub async fn list_schemas(&mut self, dataset: &str) -> crate::Result<Vec<Schema>> {
+    pub async fn list_schemas(&mut self, dataset: impl AsRef<str>) -> crate::Result<Vec<Schema>> {
         let resp = self
             .get("list_schemas")?
-            .query(&[("dataset", dataset)])
+            .query(&[("dataset", dataset.as_ref())])
             .send()
             .await?;
         handle_response(resp).await
@@ -86,11 +86,11 @@ impl MetadataClient<'_> {
     /// or the API indicates there's an issue with the request.
     pub async fn list_unit_prices(
         &mut self,
-        dataset: &str,
+        dataset: impl AsRef<str>,
     ) -> crate::Result<Vec<UnitPricesForMode>> {
         let builder = self
             .get("list_unit_prices")?
-            .query(&[("dataset", &dataset)]);
+            .query(&[("dataset", &dataset.as_ref())]);
         let resp = builder.send().await?;
         handle_response(resp).await
     }
@@ -123,10 +123,13 @@ impl MetadataClient<'_> {
     /// # Errors
     /// This function returns an error when it fails to communicate with the Databento API
     /// or the API indicates there's an issue with the request.
-    pub async fn get_dataset_range(&mut self, dataset: &str) -> crate::Result<DatasetRange> {
+    pub async fn get_dataset_range(
+        &mut self,
+        dataset: impl AsRef<str>,
+    ) -> crate::Result<DatasetRange> {
         let resp = self
             .get("get_dataset_range")?
-            .query(&[("dataset", dataset)])
+            .query(&[("dataset", dataset.as_ref())])
             .send()
             .await?;
         handle_response(resp).await
diff --git a/src/historical/symbology.rs b/src/historical/symbology.rs
@@ -250,7 +250,7 @@ mod tests {
                     .dataset(dbn::Dataset::GlbxMdp3)
                     .symbols(vec!["ES.c.0", "ES.d.0"])
                     .stype_in(SType::Continuous)
-                    .date_range((date!(2023 - 06 - 14), date!(2023 - 06 - 17)))
+                    .date_range(date!(2023 - 06 - 14)..date!(2023 - 06 - 17))
                     .build(),
             )
             .await
diff --git a/src/historical/timeseries.rs b/src/historical/timeseries.rs
@@ -341,7 +341,7 @@ mod tests {
                     .dataset(dbn::Dataset::XnasItch)
                     .schema(SCHEMA)
                     .symbols(vec!["SPOT", "AAPL"])
-                    .date_time_range((START, END))
+                    .date_time_range(START..END)
                     .build(),
             )
             .await
@@ -399,7 +399,7 @@ mod tests {
                     .schema(SCHEMA)
                     .symbols(vec!["BRN.FUT"])
                     .stype_in(SType::Parent)
-                    .date_time_range((START, END))
+                    .date_time_range(START..END)
                     .path(path.clone())
                     .build(),
             )
diff --git a/src/lib.rs b/src/lib.rs
@@ -1,7 +1,6 @@
 // Use README as crate-level documentation
 #![doc = include_str!("../README.md")]
-// Experimental feature to allow docs.rs to display features
-#![cfg_attr(docsrs, feature(doc_auto_cfg))]
+#![cfg_attr(docsrs, feature(doc_cfg))]
 #![deny(missing_docs)]
 #![deny(rustdoc::broken_intra_doc_links)]
 #![deny(clippy::missing_errors_doc)]
diff --git a/src/reference/enums.rs b/src/reference/enums.rs

Original file line number	Diff line number	Diff line change
`@@ -82,7 +82,7 @@ async fn fetch_symbols_to_parent(metadata: &Metadata) -> anyhow::Result<HashMap<`
`82`	`82`	`&GetRangeParams::builder()`
`83`	`83`	`.dataset(metadata.dataset.clone())`
`84`	`84`	`.schema(Schema::Definition)`
`85`		`- .date_time_range((metadata.start(), end))`
	`85`	`+ .date_time_range(metadata.start()..end)`
`86`	`86`	`.symbols(Vec::from(chunk))`
`87`	`87`	`.build(),`
`88`	`88`	`)`
Original file line number	Diff line number	Diff line change
`@@ -751,7 +751,7 @@ mod tests {`
`751`	`751`	`.dataset(dbn::Dataset::XnasItch)`
`752`	`752`	`.schema(SCHEMA)`
`753`	`753`	`.symbols("TSLA")`
`754`		`- .date_time_range((START, END))`
	`754`	`+ .date_time_range(START..END)`
`755`	`755`	`.build(),`
`756`	`756`	`)`
`757`	`757`	`.await?;`
Original file line number	Diff line number	Diff line change
`@@ -250,7 +250,7 @@ mod tests {`
`250`	`250`	`.dataset(dbn::Dataset::GlbxMdp3)`
`251`	`251`	`.symbols(vec!["ES.c.0", "ES.d.0"])`
`252`	`252`	`.stype_in(SType::Continuous)`
`253`		`- .date_range((date!(2023 - 06 - 14), date!(2023 - 06 - 17)))`
	`253`	`+ .date_range(date!(2023 - 06 - 14)..date!(2023 - 06 - 17))`
`254`	`254`	`.build(),`
`255`	`255`	`)`
`256`	`256`	`.await`