feat: add logging for event processing in ProcessAggregatedEvents and ProcessWebhookEvent

Author: tanhongit

src/Jobs/ProcessAggregatedEvents.php

@@ -9,6 +9,7 @@
 use Illuminate\Queue\InteractsWithQueue;
 use Illuminate\Queue\SerializesModels;
 use Illuminate\Support\Facades\Cache;
+use Illuminate\Support\Facades\Log;
 
 class ProcessAggregatedEvents implements ShouldQueue
 {
@@ -42,16 +43,18 @@ public function handle(): void
 
             return;
         }
-
+        Log::info('ProcessAggregatedEvents: Event message: '.json_encode($eventMessages));
         $message = $this->aggregateMessages($eventMessages);
         Cache::forget($commentAggregationCacheKey);
         $author = Cache::pull($commentAggregationCacheKey.'_author', '');
 
+        Log::info('ProcessAggregatedEvents: Author: '.json_encode($author));
         $message .= '\n\n'.view(
             'github-project::md.shared.author',
             ['name' => $author['name'], 'html_url' => $author['html_url']]
         )->render();
 
+        Log::info('ProcessAggregatedEvents: Message: '.$message);
         $githubService = new GithubService;
         $githubService->commentOnNode($this->nodeId, $message);
     }

src/Jobs/ProcessWebhookEvent.php

@@ -8,6 +8,7 @@
 use Illuminate\Queue\InteractsWithQueue;
 use Illuminate\Queue\SerializesModels;
 use Illuminate\Support\Facades\Cache;
+use Illuminate\Support\Facades\Log;
 
 class ProcessWebhookEvent implements ShouldQueue
 {
@@ -55,7 +56,9 @@ public function handle(): void
                 now()->addSeconds($commentAggregationTime)
             );
         }
-
+        Log::info('Event message count: '.count($eventMessages));
+        Log::info('Event message: '.json_encode($eventMessages));
+        Log::info('Event author: '.json_encode(Cache::get($commentAggregationCacheKey.'_author')));
         if (count($eventMessages) === 1) {
             ProcessAggregatedEvents::dispatch($nodeId)->delay(now()->addSeconds($commentAggregationTime));
         }