Merge pull request #1 from imikemiller/query_logging

Query logging configuration

Author: imikemiller

composer.json

@@ -42,7 +42,8 @@
         "elasticsearch/elasticsearch": "^5.0",
         "illuminate/pagination": "*",
         "illuminate/support": "*",
-        "symfony/var-dumper": "*"
+        "symfony/var-dumper": "*",
+        "monolog/monolog": "^1.23"
     },
     "require-dev": {
         "phpunit/phpunit": "5.7.0"

src/Connection.php

@@ -121,6 +121,16 @@ function connection($name)
     }
 
 
+    public static function configureLogging(ClientBuilder $clientBuilder,array $config)
+    {
+        if (array_get($config,'logging.enabled')) {
+            $logger = ClientBuilder::defaultLogger(array_get($config,'logging.location'), array_get($config,'logging.level','all'));
+            $clientBuilder->setLogger($logger);
+        }
+        return $clientBuilder;
+    }
+
+
     /**
      * route the request to the query class
      * @param $connection

src/config/es.php

@@ -31,8 +31,8 @@
             'servers' => [
 
                 [
-                    "host" => env("ELASTIC_HOST", "127.0.0.1"),
-                    "port" => env("ELASTIC_PORT", 9200),
+                    'host' => env('ELASTIC_HOST', '127.0.0.1'),
+                    'port' => env('ELASTIC_PORT', 9200),
                     'user' => env('ELASTIC_USER', ''),
                     'pass' => env('ELASTIC_PASS', ''),
                     'scheme' => env('ELASTIC_SCHEME', 'http'),
@@ -44,6 +44,12 @@
 
             // Elasticsearch handlers
             // 'handler' => new MyCustomHandler(),
+            
+            'logging' => [
+                'enabled'   => env('ELASTIC_LOGGING_ENABLED',false),
+                'level'     => env('ELASTIC_LOGGING_LEVEL','all'),
+                'location'  => env('ELASTIC_LOGGING_LOCATION',base_path('storage/logs/elasticsearch.log'))
+            ],            
         ]
     ],
 
@@ -64,18 +70,18 @@
 
         'my_index_1' => [
 
-            "aliases" => [
-                "my_index"
+            'aliases' => [
+                'my_index'
             ],
 
             'settings' => [
-                "number_of_shards" => 1,
-                "number_of_replicas" => 0,
+                'number_of_shards' => 1,
+                'number_of_replicas' => 0,
             ],
 
             'mappings' => [
                 'posts' => [
-                    "properties" => [
+                    'properties' => [
                         'title' => [
                             'type' => 'string'
                         ]

src/helpers.php

@@ -28,4 +28,18 @@ function is_callback_function($callback)
     }
 }
 
+if (! function_exists('base_path')) {
+    /**
+     * Get the path to the base of the install.
+     *
+     * @param  string  $path
+     * @return string
+     */
+    function base_path($path = '')
+    {
+        return app()->basePath().($path ? '/'.$path : $path);
+    }
+}
+
+
 

src/storage/logs/.gitignore

@@ -0,0 +1,2 @@
+*
+!.gitignore

tests/LoggingTest.php

@@ -0,0 +1,33 @@
+<?php
+/**
+ * Created by PhpStorm.
+ * User: mike
+ * Date: 07/05/18
+ * Time: 19:58
+ */
+
+namespace Basemkhirat\Elasticsearch\Tests;
+
+
+use Basemkhirat\Elasticsearch\Connection;
+use Elasticsearch\ClientBuilder;
+use Monolog\Logger;
+
+class LoggingTest extends \PHPUnit_Framework_TestCase
+{
+
+    public function testConfigureLogging()
+    {
+        $client = ClientBuilder::create();
+        $newClientBuilder = Connection::configureLogging($client,[
+            'logging'=>[
+                'enabled'=>true,
+                'level'=>'all',
+                'location'=>'../src/storage/logs/elasticsearch.log'
+            ]
+        ]);
+
+        $this->assertInstanceOf(ClientBuilder::class,$newClientBuilder);
+        $this->assertAttributeInstanceOf(Logger::class,'logger',$newClientBuilder);
+    }
+}