Merge pull request #263 from kube-tarian/plugins-api-impl

get capten plugins apis implementation

capten/agent/pkg/agent/get_capten_plugins.go

@@ -0,0 +1,42 @@
+package agent
+
+import (
+	"context"
+
+	"github.com/kube-tarian/kad/capten/agent/pkg/pb/captenpluginspb"
+)
+
+func (a *Agent) GetCaptenPlugins(ctx context.Context, request *captenpluginspb.GetCaptenPluginsRequest) (
+	*captenpluginspb.GetCaptenPluginsResponse, error) {
+	a.log.Infof("Get Capten Plugins %s request recieved")
+
+	res, err := a.as.GetAllApps()
+	if err != nil {
+		return &captenpluginspb.GetCaptenPluginsResponse{
+			Status:        captenpluginspb.StatusCode_INTERNAL_ERROR,
+			StatusMessage: "failed to fetch pluginss",
+		}, nil
+	}
+
+	plugins := make([]*captenpluginspb.CaptenPlugin, 0)
+	for _, r := range res {
+		appConfig := r.GetConfig()
+		if len(appConfig.PluginName) == 0 {
+			continue
+		}
+
+		plugins = append(plugins, &captenpluginspb.CaptenPlugin{
+			PluginName:        r.GetConfig().GetPluginName(),
+			PluginDescription: r.GetConfig().GetPluginDescription(),
+			LaunchIcon:        r.GetConfig().GetIcon(),
+			LaunchURL:         r.GetConfig().GetLaunchURL(),
+			InstallStatus:     r.GetConfig().GetInstallStatus(),
+			RuntimeStatus:     r.GetConfig().GetRuntimeStatus(),
+		})
+	}
+
+	a.log.Infof("Fetched %d capten plugins", len(plugins))
+	return &captenpluginspb.GetCaptenPluginsResponse{Status: captenpluginspb.StatusCode_OK,
+		StatusMessage: "successfully fetched plugin",
+		Plugins:       plugins}, nil
+}

charts/server/Chart.yaml

@@ -15,10 +15,10 @@ type: application
 # This is the chart version. This version number should be incremented each time you make changes
 # to the chart and its templates, including the app version.
 # Versions are expected to follow Semantic Versioning (https://semver.org/)
-version: 0.1.23
+version: 0.1.24
 
 # This is the version number of the application being deployed. This version number should be
 # incremented each time you make changes to the application. Versions are not expected to
 # follow Semantic Versioning. They should reflect the version the application is using.
 # It is recommended to use it with quotes.
-appVersion: "1.23.0"
+appVersion: "1.24.0"

charts/server/templates/deployment.yaml

@@ -61,14 +61,6 @@ spec:
               value: "{{ .Values.astra.entityName }}"
             - name: ASTRA_CRED_IDENTIFIER
               value: "{{ .Values.astra.credIdentifier }}"
-            - name: CASSANDRA_ADDRESSES
-              value: "{{ .Values.cassandra.dbAddresses }}"
-            - name: CASSANDRA_SERVICE_USERNAME
-              value: "{{ .Values.cassandra.dbUserName }}"
-            - name: CASSANDRA_ENTITY_NAME
-              value: "{{ .Values.cassandra.entityName }}"
-            - name: CASSANDRA_DB_NAME
-              value: "{{ .Values.cassandra.dbName }}"
             - name: ORY_ENTITY_NAME
               value: {{ .Values.ory.entityName }}
             - name: ORY_CRED_IDENTIFIER

charts/server/values.yaml

@@ -14,12 +14,6 @@ vault:
   role: vault-role-capten-server
   policyNames: "vault-policy-certs-admin,vault-policy-service-cred-read,vault-policy-generic-cred-admin"
 
-cassandra:
-  dbAddresses: cassandra.cassandra.svc.cluster.local
-  dbUserName: admin
-  entityName: cassandra
-  dbName: capten-server
-
 iam:
   address: iam:9091
 
@@ -61,10 +55,12 @@ serviceAccount:
 
 podAnnotations: {}
 
-podSecurityContext: {}
+podSecurityContext:
+  {}
   # fsGroup: 2000
 
-securityContext: {}
+securityContext:
+  {}
   # capabilities:
   #   drop:
   #   - ALL
@@ -80,7 +76,8 @@ service:
 ingress:
   enabled: false
   className: ""
-  annotations: {}
+  annotations:
+    {}
     # kubernetes.io/ingress.class: nginx
     # kubernetes.io/tls-acme: "true"
   hosts:
