PHPORM-231 Remove MongoFailedJobProvider

Author: GromNaN

src/MongoDBQueueServiceProvider.php

@@ -876,11 +876,11 @@ public function delete($id = null)
         $wheres  = $this->aliasIdForQuery($wheres);
         $options = $this->inheritConnectionOptions();
 
-        if (is_int($this->limit)) {
-            if ($this->limit !== 1) {
-                throw new LogicException(sprintf('Delete limit can be 1 or null (unlimited). Got %d', $this->limit));
-            }
-
+        /**
+         * Ignore the limit if it is set to more than 1, as it is not supported by the deleteMany method.
+         * Required for {@see DatabaseFailedJobProvider::prune()}
+         */
+        if ($this->limit === 1) {
             $result = $this->collection->deleteOne($wheres, $options);
         } else {
             $result = $this->collection->deleteMany($wheres, $options);

src/Query/Builder.php

@@ -2,19 +2,22 @@
 
 namespace MongoDB\Laravel\Tests\Queue\Failed;
 
+use Illuminate\Queue\Failed\DatabaseFailedJobProvider;
 use Illuminate\Support\Facades\Date;
 use Illuminate\Support\Facades\DB;
 use MongoDB\BSON\ObjectId;
 use MongoDB\BSON\UTCDateTime;
-use MongoDB\Laravel\Queue\Failed\MongoFailedJobProvider;
 use MongoDB\Laravel\Tests\TestCase;
 use OutOfBoundsException;
 
 use function array_map;
 use function range;
 use function sprintf;
 
-class MongoFailedJobProviderTest extends TestCase
+/**
+ * Ensure the Laravel class {@see DatabaseFailedJobProvider} works with a MongoDB connection.
+ */
+class DatabaseFailedJobProviderTest extends TestCase
 {
     public function setUp(): void
     {
@@ -57,8 +60,7 @@ public function testLog(): void
         $this->assertSame('default', $inserted->queue);
         $this->assertSame('{"foo":"bar"}', $inserted->payload);
         $this->assertStringContainsString('OutOfBoundsException: This is the error', $inserted->exception);
-        $this->assertInstanceOf(ObjectId::class, $inserted->_id);
-        $this->assertSame((string) $inserted->_id, $inserted->id);
+        $this->assertInstanceOf(ObjectId::class, $inserted->id);
     }
 
     public function testCount(): void
@@ -143,8 +145,8 @@ public function testPrune(): void
         $this->assertEquals(3, $provider->count());
     }
 
-    private function getProvider(): MongoFailedJobProvider
+    private function getProvider(): DatabaseFailedJobProvider
     {
-        return new MongoFailedJobProvider(DB::getFacadeRoot(), '', 'failed_jobs');
+        return new DatabaseFailedJobProvider(DB::getFacadeRoot(), '', 'failed_jobs');
     }
 }

src/Queue/Failed/MongoFailedJobProvider.php

@@ -6,6 +6,7 @@
 
 use Carbon\Carbon;
 use Exception;
+use Illuminate\Queue\Failed\DatabaseFailedJobProvider;
 use Illuminate\Support\Facades\Config;
 use Illuminate\Support\Facades\Queue;
 use Illuminate\Support\Str;
@@ -87,7 +88,7 @@ public function testFailQueueJob(): void
     {
         $provider = app('queue.failer');
 
-        $this->assertInstanceOf(MongoFailedJobProvider::class, $provider);
+        $this->assertInstanceOf(DatabaseFailedJobProvider::class, $provider);
     }
 
     public function testFindFailJobNull(): void

tests/Queue/Failed/MongoFailedJobProviderTest.php renamed to tests/Queue/Failed/DatabaseFailedJobProviderTest.php

@@ -7,7 +7,6 @@
 use Illuminate\Auth\Passwords\PasswordResetServiceProvider as BasePasswordResetServiceProviderAlias;
 use Illuminate\Foundation\Application;
 use MongoDB\Laravel\Auth\PasswordResetServiceProvider;
-use MongoDB\Laravel\MongoDBQueueServiceProvider;
 use MongoDB\Laravel\MongoDBServiceProvider;
 use MongoDB\Laravel\Tests\Models\User;
 use MongoDB\Laravel\Validation\ValidationServiceProvider;
@@ -40,7 +39,6 @@ protected function getPackageProviders($app): array
     {
         return [
             MongoDBServiceProvider::class,
-            MongoDBQueueServiceProvider::class,
             PasswordResetServiceProvider::class,
             ValidationServiceProvider::class,
         ];