add impl for timestampus

Author: darunrs

lazer/Cargo.lock

@@ -1,6 +1,6 @@
 [package]
 name = "pyth-lazer-protocol"
-version = "0.7.0"
+version = "0.7.1"
 edition = "2021"
 description = "Pyth Lazer SDK - protocol types."
 license = "Apache-2.0"
@@ -15,6 +15,7 @@ derive_more = { version = "1.0.0", features = ["from"] }
 itertools = "0.13.0"
 rust_decimal = "1.36.0"
 base64 = "0.22.1"
+protobuf = "3.7.2"
 
 [dev-dependencies]
 bincode = "1.3.3"

lazer/sdk/rust/protocol/Cargo.toml

@@ -4,6 +4,7 @@ use {
     crate::payload::AggregatedPriceFeedData,
     anyhow::{bail, Context},
     itertools::Itertools,
+    protobuf::{well_known_types::timestamp::Timestamp, MessageField},
     rust_decimal::{prelude::FromPrimitive, Decimal},
     serde::{de::Error, Deserialize, Serialize},
     std::{
@@ -26,6 +27,20 @@ pub struct ChannelId(pub u8);
 #[derive(Debug, Clone, Copy, PartialEq, Eq, Hash, PartialOrd, Ord, Serialize, Deserialize)]
 pub struct TimestampUs(pub u64);
 
+impl TryFrom<&MessageField<Timestamp>> for TimestampUs {
+    type Error = anyhow::Error;
+
+    fn try_from(timestamp_field: &MessageField<Timestamp>) -> anyhow::Result<Self> {
+        if let Some(timestamp) = timestamp_field.clone().into_option() {
+            let seconds_in_micros: u64 = (timestamp.seconds * 1_000_000).try_into()?;
+            let nanos_in_micros: u64 = (timestamp.nanos / 1_000).try_into()?;
+            Ok(TimestampUs(seconds_in_micros + nanos_in_micros))
+        } else {
+            bail!("timestamp field was empty")
+        }
+    }
+}
+
 impl TimestampUs {
     pub fn now() -> Self {
         let value = SystemTime::now()