From a2e3a94f11e952f9874fdb61283cbce5be4fbe26 Mon Sep 17 00:00:00 2001
From: "Abdulmhsen B. A. A." <admin@arabcoders.org>
Date: Mon, 19 Aug 2024 15:04:33 +0300
Subject: [PATCH] Updated some events log messages to be more clear.

---
 src/Listeners/ProcessProgressEvent.php | 12 +++++++++++-
 src/Listeners/ProcessPushEvent.php     |  9 ++++++++-
 2 files changed, 19 insertions(+), 2 deletions(-)

diff --git a/src/Listeners/ProcessProgressEvent.php b/src/Listeners/ProcessProgressEvent.php
index 46c71719..d3c2e7e2 100644
--- a/src/Listeners/ProcessProgressEvent.php
+++ b/src/Listeners/ProcessProgressEvent.php
@@ -178,6 +178,15 @@ final readonly class ProcessProgressEvent
             return $e;
         }
 
+        $progress = formatDuration($item->getPlayProgress());
+
+        $writer(Level::Notice, "Processing '{id}' -  '{via}: {title}' watch progress '{progress}' event.", [
+            'id' => $item->id,
+            'via' => $item->via,
+            'title' => $item->getName(),
+            'progress' => $progress,
+        ]);
+
         foreach ($this->queue->getQueue() as $response) {
             $context = ag($response->getInfo('user_data'), 'context', []);
 
@@ -204,8 +213,9 @@ final readonly class ProcessProgressEvent
                     continue;
                 }
 
-                $writer(Level::Notice, "Updated '{backend}: {item.title}' watch progress.", [
+                $writer(Level::Notice, "Updated '{backend}: {item.title}' watch progress to '{progress}'.", [
                     ...$context,
+                    'progress' => $progress,
                     'status_code' => $response->getStatusCode(),
                 ]);
             } catch (Throwable $e) {
diff --git a/src/Listeners/ProcessPushEvent.php b/src/Listeners/ProcessPushEvent.php
index b766c8e1..9dc189e2 100644
--- a/src/Listeners/ProcessPushEvent.php
+++ b/src/Listeners/ProcessPushEvent.php
@@ -141,6 +141,13 @@ final readonly class ProcessPushEvent
             return $e;
         }
 
+        $writer(Level::Notice, "Processing '{id}' -  '{via}: {title}' '{state}' push event.", [
+            'id' => $item->id,
+            'via' => $item->via,
+            'title' => $item->getName(),
+            'state' => $item->isWatched() ? 'watched' : 'unwatched',
+        ]);
+
         foreach ($this->queue->getQueue() as $response) {
             $context = ag($response->getInfo('user_data'), 'context', []);
 
@@ -154,7 +161,7 @@ final readonly class ProcessPushEvent
                     continue;
                 }
 
-                $writer(Level::Notice, "Marked '{backend}: {item.title}' as '{play_state}'.", $context);
+                $writer(Level::Notice, "Updated '{backend}: {item.title}' watch state to '{play_state}'.", $context);
             } catch (Throwable $e) {
                 $writer(
                     Level::Error,