[EasyBugsnag] Session tracking for laravel queue job (#655)

packages/EasyBugsnag/src/Bridge/Laravel/EasyBugsnagServiceProvider.php

@@ -11,6 +11,7 @@
 use EonX\EasyBugsnag\Bridge\Laravel\Session\SessionTrackingConfigurator;
 use EonX\EasyBugsnag\Bridge\Laravel\Session\SessionTrackingListener;
 use EonX\EasyBugsnag\Bridge\Laravel\Session\SessionTrackingMiddleware;
+use EonX\EasyBugsnag\Bridge\Laravel\Session\SessionTrackingQueueListener;
 use EonX\EasyBugsnag\ClientFactory;
 use EonX\EasyBugsnag\Configurators\AwsEcsFargateConfigurator;
 use EonX\EasyBugsnag\Configurators\BasicsConfigurator;
@@ -19,6 +20,7 @@
 use EonX\EasyBugsnag\Session\SessionTracker;
 use EonX\EasyBugsnag\Shutdown\ShutdownStrategy;
 use Illuminate\Contracts\Container\Container;
+use Illuminate\Queue\Events\JobProcessing;
 use Illuminate\Routing\Events\RouteMatched;
 use Illuminate\Support\ServiceProvider;
 use Illuminate\Support\Str;
@@ -165,7 +167,15 @@ static function (Container $app): SessionTrackingConfigurator {
                 $this->app->middleware([SessionTrackingMiddleware::class]);
             }
 
-            $this->app->make('events')->listen(RouteMatched::class, SessionTrackingListener::class);
+            $events = $this->app->make('events');
+
+            $this->app->singleton(SessionTrackingListener::class);
+            $events->listen(RouteMatched::class, SessionTrackingListener::class);
+
+            if (\config('easy-bugsnag.session_tracking.queue_job_count_for_sessions', false)) {
+                $this->app->singleton(SessionTrackingQueueListener::class);
+                $events->listen(JobProcessing::class, SessionTrackingQueueListener::class);
+            }
         }
     }
 

packages/EasyBugsnag/src/Bridge/Laravel/Session/SessionTrackingQueueListener.php

@@ -0,0 +1,43 @@
+<?php
+
+declare(strict_types=1);
+
+namespace EonX\EasyBugsnag\Bridge\Laravel\Session;
+
+use Bugsnag\Client;
+use Illuminate\Queue\Events\JobProcessing;
+
+final class SessionTrackingQueueListener
+{
+    /**
+     * @var \Bugsnag\Client
+     */
+    private $client;
+
+    /**
+     * @var bool
+     */
+    private $configured = false;
+
+    public function __construct(Client $client)
+    {
+        $this->client = $client;
+    }
+
+    public function handle(JobProcessing $event): void
+    {
+        $sessionTracker = $this->client->getSessionTracker();
+        $sessionTracker->startSession();
+
+        if ($this->configured) {
+            return;
+        }
+
+        // Make sure sessions are sent when worker stops
+        \register_shutdown_function(static function () use ($sessionTracker): void {
+            $sessionTracker->sendSessions();
+        });
+
+        $this->configured = true;
+    }
+}

packages/EasyBugsnag/src/Bridge/Laravel/config/easy-bugsnag.php

@@ -69,7 +69,12 @@
         /**
          * Delimiter used in Regex to resolve excluded URLs.
          */
-        'session_tracking_exclude_urls_delimiter' => '#'
+        'session_tracking_exclude_urls_delimiter' => '#',
+
+        /**
+         * Enable/Disable session tracking for queue jobs.
+         */
+        'queue_job_count_for_sessions' => false,
     ],
 
     /**