[proxy] don't call post_actions for already handled requests

for example oauth has own routes that can handle the request
so there is no need to call post_action for them

it should be called only when the access phase is evaluated

Author: mikz

apicast/src/apicast.lua

@@ -80,9 +80,10 @@ function _M:post_action()
   post_action_proxy[request_id] = nil
 
   if p then
-    p:post_action()
+    return p:post_action()
   else
     ngx.log(ngx.INFO, 'could not find proxy for request id: ', request_id)
+    return nil, 'no proxy for request'
   end
 end
 
@@ -94,10 +95,17 @@ function _M:access()
     return nil, 'not initialized'
   end
 
-  local fun = p:call() -- proxy:access() or oauth handler
-  local ok, err = fun()
+  local access, handler = p:call() -- proxy:access() or oauth handler
 
-  post_action_proxy[ngx.var.original_request_id] = p
+  local ok, err
+
+  if access then
+    ok, err = access()
+    post_action_proxy[ngx.var.original_request_id] = p
+  elseif handler then
+    ok, err = handler()
+    -- no proxy because that would trigger post action
+  end
 
   return ok, err
 end

apicast/src/proxy.lua

@@ -279,7 +279,7 @@ function _M:call(host)
 
     if f then
       ngx.log(ngx.DEBUG, 'apicast oauth flow')
-      return function() return f(params) end
+      return nil, function() return f(params) end
     end
   end
 

spec/apicast_spec.lua

@@ -1,12 +1,57 @@
-local apicast = require 'apicast'
+local _M = require 'apicast'
 
 describe('APIcast module', function()
 
   it('has a name', function()
-    assert.truthy(apicast._NAME)
+    assert.truthy(_M._NAME)
   end)
 
   it('has a version', function()
-    assert.truthy(apicast._VERSION)
+    assert.truthy(_M._VERSION)
+  end)
+
+  describe(':access', function()
+
+    local apicast
+
+    before_each(function()
+      apicast = _M.new()
+      ngx.ctx.proxy = {}
+    end)
+
+    it('triggers post action when access phase succeeds', function()
+      ngx.var = { original_request_id = 'foobar' }
+
+      stub(ngx.ctx.proxy, 'call', function()
+        return function() return 'ok' end
+      end)
+
+      stub(ngx.ctx.proxy, 'post_action', function()
+        return 'post_ok'
+      end)
+
+      local ok, err = apicast:access()
+
+      assert.same('ok', ok)
+      assert.falsy(err)
+
+      assert.same('post_ok', apicast:post_action())
+    end)
+
+    it('skips post action when access phase not executed', function()
+      stub(ngx.ctx.proxy, 'call', function()
+        -- return nothing for example
+      end)
+
+      local ok, err = apicast:access()
+
+      assert.falsy(ok)
+      assert.falsy(err)
+
+      ngx.ctx.proxy = nil -- in post_action the ctx is not shared
+      ngx.var = { original_request_id = 'foobar' }
+
+      assert.equal(nil, apicast:post_action())
+    end)
   end)
 end)

spec/proxy_spec.lua

@@ -13,14 +13,36 @@ describe('Proxy', function()
     assert.same('function', type(proxy.access))
   end)
 
-  it('has authorize function after call', function()
-    ngx.var = { backend_endpoint = 'http://localhost:1853' }
-    configuration:add({ id = 42, hosts = { 'localhost' }})
+  describe(':call', function()
+    before_each(function()
+      ngx.var = { backend_endpoint = 'http://localhost:1853' }
+      configuration:add({ id = 42, hosts = { 'localhost' }})
+    end)
+
+    it('has authorize function after call', function()
+      proxy:call('localhost')
 
-    proxy:call('localhost')
+      assert.truthy(proxy.authorize)
+      assert.same('function', type(proxy.authorize))
+    end)
 
-    assert.truthy(proxy.authorize)
-    assert.same('function', type(proxy.authorize))
+    it('returns access function', function()
+      local access = proxy:call('localhost')
+
+      assert.same('function', type(access))
+    end)
+
+    it('returns oauth handler when matches oauth route', function()
+      local service = configuration:find_by_id(42)
+      service.backend_version = 'oauth'
+      stub(ngx.req, 'get_method', function() return 'GET' end)
+      ngx.var.uri = '/authorize'
+
+      local access, handler = proxy:call('localhost')
+
+      assert.equal(nil, access)
+      assert.same('function', type(handler))
+    end)
   end)
 
   it('has post_action function', function()