package = "lua-resty-motan"
version = "0.1.5-8"
source = {
   url = "git+https://github.com/weibocom/motan-openresty.git",
   tag = "v0.1.5"
}
description = {
   summary = "motan library for OpenResty",
   detailed = [[
                Motan is a cross-language remote procedure call(RPC) framework
                for rapid development of high performance distributed services.
                This is OpenResty motan implementation for Motan.
              ]],
   homepage = "https://github.com/weibocom/motan-openresty",
   license = "Apache 2.0"
}
dependencies = {
   "lua >= 5.1",
   "lua-resty-http >= 0.12",
   "lua-resty-timer >=0.0.1",
   "lua-resty-consul >= 0.2"
}

build = {
   patches = {
      ["client.call.patch"] = [[
diff --git a/lib/motan/client/init.lua b/lib/motan/client/init.lua
index 3208cb0..1e89593 100644
--- a/lib/motan/client/init.lua
+++ b/lib/motan/client/init.lua
@@ -23,6 +23,15 @@ end

 -- for calling with metadata
 function _M.call(self, fucname, metadata, ...)
+    local resp, err = self:fcall(fucname, metadata, ...)
+
+    if err ~= nil then
+        return nil, err
+    end
+    return resp.value
+end
+
+function _M.fcall(self, fucname, metadata, ...)
     local protocol = singletons.motan_ext:get_protocol(self.url.protocol)
     local req = protocol:make_motan_request(self.url, fucname, ...)
     if not utils.is_empty(metadata) then
@@ -34,7 +43,7 @@ function _M.call(self, fucname, metadata, ...)
     if resp:get_exception() ~= nil then
         return nil, resp:get_exception()
     end
-    return resp.value
+    return resp
 end

 -- for purge RPC call
      ]],
      ["unix.sock.patch"] = [[
diff --git a/lib/motan/endpoint/motan.lua b/lib/motan/endpoint/motan.lua
index 5490eca..a56988a 100644
--- a/lib/motan/endpoint/motan.lua
+++ b/lib/motan/endpoint/motan.lua
@@ -69,7 +69,12 @@ function _M.connect(self)
     if not sock then
         return nil, "not initialized"
     end
-    local ok, err = sock:connect(self.url.host, self.url.port)
+    local ok, err
+    if self.url.unixSock ~= "" then
+        ok, err = sock:connect("unix:" .. self.url.unixSock)
+    else
+        ok, err = sock:connect(self.url.host, self.url.port)
+    end
     if err == nil then
         return ok, nil
     end
@@ -78,7 +83,7 @@ function _M.connect(self)
     if
         singletons.config.conf_set["WEIBO_MESH"] ~= nil and
             singletons.config.conf_set["WEIBO_MESH"] == table.concat({self.url.host, self.url.port}, ":")
-     then
+    then
         use_weibo_mesh = true
     end
     -- when connect fail to mesh, we need retry though snapshot nodes.
diff --git a/lib/motan/registry/direct.lua b/lib/motan/registry/direct.lua
index 739b944..9cfbe8e 100644
--- a/lib/motan/registry/direct.lua
+++ b/lib/motan/registry/direct.lua
@@ -15,7 +15,8 @@ local mt = {__index = _M}
 function _M:new(opts)
     local direct = {
         host = opts.host,
-        port = opts.port
+        port = opts.port,
+        unixSock = opts.unixSock
     }
     return setmetatable(direct, mt)
 end
@@ -44,6 +45,7 @@ function _M:discover(url)
         protocol = url.protocol,
         host = self.host,
         port = self.port,
+        unixSock = self.unixSock,
         path = url.path,
         group = url.group,
         params = url.params
diff --git a/lib/motan/url.lua b/lib/motan/url.lua
index 7fd46a8..2ef918f 100644
--- a/lib/motan/url.lua
+++ b/lib/motan/url.lua
@@ -23,6 +23,7 @@ function _M.new(self, opts)
             host = opts.host or singletons.var.LOCAL_IP,
             port = opts.port or 0,
             path = opts.path or "",
+            unixSock = opts.unixSock or "",
             group = opts.group or "",
             params = opts.params or {}
         }
@@ -30,6 +31,7 @@ function _M.new(self, opts)
             "protocol",
             "host",
             "port",
+            "unixSock",
             "path",
             "group",
             "params"
@@ -46,12 +48,22 @@ function _M.new(self, opts)
 end

 function _M.get_addr(self)
+    local addr = {
+        self.host,
+        consts.COLON_SEPARATOR,
+        self.port
+    }
+
+    if self.unixSock ~= "" then
+        addr = {
+            self.unixSock
+        }
+    end
+
     local addr_info = {
         self.protocol,
         consts.PROTOCOL_SEPARATOR,
-        self.host,
-        consts.COLON_SEPARATOR,
-        self.port,
+        tab_concat(addr),
         consts.PATH_SEPARATOR
     }
     return tab_concat(addr_info)
@@ -63,10 +75,11 @@ function _M.copy(self)
     for k, v in pairs(self.params) do
         params[k] = v
     end
-    url.protocol, url.host, url.port, url.path, url.group, url.params =
+    url.protocol, url.host, url.port, url.unixSock, url.path, url.group, url.params =
         self.protocol,
         self.host,
         self.port,
+        self.unixSock,
         self.path,
         self.group,
         params
@@ -79,12 +92,22 @@ function _M.get_identity(self)
 end

 function _M.get_urlinfo(self, with_params_str)
+    local addr = {
+        self.host,
+        consts.COLON_SEPARATOR,
+        self.port
+    }
+
+    if self.unixSock ~= "" then
+        addr = {
+            self.unixSock
+        }
+    end
+
     local url_info = {
         self.protocol,
         consts.PROTOCOL_SEPARATOR,
-        self.host,
-        consts.COLON_SEPARATOR,
-        self.port,
+        tab_concat(addr),
         consts.PATH_SEPARATOR,
         self.path,
         consts.QMARK_SEPARATOR,
      ]]
   },

   type = "command",

   -- TODO(yunlong18): get install path from config
   build_command = "cd lib/motan/libs && gcc -g -o libmotan_tools.so -fpic -shared motan_tools.c",
   install_command = "cp -R lib/motan /usr/local/share/lua/5.1"..
                     " && mkdir -p /usr/local/lib/lua/5.1/"..
                     " && ln -sf /usr/local/share/lua/5.1/motan/libs/cmotan.so /usr/local/lib/lua/5.1/cmotan.so"..
                     " && ln -sf /usr/local/share/lua/5.1/motan/libs/libmotan_tools.so /lib/libmotan_tools.so"..
                     " && ldconfig"
}