add composer.json file

Author: weezqyd

.gitignore

@@ -0,0 +1 @@
+/vendor/

composer.json

@@ -0,0 +1,21 @@
+{
+    "name": "elimuswift/connection-resolver",
+    "description": "A laravel package that dynamically switches between different database connections",
+    "type": "library",
+    "license": "MIT",
+    "authors": [
+        {
+            "name": "Master Weez",
+            "email": "wizqydy@gmail.com"
+        }
+    ],
+    "autoload": {
+        "psr-4": {
+            "Elimuswift\\Connection": "src/"
+        }
+    },
+    "minimum-stability": "dev",
+    "require": {
+        "laravel/framework": "~5.2"
+    }
+}

src/Connnection/Commands/HandleResolver.php

@@ -0,0 +1,54 @@
+<?php
+
+namespace Elimuswift\Connection\Commands;
+
+use Illuminate\Console\Command;
+use Elimuswift\Connection\SupervisorConfiguration;
+
+class HandleResolver extends Command
+{
+    /**
+     * The supervisor config repository
+     *
+     * @var object
+     **/
+    protected $supervisor;
+
+    /**
+     * The name and signature of the console command.
+     *
+     * @var string
+     */
+    protected $signature = 'db-resolver:make-worker {tenant : The tenant\'s id or uuid or domain}';
+
+    /**
+     * The console command description.
+     *
+     * @var string
+     */
+    protected $description = 'Create a supervisor config file for the specified tenant';
+
+    /**
+     * Create a new command instance.
+     *
+     * @return void
+     */
+    public function __construct(SupervisorConfiguration $config)
+    {
+        $this->supervisor = $config;
+        parent::__construct();
+    }
+
+    /**
+     * Execute the console command.
+     *
+     * @return mixed
+     */
+    public function handle()
+    {
+        $this->supervisor->getTenant($this->argument('tenant'));
+        $file = $this->supervisor->create();
+        $this->info("Config file $file created");
+
+    }
+}

src/Connnection/ConnectionServiceProvider.php

@@ -16,20 +16,29 @@ public function register(){
     }
 
     public function boot(Resolver $resolver){
-        $this->publishes(array(
-            realpath(__DIR__.'/../migrations') => database_path('migrations')
-        ));
-
-        //resolve tenant, catch PDOExceptions to prevent errors during migration
+        $this->mergeConfigFrom(
+            realpath(__DIR__ .'/../').'/config/elimuswift.php', 'elimuswift'
+        );
+         //resolve tenant, catch PDOExceptions to prevent errors during migration
         try {
-        	$resolver->resolveTenant();
+            $resolver->resolveTenant();
             if(!$resolver->isResolved()){
                 //abort('404');
             }
         } catch( \PDOException $e ) {
-            //abort('404');
+            throw new Exceptions\TenantNotResolvedException("Tenant not resolved or does not exist");
          }
 
+        $this->publishes(array(
+            realpath(__DIR__.'/../migrations') => database_path('migrations')
+        ),'migrations');
+
+         if ($this->app->runningInConsole()) {
+            $this->commands([
+                Commands\HandleResolver::class,
+            ]);
+        }
+
     }
 
 }

src/Connnection/Exceptions/TenantNotResolvedException.php

@@ -0,0 +1,14 @@
+<?php
+namespace Elimuswift\Connection\Exceptions;
+
+use Exception;
+
+/**
+ * Thrown when a tenant instance is not resolved
+ *
+ * @package Exception
+ * 
+ **/
+class TenantNotResolvedException  extends Exception
+{
+} // END class TenantNotResolvedException  

src/Connnection/SupervisorConfiguration.php

@@ -7,6 +7,8 @@
  * @package supervisor-config
  * @author The Weezqyd
  **/
+use Exception;
+
 class SupervisorConfiguration
 {
     /**
@@ -32,12 +34,6 @@ class SupervisorConfiguration
 stdout_logfile = {PATH}/storage/logs/worker.log';
 
 
-
-    public function __construct(Tenant $tenant)
-    {
-        $this->tenant = $tenant;
-    }
-
     /**
      * Set the config values
      *
@@ -63,10 +59,36 @@ private function set()
     public function create()
     {
         $configs = $this->set();
-        $this->save($configs);
-        return $configs;
+        return $this->save($configs);
+    
+    }
+    /**
+     * Set tenant object
+     *
+     * @return void
+     * @param object $tenant 
+     **/
+    private function setTenant(Tenant $tenant)
+    {
+        $this->tenant = $tenant;
     }
 
+    /**
+     * Get tenant from storage
+     *
+     * @return void
+     * @param mixed $tenant 
+     **/
+    public function getTenant($tenant)
+    {
+        $model = new Tenant();
+
+        $instance = $model->whereId($tenant)->orWhere('uuid',$tenant)->orWhere('domain', $tenant)->first();
+        if(is_null($instance))
+            throw new Exceptions\TenantNotResolvedException("Tenant not resolved or does not exist");
+            
+        $this->setTenant($instance);
+    }
     /**
      * undocumented function
      *
@@ -75,6 +97,8 @@ public function create()
      **/
     protected function save($conf)
     {
-        return file_put_contents(base_path('supervisor/elimuswift-'.$this->tenant->uuid.'.conf'), $conf);
+        $file = base_path('supervisor/elimuswift-'.$this->tenant->uuid.'.conf');
+        file_put_contents($file, $conf);
+        return $file;
     }
 } // END class SupervisorConfiguration

src/config/elimuswift.php

@@ -0,0 +1,7 @@
+<?php
+return [
+	'database'			=> [
+		'default'		=> 		null,
+		'tenant'		=>		'demo'
+	],
+];