fix[backend](integrations): fixed plugins yaml files integration format to match event processor expected format

Author: AlexSanchez-bit

backend/modules/integrations/repository/tenant_store.go

@@ -37,18 +37,31 @@ var pluginNames = map[string]string{
 	"SOPHOS":       "sophos",
 }
 
-func tenantFileName(module string) string {
+func pluginKey(module string) string {
 	name, ok := pluginNames[strings.ToUpper(module)]
 	if !ok {
 		name = strings.ToLower(module)
 	}
-	return "system_plugins_" + name + ".yaml"
+	return name
+}
+
+func tenantFileName(module string) string {
+	return "system_plugins_" + pluginKey(module) + ".yaml"
 }
 
 func (s *TenantStore) path(module string) string {
 	return filepath.Join(s.dir, tenantFileName(module))
 }
 
+// pluginsFile is the on-disk wrapper: plugins.<name>.tenants: [...].
+type pluginsFile struct {
+	Plugins map[string]pluginEntry `yaml:"plugins"`
+}
+
+type pluginEntry struct {
+	Tenants []domain.Tenant `yaml:"tenants"`
+}
+
 func (s *TenantStore) SetActiveByModule(_ context.Context, module string, active bool) error {
 	if active {
 		return nil
@@ -70,18 +83,24 @@ func (s *TenantStore) Load(module string) ([]domain.Tenant, error) {
 	if err != nil {
 		return nil, err
 	}
-	var tenants []domain.Tenant
-	if err := yaml.Unmarshal(data, &tenants); err != nil {
+	var pf pluginsFile
+	if err := yaml.Unmarshal(data, &pf); err != nil {
 		return nil, err
 	}
-	return tenants, nil
+	entry, ok := pf.Plugins[pluginKey(module)]
+	if !ok {
+		return []domain.Tenant{}, nil
+	}
+	return entry.Tenants, nil
 }
 
 func (s *TenantStore) Save(module string, tenants []domain.Tenant) error {
 	if err := os.MkdirAll(s.dir, 0o755); err != nil {
 		return err
 	}
-	data, err := yaml.Marshal(tenants)
+	key := pluginKey(module)
+	pf := pluginsFile{Plugins: map[string]pluginEntry{key: {Tenants: tenants}}}
+	data, err := yaml.Marshal(pf)
 	if err != nil {
 		return err
 	}

backend/modules/integrations/repository/tenant_store_test.go

@@ -0,0 +1,48 @@
+package repository
+
+import (
+	"os"
+	"strings"
+	"testing"
+
+	"github.com/utmstack/utmstack/backend/modules/integrations/domain"
+)
+
+func TestTenantStoreRoundtrip(t *testing.T) {
+	dir := t.TempDir()
+	s := NewTenantStore(dir)
+
+	want := []domain.Tenant{
+		{Name: "t1", Config: map[string]string{"access_key": "AK", "secret": "SK"}},
+		{Name: "t2", Config: map[string]string{"access_key": "AK2"}},
+	}
+	if err := s.Save("AWS_IAM_USER", want); err != nil {
+		t.Fatalf("Save: %v", err)
+	}
+	got, err := s.Load("AWS_IAM_USER")
+	if err != nil {
+		t.Fatalf("Load: %v", err)
+	}
+	if len(got) != len(want) {
+		t.Fatalf("len(got)=%d want %d", len(got), len(want))
+	}
+	for i := range want {
+		if got[i].Name != want[i].Name {
+			t.Fatalf("[%d] name got %q want %q", i, got[i].Name, want[i].Name)
+		}
+		for k, v := range want[i].Config {
+			if got[i].Config[k] != v {
+				t.Fatalf("[%d] %s got %q want %q", i, k, got[i].Config[k], v)
+			}
+		}
+	}
+
+	data, err := os.ReadFile(s.path("AWS_IAM_USER"))
+	if err != nil {
+		t.Fatalf("read: %v", err)
+	}
+	txt := string(data)
+	if !strings.Contains(txt, "plugins:") || !strings.Contains(txt, "aws:") || !strings.Contains(txt, "tenants:") {
+		t.Fatalf("unexpected file layout:\n%s", txt)
+	}
+}