🚏Make Log save event queueable. Add timestamp, since some Laravel model builder functions depend on them <- timestamps added to DB table so migration needs to be re-run or created_at and updated_at needs to be added manually.

Author: danielme85

readme.md

@@ -9,7 +9,7 @@
 Custom Larvel 5.6+ Log channel handler that can store log events to SQL or MongoDB databases. 
 Uses Laravel native logging functionality.
 
-### Installation
+## Installation
 ```
 require danielme85/laravel-log-to-db
 ```
@@ -19,7 +19,7 @@ If you are going to be using SQL database server to store log events you would n
 php artisan migrate
 ```
 
-### Configuration
+## Configuration
 Starting with Laravel 5.6 you will have a new settings file: "config/logging.php". 
 You will need to add an array under 'channels' for Log-to-DB here like so:
 ```php
@@ -46,7 +46,7 @@ You will need to add an array under 'channels' for Log-to-DB here like so:
 More info about some of these options: https://laravel.com/docs/5.6/logging#customizing-monolog-for-channels
 
 There are some default settings and more information about configuring the logger in the 'logtodb.php' config file.
-This can be copied to your project so you can edit it with the vendor publish command.
+This could be copied to your project if you would like edit it with the vendor publish command.
 ```
 php artisan vendor:publish
 ```
@@ -58,6 +58,42 @@ Log::channel('mongodb')->info("This thing just happened");
 ```
 This logger works the same as any other across Laravel, for example you can add it to a stack. 
 You can log multiple levels to multiple DB connections... the possibilities are ENDLESS! 😎
+
+#### Log Worker Queue
+It might be a good idea to save the log events with a Queue Worker. This way your server does not have to wait for
+the save process to finish. You would have to configure the Laravel Queue settings and run the Queue listener. 
+https://laravel.com/docs/5.6/queues#running-the-queue-worker
+
+## Usage
+Since this is a custom log channel for Laravel, all "standard" ways of generating log events etc should work with 
+the Laravel Log Facade. See https://laravel.com/docs/5.6/logging for more information.
+
+#### Fetching Logs
+The logging by this channel is done trough the Eloquent Model builder.
+LogToDB::model($channel, $connection, $collection);
+You can skip all function variables and the default settings from the config/logtodb.php will be used.
+```php
+$model = LogToDB::model();
+$model->all(); //All logs for defualt channel/connection
+```
+
+Some more examples of getting logs
+```php
+$logs = LogToDB::model()->all();
+$logs = LogToDB::model()->where('id' = $id)->first();
+```
+
+When getting logs for specific channel or DB connection and collection you can either use the channel name matching 
+config/logging.php or connection name from config/databases.php. You can also specify collection/table name if needed as 
+the third function variable when fetching the model.  
+```php
+$logsFromDefault = LogDB::model()->all();
+$logsFromChannel = LogDB::model('database')->all();
+$logsFromMysql   = LogToDB::model(null, 'mysql')->all();
+$logsFromMongoDB = LogToDB::model(null, 'mongodb', 'log')->all();
+```
+
+##### Advanced /config/logging.php example
 ```php
 'default' => env('LOG_CHANNEL', 'stack'),
 
@@ -90,33 +126,4 @@ You can log multiple levels to multiple DB connections... the possibilities are
     ],
     //....
 ]
