PoC dsl (no parsing at this point)

Author: jotak

pkg/dsl/dsl.go

@@ -0,0 +1,56 @@
+package dsl
+
+import (
+	"github.com/netobserv/flowlogs-pipeline/pkg/api"
+	"github.com/netobserv/flowlogs-pipeline/pkg/config"
+	"github.com/netobserv/flowlogs-pipeline/pkg/utils/filters"
+)
+
+type Node struct {
+	op        string
+	leaf      *api.KeepEntryRule
+	children  []*Node
+	predicate filters.Predicate
+}
+
+func Parse(s string) Node {
+	return Node{}
+}
+
+func (n *Node) Preprocess() error {
+	if n.leaf != nil {
+		p, err := filters.FromKeepEntry(n.leaf)
+		if err != nil {
+			return err
+		}
+		n.predicate = p
+		return nil
+	}
+	for _, child := range n.children {
+		err := child.Preprocess()
+		if err != nil {
+			return err
+		}
+	}
+	return nil
+}
+
+func (n *Node) Apply(flow config.GenericMap) bool {
+	if n.leaf != nil {
+		return n.predicate(flow)
+	}
+	if n.op == "and" {
+		for _, child := range n.children {
+			if !child.Apply(flow) {
+				return false
+			}
+		}
+		return true
+	}
+	for _, child := range n.children {
+		if child.Apply(flow) {
+			return true
+		}
+	}
+	return false
+}

pkg/dsl/dsl_test.go

@@ -0,0 +1,85 @@
+package dsl
+
+import (
+	"testing"
+
+	"github.com/netobserv/flowlogs-pipeline/pkg/api"
+	"github.com/netobserv/flowlogs-pipeline/pkg/config"
+	"github.com/stretchr/testify/assert"
+)
+
+func Test(t *testing.T) {
+	n := Node{
+		op: "and",
+		children: []*Node{
+			{
+				op: "or",
+				children: []*Node{
+					{
+						leaf: &api.KeepEntryRule{
+							Type: api.KeepEntryIfEqual,
+							KeepEntry: &api.TransformFilterGenericRule{
+								Input: "srcnamespace",
+								Value: "netobserv",
+							},
+						},
+					},
+					{
+						op: "and",
+						children: []*Node{
+							{
+								leaf: &api.KeepEntryRule{
+									Type: api.KeepEntryIfEqual,
+									KeepEntry: &api.TransformFilterGenericRule{
+										Input: "srcnamespace",
+										Value: "ingress",
+									},
+								},
+							},
+							{
+								leaf: &api.KeepEntryRule{
+									Type: api.KeepEntryIfEqual,
+									KeepEntry: &api.TransformFilterGenericRule{
+										Input: "dstnamespace",
+										Value: "netobserv",
+									},
+								},
+							},
+						},
+					},
+				},
+			},
+			{
+				leaf: &api.KeepEntryRule{
+					Type: api.KeepEntryIfEqual,
+					KeepEntry: &api.TransformFilterGenericRule{
+						Input: "srckind",
+						Value: "pod",
+					},
+				},
+			},
+		},
+	}
+	n.Preprocess()
+
+	result := n.Apply(config.GenericMap{
+		"srcnamespace": "plop",
+		"dstnamespace": "netobserv",
+		"srckind":      "pod",
+	})
+	assert.False(t, result)
+
+	result = n.Apply(config.GenericMap{
+		"srcnamespace": "ingress",
+		"dstnamespace": "netobserv",
+		"srckind":      "pod",
+	})
+	assert.True(t, result)
+
+	result = n.Apply(config.GenericMap{
+		"srcnamespace": "ingress",
+		"dstnamespace": "netobserv",
+		"srckind":      "service",
+	})
+	assert.False(t, result)
+}