Merge pull request Sammyjo20#3 from amaelftah/support-multiple-db-con…

…nection

Support multiple db connection

config/haystack.php

@@ -71,4 +71,15 @@
 
     'keep_finished_haystacks_for_days' => 1,
 
+     /*
+    |--------------------------------------------------------------------------
+    | Default Database Connection Name
+    |--------------------------------------------------------------------------
+    |
+    | Here you may specify which database connectionsyou wish
+    | to use to store haystack jobs .
+    |
+    */
+
+    'db_connection' => env('DB_CONNECTION'),
 ];

src/Models/Haystack.php

@@ -128,4 +128,14 @@ public function getFinishedAttribute(): bool
     {
         return $this->finished_at instanceof CarbonImmutable;
     }
+
+     /**
+     * Get the current connection name for the model.
+     *
+     * @return string|null
+     */
+    public function getConnectionName()
+    {
+        return config('haystack.db_connection');
+    }
 }

src/Models/HaystackBale.php

@@ -71,4 +71,14 @@ public function configuredJob(): StackableJob
 
         return $job;
     }
+
+    /**
+     * Get the current connection name for the model.
+     *
+     * @return string|null
+     */
+    public function getConnectionName()
+    {
+        return config('haystack.db_connection');
+    }
 }

src/Models/HaystackData.php

@@ -72,4 +72,14 @@ public function getValueAttribute($value): mixed
 
         return $this->castAttribute('value', $value);
     }
+
+    /**
+     * Get the current connection name for the model.
+     *
+     * @return string|null
+     */
+    public function getConnectionName()
+    {
+        return config('haystack.db_connection');
+    }
 }

tests/TestCase.php

@@ -33,6 +33,7 @@ protected function getApplicationTimezone($app)
 
     public function getEnvironmentSetUp($app)
     {
+        config()->set('haystack.db_connection', 'testing');
         config()->set('database.default', 'testing');
         config()->set('database.connections.testing.foreign_key_constraints', true);
         config()->set('haystack.process_automatically', false);