-```
-
-### Usage
-Since this is a custom log channel for Laravel, all "standard" ways of generating log events etc should work with 
-the Laravel Log Facade. See https://laravel.com/docs/5.6/logging for more information.
-
-#### Fetching Logs
-The logging by this channel is done trough the Eloquent Model builder.
-LogToDB::model($channel, $connection, $collection);
-You can skip all function variables and the default settings from the config/logtodb.php will be used.
-```php
-$model = LogToDB::model();
-$model->all(); //All logs for defualt channel/connection
-```
-
-Some more examples of getting logs
-```php
-$logs = LogToDB::model()->all();
-$logs = LogToDB::model()->where('id' = $id)->first();
-```
-
-When getting logs for specific channel or DB connection and collection you can either use the channel name matching 
-config/logging.php or connection name from config/databases.php. You can also specify collection/table name if needed as 
-the third function variable when fetching the model.  
-```php
-$logsFromDefault = LogDB::model()->all();
-$logsFromChannel = LogDB::model('database')->all();
-$logsFromMysql   = LogToDB::model(null, 'mysql')->all();
-$logsFromMongoDB = LogToDB::model(null, 'mongodb', 'log')->all();
 ```

src/Jobs/SaveNewLogEvent.php

@@ -0,0 +1,40 @@
+<?php
+
+namespace danielme85\LaravelLogToDB\Jobs;
+
+
+use danielme85\LaravelLogToDB\Models\DBLog;
+use danielme85\LaravelLogToDB\Models\DBLogMongoDB;
+use Illuminate\Bus\Queueable;
+use Illuminate\Queue\SerializesModels;
+use Illuminate\Queue\InteractsWithQueue;
+use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Foundation\Bus\Dispatchable;
+
+class SaveNewLogEvent implements ShouldQueue
+{
+    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
+
+    protected $log;
+
+    /**
+     * Create a new job instance.
+     *
+     * @param  DBLog | DBLogMongoDB $log
+     * @return void
+     */
+    public function __construct($log)
+    {
+        $this->log = $log;
+    }
+
+    /**
+     * Execute the job.
+     *
+     * @return void
+     */
+    public function handle()
+    {
+        $this->log->save();
+    }
+}

src/LogToDB.php

@@ -1,6 +1,9 @@
 <?php
 
 namespace danielme85\LaravelLogToDB;
+use danielme85\LaravelLogToDB\Jobs\SaveNewLogEvent;
+use danielme85\LaravelLogToDB\Models\DBLog;
+use danielme85\LaravelLogToDB\Models\DBLogMongoDB;
 
 /**
  * Class LogToDb
@@ -34,6 +37,10 @@ class LogToDB
      * @var string
      */
     public $collection;
+
+    public $saveWithQueue;
+
+
     /**
      * The DB config details
      * @var null
@@ -65,6 +72,9 @@ function __construct($channelConnection = null, $collection = null, $detailed =
             if (isset($config['max_rows'])) {
                 $this->maxRows = (int)$config['max_rows'];
             }
+            if (isset($config['queue_db_saves'])) {
+                $this->saveWithQueue = $config['queue_db_saves'];
+            }
         }
 
         //Set config based on specified config from the Log handler
@@ -204,11 +214,21 @@ public function newFromMonolog(array $record) : self
         }
         $log->unix_time = time();
 
-        if ($log->save()) {
-            if (!empty($this->maxRows)) {
-                $this->removeOldestIfMaxRows();
+        if (!empty($this->saveWithQueue)) {
+            if(dispatch(new SaveNewLogEvent($log))->onQueue($this->saveWithQueue)) {
+                if (!empty($this->maxRows)) {
+                    $this->removeOldestIfMaxRows();
+                }
             }
         }
+        else {
+            if ($log->save()) {
+                if (!empty($this->maxRows)) {
+                    $this->removeOldestIfMaxRows();
+                }
+            }
+        }
+
 
         return $this;
     }

src/DBLog.php renamed to src/Models/DBLog.php

@@ -1,6 +1,6 @@
 <?php
 
-namespace danielme85\LaravelLogToDB;
+namespace danielme85\LaravelLogToDB\Models;
 
 use Illuminate\Database\Eloquent\Model;
 
@@ -13,7 +13,6 @@ class DBLog extends Model
 {
     use LogToDbCreateObject;
 
-    public $timestamps = false;
     protected $connection;
     protected $table;
 

src/DBLogMongoDB.php renamed to src/Models/DBLogMongoDB.php

@@ -1,6 +1,6 @@
 <?php
 
-namespace danielme85\LaravelLogToDB;
+namespace danielme85\LaravelLogToDB\Models;
 
 use Jenssegers\Mongodb\Eloquent\Model as Eloquent;
 
@@ -13,7 +13,6 @@ class DBLogMongoDB extends Eloquent
 {
     use LogToDbCreateObject;
 
-    public $timestamps = false;
     protected $connection;
     protected $collection;
 

src/LogToDbCreateObject.php renamed to src/Models/LogToDbCreateObject.php

@@ -1,6 +1,6 @@
 <?php
 
-namespace danielme85\LaravelLogToDB;
+namespace danielme85\LaravelLogToDB\Models;
 
 /**
  * Trait LogToDbCreateObject

src/config/logtodb.php

@@ -62,4 +62,17 @@
     | 'max_rows' => false for no limit.
     */
     'max_rows' => false,
+
+    /*
+    |--------------------------------------------------------------------------
+    | Name of Queue
+    |--------------------------------------------------------------------------
+    |
+    | It might be a good idea to save log events with the queue helper.
+    | This way the requests going to your sever does not have to wait for the Log
+    | event to be saved. Set to a string like: 'queue_db_saves' => 'logWorker',
+    | and make sure to run the queue worker.
+    | https://laravel.com/docs/5.6/queues#running-the-queue-worker
+    */
+    'queue_db_saves' => false,
 ];

src/migrations/2018_08_11_003343_create_log_table.php

@@ -23,6 +23,7 @@ public function up()
             $table->text('datetime')->nullable();
             $table->longText('context')->nullable();
             $table->text('extra')->nullable();
+            $table->timestamps();
         });
     }
 

tests/LogToDbTest.php

@@ -2,6 +2,8 @@
 
 use danielme85\LaravelLogToDB\LogToDB;
 use Illuminate\Support\Facades\Log;
+use Illuminate\Support\Facades\Queue;
+use danielme85\LaravelLogToDB\Jobs\SaveNewLogEvent;
 
 class LogToDbTest extends Orchestra\Testbench\TestCase
 {
@@ -14,9 +16,6 @@ protected function setUp(): void
 
         $this->artisan('migrate', ['--database' => 'mysql']);
 
-        $this->beforeApplicationDestroyed(function () {
-            $this->artisan('migrate:rollback', ['--database' => 'mysql']);
-        });
     }
     /**
      * Define environment setup.
@@ -149,6 +148,24 @@ public function testException() {
         $this->assertNotEmpty($log->context);
     }
 
+    /**
+     * @group queue
+     *
+     */
+    public function testQueue() {
+        Queue::fake();
+
+        config()->set('logtodb.queue_db_saves', 'saveLogJob');
+
+        Log::info("I'm supposed to be added to the queue...");
+        Log::warning("I'm supposed to be added to the queue...");
+        Log::debug("I'm supposed to be added to the queue...");
+
+        Queue::assertPushedOn(config('logtodb.queue_db_saves'), SaveNewLogEvent::class);
+        Queue::assertPushed(SaveNewLogEvent::class, 6);
+
+    }
+
     public function testCleanup() {
         LogToDB::model()::truncate();
         LogToDB::model('mongodb')::truncate();