From 27c05f28ccf016fbe277270b8b9b2c0799555fd0 Mon Sep 17 00:00:00 2001
From: Abrar Ahmad <abrar.dev99@gmail.com>
Date: Wed, 23 Nov 2022 14:45:55 +0500
Subject: [PATCH] use tenant connection and central connection listener

---
 src/Listeners/UseCentralConnection.php | 24 ++++++++++++++++++++++++
 src/Listeners/UseTenantConnection.php  | 21 +++++++++++++++++++++
 2 files changed, 45 insertions(+)
 create mode 100644 src/Listeners/UseCentralConnection.php
 create mode 100644 src/Listeners/UseTenantConnection.php

diff --git a/src/Listeners/UseCentralConnection.php b/src/Listeners/UseCentralConnection.php
new file mode 100644
index 00000000..17d17863
--- /dev/null
+++ b/src/Listeners/UseCentralConnection.php
@@ -0,0 +1,24 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Stancl\Tenancy\Listeners;
+
+use Illuminate\Foundation\Application;
+use Stancl\Tenancy\Database\DatabaseManager;
+use Stancl\Tenancy\Events\Contracts\TenancyEvent;
+
+class UseCentralConnection
+{
+    public function __construct(
+        protected DatabaseManager $database,
+        protected Application $app
+    ) {
+    }
+
+    public function handle(TenancyEvent $event): void
+    {
+        $this->database->purgeTenantConnection();
+        $this->database->setDefaultConnection($this->app['config']->get('tenancy.database.central_connection'));
+    }
+}
diff --git a/src/Listeners/UseTenantConnection.php b/src/Listeners/UseTenantConnection.php
new file mode 100644
index 00000000..a4c12108
--- /dev/null
+++ b/src/Listeners/UseTenantConnection.php
@@ -0,0 +1,21 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Stancl\Tenancy\Listeners;
+
+use Stancl\Tenancy\Database\DatabaseManager;
+use Stancl\Tenancy\Events\Contracts\TenancyEvent;
+
+class UseTenantConnection
+{
+    public function __construct(
+        protected DatabaseManager $database,
+    ) {
+    }
+
+    public function handle(TenancyEvent $event): void
+    {
+        $this->database->setDefaultConnection('tenant');
+    }
+}