Changed failed_at field as ISODate (#2607)

Author: BehroozBvk

src/Queue/Failed/MongoFailedJobProvider.php

@@ -7,6 +7,7 @@
 use Carbon\Carbon;
 use Exception;
 use Illuminate\Queue\Failed\DatabaseFailedJobProvider;
+use MongoDB\BSON\UTCDateTime;
 
 use function array_map;
 
@@ -28,7 +29,7 @@ public function log($connection, $queue, $payload, $exception)
             'connection' => $connection,
             'queue' => $queue,
             'payload' => $payload,
-            'failed_at' => Carbon::now()->getTimestamp(),
+            'failed_at' => new UTCDateTime(Carbon::now()),
             'exception' => (string) $exception,
         ]);
     }

tests/QueueTest.php

@@ -5,10 +5,12 @@
 namespace MongoDB\Laravel\Tests;
 
 use Carbon\Carbon;
+use Exception;
 use Illuminate\Support\Facades\Config;
 use Illuminate\Support\Facades\Queue;
 use Illuminate\Support\Str;
 use Mockery;
+use MongoDB\BSON\UTCDateTime;
 use MongoDB\Laravel\Queue\Failed\MongoFailedJobProvider;
 use MongoDB\Laravel\Queue\MongoJob;
 use MongoDB\Laravel\Queue\MongoQueue;
@@ -30,10 +32,7 @@ public function setUp(): void
     public function testQueueJobLifeCycle(): void
     {
         $uuid = Str::uuid();
-
-        Str::createUuidsUsing(function () use ($uuid) {
-            return $uuid;
-        });
+        Str::createUuidsUsing(fn () => $uuid);
 
         $id = Queue::push('test', ['action' => 'QueueJobLifeCycle'], 'test');
         $this->assertNotNull($id);
@@ -185,4 +184,19 @@ public function testQueueDeleteAndRelease(): void
 
         $mock->deleteAndRelease($queue, $job, $delay);
     }
+
+    public function testFailedJobLogging()
+    {
+        Carbon::setTestNow('2019-01-01 00:00:00');
+        $provider = app('queue.failer');
+        $provider->log('test_connection', 'test_queue', 'test_payload', new Exception('test_exception'));
+
+        $failedJob = Queue::getDatabase()->table(Config::get('queue.failed.table'))->first();
+
+        $this->assertSame('test_connection', $failedJob['connection']);
+        $this->assertSame('test_queue', $failedJob['queue']);
+        $this->assertSame('test_payload', $failedJob['payload']);
+        $this->assertEquals(new UTCDateTime(Carbon::now()), $failedJob['failed_at']);
+        $this->assertStringStartsWith('Exception: test_exception in ', $failedJob['exception']);
+    }
 }