diff --git a/.github/workflows/rust.yml b/.github/workflows/rust.yml index 1e44302..9bf0234 100644 --- a/.github/workflows/rust.yml +++ b/.github/workflows/rust.yml @@ -28,9 +28,9 @@ jobs: with: components: clippy - name: Check Clippy lints (reqwest) - run: cargo clippy --manifest-path influxdb/Cargo.toml --all-targets --no-default-features --features serde,derive,reqwest-client-rustls -- -D warnings + run: cargo clippy --manifest-path influxdb/Cargo.toml --all-targets --no-default-features --features chrono,time,serde,derive,reqwest-client-rustls -- -D warnings - name: Check Clippy lints (surf) - run: cargo clippy --manifest-path influxdb/Cargo.toml --all-targets --no-default-features --features serde,derive,hyper-client -- -D warnings + run: cargo clippy --manifest-path influxdb/Cargo.toml --all-targets --no-default-features --features chrono,time,serde,derive,hyper-client -- -D warnings # this checks that the code is formatted with rustfmt rustfmt: @@ -145,7 +145,7 @@ jobs: run: | for test in integration_tests{,_v2} do - cargo test -p influxdb --no-default-features --features 'serde derive ${{matrix.http-backend}}' --no-fail-fast --test $test + cargo test -p influxdb --no-default-features --features 'chrono time serde derive ${{matrix.http-backend}}' --no-fail-fast --test $test done # this uses cargo-tarpaulin to inspect the code coverage @@ -192,7 +192,7 @@ jobs: cargo tarpaulin -v \ --target-dir target/tarpaulin \ --workspace \ - --features serde,derive \ + --features chrono,time,serde,derive \ --exclude-files 'derive/*' \ --exclude-files 'target/*' \ --ignore-panics --ignore-tests \ diff --git a/influxdb/Cargo.toml b/influxdb/Cargo.toml index ffca9ae..6202960 100644 --- a/influxdb/Cargo.toml +++ b/influxdb/Cargo.toml @@ -13,18 +13,18 @@ include = ["src/**/*", "tests/**/*", "Cargo.toml", "LICENSE"] repository = "https://github.com/influxdb-rs/influxdb-rust" [dependencies] -chrono = { version = "0.4.23", features = ["serde"], default-features = false } +chrono = { version = "0.4.23", features = ["serde"], default-features = false, optional = true } futures-util = "0.3.17" http = "0.2.4" influxdb_derive = { version = "0.5.1", optional = true } lazy-regex = "3.1" reqwest = { version = "0.11.4", default-features = false, optional = true } -surf = { version = "2.2.0", default-features = false, optional = true } serde = { version = "1.0.186", optional = true } serde_derive = { version = "1.0.186", optional = true } serde_json = { version = "1.0.48", optional = true } +surf = { version = "2.2.0", default-features = false, optional = true } thiserror = "1.0" -time = "0.3.34" +time = { version = "0.3.34", optional = true } [features] default = ["serde", "reqwest-client-rustls"] @@ -41,6 +41,10 @@ reqwest-client-native-tls = ["reqwest", "reqwest/native-tls-alpn"] reqwest-client-native-tls-vendored = ["reqwest", "reqwest/native-tls-vendored"] wasm-client = ["surf", "surf/wasm-client"] +# etc +time = ["dep:time"] +chrono = ["dep:chrono"] + [dev-dependencies] async-std = { version = "1.6.5", features = ["attributes", "tokio02", "tokio1"] } indoc = "1.0" diff --git a/influxdb/src/query/mod.rs b/influxdb/src/query/mod.rs index 0dcdf49..9ef1c9b 100644 --- a/influxdb/src/query/mod.rs +++ b/influxdb/src/query/mod.rs @@ -20,8 +20,6 @@ //! assert!(read_query.is_ok()); //! ``` -use chrono::prelude::{DateTime, TimeZone, Utc}; - pub mod consts; mod line_proto_term; pub mod read_query; @@ -71,27 +69,32 @@ impl fmt::Display for Timestamp { } } -impl From for DateTime { - fn from(ts: Timestamp) -> DateTime { - Utc.timestamp_nanos(ts.nanos() as i64) +#[cfg(feature = "chrono")] +impl From for chrono::prelude::DateTime { + fn from(ts: Timestamp) -> chrono::prelude::DateTime { + use chrono::prelude::TimeZone; + chrono::prelude::Utc.timestamp_nanos(ts.nanos() as i64) } } -impl From> for Timestamp +#[cfg(feature = "chrono")] +impl From> for Timestamp where - T: TimeZone, + T: chrono::prelude::TimeZone, { - fn from(date_time: DateTime) -> Self { + fn from(date_time: chrono::prelude::DateTime) -> Self { Timestamp::Nanoseconds(date_time.timestamp_nanos_opt().unwrap() as u128) } } +#[cfg(feature = "time")] impl From for time::OffsetDateTime { fn from(value: Timestamp) -> Self { time::OffsetDateTime::from_unix_timestamp_nanos(value.nanos() as i128).unwrap() } } +#[cfg(feature = "time")] impl From for Timestamp { fn from(value: time::OffsetDateTime) -> Self { Timestamp::Nanoseconds(value.unix_timestamp_nanos() as u128) @@ -238,7 +241,6 @@ mod tests { MILLIS_PER_SECOND, MINUTES_PER_HOUR, NANOS_PER_MICRO, NANOS_PER_MILLI, SECONDS_PER_MINUTE, }; use crate::query::{Timestamp, ValidQuery}; - use chrono::prelude::{DateTime, TimeZone, Utc}; use std::convert::TryInto; #[test] fn test_equality_str() { @@ -255,8 +257,10 @@ mod tests { fn test_format_for_timestamp_else() { assert!(format!("{}", Timestamp::Nanoseconds(100)) == "100"); } + #[cfg(feature = "chrono")] #[test] fn test_chrono_datetime_from_timestamp_hours() { + use chrono::prelude::*; let datetime_from_timestamp: DateTime = Timestamp::Hours(2).into(); assert_eq!( Utc.timestamp_nanos( @@ -267,8 +271,10 @@ mod tests { datetime_from_timestamp ) } + #[cfg(feature = "chrono")] #[test] fn test_chrono_datetime_from_timestamp_minutes() { + use chrono::prelude::*; let datetime_from_timestamp: DateTime = Timestamp::Minutes(2).into(); assert_eq!( Utc.timestamp_nanos( @@ -279,8 +285,10 @@ mod tests { datetime_from_timestamp ) } + #[cfg(feature = "chrono")] #[test] fn test_chrono_datetime_from_timestamp_seconds() { + use chrono::prelude::*; let datetime_from_timestamp: DateTime = Timestamp::Seconds(2).into(); assert_eq!( Utc.timestamp_nanos( @@ -291,29 +299,37 @@ mod tests { datetime_from_timestamp ) } + #[cfg(feature = "chrono")] #[test] fn test_chrono_datetime_from_timestamp_millis() { + use chrono::prelude::*; let datetime_from_timestamp: DateTime = Timestamp::Milliseconds(2).into(); assert_eq!( Utc.timestamp_nanos((2 * NANOS_PER_MILLI).try_into().unwrap()), datetime_from_timestamp ) } + #[cfg(feature = "chrono")] #[test] fn test_chrono_datetime_from_timestamp_nanos() { + use chrono::prelude::*; let datetime_from_timestamp: DateTime = Timestamp::Nanoseconds(1).into(); assert_eq!(Utc.timestamp_nanos(1), datetime_from_timestamp) } + #[cfg(feature = "chrono")] #[test] fn test_chrono_datetime_from_timestamp_micros() { + use chrono::prelude::*; let datetime_from_timestamp: DateTime = Timestamp::Microseconds(2).into(); assert_eq!( Utc.timestamp_nanos((2 * NANOS_PER_MICRO).try_into().unwrap()), datetime_from_timestamp ) } + #[cfg(feature = "chrono")] #[test] fn test_timestamp_from_chrono_date() { + use chrono::prelude::*; let timestamp_from_datetime: Timestamp = Utc .with_ymd_and_hms(1970, 1, 1, 0, 0, 1) .single()