added the debugger for flux app listing

devtron-labs · Jul 5, 2024 · 88e0cc7 · 88e0cc7
1 parent c39c7c6
commit 88e0cc7
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 0 deletions.
diff --git a/pkg/service/HelmAppServiceWrapper.go b/pkg/service/HelmAppServiceWrapper.go
@@ -596,21 +596,27 @@ func (impl *ApplicationServiceServerImpl) PushHelmChartToOCIRegistry(ctx context
 
 func (impl *ApplicationServiceServerImpl) ListFluxApplications(req *client.AppListRequest, res client.ApplicationService_ListFluxApplicationsServer) error {
 	impl.Logger.Infow("List Flux Application Request", "req", req)
+	impl.Logger.Debugw("List Flux Application Request received in kubelink ", "req", req)
+
 	clusterConfigs := req.GetClusters()
 	eg := new(errgroup.Group)
 	for _, config := range clusterConfigs {
 		clusterConfig := *config
 		eg.Go(func() error {
 			apps := impl.FluxAppService.GetFluxApplicationListForCluster(&clusterConfig)
 			err := res.Send(apps)
+			impl.Logger.Debugw("List Flux Application Request served having the list", "apps", apps)
 			return err
 		})
 	}
 	if err := eg.Wait(); err != nil {
+		impl.Logger.Debugw("Error in fetching application list", "err", err)
 		impl.Logger.Errorw("Error in fetching application list", "err", err)
 		return err
 	}
 	impl.Logger.Info("List Flux Application Request served")
+	impl.Logger.Debugw("List Flux Application Request served")
+
 	return nil
 }
 

diff --git a/pkg/service/fluxService/fluxApplicationService.go b/pkg/service/fluxService/fluxApplicationService.go
@@ -50,10 +50,13 @@ func (impl *FluxApplicationServiceImpl) GetFluxApplicationListForCluster(config
 	restConfig, err := impl.k8sUtil.GetRestConfigByCluster(k8sClusterConfig)
 	if err != nil {
 		impl.logger.Errorw("Error in building rest config ", "clusterId", config.ClusterId, "err", err)
+		impl.logger.Debugw("Error in building rest config ", "clusterId", config.ClusterId, "err", err)
+
 		deployedApp.Errored = true
 		deployedApp.ErrorMsg = err.Error()
 		return deployedApp
 	}
+
 	//restConf := *restConfig
 	kustomizationListResp, helmReleaseListResp, err := impl.fetchFluxK8sResponseLists(restConfig)
 	if err != nil && kustomizationListResp == nil {