refactor backend

cmd/run-server.go

@@ -2,17 +2,13 @@ package main
 
 import (
 	"sighupio/permission-manager/internal/config"
-	"sighupio/permission-manager/internal/kubeclient"
-	"sighupio/permission-manager/internal/resources"
 	"sighupio/permission-manager/internal/server"
 )
 
 func main() {
 	cfg := config.New()
-	kc := kubeclient.New()
-	rs := resources.NewResourcesService(kc)
 
-	s := server.New(kc, cfg, rs)
-	addr := ":" + cfg.Port
+	s := server.New(*cfg)
+	addr := ":" + cfg.Backend.Port
 	s.Logger.Fatal(s.Start(addr))
 }

internal/config/config.go

@@ -5,34 +5,42 @@ import (
 	"os"
 )
 
+type ClusterConfig struct {
+	Name                string
+	ControlPlaneAddress string
+}
+
+type BackendConfig struct {
+	Port string
+}
+
+// Config contains PermissionManager cluster/server configuration
 type Config struct {
-	ClusterName                string
-	ClusterControlPlaceAddress string
-	Port                       string
+	Cluster ClusterConfig
+	Backend BackendConfig
 }
 
 func New() *Config {
-	cfg := &Config{}
+	cfg := &Config{
+		Cluster: ClusterConfig{
+			Name:                os.Getenv("CLUSTER_NAME"),
+			ControlPlaneAddress: os.Getenv("CONTROL_PLANE_ADDRESS"),
+		},
+		Backend: BackendConfig{
+			Port: os.Getenv("PORT"),
+		},
+	}
 
-	port := os.Getenv("PORT")
-	if port == "" {
+	if cfg.Backend.Port == "" {
 		log.Fatal("PORT env cannot be empty")
-	} else {
-		cfg.Port = port
 	}
 
-	clusterName := os.Getenv("CLUSTER_NAME")
-	if clusterName == "" {
+	if cfg.Cluster.Name == "" {
 		log.Fatal("CLUSTER_NAME env cannot be empty")
-	} else {
-		cfg.ClusterName = clusterName
 	}
 
-	clusterControlPlaceAddress := os.Getenv("CONTROL_PLANE_ADDRESS")
-	if clusterControlPlaceAddress == "" {
+	if cfg.Cluster.ControlPlaneAddress == "" {
 		log.Fatal("CONTROL_PLANE_ADDRESS env cannot be empty")
-	} else {
-		cfg.ClusterControlPlaceAddress = clusterControlPlaceAddress
 	}
 
 	return cfg

internal/config/config_test.go

@@ -12,9 +12,9 @@ func ExampleNew() {
 	os.Setenv("CONTROL_PLANE_ADDRESS", "https://192.168.64.33:8443")
 	cfg := config.New()
 
-	fmt.Println(cfg.Port)
-	fmt.Println(cfg.ClusterName)
-	fmt.Println(cfg.ClusterControlPlaceAddress)
+	fmt.Println(cfg.Backend.Port)
+	fmt.Println(cfg.Cluster.Name)
+	fmt.Println(cfg.Cluster.ControlPlaneAddress)
 
 	// Output:
 	// 4000

internal/crd/v1alpha1/permissionmanageruser_types.go

@@ -0,0 +1,25 @@
+package v1alpha1
+
+import metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+
+const (
+	ResourceURL    = "apis/permissionmanager.user/v1alpha1/permissionmanagerusers"
+	ResourcePrefix = "permissionmanagerusers.permissionmanager.user."
+)
+
+type PermissionManagerUserSpec struct {
+	Name string `json:"name"`
+}
+
+// PermissionManagerUser is the PermissionManager representation of an user of the managed K8s cluster
+type PermissionManagerUser struct {
+	metav1.TypeMeta `json:",inline"`
+	Metadata        metav1.ObjectMeta         `json:"metadata,omitempty"`
+	Spec            PermissionManagerUserSpec `json:"spec"`
+}
+
+type PermissionManagerUserList struct {
+	metav1.TypeMeta `json:",inline"`
+	metav1.ListMeta `json:"metadata,omitempty"`
+	Items           []PermissionManagerUser `json:"items"`
+}