feat(lazer): improve time types (#2851)

* feat(lazer): improve time types (wip)

* chore: remove cadd for now

* feat(lazer): add a few more functions and costs

* test(lazer): add time tests

* chore: fix ci

* fix(lazer): is_multiple_of

* chore: bump version

Author: Riateche

.github/workflows/ci-lazer-rust.yml

@@ -41,6 +41,12 @@ jobs:
       - name: Clippy check
         run: cargo clippy -p pyth-lazer-protocol -p pyth-lazer-client -p pyth-lazer-publisher-sdk --all-targets -- --deny warnings
         if: success() || failure()
+      - name: Clippy check with mry
+        run: cargo clippy -F mry -p pyth-lazer-protocol --all-targets -- --deny warnings
+        if: success() || failure()
       - name: test
         run: cargo test -p pyth-lazer-protocol -p pyth-lazer-client -p pyth-lazer-publisher-sdk
         if: success() || failure()
+      - name: test with mry
+        run: cargo test -F mry -p pyth-lazer-protocol
+        if: success() || failure()

Cargo.lock

@@ -22,7 +22,7 @@ no-log-ix-name = []
 idl-build = ["anchor-lang/idl-build"]
 
 [dependencies]
-pyth-lazer-protocol = { path = "../../../../sdk/rust/protocol", version = "0.8.1" }
+pyth-lazer-protocol = { path = "../../../../sdk/rust/protocol", version = "0.9.0" }
 
 anchor-lang = "0.30.1"
 bytemuck = "1.20.0"

lazer/contracts/solana/Cargo.lock

@@ -7,7 +7,7 @@ license = "Apache-2.0"
 repository = "https://github.com/pyth-network/pyth-crosschain"
 
 [dependencies]
-pyth-lazer-protocol = { version = "0.8.1", path = "../../sdk/rust/protocol" }
+pyth-lazer-protocol = { version = "0.9.0", path = "../../sdk/rust/protocol" }
 anyhow = "1.0.98"
 protobuf = "3.7.2"
 serde-value = "0.7.0"

lazer/contracts/solana/programs/pyth-lazer-solana-contract/Cargo.toml

@@ -7,7 +7,7 @@ use anyhow::{bail, ensure, Context};
 use humantime::format_duration;
 use protobuf::dynamic_value::{dynamic_value, DynamicValue};
 use pyth_lazer_protocol::jrpc::{FeedUpdateParams, UpdateParams};
-use pyth_lazer_protocol::router::TimestampUs;
+use pyth_lazer_protocol::time::TimestampUs;
 
 pub mod transaction_envelope {
     pub use crate::protobuf::transaction_envelope::*;
@@ -141,7 +141,7 @@ impl TryFrom<DynamicValue> for serde_value::Value {
             }
             dynamic_value::Value::TimestampValue(ts) => {
                 let ts = TimestampUs::try_from(&ts)?;
-                Ok(serde_value::Value::U64(ts.0))
+                Ok(serde_value::Value::U64(ts.as_micros()))
             }
             dynamic_value::Value::List(list) => {
                 let mut output = Vec::new();

lazer/publisher_sdk/rust/Cargo.toml

@@ -6,7 +6,7 @@ description = "A Rust client for Pyth Lazer"
 license = "Apache-2.0"
 
 [dependencies]
-pyth-lazer-protocol = { path = "../protocol", version = "0.8.1" }
+pyth-lazer-protocol = { path = "../protocol", version = "0.9.0" }
 tokio = { version = "1", features = ["full"] }
 tokio-tungstenite = { version = "0.20", features = ["native-tls"] }
 futures-util = "0.3"

lazer/publisher_sdk/rust/src/lib.rs

@@ -44,9 +44,7 @@ async fn main() -> anyhow::Result<()> {
                 delivery_format: DeliveryFormat::Json,
                 json_binary_encoding: JsonBinaryEncoding::Base64,
                 parsed: true,
-                channel: Channel::FixedRate(
-                    FixedRate::from_ms(200).expect("unsupported update rate"),
-                ),
+                channel: Channel::FixedRate(FixedRate::RATE_200_MS),
                 ignore_invalid_feed_ids: false,
             })
             .expect("invalid subscription params"),
@@ -66,9 +64,7 @@ async fn main() -> anyhow::Result<()> {
                 delivery_format: DeliveryFormat::Binary,
                 json_binary_encoding: JsonBinaryEncoding::Base64,
                 parsed: false,
-                channel: Channel::FixedRate(
-                    FixedRate::from_ms(50).expect("unsupported update rate"),
-                ),
+                channel: Channel::FixedRate(FixedRate::RATE_50_MS),
                 ignore_invalid_feed_ids: false,
             })
             .expect("invalid subscription params"),

lazer/sdk/rust/client/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "pyth-lazer-protocol"
-version = "0.8.1"
+version = "0.9.0"
 edition = "2021"
 description = "Pyth Lazer SDK - protocol types."
 license = "Apache-2.0"
@@ -16,6 +16,8 @@ itertools = "0.13.0"
 rust_decimal = "1.36.0"
 protobuf = "3.7.2"
 humantime-serde = "1.1.1"
+mry = { version = "0.13.0", features = ["serde"], optional = true }
+chrono = "0.4.41"
 
 [dev-dependencies]
 bincode = "1.3.3"

lazer/sdk/rust/client/examples/subscribe_price_feeds.rs

@@ -1,7 +1,8 @@
 use serde::{Deserialize, Serialize};
 
-use crate::router::{
-    Channel, Format, JsonBinaryEncoding, JsonUpdate, PriceFeedId, PriceFeedProperty, TimestampUs,
+use crate::{
+    router::{Channel, Format, JsonBinaryEncoding, JsonUpdate, PriceFeedId, PriceFeedProperty},
+    time::TimestampUs,
 };
 
 #[derive(Debug, Clone, PartialEq, Eq, Hash, Serialize, Deserialize)]