3scale · davidor · Mar 7, 2018 · Mar 2, 2018 · Mar 2, 2018 · Mar 2, 2018
@@ -10,6 +10,8 @@ and this project adheres to [Semantic Versioning](http://semver.org/).
 
 - New property `summary` in the policy manifests [PR #633](https://github.com/3scale/apicast/pull/633)
 - OAuth2.0 Token Introspection policy [PR #619](https://github.com/3scale/apicast/pull/619)
+- New `metrics` phase that runs when prometheus is collecting metrics [PR #629](https://github.com/3scale/apicast/pull/629)
+- Validation of policy configs both in integration and unit tests [PR #646](https://github.com/3scale/apicast/pull/646)
 
 ## Fixed
 
@@ -18,10 +20,6 @@ and this project adheres to [Semantic Versioning](http://semver.org/).
 - Avoid `nameserver` repetion from `RESOLVER` variable and `resolv.conf` file [PR #636](https://github.com/3scale/apicast/pull/636)
 - Bug in URL rewriting policy that ignored the `commands` attribute in the policy manifest [PR #641](https://github.com/3scale/apicast/pull/641)
 
-## Added
-
-- New `metrics` phase that runs when prometheus is collecting metrics [PR #629](https://github.com/3scale/apicast/pull/629)
-
 ## [3.2.0-beta1] - 2018-02-20
 
 ## Added

@@ -4,6 +4,7 @@ luarocks {
 
     group 'testing' {
         module { 'busted' },
+        module { 'ljsonschema' },
     },
 
     group 'development' {

@@ -4,6 +4,7 @@ dkjson 2.5-2||testing
 inspect 3.1.1-0||production
 ldoc 1.4.6-2||development
 liquid 0.1.0-1||production
+ljsonschema 0.1.0-1||testing
 lua-resty-env 0.4.0-1||production
 lua-resty-execvp 0.1.0-1||production
 lua-resty-http 0.12-0||production
@@ -18,6 +19,7 @@ luassert 1.7.10-0||testing
 luasystem 0.2.1-0||testing
 markdown 0.33-1||development
 mediator_lua 1.1.2-0||testing
+net-url 0.9-1||testing
 nginx-lua-prometheus 0.20171117-4||production
 penlight 1.5.4-1||production,development,testing
 router 2.1-0||production

@@ -27,19 +27,19 @@
         "type": "string",
         "oneOf": [
           {
-            "const": "resilient",
+            "enum": ["resilient"],
             "description": "Authorize according to last request when backend is down."
           },
           {
-            "const": "strict",
+            "enum": ["strict"],
             "description": "It only caches authorized calls."
           },
           {
-            "const": "allow",
+            "enum": ["allow"],
             "description": "When backend is down, allow everything unless seen before and denied."
           },
           {
-            "const": "none",
+            "enum": ["none"],
             "description": "Disables caching."
           }
         ]

@@ -98,7 +98,7 @@ end
 -- @tparam[opt] table config
 -- @field caching_type Caching type (strict, resilient, allow, none)
 function _M.new(config)
-  local self = new()
+  local self = new(config)
   self.cache_handler = handler(config or {})
   return self
 end

@@ -25,7 +25,7 @@ local new = _M.new
 -- @field[opt] allow_origin Allowed origins (e.g. 'http://example.com', '*')
 -- @field[opt] allow_credentials Boolean
 function _M.new(config)
-  local self = new()
+  local self = new(config)
   self.config = config or {}
   return self
 end

@@ -18,11 +18,11 @@
         "type": "string",
         "oneOf": [
           {
-            "const": "request",
+            "enum": ["request"],
             "description": "Interrupts the processing of the request."
           },
           {
-            "const": "set",
+            "enum": ["set"],
             "description": "Only skips the rewrite phase."
           }
         ]

@@ -22,15 +22,15 @@
               "type": "string",
               "oneOf": [
                 {
-                  "const": "add",
+                  "enum": ["add"],
                   "description": "Adds a value to an existing header."
                 },
                 {
-                  "const": "set",
+                  "enum": ["set"],
                   "description": "Creates the header when not set, replaces its value when set."
                 },
                 {
-                  "const": "push",
+                  "enum": ["push"],
                   "description": "Creates the header when not set, adds the value when set."
                 }
               ]

@@ -106,7 +106,7 @@ end
 --   2) When the header is set, it creates a new header with the same name and
 --      the given value.
 function _M.new(config)
-  local self = new()
+  local self = new(config)
   self.config = init_config(config)
   return self
 end

@@ -10,7 +10,7 @@ local resty_env = require('resty.env')
 local new = _M.new
 
 function _M.new(config)
-  local self = new()
+  local self = new(config)
   self.config = config or {}
   --- authorization for the token introspection endpoint.
   -- https://tools.ietf.org/html/rfc7662#section-2.2

@@ -23,11 +23,11 @@
               "type": "string",
               "oneOf": [
                 {
-                  "const": "sub",
+                  "enum": ["sub"],
                   "description": "Substitutes the first match of the regex applied."
                 },
                 {
-                  "const": "gsub",
+                  "enum": ["gsub"],
                   "description": "Substitutes all the matches of the regex applied."
                 }
               ]

@@ -57,7 +57,7 @@ end
 --   - break[opt]: defaults to false. When set to true, if the command rewrote
 --     the URL, it will be the last command applied.
 function _M.new(config)
-  local self = new()
+  local self = new(config)
   self.commands = (config and config.commands) or {}
   return self
 end

@@ -0,0 +1,20 @@
+--- Policy Config Validator
+-- @module policy_config_validator
+-- Validates a policy configuration against a policy config JSON schema.
+
+local jsonschema = require('jsonschema')
+
+local _M = { }
+
+--- Validate a policy configuration
+-- Checks if a policy configuration is valid according to the given schema.
+-- @tparam table config Policy configuration
+-- @tparam table config_schema Policy configuration schema
+-- @treturn boolean True if the policy configuration is valid. False otherwise.
+-- @treturn string Error message only when the policy config is invalid.
+function _M.validate_config(config, config_schema)
+  local validator = jsonschema.generate_validator(config_schema or {})
+  return validator(config or {})
+end
+
+return _M
@@ -14,6 +14,8 @@ local insert = table.insert
 local setmetatable = setmetatable
 local pcall = pcall
 
+local policy_config_validator = require('apicast.policy_config_validator')
+
 local _M = {}
 
 local resty_env = require('resty.env')
@@ -38,6 +40,15 @@ do
   end
 end
 
+-- Returns true if config validation has been enabled via ENV or if we are
+-- running Test::Nginx integration tests. We know that the framework always
+-- sets TEST_NGINX_BINARY so we can use it to detect whether we are running the
+-- tests.
+local function policy_config_validation_is_enabled()
+  return resty_env.enabled('APICAST_VALIDATE_POLICY_CONFIGS')
+    or resty_env.value('TEST_NGINX_BINARY')
+end
+
 local function read_manifest(path)
   local handle = io.open(format('%s/%s', path, 'apicast-policy.json'))
 
@@ -71,43 +82,69 @@ local function load_manifest(name, version, path)
   return nil, lua_load_path(path)
 end
 
+local function with_config_validator(policy, policy_config_schema)
+  local original_new = policy.new
+
+  local new_with_validator = function(config)
+    local is_valid, err = policy_config_validator.validate_config(
+      config, policy_config_schema)
+
+    if not is_valid then
+      error(format('Invalid config for policy: %s', err))
+    end
+
+    return original_new(config)
+  end
+
+  return setmetatable(
+    { new = new_with_validator },
+    { __index = policy }
+  )
+end
+
 function _M:load_path(name, version, paths)
   local failures = {}
 
   for _, path in ipairs(paths or self.policy_load_paths()) do
-    local ok, load_path = load_manifest(name, version, format('%s/%s/%s', path, name, version) )
+    local manifest, load_path = load_manifest(name, version, format('%s/%s/%s', path, name, version) )
 
-    if ok then
-      return load_path
+    if manifest then
+      return load_path, manifest.configuration
     else
       insert(failures, load_path)
     end
   end
 
   if version == 'builtin' then
-    local ok, load_path = load_manifest(name, version, format('%s/%s', self.builtin_policy_load_path(), name) )
+    local manifest, load_path = load_manifest(name, version, format('%s/%s', self.builtin_policy_load_path(), name) )
 
-    if ok then
-      return load_path
+    if manifest then
+      return load_path, manifest.configuration
     else
       insert(failures, load_path)
     end
   end
 
-  return nil, failures
+  return nil, nil, failures
 end
 
 function _M:call(name, version, dir)
   local v = version or 'builtin'
-  local load_path, invalid_paths = self:load_path(name, v, dir)
+  local load_path, policy_config_schema, invalid_paths = self:load_path(name, v, dir)
 
   local loader = sandbox.new(load_path and { load_path } or invalid_paths)
 
   ngx.log(ngx.DEBUG, 'loading policy: ', name, ' version: ', v)
 
   -- passing the "exclusive" flag for the require so it does not fallback to native require
   -- it should load only policies and not other code and fail if there is no such policy
-  return loader('init', true)
+  local res = loader('init', true)
+
+  if policy_config_validation_is_enabled() then
+    return with_config_validator(res, policy_config_schema)
+  else
+    return res
+  end
 end
 
 function _M:pcall(name, version, dir)

@@ -24,16 +24,6 @@ describe('Caching policy', function()
       ctx.cache_handler(cache, 'a_key', { status = 200 }, nil)
       assert.is_nil(cache:get('a_key'))
     end)
-
-    it('disables caching when invalid caching type is specified', function()
-      local config = { caching_type = 'invalid_caching_type' }
-      local caching_policy = require('apicast.policy.caching').new(config)
-      local ctx = {}
-      caching_policy:rewrite(ctx)
-
-      ctx.cache_handler(cache, 'a_key', { status = 200 }, nil)
-      assert.is_nil(cache:get('a_key'))
-    end)
   end)
 
   describe('.access', function()

@@ -0,0 +1,58 @@
+local cjson = require('cjson')
+local policy_config_validator = require('apicast.policy_config_validator')
+
+describe('policy_config_validator', function()
+  -- We use the echo policy schema as an example for the tests.
+  local test_config_schema = cjson.decode([[
+    {
+      "type": "object",
+      "properties": {
+        "status": {
+          "description": "HTTP status code to be returned",
+          "type": "integer"
+        },
+        "exit": {
+          "description": "Exit mode",
+          "type": "string",
+          "oneOf": [{
+              "enum": ["request"],
+              "description": "Interrupts the processing of the request."
+            },
+            {
+              "enum": ["set"],
+              "description": "Only skips the rewrite phase."
+            }
+          ]
+        }
+      }
+    }
+  ]])
+
+  it('returns true with a config that conforms with the schema', function()
+    local valid_config = { status = 200, exit = "request" }
+
+    local is_valid, err = policy_config_validator.validate_config(
+      valid_config, test_config_schema)
+
+    assert.is_true(is_valid)
+    assert.is_nil(err)
+  end)
+
+  it('returns false with a config that does not conform with the schema', function()
+    local invalid_config = { status = "not_an_integer" }
+
+    local is_valid, err = policy_config_validator.validate_config(
+      invalid_config, test_config_schema)
+
+    assert.is_false(is_valid)
+    assert.is_not_nil(err)
+  end)
+
+  it('returns true when the schema is empty', function()
+    assert.is_true(policy_config_validator.validate_config({ a_param = 1 }, {}))
+  end)
+
+  it('returns true when the schema is nil', function()
+    assert.is_true(policy_config_validator.validate_config({ a_param = 1 }, nil))
+  end)
+end)
@@ -38,6 +38,9 @@ local function reset()
 
   previous_env = {}
 
+  -- To make sure that we are using valid policy configs in the tests.
+  set('APICAST_VALIDATE_POLICY_CONFIGS', true)
+
   env.reset()
 end