Initial commit. Not ready yet.

.gitignore

@@ -0,0 +1,4 @@
+vendor
+composer.lock
+.bashrc
+.idea

composer.json

@@ -0,0 +1,30 @@
+{
+  "name": "cyppe/laravel-batch-jobs-redis-driver",
+  "description": "Redis driver for handling batch jobs in Laravel instead of default mysql table job_batches",
+  "autoload": {
+    "psr-4": {
+      "Cyppe\\LaravelBatchJobsRedisDriver\\": "src/"
+    }
+  },
+  "authors": [
+    {
+      "name": "cyppe",
+      "email": "[email protected]"
+    }
+  ],
+  "require": {
+    "php": "^8.0",
+    "illuminate/support": "^10.0",
+    "illuminate/bus": "^10.0",
+    "illuminate/database": "^10.0",
+    "illuminate/redis": "^10.0",
+    "ext-redis": "*"
+  },
+  "extra": {
+    "laravel": {
+      "providers": [
+        "Cyppe\\LaravelBatchJobsRedisDriver\\CustomBusServiceProvider"
+      ]
+    }
+  }
+}

src/CustomBusServiceProvider.php

@@ -0,0 +1,28 @@
+<?php
+
+namespace Cyppe\LaravelBatchJobsRedisDriver;
+
+use Illuminate\Bus\BatchRepository;
+use Illuminate\Bus\BusServiceProvider;
+use Cyppe\LaravelBatchJobsRedisDriver\Repositories\RedisBatchRepository;
+
+class CustomBusServiceProvider extends BusServiceProvider
+{
+    protected function registerBatchServices()
+    {
+        $this->app->singleton(
+            BatchRepository::class, function ( $app ) {
+            $driver = config( 'queue.batching.database' );
+            if ( $driver === 'redis' ) {
+                $factory = $app->make( \Illuminate\Bus\BatchFactory::class );
+                return new RedisBatchRepository(
+                    $factory
+                );
+            }
+
+            // Fallback to parent method if not using Redis
+            return parent::registerBatchServices();
+        }
+        );
+    }
+}