Fix parsing received_timestamp (#939)

* Fix parsing received_timestamp * fix parsing received_timestamp from proto value * fix parsing receive_timestamp for VerifiedSubscriberVerifiedMappingEventIngestReports --------- Co-authored-by: Michael Jeffrey <[email protected]>
helium · Feb 6, 2025 · 21e5dae · 21e5dae
1 parent f2130dd
commit 21e5dae
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/file_store/src/subscriber_verified_mapping_event_ingest_report.rs b/file_store/src/subscriber_verified_mapping_event_ingest_report.rs
@@ -21,13 +21,13 @@ impl MsgDecode for SubscriberVerifiedMappingEventIngestReport {
 
 impl MsgTimestamp<Result<DateTime<Utc>>> for SubscriberVerifiedMappingEventIngestReportV1 {
     fn timestamp(&self) -> Result<DateTime<Utc>> {
-        self.received_timestamp.to_timestamp()
+        self.received_timestamp.to_timestamp_millis()
     }
 }
 
 impl MsgTimestamp<u64> for SubscriberVerifiedMappingEventIngestReport {
     fn timestamp(&self) -> u64 {
-        self.received_timestamp.encode_timestamp()
+        self.received_timestamp.encode_timestamp_millis()
     }
 }
 

diff --git a/file_store/src/verified_subscriber_verified_mapping_event_ingest_report.rs b/file_store/src/verified_subscriber_verified_mapping_event_ingest_report.rs
@@ -23,13 +23,13 @@ impl MsgDecode for VerifiedSubscriberVerifiedMappingEventIngestReport {
 
 impl MsgTimestamp<Result<DateTime<Utc>>> for VerifiedSubscriberVerifiedMappingEventIngestReportV1 {
     fn timestamp(&self) -> Result<DateTime<Utc>> {
-        self.timestamp.to_timestamp()
+        self.timestamp.to_timestamp_millis()
     }
 }
 
 impl MsgTimestamp<u64> for VerifiedSubscriberVerifiedMappingEventIngestReport {
     fn timestamp(&self) -> u64 {
-        self.timestamp.encode_timestamp()
+        self.timestamp.encode_timestamp_millis()
     }
 }