From 421848f437c6cddb4d38ea1f70d82125fafd485e Mon Sep 17 00:00:00 2001
From: Raphiiko <iam@raphii.co>
Date: Sun, 27 Oct 2024 11:30:21 +0100
Subject: [PATCH] Fixed ambiguously timed VRChat logs produced during DST end
 from crashing OyasumiVR

---
 CHANGELOG.md                       |  6 ++++++
 src-core/src/vrc_log_parser/mod.rs | 31 +++++++++++++++++++++++-------
 2 files changed, 30 insertions(+), 7 deletions(-)

diff --git a/CHANGELOG.md b/CHANGELOG.md
index 416f899b..ad18052c 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -5,6 +5,12 @@ All notable changes to this project will be documented in this file.
 The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
+## [1.14.4]
+
+### Fixed
+
+- OyasumiVR crashing when parsing VRChat logs produced during the two hours of DST ending.
+
 ## [1.14.3]
 
 ### Changed
diff --git a/src-core/src/vrc_log_parser/mod.rs b/src-core/src/vrc_log_parser/mod.rs
index a2a3b55a..79be1a3e 100644
--- a/src-core/src/vrc_log_parser/mod.rs
+++ b/src-core/src/vrc_log_parser/mod.rs
@@ -58,10 +58,15 @@ fn get_latest_log_path() -> Option<String> {
         .map(|entry| String::from(entry.path.to_str().unwrap()))
 }
 
-fn parse_datetime_from_line(line: String) -> u64 {
+fn parse_datetime_from_line(line: String) -> Option<u64> {
     let localtime = NaiveDateTime::parse_from_str(&line[0..19], "%Y.%m.%d %H:%M:%S").unwrap();
-    let time = Local.from_local_datetime(&localtime).unwrap();
-    time.timestamp_millis() as u64
+    // In the case of a DST rollback, we pick the latest possible time
+    // During this hour, the logs will still be parsed in order, but their timestamps will be out of order.
+    let time = Local.from_local_datetime(&localtime).latest();
+    match time {
+        Some(v) => Some(v.timestamp_millis() as u64),
+        None => return None,
+    }
 }
 
 async fn process_log_line(line: String, initial_load: bool) {
@@ -81,8 +86,12 @@ async fn parse_on_player_joined(line: String, initial_load: bool) -> bool {
             return true;
         }
         let display_name = line[offset..].to_string();
+        let time = match parse_datetime_from_line(line) {
+            Some(v) => v,
+            None => return true,
+        };
         let event = VRCLogEvent {
-            time: parse_datetime_from_line(line),
+            time: time,
             event: String::from("OnPlayerJoined"),
             data: display_name,
             initial_load,
@@ -112,8 +121,12 @@ async fn parse_on_player_left(line: String, initial_load: bool) -> bool {
             return true;
         }
         let display_name = line[offset..].to_string();
+        let time = match parse_datetime_from_line(line) {
+            Some(v) => v,
+            None => return true,
+        };
         let event = VRCLogEvent {
-            time: parse_datetime_from_line(line),
+            time: time,
             event: String::from("OnPlayerLeft"),
             data: display_name,
             initial_load,
@@ -143,8 +156,12 @@ async fn parse_on_location_change(line: String, initial_load: bool) -> bool {
             return true;
         }
         let instance_id = line[offset..].to_string();
+        let time = match parse_datetime_from_line(line) {
+            Some(v) => v,
+            None => return true,
+        };
         let event = VRCLogEvent {
-            time: parse_datetime_from_line(line),
+            time: time,
             event: String::from("OnLocationChange"),
             data: instance_id,
             initial_load,
@@ -203,7 +220,7 @@ fn start_log_watch_task(path: String) -> CancellationToken {
                         initial_load: true,
                     },
                 )
-                    .await;
+                .await;
                 first_run = false;
             }
         }