add boot method

Author: basemkhirat

src/Collection.php

@@ -4,7 +4,6 @@
 
 use Illuminate\Support\Collection as BaseCollection;
 
-
 class Collection extends BaseCollection
 {
 
@@ -19,16 +18,4 @@ public function toJson($options = 0)
         return json_encode($this->toArray(), $options);
     }
 
-    /**
-     * Get the collection of items as Array.
-     *
-     * @return string
-     */
-    public function toArray()
-    {
-        return array_map(function($item){
-            return $item->toArray();
-        }, $this->items);
-    }
-
 }

src/Connection.php

@@ -2,7 +2,9 @@
 
 namespace Basemkhirat\Elasticsearch;
 
+use Elasticsearch\Client;
 use Elasticsearch\ClientBuilder;
+use Symfony\Component\HttpKernel\Exception\HttpException as HttpException;
 
 /**
  * Class Connection
@@ -13,7 +15,7 @@ class Connection
 
     /**
      * Laravel app instance
-     * @var \Illuminate\Foundation\Application|mixed
+     * @var \Illuminate\contracts\Foundation\Application|mixed
      */
     protected $app;
 
@@ -25,13 +27,13 @@ class Connection
 
     /**
      * The current connection
-     * @var
+     * @var Client
      */
     protected $connection;
 
     /**
      * all available connections
-     * @var array
+     * @var Client[]
      */
     protected $connections = [];
 
@@ -77,11 +79,11 @@ public static function create($config)
     /**
      * Create a connection for laravel or lumen frameworks
      * @param $name
+     * @throws HttpException
      * @return Query
      */
     function connection($name)
     {
-
         // Check if connection is already loaded.
 
         if ($this->isLoaded($name)) {
@@ -121,6 +123,16 @@ function connection($name)
     }
 
 
+    /**
+     * @param string $name
+     * @throws HttpException
+     * @return Query
+     */
+    function connectionByName($name = 'default') {
+        return $this->connection($this->config[$name]);
+    }
+
+
     /**
      * route the request to the query class
      * @param $connection
@@ -148,35 +160,22 @@ function newQuery($connection)
     function isLoaded($name)
     {
 
-        if (array_key_exists($name, $this->connections)) {
-            return true;
-        }
-
-        return false;
+        return array_key_exists($name, $this->connections);
     }
 
 
     /**
      * Set the default connection
      * @param $name
      * @param $arguments
+     * @throws HttpException
      * @return mixed
      */
     function __call($name, $arguments)
     {
-        if (method_exists($this, $name)) {
-
-            return call_user_func_array([$this, $name], $arguments);
-
-        } else {
 
-            // if no connection, use default.
+        $query = $this->connectionByName('default');
 
-            $query = $this->connection($this->config["default"]);
-
-            return call_user_func_array([$query, $name], $arguments);
-
-        }
+        return call_user_func_array([$query, $name], $arguments);
     }
-
 }

src/ElasticsearchServiceProvider.php

@@ -73,10 +73,7 @@ public function boot()
                 // Laravel Scout service provider was not loaded yet.
 
             }
-
         }
-
-
     }
 
     /**

src/Query.php

@@ -4,7 +4,8 @@
 
 use Basemkhirat\Elasticsearch\Classes\Bulk;
 use Basemkhirat\Elasticsearch\Classes\Search;
-use Basemkhirat\Elasticsearch\Collection;
+use Elasticsearch\Client;
+use Elasticsearch\Common\Exceptions\BadMethodCallException;
 
 
 /**
@@ -16,13 +17,13 @@ class Query
 
     /**
      * Native elasticsearch connection instance
-     * @var Connection
+     * @var Client
      */
     public $connection;
 
     /**
      * Ignored HTTP errors
-     * @var array
+     * @var string[]
      */
     public $ignores = [];
 
