accumulator imp

.gitignore

@@ -1,3 +1,4 @@
 sniffer
 temp
-.vscode
+.vscode
+resources/ebpf/falco/*

go.mod

@@ -2,38 +2,18 @@ module sniffer
 
 go 1.19
 
-require (
-	github.com/kubescape/go-logger v0.0.8
-	k8s.io/apimachinery v0.26.1
-	k8s.io/client-go v0.26.1
-)
+require github.com/kubescape/go-logger v0.0.8
 
 require (
 	github.com/cenkalti/backoff/v4 v4.2.0 // indirect
-	github.com/davecgh/go-spew v1.1.1 // indirect
-	github.com/emicklei/go-restful/v3 v3.9.0 // indirect
 	github.com/fatih/color v1.13.0 // indirect
 	github.com/go-logr/logr v1.2.3 // indirect
 	github.com/go-logr/stdr v1.2.2 // indirect
-	github.com/go-openapi/jsonpointer v0.19.5 // indirect
-	github.com/go-openapi/jsonreference v0.20.0 // indirect
-	github.com/go-openapi/swag v0.19.14 // indirect
-	github.com/gogo/protobuf v1.3.2 // indirect
 	github.com/golang/protobuf v1.5.2 // indirect
-	github.com/google/gnostic v0.5.7-v3refs // indirect
-	github.com/google/go-cmp v0.5.9 // indirect
-	github.com/google/gofuzz v1.1.0 // indirect
 	github.com/grpc-ecosystem/grpc-gateway/v2 v2.15.0 // indirect
-	github.com/imdario/mergo v0.3.6 // indirect
-	github.com/josharian/intern v1.0.0 // indirect
-	github.com/json-iterator/go v1.1.12 // indirect
-	github.com/mailru/easyjson v0.7.6 // indirect
 	github.com/mattn/go-colorable v0.1.9 // indirect
 	github.com/mattn/go-isatty v0.0.14 // indirect
-	github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd // indirect
-	github.com/modern-go/reflect2 v1.0.2 // indirect
-	github.com/munnerz/goautoneg v0.0.0-20191010083416-a7dc8b61c822 // indirect
-	github.com/spf13/pflag v1.0.5 // indirect
+	github.com/pkg/errors v0.9.1 // indirect
 	github.com/uptrace/opentelemetry-go-extra/otelutil v0.1.18 // indirect
 	github.com/uptrace/opentelemetry-go-extra/otelzap v0.1.18 // indirect
 	github.com/uptrace/uptrace-go v1.11.8 // indirect
@@ -54,23 +34,9 @@ require (
 	go.uber.org/multierr v1.9.0 // indirect
 	go.uber.org/zap v1.24.0 // indirect
 	golang.org/x/net v0.5.0 // indirect
-	golang.org/x/oauth2 v0.3.0 // indirect
 	golang.org/x/sys v0.4.0 // indirect
-	golang.org/x/term v0.4.0 // indirect
 	golang.org/x/text v0.6.0 // indirect
-	golang.org/x/time v0.0.0-20220210224613-90d013bbcef8 // indirect
-	google.golang.org/appengine v1.6.7 // indirect
 	google.golang.org/genproto v0.0.0-20230106154932-a12b697841d9 // indirect
 	google.golang.org/grpc v1.51.0 // indirect
 	google.golang.org/protobuf v1.28.1 // indirect
-	gopkg.in/inf.v0 v0.9.1 // indirect
-	gopkg.in/yaml.v2 v2.4.0 // indirect
-	gopkg.in/yaml.v3 v3.0.1 // indirect
-	k8s.io/api v0.26.1 // indirect
-	k8s.io/klog/v2 v2.80.1 // indirect
-	k8s.io/kube-openapi v0.0.0-20221012153701-172d655c2280 // indirect
-	k8s.io/utils v0.0.0-20221107191617-1a15be271d1d // indirect
-	sigs.k8s.io/json v0.0.0-20220713155537-f223a00ba0e2 // indirect
-	sigs.k8s.io/structured-merge-diff/v4 v4.2.3 // indirect
-	sigs.k8s.io/yaml v1.3.0 // indirect
 )

internal/validator/validator.go

@@ -10,8 +10,8 @@ import (
 )
 
 const (
-	FALCO_EBPF_ENGINE_MIN_KERNEL_VERSION_SUPPORT     = "4.14"
-	KUBESCAPE_EBPF_ENGINE_MIN_KERNEL_VERSION_SUPPORT = "5.1"
+	FalcoEBPFEngineMinKernelVersionSupport     = "4.14"
+	KubescapeEBPFEngineMinKernelVersionSupport = "5.1"
 )
 
 var minKernelVersion string
@@ -44,9 +44,9 @@ func checkKernelVersion() error {
 
 func checkNodePrerequisites() error {
 	if config.GetConfigurationConfigContext().IsFalcoEbpfEngine() {
-		minKernelVersion = FALCO_EBPF_ENGINE_MIN_KERNEL_VERSION_SUPPORT
+		minKernelVersion = FalcoEBPFEngineMinKernelVersionSupport
 	} else {
-		minKernelVersion = KUBESCAPE_EBPF_ENGINE_MIN_KERNEL_VERSION_SUPPORT
+		minKernelVersion = KubescapeEBPFEngineMinKernelVersionSupport
 	}
 	err := checkKernelVersion()
 	if err != nil {

pkg/config/config.go

@@ -9,16 +9,17 @@ import (
 )
 
 const (
-	FALCO_EBPF_ENGINE  = "falco"
-	CILIUM_EBPF_ENGINE = "cilium"
+	EBPFEngineFalco  = "falco"
+	EBPFEngineCilium = "cilium"
+	CONFIG_ENV_VAR   = "CONFIG_ENV_VAR"
 )
 
 type Config struct {
 	data ConfigDataInterface
 }
 
 func (cfg *Config) getConfigFilePath() (string, bool) {
-	return os.LookupEnv("SNIFFER_CONFIG")
+	return os.LookupEnv(CONFIG_ENV_VAR)
 }
 
 func (cfg *Config) GetConfigurationReader() (io.Reader, error) {

pkg/config/config_test.go

@@ -2,14 +2,17 @@ package config
 
 import (
 	"os"
+	"path"
 	v1 "sniffer/pkg/config/v1"
+	"sniffer/pkg/utils"
 	"testing"
 )
 
 func TestConfig(t *testing.T) {
-	err := os.Setenv("SNIFFER_CONFIG", "../../configuration/ConfigurationFile.json")
+	configPath := path.Join(utils.CurrentDir(), "..", "..", "configuration", "ConfigurationFile.json")
+	err := os.Setenv(CONFIG_ENV_VAR, configPath)
 	if err != nil {
-		t.Fatalf("failed to set env SNIFFER_CONFIG with err %v", err)
+		t.Fatalf("failed to set env %s with err %v", CONFIG_ENV_VAR, err)
 	}
 
 	cfg := GetConfigurationConfigContext()