@@ -93,7 +90,8 @@ ingress:
   #    hosts:
   #      - chart-example.local
 
-resources: {}
+resources:
+  {}
   # We usually recommend not to specify default resources and to leave this as a conscious
   # choice for the user. This also increases chances charts run on environments with little
   # resources, such as Minikube. If you do want to specify resources, uncomment the following

proto/agent.proto

@@ -203,6 +203,8 @@ message AppConfig {
   string runtimeStatus = 16;
   bool defualtApp = 17;
   string lastUpdateTime = 18;
+  string pluginName = 19;
+  string pluginDescription = 20;
 }
 
 message AppValues {

proto/capten_plugins.proto

@@ -228,7 +228,9 @@ message CaptenPlugin {
     string pluginName = 1;
     string pluginDescription = 2;
     string launchURL = 3;
-    string launchIcon = 4;    
+    bytes launchIcon = 4;
+    string installStatus = 5;
+    string runtimeStatus = 6;
 }
 
 message GetCaptenPluginsRequest {

server/data/store-apps/conf/argo-cd-v1.0.0.yaml

@@ -9,6 +9,8 @@ ReleaseName: "argo-cd"
 Icon: "argo-cd.svg"
 Version: "1.0.0"
 CreateNamespace: true
+PluginName: ArgoCD
+PluginDescription: "Configure ArgoCD projects and resources"
 LaunchURL: https://argo.{{.DomainName}}
 LaunchUIDescription: "Intelops ArgoCD"
 LaunchUIIcon: "argo-cd.svg"

server/data/store-apps/conf/crossplane-v1.0.0.yaml

@@ -8,5 +8,7 @@ Namespace: "crossplane-system"
 ReleaseName: "crossplane"
 Version: "1.0.0"
 CreateNamespace: true
+PluginName: "Crossplane"
+PluginDescription: "Configure Infra with Crossplane"
 OverrideValues:
   DomainName: "{{.DomainName}}"

server/data/store-apps/conf/tekton-v0.1.1.yaml

@@ -7,4 +7,6 @@ RepoURL: "https://kube-tarian.github.io/helmrepo-supporting-tools"
 Namespace: "tekton"
 ReleaseName: "tekton"
 Version: "0.1.1"
-CreateNamespace: true
+PluginName: "Tekton"
+PluginDescription: "Configure Build pipeline with Tekton"
+CreateNamespace: true

server/pkg/api/get_capten_plugins.go

@@ -0,0 +1,40 @@
+package api
+
+import (
+	"context"
+
+	"github.com/kube-tarian/kad/server/pkg/pb/captenpluginspb"
+)
+
+func (s *Server) GetCaptenPlugins(ctx context.Context, request *captenpluginspb.GetCaptenPluginsRequest) (
+	*captenpluginspb.GetCaptenPluginsResponse, error) {
+	orgId, clusterId, err := validateOrgClusterWithArgs(ctx)
+	if err != nil {
+		s.log.Infof("request validation failed", err)
+		return &captenpluginspb.GetCaptenPluginsResponse{
+			Status:        captenpluginspb.StatusCode_INVALID_ARGUMENT,
+			StatusMessage: "request validation failed",
+		}, nil
+	}
+	s.log.Infof("Get Capten Plugins %s request for cluster %s recieved, [org: %s]",
+		clusterId, orgId)
+
+	a, err := s.agentHandeler.GetAgent(orgId, clusterId)
+	if err != nil {
+		s.log.Error("failed to connect to agent", err)
+		return &captenpluginspb.GetCaptenPluginsResponse{Status: captenpluginspb.StatusCode_INTERNAL_ERROR,
+			StatusMessage: "failed to connect to agent"}, nil
+	}
+
+	resp, err := a.GetCaptenPluginsClient().GetCaptenPlugins(ctx, &captenpluginspb.GetCaptenPluginsRequest{})
+	if err != nil {
+		s.log.Error("failed to get cluster capten plugins from agent", err)
+		return &captenpluginspb.GetCaptenPluginsResponse{Status: captenpluginspb.StatusCode_INTERNAL_ERROR,
+			StatusMessage: "failed to get cluster application from agent"}, nil
+	}
+
+	s.log.Infof("Fetched %d capten plugins from the cluster %s, [org: %s]", len(resp.Plugins), clusterId, orgId)
+	return &captenpluginspb.GetCaptenPluginsResponse{Status: captenpluginspb.StatusCode_OK,
+		StatusMessage: "successfully fetched the data from agent",
+		Plugins:       resp.Plugins}, nil
+}