From 8e584c9e617d2317dcf2ae3c7f3d84db3b4d6154 Mon Sep 17 00:00:00 2001
From: Jeremy Wall <jeremy@marzhillstudios.com>
Date: Fri, 7 Jun 2024 10:36:36 -0400
Subject: [PATCH] logs: add some minimal logging for debugging

---
 src/main.rs | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)

diff --git a/src/main.rs b/src/main.rs
index 26d8a2c..5c93c20 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -129,6 +129,7 @@ async fn main() -> anyhow::Result<ExitCode> {
                 match out_result {
                     Ok(n) => {
                         if !check_for_stale_handle(&stdout_writer)? {
+                            eprintln!("Detected closed stdout handle");
                             stdout_writer.flush().await?;
                             stdout_writer = File::options().append(true).create(true).open(stdout_path).await?;
                         }
@@ -150,6 +151,7 @@ async fn main() -> anyhow::Result<ExitCode> {
                 match err_result {
                     Ok(n) => {
                         if !check_for_stale_handle(&stderr_writer)? {
+                            eprintln!("Detected closed stderr handle");
                             stderr_writer.flush().await?;
                             stderr_writer = File::options().append(true).create(true).open(stderr_path).await?;
                         }
@@ -167,17 +169,18 @@ async fn main() -> anyhow::Result<ExitCode> {
                 }
             }
             _ = rotation_signal_stream.recv() => {
-                // on sighub sync and reopen our files
+                // on sighup sync and reopen our files
                 // NOTE(zaphar): This will cause the previously opened handles to get
                 // dropped which will cause them to close assuming all the io has finished. This is why we sync
                 // before reopening the files.
-                // TODO(zaphar): These should do something in the event of an error
+                eprintln!("got rotation signal");
                 _ = stderr_writer.sync_all().await;
                 _ = stdout_writer.sync_all().await;
                 stderr_writer = File::options().append(true).create(true).open(stderr_path).await?;
                 stdout_writer = File::options().append(true).create(true).open(stdout_path).await?;
             }
             _ = sigterm_stream.recv() => {
+                eprintln!("got sigterm signal");
                 // NOTE(zaphar): This is a giant hack.
                 // If https://github.com/tokio-rs/tokio/issues/3379 ever get's implemented it will become
                 // unnecessary.
@@ -193,6 +196,7 @@ async fn main() -> anyhow::Result<ExitCode> {
                 }
             }
             _ = sigquit_stream.recv() => {
+                eprintln!("got sigquit signal");
                 // NOTE(zaphar): This is a giant hack.
                 // If https://github.com/tokio-rs/tokio/issues/3379 ever get's implemented it will become
                 // unnecessary.
@@ -208,6 +212,7 @@ async fn main() -> anyhow::Result<ExitCode> {
                 }
             }
             _ = sigint_stream.recv() => {
+                eprintln!("got sigint signal");
                 // NOTE(zaphar): This is a giant hack.
                 // If https://github.com/tokio-rs/tokio/issues/3379 ever get's implemented it will become
                 // unnecessary.