Display chat time stamps in configured time zone

cove/src/euph/small_message.rs

@@ -4,6 +4,7 @@ use crossterm::style::Stylize;
 use euphoxide::api::{MessageId, Snowflake, Time};
 use time::OffsetDateTime;
 use toss::{Style, Styled};
+use tz::TimeZone;
 
 use crate::store::Msg;
 use crate::ui::ChatMsg;
@@ -207,6 +208,7 @@ pub struct SmallMessage {
     pub id: MessageId,
     pub parent: Option<MessageId>,
     pub time: Time,
+    pub time_zone: &'static TimeZone,
     pub nick: String,
     pub content: String,
     pub seen: bool,
@@ -270,8 +272,8 @@ impl Msg for SmallMessage {
 }
 
 impl ChatMsg for SmallMessage {
-    fn time(&self) -> OffsetDateTime {
+    fn time(&self) -> Option<OffsetDateTime> {
-        self.time.0
+        crate::util::convert_to_time_zone(self.time_zone, self.time.0)
     }
 
     fn styled(&self) -> (Styled, Styled) {

cove/src/logger.rs

@@ -42,8 +42,8 @@ impl Msg for LogMsg {
 }
 
 impl ChatMsg for LogMsg {
-    fn time(&self) -> OffsetDateTime {
+    fn time(&self) -> Option<OffsetDateTime> {
-        self.time
+        Some(self.time)
     }
 
     fn styled(&self) -> (Styled, Styled) {

cove/src/main.rs

@@ -131,6 +131,7 @@ fn update_config_with_args(config: &mut Config, args: &Args) {
 
 fn open_vault(config: &Config, dirs: &ProjectDirs) -> anyhow::Result<Vault> {
     let time_zone = util::load_time_zone(config.time_zone_ref())?;
+    let time_zone = Box::leak(Box::new(time_zone));
 
     let vault = if config.ephemeral {
         vault::launch_in_memory(time_zone)?

cove/src/ui/chat.rs

@@ -18,7 +18,7 @@ use self::tree::TreeViewState;
 use super::UiError;
 
 pub trait ChatMsg {
-    fn time(&self) -> OffsetDateTime;
+    fn time(&self) -> Option<OffsetDateTime>;
     fn styled(&self) -> (Styled, Styled);
     fn edit(nick: &str, content: &str) -> (Styled, Styled);
     fn pseudo(nick: &str, content: &str) -> (Styled, Styled);

cove/src/ui/chat/tree/widgets.rs

@@ -58,7 +58,7 @@ pub fn msg<M: Msg + ChatMsg>(
 
     Join5::horizontal(
         Seen::new(msg.seen()).segment().with_fixed(true),
-        Time::new(Some(msg.time()), style_time(highlighted))
+        Time::new(msg.time(), style_time(highlighted))
             .padding()
             .with_right(1)
             .with_stretch(true)

cove/src/util.rs

@@ -1,6 +1,7 @@
 use std::convert::Infallible;
 use std::env;
 
+use time::{OffsetDateTime, UtcOffset};
 use tz::{TimeZone, TzError};
 
 pub trait InfallibleExt {
@@ -35,3 +36,14 @@ pub fn load_time_zone(tz_string: Option<&str>) -> Result<TimeZone, TzError> {
         Some(tz_string) => TimeZone::from_posix_tz(tz_string),
     }
 }
+
+pub fn convert_to_time_zone(tz: &TimeZone, time: OffsetDateTime) -> Option<OffsetDateTime> {
+    let utc_offset_in_seconds = tz
+        .find_local_time_type(time.unix_timestamp())
+        .ok()?
+        .ut_offset();
+
+    let utc_offset = UtcOffset::from_whole_seconds(utc_offset_in_seconds).ok()?;
+
+    Some(time.to_offset(utc_offset))
+}

cove/src/vault.rs

@@ -15,7 +15,7 @@ pub use self::euph::{EuphRoomVault, EuphVault, RoomIdentifier};
 #[derive(Debug, Clone)]
 pub struct Vault {
     tokio_vault: TokioVault,
-    time_zone: TimeZone,
+    time_zone: &'static TimeZone,
     ephemeral: bool,
 }
 
@@ -50,7 +50,7 @@ impl Vault {
 
 fn launch_from_connection(
     conn: Connection,
-    time_zone: TimeZone,
+    time_zone: &'static TimeZone,
     ephemeral: bool,
 ) -> rusqlite::Result<Vault> {
     conn.pragma_update(None, "foreign_keys", true)?;
@@ -64,7 +64,7 @@ fn launch_from_connection(
     })
 }
 
-pub fn launch(path: &Path, time_zone: TimeZone) -> rusqlite::Result<Vault> {
+pub fn launch(path: &Path, time_zone: &'static TimeZone) -> rusqlite::Result<Vault> {
     // If this fails, rusqlite will complain about not being able to open the db
     // file, which saves me from adding a separate vault error type.
     let _ = fs::create_dir_all(path.parent().expect("path to file"));
@@ -82,7 +82,7 @@ pub fn launch(path: &Path, time_zone: TimeZone) -> rusqlite::Result<Vault> {
     launch_from_connection(conn, time_zone, false)
 }
 
-pub fn launch_in_memory(time_zone: TimeZone) -> rusqlite::Result<Vault> {
+pub fn launch_in_memory(time_zone: &'static TimeZone) -> rusqlite::Result<Vault> {
     let conn = Connection::open_in_memory()?;
     launch_from_connection(conn, time_zone, true)
 }

cove/src/vault/euph.rs

@@ -239,6 +239,8 @@ macro_rules! euph_room_vault_actions {
         $(
             struct $struct {
                 room: RoomIdentifier,
+                #[allow(unused)]
+                time_zone: &'static tz::TimeZone,
                 $( $arg: $arg_ty, )*
             }
         )*
@@ -248,6 +250,7 @@ macro_rules! euph_room_vault_actions {
                 pub async fn $fn(&self, $( $arg: $arg_ty, )* ) -> Result<$res, vault::tokio::Error<rusqlite::Error>> {
                     self.vault.vault.tokio_vault.execute($struct {
                         room: self.room.clone(),
+                        time_zone: self.vault.vault.time_zone,
                         $( $arg, )*
                     }).await
                 }
@@ -607,6 +610,7 @@ impl Action for GetMsg {
                         id: MessageId(row.get::<_, WSnowflake>(0)?.0),
                         parent: row.get::<_, Option<WSnowflake>>(1)?.map(|s| MessageId(s.0)),
                         time: row.get::<_, WTime>(2)?.0,
+                        time_zone: self.time_zone,
                         nick: row.get(3)?,
                         content: row.get(4)?,
                         seen: row.get(5)?,
@@ -700,6 +704,7 @@ impl Action for GetTree {
                         id: MessageId(row.get::<_, WSnowflake>(0)?.0),
                         parent: row.get::<_, Option<WSnowflake>>(1)?.map(|s| MessageId(s.0)),
                         time: row.get::<_, WTime>(2)?.0,
+                        time_zone: self.time_zone,
                         nick: row.get(3)?,
                         content: row.get(4)?,
                         seen: row.get(5)?,