Added multi database support

Author: plokko

composer.json

@@ -11,7 +11,7 @@
   "type": "library",
   "require": {
     "php": ">=7.1",
-    "plokko/firebase-php":"^0.2.4",
+    "plokko/firebase-php":"^0.3.0",
     "illuminate/support": ">=5.4.0"
   },
   "require-dev": {

config/laravel-firebase.php

@@ -4,7 +4,7 @@
     /**
      * Enables or disables write sync with firebase database (usefull for debugging purpuses)
      */
-    'read_only' => env('FIREBASEDB_READONLY',false),
+    'read_only' => env('FIREBASEDB_READONLY', false),
 
     /**
      * Firebase service account information, can be either:
@@ -32,4 +32,17 @@
      * @var string|null
      */
     'FCMInvalidTokenTriggerEvent' => null,
+
+    /**
+     * Specify wich Firebase Realtime DB URL to use
+     * @var string
+     */
+    'default_db' => 'default',
+    'firebasedb_urls' => [
+        /**
+         * Specify the Firebase Realtime DB URL, if not set https://<project_id>.firebaseio.com/ will be used
+         * @var string|null
+         */
+        'default' => rtrim(env('FIREBASEDB_URL', null), '/'),
+    ],
 ];

src/Channels/FcmNotificationChannel.php

@@ -17,9 +17,9 @@ function __construct()
      * @param  \Illuminate\Notifications\Notification  $notification
      * @return void
      */
-    public function send($notifiable,Notification $notification)
+    public function send($notifiable, Notification $notification)
     {
         $message = $notification->toFcm($notifiable);
         $message->send();
     }
-}
+}

src/Collections/SyncsWithFirebaseCollection.php

@@ -5,9 +5,10 @@
 
 class SyncsWithFirebaseCollection extends Collection
 {
-    public function syncWithFirebase($withRelated=false){
-        foreach($this AS $e){
+    public function syncWithFirebase($withRelated = false)
+    {
+        foreach ($this as $e) {
             $e->syncWithFirebase($withRelated);
         }
     }
-}
+}

src/Exceptions/FcmTargetNotSpecifiedException.php

@@ -11,4 +11,4 @@ function __construct(string $message = "FCM message target not specified!", int
         parent::__construct($message, $code, $previous);
     }
 
-}
+}

src/Facades/FCM.php

@@ -3,11 +3,12 @@
 
 
 use Illuminate\Support\Facades\Facade;
+use Plokko\LaravelFirebase\FcmMessageBuilder;
 
 class FCM extends Facade
 {
     protected static function getFacadeAccessor()
     {
-        return \Plokko\LaravelFirebase\FcmMessageBuilder::class;
+        return FcmMessageBuilder::class;
     }
-}
+}

src/Facades/FirebaseDb.php

@@ -2,12 +2,12 @@
 namespace Plokko\LaravelFirebase\Facades;
 
 use Illuminate\Support\Facades\Facade;
-use Plokko\Firebase\IO\Database;
+use Plokko\LaravelFirebase\RealtimeDb;
 
 class FirebaseDb extends Facade
 {
     protected static function getFacadeAccessor()
     {
-        return Database::class;
+        return RealtimeDb::class;
     }
-}
+}

src/Facades/FirebaseJWT.php

@@ -9,6 +9,6 @@ class FirebaseJWT extends Facade
 {
     protected static function getFacadeAccessor()
     {
-            return  JWT::class;
+        return JWT::class;
     }
-}
+}

src/RealtimeDb.php

@@ -0,0 +1,19 @@
+<?php
+namespace Plokko\LaravelFirebase;
+
+use App;
+use Plokko\Firebase\IO\Database;
+
+/**
+ * Extends base class to allow database selction
+ */
+class RealtimeDb extends Database
+{
+    /**
+     * @param string $dbName Database name to use
+     */
+    public function use ($dbName): Database
+    {
+        return App::makeWith(Database::class, ['db' => $dbName]);
+    }
+}

src/ServiceProvider.php

@@ -10,7 +10,7 @@ class ServiceProvider extends \Illuminate\Support\ServiceProvider
         CONFIG_PATH = __DIR__ . '/../config/laravel-firebase.php';
 
     protected
-        $defer = false;
+    $defer = false;
 
     public function boot()
     {
@@ -27,33 +27,36 @@ public function register()
         );
 
         // Provides the Firebase ServiceAccount
-        $this->app->singleton(ServiceAccount::class,function($app){
+        $this->app->singleton(ServiceAccount::class, function ($app) {
             $sa = new ServiceAccount(config('laravel-firebase.service_account'));
             // Add cache handler if cache is enabled
-            if(config('laravel-firebase.cache')){
+            if (config('laravel-firebase.cache')) {
                 $sa->setCacheHandler(new ServiceAccountCacheItemPool());
             }
             return $sa;
         });
 
         // Provide Firebase Database
-        $this->app->singleton(Database::class,function($app){
-            return (config('laravel-firebase.read_only'))?
-                        new ReadonlyDatabase($app->make(ServiceAccount::class)):
-                        new Database($app->make(ServiceAccount::class));
+        $this->app->singleton(Database::class, function ($app, array $opt = []) {
+            $dbName = $opt['db'] ?? config('laravel-firebase.default_db');
+            $dbUrl = config('laravel-firebase.firebasedb_urls.' . $dbName);
+
+            return (config('laravel-firebase.read_only')) ?
+                new ReadonlyDatabase($app->make(ServiceAccount::class), $dbUrl) :
+                new Database($app->make(ServiceAccount::class), $dbUrl);
         });
 
-        $this->app->bind(FcmMessageBuilder::class,function($app){
+        $this->app->bind(FcmMessageBuilder::class, function ($app) {
             $fcm = new FcmMessageBuilder($app->make(ServiceAccount::class));
 
             $event = config('laravel-firebase.FCMInvalidTokenTriggerEvent');
-            if($event){
+            if ($event) {
                 $fcm->setInvalidTokenEvent($event);
             }
             return $fcm;
         });
 
-        $this->app->singleton(JWT::class,function($app){
+        $this->app->singleton(JWT::class, function ($app) {
             return new JWT($app->make(ServiceAccount::class));
         });
     }