fix: backport check failed log storage (#2364)

* fix: backport check failed log storage

Backport #2357 to L8

Co-Authored-By: Rob Brain <10143910+robjbrain@users.noreply.github.com>

* chore: update changelog

Co-Authored-By: Rob Brain <10143910+robjbrain@users.noreply.github.com>

Co-authored-by: Rob Brain <10143910+robjbrain@users.noreply.github.com>

Author: divine

CHANGELOG.md

@@ -6,6 +6,9 @@ All notable changes to this project will be documented in this file.
 ### Added
 - Support for cursor pagination [#2358](https://github.com/jenssegers/laravel-mongodb/pull/2358) by [@Jeroenwv](https://github.com/Jeroenwv).
 
+### Fixed
+- Backport check if queue service is disabled [#2357](https://github.com/jenssegers/laravel-mongodb/pull/2357) by [@robjbrain](https://github.com/robjbrain).
+
 ## [3.8.4] - 2021-05-27
 
 ### Fixed

src/MongodbQueueServiceProvider.php

@@ -2,23 +2,46 @@
 
 namespace Jenssegers\Mongodb;
 
+use Illuminate\Queue\Failed\NullFailedJobProvider;
 use Illuminate\Queue\QueueServiceProvider;
 use Jenssegers\Mongodb\Queue\Failed\MongoFailedJobProvider;
 
 class MongodbQueueServiceProvider extends QueueServiceProvider
 {
     /**
-     * @inheritdoc
+     * Register the failed job services.
+     *
+     * @return void
      */
     protected function registerFailedJobServices()
     {
-        // Add compatible queue failer if mongodb is configured.
-        if ($this->app['db']->connection(config('queue.failed.database'))->getDriverName() == 'mongodb') {
-            $this->app->singleton('queue.failer', function ($app) {
-                return new MongoFailedJobProvider($app['db'], config('queue.failed.database'), config('queue.failed.table'));
-            });
-        } else {
-            parent::registerFailedJobServices();
-        }
+        $this->app->singleton('queue.failer', function ($app) {
+            $config = $app['config']['queue.failed'];
+
+            if (array_key_exists('driver', $config) &&
+                (is_null($config['driver']) || $config['driver'] === 'null')) {
+                return new NullFailedJobProvider;
+            }
+
+            if (isset($config['driver']) && $config['driver'] === 'mongodb') {
+                return $this->mongoFailedJobProvider($config);
+            } elseif (isset($config['driver']) && $config['driver'] === 'dynamodb') {
+                return $this->dynamoFailedJobProvider($config);
+            } elseif (isset($config['driver']) && $config['driver'] === 'database-uuids') {
+                return $this->databaseUuidFailedJobProvider($config);
+            } elseif (isset($config['table'])) {
+                return $this->databaseFailedJobProvider($config);
+            } else {
+                return new NullFailedJobProvider;
+            }
+        });
+    }
+
+    /**
+     * Create a new MongoDB failed job provider.
+     */
+    protected function mongoFailedJobProvider(array $config): MongoFailedJobProvider
+    {
+        return new MongoFailedJobProvider($this->app['db'], $config['database'], $config['table']);
     }
 }

tests/TestCase.php

@@ -68,5 +68,6 @@ protected function getEnvironmentSetUp($app)
             'expire' => 60,
         ]);
         $app['config']->set('queue.failed.database', 'mongodb2');
+        $app['config']->set('queue.failed.driver', 'mongodb');
     }
 }

tests/config/queue.php

@@ -17,6 +17,7 @@
 
     'failed' => [
         'database' => env('MONGO_DATABASE'),
+        'driver' => 'mongodb',
         'table' => 'failed_jobs',
     ],