From d8d791c525627ed977fd8d5454a6f0771c298256 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Charles-Edouard=20Br=C3=A9t=C3=A9ch=C3=A9?=
 <charles.edouard@nirmata.com>
Date: Sun, 9 Jun 2024 23:46:19 +0200
Subject: [PATCH] feat: add external bindings support to the engine
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Signed-off-by: Charles-Edouard Brétéché <charles.edouard@nirmata.com>
---
 pkg/json-engine/engine.go | 13 ++++++++++++-
 1 file changed, 12 insertions(+), 1 deletion(-)

diff --git a/pkg/json-engine/engine.go b/pkg/json-engine/engine.go
index 700f1e1a2..aa50cd776 100644
--- a/pkg/json-engine/engine.go
+++ b/pkg/json-engine/engine.go
@@ -3,6 +3,7 @@ package jsonengine
 import (
 	"context"
 	"fmt"
+	"time"
 
 	jpbinding "github.com/jmespath-community/go-jmespath/pkg/binding"
 	"github.com/kyverno/kyverno-json/pkg/apis/policy/v1alpha1"
@@ -16,6 +17,7 @@ import (
 type Request struct {
 	Resource any
 	Policies []*v1alpha1.ValidatingPolicy
+	Bindings map[string]any
 }
 
 type Response struct {
@@ -30,6 +32,7 @@ type PolicyResponse struct {
 
 type RuleResponse struct {
 	Rule       v1alpha1.ValidatingRule
+	Timestamp  time.Time
 	Identifier string
 	Error      error
 	Violations matching.Results
@@ -75,6 +78,7 @@ func New() engine.Engine[Request, Response] {
 				if err != nil {
 					return []RuleResponse{{
 						Rule:       r.rule,
+						Timestamp:  time.Now(),
 						Identifier: identifier,
 						Error:      err,
 					}}
@@ -89,6 +93,7 @@ func New() engine.Engine[Request, Response] {
 				if err != nil {
 					return []RuleResponse{{
 						Rule:       r.rule,
+						Timestamp:  time.Now(),
 						Identifier: identifier,
 						Error:      err,
 					}}
@@ -102,12 +107,14 @@ func New() engine.Engine[Request, Response] {
 			if err != nil {
 				return []RuleResponse{{
 					Rule:       r.rule,
+					Timestamp:  time.Now(),
 					Identifier: identifier,
 					Error:      err,
 				}}
 			}
 			return []RuleResponse{{
 				Rule:       r.rule,
+				Timestamp:  time.Now(),
 				Identifier: identifier,
 				Violations: violations,
 			}}
@@ -132,7 +139,11 @@ func New() engine.Engine[Request, Response] {
 			response := Response{
 				Resource: r.Resource,
 			}
-			bindings := jpbinding.NewBindings().Register("$payload", jpbinding.NewBinding(r.Resource))
+			bindings := jpbinding.NewBindings()
+			for k, v := range r.Bindings {
+				bindings = bindings.Register("$"+k, jpbinding.NewBinding(v))
+			}
+			bindings = bindings.Register("$payload", jpbinding.NewBinding(r.Resource))
 			for _, policy := range r.Policies {
 				response.Policies = append(response.Policies, policyEngine.Run(ctx, policyRequest{
 					policy:   policy,