Add connectionstring to client hosts config

README.md

@@ -52,6 +52,7 @@ The complete documetation is [here](http://elasticsearch-lua.readthedocs.io/).
     hosts = {
       { -- Ignoring any of the following hosts parameters is allowed.
         -- The default shall be set
+        connectionstring = "",
         protocol = "http",
         host = "localhost",
         port = 9200,

src/elasticsearch/Settings.lua

@@ -27,6 +27,7 @@ local Settings = {}
 -- Initial seed of hosts
 Settings.hosts = {
   {
+    connectionstring = "",
     protocol = "http",
     host = "localhost",
     port = 9200,
@@ -131,6 +132,7 @@ function Settings:setParameters()
   -- Checking hosts
   if self.user_hosts ~= nil then
     local default_host = {
+      connectionstring = self.hosts[1].connectionstring,
       protocol = self.hosts[1].protocol,
       host = self.hosts[1].host,
       port = self.hosts[1].port,
@@ -142,6 +144,7 @@ function Settings:setParameters()
     self.hosts = {}
     for i, v in pairs(self.user_hosts) do
       self.hosts[i] = {
+        connectionstring = default_host.connectionstring,
         protocol = default_host.protocol,
         host = default_host.host,
         port = default_host.port,
@@ -172,6 +175,7 @@ function Settings:setConnectionSettings()
   self.connections = {}
   for key, host in pairs(self.hosts) do
     table.insert(self.connections, Connection:new{
+      connectionstring = host.connectionstring,
       protocol = host.protocol,
       host = host.host,
       port = host.port,

src/elasticsearch/connection/Connection.lua

@@ -16,7 +16,8 @@ local Connection = {}
 -------------------------------------------------------------------------------
 -- Declaring instance variables
 -------------------------------------------------------------------------------
-
+-- The FULL connection string should be use
+Connection.connectionstring = nil
 -- The protocol of the connection
 Connection.protocol = nil
 -- The host where the connection should be made
@@ -83,7 +84,7 @@ function Connection:request(method, uri, params, body, timeout)
     request.source = ltn12.source.string(body)
   end
   -- Adding auth to request
-  if self.username ~= nil and self.password ~= nil then
+  if self.username ~= "" and self.password ~= "" then
      local authStr, foo = mime.b64(self.username .. ':' .. self.password)
      request.headers['Authorization'] = 'Basic ' .. authStr
   end
@@ -171,6 +172,10 @@ function Connection:buildURI(uri, params)
     port = self.port,
     path = uri
   }
+  if self.connectionstring ~= "" then
+    urlComponents = url.parse(self.connectionstring)
+    urlComponents.path = uri
+  end
   if params ~= nil then
     urlComponents.query = self:buildQuery(params)
   end