Update dependencies to latest version (#117)

* Update dependencies to latest version

* Fix clippy issues when using rustc 1.88

Author: jcaden

Cargo.toml

@@ -20,36 +20,37 @@ categories = ["api-bindings", "multimedia::audio"]
 [dependencies]
 # TODO Investigate which of these dependencies can go behind features.
 bytes = "1"
-futures = "0.3"
-http = "0.2"
+futures = "^0.3"
+http = "1.3"
 pin-project = "1"
-reqwest = { version = "0.11.22", default-features = false, features = [
+reqwest = { version = "^0.12", default-features = false, features = [
   "json",
   "rustls-tls",
   "stream",
 ] }
-serde = { version = "1.0.215", features = ["derive"] }
+serde = { version = "^1.0.219", features = ["derive"] }
 serde_json = "1"
 serde_urlencoded = "0.7"
-thiserror = "1"
-tokio = { version = "1.38.0", features = ["full"] }
-tokio-stream = "0.1.15"
-tokio-tungstenite = { version = "0.20.1", features = [
+thiserror = "2"
+tokio = { version = "^1.45.1", features = ["full"] }
+tokio-stream = "^0.1.17"
+tokio-tungstenite = { version = "^0.27.0", features = [
   "rustls-tls-webpki-roots",
 ], optional = true }
-tokio-util = { version = "0.7.1", features = ["codec", "io"] }
-tungstenite = { version = "0.20.1", optional = true }
+tokio-util = { version = "^0.7", features = ["codec", "io"] }
+tungstenite = { version = "^0.27", optional = true }
 url = "2"
 uuid = { version = "1", features = ["serde"] }
 # Dependencies below are specified only to satisfy minimal-versions.
-sha256 = "1.5.0"
-anyhow = "1.0.86"
+sha256 = "^1.6.0"
+anyhow = "^1.0.98"
+tracing = ">=0.1.41"
 
 [dev-dependencies]
-cpal = "0.13"
+cpal = "^0.16"
 crossbeam = "0.8"
 audio = "0.2.0"
-rodio = { version = "0.17.0" }
+rodio = { version = "0.20" }
 pkg-config = { version = "0.3.30" }
 
 [features]

examples/speak/rest/text_to_speech_to_file.rs

@@ -31,7 +31,7 @@ async fn main() -> Result<(), DeepgramError> {
         .await?;
 
     let elapsed_time = start_time.elapsed();
-    println!("Time to download audio: {:.2?}", elapsed_time);
+    println!("Time to download audio: {elapsed_time:.2?}");
 
     Ok(())
 }

examples/speak/rest/text_to_speech_to_stream.rs

@@ -137,7 +137,7 @@ async fn main() -> Result<(), DeepgramError> {
         // Print timing information if not already printed
         if !time_to_first_byte_printed {
             let elapsed_time = start_time.elapsed();
-            println!("Time to first audio byte: {:.2?}", elapsed_time);
+            println!("Time to first audio byte: {elapsed_time:.2?}");
             time_to_first_byte_printed = true;
         }
 

examples/transcription/rest/make_prerecorded_request_builder.rs

@@ -39,7 +39,7 @@ async fn main() -> Result<(), DeepgramError> {
     let response: Response = customized_request_builder.send().await?.json().await?;
 
     let transcript = &response.results.channels[0].alternatives[0].transcript;
-    println!("{}", transcript);
+    println!("{transcript}");
 
     Ok(())
 }

examples/transcription/rest/prerecorded_from_file.rs

@@ -33,7 +33,7 @@ async fn main() -> Result<(), DeepgramError> {
         .await?;
 
     let transcript = &response.results.channels[0].alternatives[0].transcript;
-    println!("{}", transcript);
+    println!("{transcript}");
 
     Ok(())
 }

examples/transcription/rest/prerecorded_from_url.rs

@@ -51,9 +51,9 @@ async fn main() -> Result<(), DeepgramError> {
         .await?;
 
     let transcript = &response.results.channels[0].alternatives[0].transcript;
-    println!("{}", transcript);
+    println!("{transcript}");
 
-    println!("{:?}", response);
+    println!("{response:?}");
 
     Ok(())
 }

examples/transcription/websocket/callback_stream.rs

@@ -47,7 +47,7 @@ async fn main() -> Result<(), DeepgramError> {
 
     println!("Deepgram Request ID: {}", results.request_id());
     while let Some(result) = results.next().await {
-        println!("got: {:?}", result);
+        println!("got: {result:?}");
     }
 
     Ok(())

examples/transcription/websocket/microphone_stream.rs

@@ -3,7 +3,7 @@ use std::thread;
 
 use bytes::{BufMut, Bytes, BytesMut};
 use cpal::traits::{DeviceTrait, HostTrait, StreamTrait};
-use cpal::Sample;
+use cpal::{Sample, SampleFormat};
 use crossbeam::channel::RecvError;
 use deepgram::common::options::Encoding;
 use futures::channel::mpsc::{self, Receiver as FuturesReceiver};
@@ -12,6 +12,25 @@ use futures::SinkExt;
 
 use deepgram::{Deepgram, DeepgramError};
 
+macro_rules! create_stream {
+    ($device:ident, $config:expr, $sync_tx:ident, $sample_type:ty) => {
+        $device
+            .build_input_stream(
+                &$config.into(),
+                move |data: &[$sample_type], _: &_| {
+                    let mut bytes = BytesMut::with_capacity(data.len() * 2);
+                    for sample in data {
+                        bytes.put_i16_le(sample.to_sample());
+                    }
+                    $sync_tx.send(bytes.freeze()).unwrap();
+                },
+                |_| panic!(),
+                None,
+            )
+            .unwrap()
+    };
+}
+
 fn microphone_as_stream() -> FuturesReceiver<Result<Bytes, RecvError>> {
     let (sync_tx, sync_rx) = crossbeam::channel::unbounded();
     let (mut async_tx, async_rx) = mpsc::channel(1);
@@ -30,45 +49,12 @@ fn microphone_as_stream() -> FuturesReceiver<Result<Bytes, RecvError>> {
         // dbg!(&config);
 
         let stream = match config.sample_format() {
-            cpal::SampleFormat::F32 => device
-                .build_input_stream(
-                    &config.into(),
-                    move |data: &[f32], _: &_| {
-                        let mut bytes = BytesMut::with_capacity(data.len() * 2);
-                        for sample in data {
-                            bytes.put_i16_le(sample.to_i16());
-                        }
-                        sync_tx.send(bytes.freeze()).unwrap();
-                    },
-                    |_| panic!(),
-                )
-                .unwrap(),
-            cpal::SampleFormat::I16 => device
-                .build_input_stream(
-                    &config.into(),
-                    move |data: &[i16], _: &_| {
-                        let mut bytes = BytesMut::with_capacity(data.len() * 2);
-                        for sample in data {
-                            bytes.put_i16_le(*sample);
-                        }
-                        sync_tx.send(bytes.freeze()).unwrap();
-                    },
-                    |_| panic!(),
-                )
-                .unwrap(),
-            cpal::SampleFormat::U16 => device
-                .build_input_stream(
-                    &config.into(),
-                    move |data: &[u16], _: &_| {
-                        let mut bytes = BytesMut::with_capacity(data.len() * 2);
-                        for sample in data {
-                            bytes.put_i16_le(sample.to_i16());
-                        }
-                        sync_tx.send(bytes.freeze()).unwrap();
-                    },
-                    |_| panic!(),
-                )
-                .unwrap(),
+            SampleFormat::F32 => create_stream!(device, config, sync_tx, f32),
+            SampleFormat::I16 => create_stream!(device, config, sync_tx, i16),
+            SampleFormat::U16 => create_stream!(device, config, sync_tx, u16),
+            sample_format => {
+                panic!("Unsupported sample format: {sample_format:?}");
+            }
         };
 
         stream.play().unwrap();
@@ -109,7 +95,7 @@ async fn main() -> Result<(), DeepgramError> {
 
     println!("Deepgram Request ID: {}", results.request_id());
     while let Some(result) = results.next().await {
-        println!("got: {:?}", result);
+        println!("got: {result:?}");
     }
 
     Ok(())

examples/transcription/websocket/simple_stream.rs

@@ -41,7 +41,7 @@ async fn main() -> Result<(), DeepgramError> {
 
     println!("Deepgram Request ID: {}", results.request_id());
     while let Some(result) = results.next().await {
-        println!("got: {:?}", result);
+        println!("got: {result:?}");
     }
 
     Ok(())

src/common/options.rs

@@ -2288,7 +2288,7 @@ impl Serialize for SerializableOptions<'_> {
 
         if let Some(extra) = extra {
             for (key, value) in extra.iter() {
-                seq.serialize_element(&("extra", format!("{}:{}", key, value)))?;
+                seq.serialize_element(&("extra", format!("{key}:{value}")))?;
             }
         }
 
@@ -2706,7 +2706,7 @@ mod serialize_options_tests {
 
         let expected = limited_letters
             .iter()
-            .map(|letter| format!("{}={}", key, letter))
+            .map(|letter| format!("{key}={letter}"))
             .collect::<Vec<String>>()
             .join("&");