[11.x] Adds support to allow specifying number of days to keep failed jobs in DynamoDB

src/Illuminate/Queue/Failed/DynamoDbFailedJobProvider.php

@@ -32,19 +32,28 @@ class DynamoDbFailedJobProvider implements FailedJobProviderInterface
      */
     protected $table;
 
+    /**
+     * The number of days a failed job should be retained.
+     *
+     * @var string
+     */
+    protected $expireDays;
+
     /**
      * Create a new DynamoDb failed job provider.
      *
      * @param  \Aws\DynamoDb\DynamoDbClient  $dynamo
      * @param  string  $applicationName
      * @param  string  $table
+     * @param  string  $expireDays
      * @return void
      */
-    public function __construct(DynamoDbClient $dynamo, $applicationName, $table)
+    public function __construct(DynamoDbClient $dynamo, $applicationName, $table, $expireDays)
     {
         $this->table = $table;
         $this->dynamo = $dynamo;
         $this->applicationName = $applicationName;
+        $this->expireDays = (int) $expireDays;
     }
 
     /**
@@ -72,7 +81,7 @@ public function log($connection, $queue, $payload, $exception)
                 'payload' => ['S' => $payload],
                 'exception' => ['S' => (string) $exception],
                 'failed_at' => ['N' => (string) $failedAt->getTimestamp()],
-                'expires_at' => ['N' => (string) $failedAt->addDays(3)->getTimestamp()],
+                'expires_at' => ['N' => (string) $failedAt->addDays($this->expireDays)->getTimestamp()],
             ],
         ]);
 

src/Illuminate/Queue/QueueServiceProvider.php

@@ -324,7 +324,8 @@ protected function dynamoFailedJobProvider($config)
         return new DynamoDbFailedJobProvider(
             new DynamoDbClient($dynamoConfig),
             $this->app['config']['app.name'],
-            $config['table']
+            $config['table'],
+            $config['expire_days'] ?? '3'
         );
     }
 

tests/Queue/DynamoDbFailedJobProviderTest.php

@@ -47,7 +47,7 @@ public function testCanProperlyLogFailedJob()
             ],
         ]);
 
-        $provider = new DynamoDbFailedJobProvider($dynamoDbClient, 'application', 'table');
+        $provider = new DynamoDbFailedJobProvider($dynamoDbClient, 'application', 'table', '3');
 
         $provider->log('connection', 'queue', json_encode(['uuid' => (string) $uuid]), $exception);
 
@@ -83,7 +83,7 @@ public function testCanRetrieveAllFailedJobs()
             ],
         ]);
 
-        $provider = new DynamoDbFailedJobProvider($dynamoDbClient, 'application', 'table');
+        $provider = new DynamoDbFailedJobProvider($dynamoDbClient, 'application', 'table', '3');
 
         $response = $provider->all();
 
@@ -124,7 +124,7 @@ public function testASingleJobCanBeFound()
             ],
         ]);
 
-        $provider = new DynamoDbFailedJobProvider($dynamoDbClient, 'application', 'table');
+        $provider = new DynamoDbFailedJobProvider($dynamoDbClient, 'application', 'table', '3');
 
         $response = $provider->find('id');
 
@@ -152,7 +152,7 @@ public function testNullIsReturnedIfJobNotFound()
             ],
         ])->andReturn([]);
 
-        $provider = new DynamoDbFailedJobProvider($dynamoDbClient, 'application', 'table');
+        $provider = new DynamoDbFailedJobProvider($dynamoDbClient, 'application', 'table', '3');
 
         $response = $provider->find('id');
 
@@ -171,7 +171,7 @@ public function testJobsCanBeDeleted()
             ],
         ])->andReturn([]);
 
-        $provider = new DynamoDbFailedJobProvider($dynamoDbClient, 'application', 'table');
+        $provider = new DynamoDbFailedJobProvider($dynamoDbClient, 'application', 'table', '3');
 
         $provider->forget('id');
     }