@@ -157,14 +158,14 @@ class Query
 
     /**
      * Elastic model instance
-     * @var \Basemkhirat\Elasticsearch\Model
+     * @var Model
      */
     public $model;
 
 
     /**
      * Query constructor.
-     * @param $connection
+     * @param Client|NULL $connection
      */
     function __construct($connection = NULL)
     {
@@ -196,7 +197,7 @@ public function getIndex()
     /**
      * Set the type name
      * @param $type
-     * @return $this
+     * @return Query $this
      */
     public function type($type)
     {
@@ -256,7 +257,7 @@ public function searchType($type)
 
     /**
      * get the query search type
-     * @return $this
+     * @return int
      */
     public function getSearchType()
     {
@@ -265,7 +266,7 @@ public function getSearchType()
 
     /**
      * Get the query scroll
-     * @return $this
+     * @return string
      */
     public function getScroll()
     {
@@ -362,11 +363,7 @@ public function orderBy($field, $direction = "asc")
     protected function isOperator($string)
     {
 
-        if (in_array($string, $this->operators)) {
-            return true;
-        }
-
-        return false;
+        return in_array($string, $this->operators);
     }
 
     /**
@@ -656,6 +653,7 @@ public function distance($name, $value, $distance)
     /**
      * Search the entire document fields
      * @param null $q
+     * @param NULL $settings
      * @return $this
      */
     public function search($q = NULL, $settings = NULL)
@@ -792,22 +790,21 @@ public function clear($scroll_id = NULL)
 
     /**
      * Get the collection of results
-     * @param string $scroll_id
-     * @return array|Collection
+     * @throws \Exception
+     * @return Collection
      */
-    public function get($scroll_id = NULL)
+    public function get()
     {
 
-        $scroll_id = NULL;
-
-        $result = $this->getResult($scroll_id);
+        $result = $this->getResult(NULL);
 
         return $this->getAll($result);
     }
 
     /**
      * Get the first object of results
      * @param string $scroll_id
+     * @throws \Exception
      * @return object
      */
     public function first($scroll_id = NULL)
@@ -823,6 +820,7 @@ public function first($scroll_id = NULL)
     /**
      * Get query result
      * @param $scroll_id
+     * @throws \Exception
      * @return mixed
      */
     protected function getResult($scroll_id)
@@ -846,7 +844,8 @@ protected function getResult($scroll_id)
     /**
      * Get non cached results
      * @param null $scroll_id
-     * @return mixed
+     * @throws \Exception
+     * @return array
      */
     public function response($scroll_id = NULL)
     {
@@ -909,7 +908,7 @@ function setModel($model)
     /**
      * Retrieve all records
      * @param array $result
-     * @return array|Collection
+     * @return Collection
      */
     protected function getAll($result = [])
     {
@@ -993,6 +992,7 @@ protected function getFirst($result = [])
      * @param int $per_page
      * @param      $page_name
      * @param null $page
+     * @throws \Exception
      * @return Pagination
      */
     public function paginate($per_page = 10, $page_name = "page", $page = null)
@@ -1013,7 +1013,7 @@ public function paginate($per_page = 10, $page_name = "page", $page = null)
      * Insert a document
      * @param      $data
      * @param null $_id
-     * @return object
+     * @return array
      */
     public function insert($data, $_id = NULL)
     {
@@ -1039,12 +1039,12 @@ public function insert($data, $_id = NULL)
             $parameters["id"] = $this->_id;
         }
 
-        return (object)$this->connection->index($parameters);
+        return $this->connection->index($parameters);
     }
 
     /**
      * Insert a bulk of documents
-     * @param $data multidimensional array of [id => data] pairs
+     * @param $data callable|array : multidimensional array of [id => data] pairs
      * @return object
      */
     public function bulk($data)
@@ -1321,7 +1321,6 @@ public function CachePrefix($prefix)
 
     /**
      * Get a unique cache key for the complete query.
-     *
      * @return string
      */
     public function getCacheKey()
@@ -1357,7 +1356,7 @@ public function remember($minutes, $key = null)
     /**
      * Indicate that the query results should be cached forever.
      * @param  string $key
-     * @return \Illuminate\Database\Query\Builder|static
+     * @return $this
      */
     public function rememberForever($key = null)
     {
@@ -1372,20 +1371,14 @@ public function rememberForever($key = null)
     function __call($method, $parameters)
     {
 
-        if (method_exists($this, $method)) {
-            return $this->$method(...$parameters);
-        } else {
-
-            // Check for model scopes
+        $method = "scope" . ucfirst($method);
 
-            $method = "scope" . ucfirst($method);
-
-            if (method_exists($this->model, $method)) {
-                $parameters = array_merge([$this], $parameters);
-                $this->model->$method(...$parameters);
-                return $this;
-            }
+        if (method_exists($this->model, $method)) {
+            $parameters = array_merge([$this], $parameters);
+            $this->model->$method(...$parameters);
+            return $this;
         }
 
+        throw new BadMethodCallException("Method $method does not exist.");
     }
 }