feat: Add playground mode check to allow plugins to exit early based on environment variable.

Author: osmontero

plugins/aws/main.go

@@ -5,6 +5,7 @@ import (
 	"errors"
 	"fmt"
 	"net/http"
+	"os"
 	"runtime"
 	"strings"
 	"time"
@@ -38,6 +39,10 @@ var (
 )
 
 func main() {
+	if os.Getenv("PLAYGROUND") == "true" {
+		return
+	}
+
 	mode := plugins.GetCfg("plugin_com.utmstack.aws").Env.Mode
 	if mode != "manager" {
 		return

plugins/azure/main.go

@@ -6,6 +6,7 @@ import (
 	"errors"
 	"fmt"
 	"net/http"
+	"os"
 	"runtime"
 	"strings"
 	"sync"
@@ -65,6 +66,10 @@ var SupportedClouds = []CloudEndpoints{
 }
 
 func main() {
+	if os.Getenv("PLAYGROUND") == "true" {
+		return
+	}
+
 	mode := plugins.GetCfg("plugin_com.utmstack.azure").Env.Mode
 	if mode != "worker" {
 		return

plugins/bitdefender/main.go

@@ -1,6 +1,7 @@
 package main
 
 import (
+	"os"
 	"runtime"
 
 	"github.com/threatwinds/go-sdk/plugins"
@@ -10,6 +11,10 @@ import (
 )
 
 func main() {
+	if os.Getenv("PLAYGROUND") == "true" {
+		return
+	}
+
 	mode := plugins.GetCfg("plugin_com.utmstack.bitdefender").Env.Mode
 	if mode != "manager" {
 		return

plugins/config/main.go

@@ -234,6 +234,10 @@ func (f *Filter) FromVar(id int, name any, filter any) {
 }
 
 func main() {
+	if os.Getenv("PLAYGROUND") == "true" {
+		return
+	}
+
 	for {
 		func() {
 			db, err := connect()

plugins/crowdStrike/main.go

@@ -5,6 +5,7 @@ import (
 	"encoding/json"
 	"errors"
 	"fmt"
+	"os"
 	"runtime"
 	"strings"
 	"sync"
@@ -27,6 +28,10 @@ const (
 )
 
 func main() {
+	if os.Getenv("PLAYGROUND") == "true" {
+		return
+	}
+
 	mode := plugins.GetCfg("plugin_com.utmstack.crowdstrike").Env.Mode
 	if mode != "manager" {
 		return

plugins/gcp/main.go

@@ -29,6 +29,10 @@ type GroupModule struct {
 }
 
 func main() {
+	if os.Getenv("PLAYGROUND") == "true" {
+		return
+	}
+
 	mode := plugins.GetCfg("plugin_com.utmstack.gcp").Env.Mode
 	if mode != "worker" {
 		return

plugins/inputs/main.go

@@ -16,6 +16,10 @@ const defaultTenant string = "ce66672c-e36d-4761-a8c8-90058fee1a24"
 var localLogsChannel chan *plugins.Log
 
 func main() {
+	if os.Getenv("PLAYGROUND") == "true" {
+		return
+	}
+
 	mode := plugins.GetCfg("plugin_com.utmstack.inputs").Env.Mode
 	if mode != "worker" {
 		return

plugins/o365/main.go

@@ -5,6 +5,7 @@ import (
 	"fmt"
 	"net/http"
 	"net/url"
+	"os"
 	"runtime"
 	"strings"
 	"sync"
@@ -70,6 +71,10 @@ func GetCloudConfig(env CloudEnvironment) CloudConfig {
 }
 
 func main() {
+	if os.Getenv("PLAYGROUND") == "true" {
+		return
+	}
+
 	mode := plugins.GetCfg("plugin_com.utmstack.o365").Env.Mode
 	if mode != "manager" {
 		return

plugins/sophos/main.go

@@ -5,6 +5,7 @@ import (
 	"fmt"
 	"net/http"
 	"net/url"
+	"os"
 	"runtime"
 	"strings"
 	"sync"
@@ -32,6 +33,10 @@ var (
 )
 
 func main() {
+	if os.Getenv("PLAYGROUND") == "true" {
+		return
+	}
+
 	mode := plugins.GetCfg("plugin_com.utmstack.sophos").Env.Mode
 	if mode != "manager" {
 		return

plugins/threadwinds-ingestion/main.go

@@ -19,6 +19,10 @@ const (
 )
 
 func main() {
+	if os.Getenv("PLAYGROUND") == "true" {
+		return
+	}
+
 	mode := plugins.GetCfg("plugin_com.utmstack.threadwinds-ingestion").Env.Mode
 	if mode != "manager" {
 		return