Migrate started time to recording properties (#9894)

Author: jprochazk

crates/store/re_data_loader/src/load_file.rs

@@ -101,6 +101,7 @@ pub(crate) fn prepare_store_info(
             store_id: store_id.clone(),
             cloned_from: None,
             store_source,
+            started: None,
             store_version: Some(re_build_info::CrateVersion::LOCAL),
         },
     })

crates/store/re_data_loader/src/loader_rrd.rs

@@ -354,6 +354,7 @@ mod tests {
                         rustc_version: String::new(),
                         llvm_version: String::new(),
                     },
+                    started: None,
                     store_version: Some(CrateVersion::LOCAL),
                 },
             })

crates/store/re_grpc_client/src/redap/mod.rs

@@ -221,6 +221,7 @@ pub async fn stream_partition_async(
         store_id: store_id.clone(),
         cloned_from: None,
         store_source: StoreSource::Unknown,
+        started: None,
         store_version: None,
     };
 

crates/store/re_grpc_server/src/lib.rs

@@ -856,6 +856,7 @@ mod tests {
                     rustc_version: String::new(),
                     llvm_version: String::new(),
                 },
+                started: None,
                 store_version: Some(CrateVersion::LOCAL),
             },
         }));
@@ -905,6 +906,7 @@ mod tests {
                     rustc_version: String::new(),
                     llvm_version: String::new(),
                 },
+                started: None,
                 store_version: Some(CrateVersion::LOCAL),
             },
         }));

crates/store/re_log_encoding/src/decoder/mod.rs

@@ -462,6 +462,7 @@ mod tests {
                         rustc_version: String::new(),
                         llvm_version: String::new(),
                     },
+                    started: None,
                     store_version: Some(CrateVersion::LOCAL),
                 },
             }),

crates/store/re_log_encoding/src/decoder/stream.rs

@@ -307,6 +307,7 @@ mod tests {
                 store_id: StoreId::from_string(StoreKind::Recording, "test".into()),
                 cloned_from: None,
                 store_source: StoreSource::Unknown,
+                started: None,
                 store_version: Some(CrateVersion::LOCAL),
             },
         })

crates/store/re_log_encoding/src/legacy.rs

@@ -89,6 +89,7 @@ impl LegacyLogMsg {
                     application_id,
                     store_id,
                     cloned_from,
+                    started,
                 } = info;
 
                 re_log_types::LogMsg::SetStoreInfo(re_log_types::SetStoreInfo {
@@ -98,6 +99,7 @@ impl LegacyLogMsg {
                         store_id: store_id.migrate(),
                         cloned_from: cloned_from.map(|id| id.migrate()),
                         store_source: re_log_types::StoreSource::Unknown,
+                        started: Some(started),
                         store_version: None,
                     },
                 })
@@ -296,5 +298,5 @@ pub struct LegacyStoreInfo {
     pub store_id: LegacyStoreId,
     pub cloned_from: Option<LegacyStoreId>,
     // pub is_official_example: bool,
-    // pub started: LegacyTime,
+    pub started: re_log_types::Time,
 }

crates/store/re_log_types/src/lib.rs

@@ -390,6 +390,9 @@ pub struct StoreInfo {
 
     pub store_source: StoreSource,
 
+    /// When the recording started.
+    pub started: Option<Time>,
+
     /// The Rerun version used to encoded the RRD data.
     ///
     // NOTE: The version comes directly from the decoded RRD stream's header, duplicating it here
@@ -405,6 +408,18 @@ impl StoreInfo {
     }
 }
 
+/// A date-time represented as nanoseconds since unix epoch
+#[derive(Clone, Copy, Debug, PartialEq, Eq)]
+#[cfg_attr(feature = "serde", derive(serde::Deserialize, serde::Serialize))]
+pub struct Time(i64);
+
+impl Time {
+    #[inline]
+    pub fn nanos_since_epoch(self) -> i64 {
+        self.0
+    }
+}
+
 #[derive(Clone, PartialEq, Eq)]
 pub struct PythonVersion {
     /// e.g. 3
@@ -753,6 +768,7 @@ impl SizeBytes for StoreInfo {
             store_id,
             cloned_from: _,
             store_source,
+            started: _,
             store_version,
         } = self;
 

crates/store/re_protos/src/v1alpha1/rerun.common.v1alpha1.ext.rs

@@ -653,6 +653,7 @@ impl TryFrom<crate::log_msg::v1alpha1::StoreInfo> for re_log_types::StoreInfo {
             store_id,
             cloned_from: None,
             store_source,
+            started: None,
             store_version,
         })
     }
@@ -1152,6 +1153,7 @@ mod tests {
                 patch: 0,
                 suffix: "a".to_owned(),
             }),
+            started: None,
             store_version: None,
         };
         let proto_store_info: crate::log_msg::v1alpha1::StoreInfo = store_info.clone().into();
@@ -1176,6 +1178,7 @@ mod tests {
                     patch: 0,
                     suffix: "a".to_owned(),
                 }),
+                started: None,
                 store_version: None,
             },
         };

crates/top/re_sdk/src/lib.rs

@@ -217,6 +217,7 @@ pub fn new_store_info(
             rustc_version: env!("RE_BUILD_RUSTC_VERSION").into(),
             llvm_version: env!("RE_BUILD_LLVM_VERSION").into(),
         },
+        started: None,
         store_version: Some(re_build_info::CrateVersion::LOCAL),
     }
 }