Feat ExternalApp, fix message office GRPC Authentication

apps/console/internal/app/graph/struct-to-graphql/common-types.graphqls

@@ -636,6 +636,13 @@ enum Github__com___kloudlite___api___apps___console___internal___entities__PullS
   params
 }
 
+enum Github__com___kloudlite___api___pkg___repos__MatchType {
+  array
+  exact
+  not_in_array
+  regex
+}
+
 enum Github__com___kloudlite___api___pkg___types__SyncAction {
   APPLY
   DELETE

apps/console/internal/app/graph/struct-to-graphql/matchfilter.graphqls

@@ -1,15 +1,15 @@
 type MatchFilter @shareable {
   array: [Any!]
   exact: Any
-  matchType: String!
+  matchType: Github__com___kloudlite___api___pkg___repos__MatchType!
   notInArray: [Any!]
   regex: String
 }
 
 input MatchFilterIn {
   array: [Any!]
   exact: Any
-  matchType: String!
+  matchType: Github__com___kloudlite___api___pkg___repos__MatchType!
   notInArray: [Any!]
   regex: String
 }

apps/console/internal/app/process-error-on-apply.go

@@ -11,6 +11,7 @@ import (
 
 	"github.com/kloudlite/api/apps/console/internal/domain"
 	"github.com/kloudlite/api/apps/console/internal/entities"
+	msgOfficeT "github.com/kloudlite/api/apps/message-office/types"
 	fn "github.com/kloudlite/api/pkg/functions"
 	"github.com/kloudlite/api/pkg/logging"
 	"github.com/kloudlite/api/pkg/messaging"
@@ -36,25 +37,31 @@ func ProcessErrorOnApply(consumer ErrorOnApplyConsumer, d domain.Domain, logger
 	msgReader := func(msg *msgTypes.ConsumeMsg) error {
 		counter += 1
 		logger.Debugf("received message [%d]", counter)
+
+		em, err := msgOfficeT.UnmarshalErrMessage(msg.Payload)
+		if err != nil {
+			return errors.NewE(err)
+		}
+
 		var errObj t.AgentErrMessage
-		if err := json.Unmarshal(msg.Payload, &errObj); err != nil {
+		if err := json.Unmarshal(em.Error, &errObj); err != nil {
 			return errors.NewE(err)
 		}
 
 		obj := unstructured.Unstructured{Object: errObj.Object}
 
 		mLogger := logger.WithKV(
 			"gvk", obj.GroupVersionKind(),
-			"accountName", errObj.AccountName,
-			"clusterName", errObj.ClusterName,
+			"accountName", em.AccountName,
+			"clusterName", em.ClusterName,
 		)
 
 		mLogger.Infof("received message")
 		defer func() {
 			mLogger.Infof("processed message")
 		}()
 
-		dctx := domain.NewConsoleContext(context.TODO(), "sys-user:apply-on-error-worker", errObj.AccountName)
+		dctx := domain.NewConsoleContext(context.TODO(), "sys-user:apply-on-error-worker", em.AccountName)
 
 		opts := domain.UpdateAndDeleteOpts{MessageTimestamp: msg.Timestamp}
 
@@ -103,7 +110,7 @@ func ProcessErrorOnApply(consumer ErrorOnApplyConsumer, d domain.Domain, logger
 			}
 		//case projectManagedServiceGVK.String():
 		//	{
-		//		mapping, err := d.GetProjectResourceMapping(dctx, entities.ResourceTypeProjectManagedService, errObj.ClusterName, obj.GetNamespace(), obj.GetName())
+		//		mapping, err := d.GetProjectResourceMapping(dctx, entities.ResourceTypeProjectManagedService, em.ClusterName, obj.GetNamespace(), obj.GetName())
 		//		if err != nil {
 		//			return err
 		//		}
@@ -125,7 +132,7 @@ func ProcessErrorOnApply(consumer ErrorOnApplyConsumer, d domain.Domain, logger
 
 		case appsGVK.String():
 			{
-				rctx, err := getEnvironmentResourceContext(dctx, entities.ResourceTypeApp, errObj.ClusterName, obj)
+				rctx, err := getEnvironmentResourceContext(dctx, entities.ResourceTypeApp, em.ClusterName, obj)
 				if err != nil {
 					return errors.NewE(err)
 				}
@@ -143,7 +150,7 @@ func ProcessErrorOnApply(consumer ErrorOnApplyConsumer, d domain.Domain, logger
 			}
 		case externalAppsGVK.String():
 			{
-				rctx, err := getEnvironmentResourceContext(dctx, entities.ResourceTypeExternalApp, errObj.ClusterName, obj)
+				rctx, err := getEnvironmentResourceContext(dctx, entities.ResourceTypeExternalApp, em.ClusterName, obj)
 				if err != nil {
 					return errors.NewE(err)
 				}
@@ -161,7 +168,7 @@ func ProcessErrorOnApply(consumer ErrorOnApplyConsumer, d domain.Domain, logger
 			}
 		case configGVK.String():
 			{
-				rctx, err := getEnvironmentResourceContext(dctx, entities.ResourceTypeConfig, errObj.ClusterName, obj)
+				rctx, err := getEnvironmentResourceContext(dctx, entities.ResourceTypeConfig, em.ClusterName, obj)
 				if err != nil {
 					return errors.NewE(err)
 				}
@@ -178,7 +185,7 @@ func ProcessErrorOnApply(consumer ErrorOnApplyConsumer, d domain.Domain, logger
 			}
 		case secretGVK.String():
 			{
-				rctx, err := getEnvironmentResourceContext(dctx, entities.ResourceTypeSecret, errObj.ClusterName, obj)
+				rctx, err := getEnvironmentResourceContext(dctx, entities.ResourceTypeSecret, em.ClusterName, obj)
 				if err != nil {
 					return errors.NewE(err)
 				}
@@ -195,7 +202,7 @@ func ProcessErrorOnApply(consumer ErrorOnApplyConsumer, d domain.Domain, logger
 			}
 		case routerGVK.String():
 			{
-				rctx, err := getEnvironmentResourceContext(dctx, entities.ResourceTypeRouter, errObj.ClusterName, obj)
+				rctx, err := getEnvironmentResourceContext(dctx, entities.ResourceTypeRouter, em.ClusterName, obj)
 				if err != nil {
 					return errors.NewE(err)
 				}
@@ -212,7 +219,7 @@ func ProcessErrorOnApply(consumer ErrorOnApplyConsumer, d domain.Domain, logger
 			}
 		case managedResourceGVK.String():
 			{
-				rctx, err := getEnvironmentResourceContext(dctx, entities.ResourceTypeManagedResource, errObj.ClusterName, obj)
+				rctx, err := getEnvironmentResourceContext(dctx, entities.ResourceTypeManagedResource, em.ClusterName, obj)
 				if err != nil {
 					return errors.NewE(err)
 				}