feat: add json schema conditional validations (#65)

* feat: add json schema conditional validations

* test: add JSONSchema tests

* fix: linting issues

* fix: remove unnecessary imports

* fix(kubernetes): add check for host field for URI format and http/s prefix

Co-authored-by: Rohil Surana <[email protected]>

Author: ishanarya0

modules/kubernetes/config_schema.json

@@ -4,7 +4,9 @@
   "type": "object",
   "properties": {
     "host": {
-      "type": "string"
+      "type": "string",
+      "format": "uri",
+      "pattern": "^https?://"
     },
     "insecure": {
       "type": "boolean",
@@ -27,7 +29,53 @@
       "default": 100000000
     }
   },
-  "required": [
-    "host"
+  "allOf": [
+    {
+      "oneOf": [
+        {
+          "required": [
+            "token"
+          ]
+        },
+        {
+          "allOf": [
+            {
+              "required": [
+                "client_key"
+              ]
+            },
+            {
+              "required": [
+                "client_certificate"
+              ]
+            }
+          ]
+        }
+      ]
+    },
+    {
+      "oneOf": [
+        {
+          "required": [
+            "cluster_ca_certificate"
+          ]
+        },
+        {
+          "properties": {
+            "insecure": {
+              "const": true
+            }
+          },
+          "required": [
+            "insecure"
+          ]
+        }
+      ]
+    },
+    {
+      "required": [
+        "host"
+      ]
+    }
   ]
 }

modules/kubernetes/config_schema_test.go

@@ -0,0 +1,113 @@
+package kubernetes
+
+import (
+	"errors"
+	"testing"
+
+	"github.com/stretchr/testify/assert"
+	"github.com/xeipuuv/gojsonschema"
+)
+
+func TestModule_KubernetesJSONSchema(t *testing.T) {
+	tests := []struct {
+		Case    string
+		wantErr error
+		want    bool
+	}{
+		{
+			Case: `{
+				"host": "http://0.0.0.0:1234",
+				"insecure": true,
+				"token": "token"
+			}`,
+			wantErr: nil,
+			want:    true,
+		},
+		{
+			Case: `{
+				"host": "http://0.0.0.0:1234",
+				"insecure": false,
+				"token": "token"
+			  }`,
+			wantErr: nil,
+			want:    false,
+		},
+		{
+			Case: `{
+				"host": "http://0.0.0.0:1234",
+				"insecure": false,
+				"cluster_ca_certificate": "c_ca_cert",
+				"token": "token"
+			  }`,
+			wantErr: nil,
+			want:    true,
+		},
+		{
+			Case: `{
+				"host": "http://0.0.0.0:1234",
+				"cluster_ca_certificate": "c_ca_cert",
+				"token": "token"
+			  }`,
+			wantErr: nil,
+			want:    true,
+		},
+		{
+			Case: `{
+				"host": "http://0.0.0.0:1234",
+				"insecure": true,
+				"client_key": "c_key",
+				"client_certificate": "c_cert"
+			  }`,
+			wantErr: nil,
+			want:    true,
+		},
+		{
+			Case: `  "host": "http://0.0.0.0:1234",
+			"insecure": true,
+			"client_key": "c_key"
+		  }`,
+			wantErr: nil,
+			want:    false,
+		},
+		{
+			Case: `{
+				"host": "http://0.0.0.0:1234",
+				"insecure": true,
+				"token": "token",
+				"client_key": "c_key",
+				"client_certificate": "c_cert"
+			  }`,
+			wantErr: nil,
+			want:    false,
+		},
+		{
+			Case: `{
+				"host": "http://0.0.0.0:1234",
+				"insecure": true,
+				"token": "token",
+				"client_key": "c_key"
+			  }`,
+			wantErr: nil,
+			want:    true,
+		},
+	}
+	loader := gojsonschema.NewStringLoader(configSchema)
+	schema, _ := gojsonschema.NewSchema(loader)
+
+	for _, tt := range tests {
+		tt := tt
+		t.Run(tt.Case, func(t *testing.T) {
+			t.Parallel()
+
+			c := gojsonschema.NewStringLoader(tt.Case)
+			result, err := schema.Validate(c)
+			if tt.wantErr != nil {
+				assert.Error(t, err)
+				assert.True(t, errors.Is(err, tt.wantErr))
+			} else {
+				assert.NoError(t, err)
+			}
+			assert.Equal(t, tt.want, result.Valid())
+		})
+	}
+}