feature: used lua-resty-socket when the phase is not yieldable

Author: tokers

lib/resty/requests/adapter.lua

@@ -1,6 +1,7 @@
 -- Copyright (C) Alex Zhang
 
 local util = require "resty.requests.util"
+local resty_socket = require "resty.socket"
 local response = require "resty.requests.response"
 local check_http2, http2 = pcall(require, "resty.http2")
 
@@ -11,9 +12,10 @@ local lower = string.lower
 local format = string.format
 local insert = table.insert
 local concat = table.concat
-local socket = ngx.socket.tcp
+local tcp_socket = ngx.socket.tcp
 local ngx_match = ngx.re.match
 local ngx_now = ngx.now
+local get_phase = ngx.get_phase
 local dict = util.dict
 local new_tab = util.new_tab
 local is_tab = util.is_tab
@@ -43,6 +45,21 @@ if check_http2 then
 end
 
 
+local function socket()
+    local phase = get_phase()
+
+    -- ignore the other non-yiedable phases, since these phases are
+    -- requests-specific and we shouldn't use the blocking APIs, it will hurt
+    -- the event loop, so just let the Cosocket throws "API disabled ..."
+    -- error.
+    if phase == "init" or phase == "init_worker" then
+        return resty_socket()
+    end
+
+    return tcp_socket()
+end
+
+
 local function parse_status_line(status_line)
     local m, err = ngx_match(status_line, "HTTP/(.+?)\\s.*?(\\d+).*", "jo")
     if not m then

lua-resty-requests-0.7-1.rockspec

@@ -1,9 +1,11 @@
 package = "lua-resty-requests"
-version = "0.7-1"
+version = "0.7.1-1"
+
 source = {
    url = "git://github.com/tokers/lua-resty-requests",
    tag = "v0.7",
 }
+
 description = {
    summary = "Yet Another HTTP library for OpenResty",
    detailed = [[
@@ -13,9 +15,12 @@ description = {
    homepage = "https://github.com/tokers/lua-resty-requests",
    maintainer = "Alex Zhang <[email protected]>",
 }
+
 dependencies = {
-   "lua >= 5.1"
+   "lua >= 5.1",
+   "lua-resty-socket == 0.0.4",
 }
+
 build = {
    type = "builtin",
    modules = {