VER: Release 0.19.0

Author: threecgreen

CHANGELOG.md

@@ -1,5 +1,18 @@
 # Changelog
 
+## 0.19.0 - 2025-01-21
+
+### Enhancements
+- Upgraded DBN version to 0.27.0:
+  - Updated enumerations for unreleased US equities datasets and publishers
+  - Added new venue `EQUS` for consolidated US equities
+  - Added new dataset `EQUS.MINI` and new publishers `EQUS.MINI.EQUS` and
+    `XNYS.TRADES.EQUS`
+
+### Bug fixes
+- Changed historical metadata methods with `symbols` parameter to use a `POST` request
+  to allow for requesting supported maximum of 2000 symbols
+
 ## 0.18.0 - 2025-01-08
 
 ### Enhancements
@@ -15,7 +28,8 @@
     - Decoding streams: `MergeDecoder` and `MergeRecordDecoder` structs
     - Metadata: `MergeDecoder` struct and `Metadata::merge()` method
     - In the CLI: specify more than one input file to initiate a merge
-  - Eliminated `unsafe` in `From` implementations for record structs from different versions
+  - Eliminated `unsafe` in `From` implementations for record structs from different
+    versions
 
 ## 0.17.0 - 2024-12-17
 
@@ -47,8 +61,8 @@
 
 #### Deprecations
 - Deprecated `Packaging` enum and `packaging` field on `SubmitJobParams` and `BatchJob`.
-  These will be removed in a future version. All files from a batch job can be downloaded
-  with the `batch().download()` method on the historical client
+  These will be removed in a future version. All files from a batch job can be
+  downloaded with the `batch().download()` method on the historical client
 
 ## 0.15.0 - 2024-10-22
 
@@ -174,11 +188,13 @@
 ## 0.9.0 - 2024-05-14
 
 #### Enhancements
-- Added `start` and `end` fields to the `DatasetRange` struct which provide time resolution and an exclusive end date
+- Added `start` and `end` fields to the `DatasetRange` struct which provide time
+  resolution and an exclusive end date
 - Upgraded DBN version to 0.17.1
 
 #### Deprecations
-- The `start_date` and `end_date` fields of the `DatasetRange` struct are deprecated and will be removed in a future release
+- The `start_date` and `end_date` fields of the `DatasetRange` struct are deprecated and
+  will be removed in a future release
 
 ## 0.8.0 - 2024-04-01
 

Cargo.toml

@@ -1,7 +1,7 @@
 [package]
 name = "databento"
 authors = ["Databento <[email protected]>"]
-version = "0.18.0"
+version = "0.19.0"
 edition = "2021"
 repository = "https://github.com/databento/databento-rs"
 description = "Official Databento client library"
@@ -23,7 +23,7 @@ historical = ["dep:futures", "dep:reqwest", "dep:serde", "dep:tokio-util", "dep:
 live = ["dep:hex", "dep:sha2", "tokio/net"]
 
 [dependencies]
-dbn = { version = "0.26.0", features = ["async", "serde"] }
+dbn = { version = "0.27.0", features = ["async", "serde"] }
 # Async stream trait
 futures = { version = "0.3", optional = true }
 # Used for Live authentication

src/historical/metadata.rs

@@ -136,11 +136,9 @@ impl MetadataClient<'_> {
     /// 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_record_count(&mut self, params: &GetRecordCountParams) -> crate::Result<u64> {
-        let resp = self
-            .get("get_record_count")?
-            .add_to_query(params)
-            .send()
-            .await?;
+        let mut form = Vec::new();
+        params.add_to_form(&mut form);
+        let resp = self.post("get_record_count")?.form(&form).send().await?;
         handle_response(resp).await
     }
 
@@ -154,11 +152,9 @@ impl MetadataClient<'_> {
         &mut self,
         params: &GetBillableSizeParams,
     ) -> crate::Result<u64> {
-        let resp = self
-            .get("get_billable_size")?
-            .add_to_query(params)
-            .send()
-            .await?;
+        let mut form = Vec::new();
+        params.add_to_form(&mut form);
+        let resp = self.post("get_billable_size")?.form(&form).send().await?;
         handle_response(resp).await
     }
 
@@ -169,13 +165,19 @@ impl MetadataClient<'_> {
     /// 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_cost(&mut self, params: &GetCostParams) -> crate::Result<f64> {
-        let resp = self.get("get_cost")?.add_to_query(params).send().await?;
+        let mut form = Vec::new();
+        params.add_to_form(&mut form);
+        let resp = self.post("get_cost")?.form(&form).send().await?;
         handle_response(resp).await
     }
 
     fn get(&mut self, slug: &str) -> crate::Result<RequestBuilder> {
         self.inner.get(&format!("metadata.{slug}"))
     }
+
+    fn post(&mut self, slug: &str) -> crate::Result<RequestBuilder> {
+        self.inner.post(&format!("metadata.{slug}"))
+    }
 }
 
 /// A type of data feed.
@@ -284,7 +286,6 @@ pub struct DatasetRange {
     pub end: time::OffsetDateTime,
 }
 
-#[allow(deprecated)]
 impl<'de> Deserialize<'de> for DatasetRange {
     fn deserialize<D>(deserializer: D) -> std::result::Result<Self, D::Error>
     where
@@ -430,20 +431,16 @@ fn deserialize_date<'de, D: serde::Deserializer<'de>>(
     let dt_str = String::deserialize(deserializer)?;
     time::Date::parse(&dt_str, super::DATE_FORMAT).map_err(serde::de::Error::custom)
 }
-impl AddToQuery<GetQueryParams> for reqwest::RequestBuilder {
-    fn add_to_query(mut self, params: &GetQueryParams) -> Self {
-        self = self
-            .query(&[
-                ("dataset", params.dataset.as_str()),
-                ("schema", params.schema.as_str()),
-                ("stype_in", params.stype_in.as_str()),
-            ])
-            .add_to_query(&params.symbols)
-            .add_to_query(&params.date_time_range);
-        if let Some(limit) = params.limit {
-            self = self.query(&[("limit", &limit.to_string())]);
+impl GetQueryParams {
+    fn add_to_form(&self, form: &mut Vec<(&'static str, String)>) {
+        form.push(("dataset", self.dataset.to_string()));
+        form.push(("schema", self.schema.to_string()));
+        form.push(("stype_in", self.stype_in.to_string()));
+        form.push(("symbols", self.symbols.to_api_string()));
+        self.date_time_range.add_to_form(form);
+        if let Some(limit) = self.limit {
+            form.push(("limit", limit.get().to_string()))
         }
-        self
     }
 }
 
@@ -650,7 +647,6 @@ mod tests {
     }
 
     #[tokio::test]
-    #[allow(deprecated)]
     async fn test_get_dataset_range() {
         const DATASET: &str = "XNAS.ITCH";
         let mock_server = MockServer::start().await;
@@ -679,7 +675,6 @@ mod tests {
     }
 
     #[tokio::test]
-    #[allow(deprecated)]
     async fn test_get_dataset_range_no_dates() {
         const DATASET: &str = "XNAS.ITCH";
         let mock_server = MockServer::start().await;

src/live/client.rs

@@ -244,7 +244,6 @@ impl fmt::Debug for Client {
 }
 
 #[cfg(test)]
-#[allow(deprecated)]
 mod tests {
     use std::{ffi::c_char, fmt};