Small fixes

pkg/controllers/bucketController.go

@@ -5,6 +5,7 @@ import (
 
 	"github.com/gimlet-io/capacitor/pkg/flux"
 	"github.com/gimlet-io/capacitor/pkg/streaming"
+	"github.com/sirupsen/logrus"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/apimachinery/pkg/runtime/schema"
 	"k8s.io/client-go/dynamic"
@@ -35,14 +36,16 @@ func BucketController(
 			case "delete":
 				fluxState, err := flux.State(client, dynamicClient)
 				if err != nil {
-					panic(err.Error())
+					logrus.Warnf("could not get flux state: %s", err)
+					return nil
 				}
 				fluxStateBytes, err := json.Marshal(streaming.Envelope{
 					Type:    streaming.FLUX_STATE_RECEIVED,
 					Payload: fluxState,
 				})
 				if err != nil {
-					panic(err.Error())
+					logrus.Warnf("could not marshal event: %s", err)
+					return nil
 				}
 				clientHub.Broadcast <- fluxStateBytes
 			}

pkg/controllers/deploymentController.go

@@ -4,6 +4,7 @@ import (
 	"encoding/json"
 
 	"github.com/gimlet-io/capacitor/pkg/streaming"
+	"github.com/sirupsen/logrus"
 	apps_v1 "k8s.io/api/apps/v1"
 	v1 "k8s.io/api/core/v1"
 	meta_v1 "k8s.io/apimachinery/pkg/apis/meta/v1"
@@ -32,7 +33,8 @@ func DeploymentController(
 					Payload: createdDeployment,
 				})
 				if err != nil {
-					panic(err.Error())
+					logrus.Warnf("could not marshal event: %s", err)
+					return nil
 				}
 				clientHub.Broadcast <- deploymentBytes
 			case "update":
@@ -42,7 +44,8 @@ func DeploymentController(
 					Payload: deployment,
 				})
 				if err != nil {
-					panic(err.Error())
+					logrus.Warnf("could not marshal event: %s", err)
+					return nil
 				}
 				clientHub.Broadcast <- deploymentBytes
 			case "delete":
@@ -51,7 +54,8 @@ func DeploymentController(
 					Payload: informerEvent.key,
 				})
 				if err != nil {
-					panic(err.Error())
+					logrus.Warnf("could not marshal event: %s", err)
+					return nil
 				}
 				clientHub.Broadcast <- deploymentBytes
 			}

pkg/controllers/eventController.go

@@ -5,6 +5,7 @@ import (
 
 	"github.com/gimlet-io/capacitor/pkg/flux"
 	"github.com/gimlet-io/capacitor/pkg/streaming"
+	"github.com/sirupsen/logrus"
 	v1 "k8s.io/api/core/v1"
 	meta_v1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/apimachinery/pkg/fields"
@@ -42,7 +43,8 @@ func EventController(
 				Payload: events,
 			})
 			if err != nil {
-				panic(err.Error())
+				logrus.Warnf("could not marshal event: %s", err)
+				return nil
 			}
 			clientHub.Broadcast <- eventBytes
 			return nil

pkg/controllers/gitrepositoryController.go

@@ -5,6 +5,7 @@ import (
 
 	"github.com/gimlet-io/capacitor/pkg/flux"
 	"github.com/gimlet-io/capacitor/pkg/streaming"
+	"github.com/sirupsen/logrus"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/apimachinery/pkg/runtime/schema"
 	"k8s.io/client-go/dynamic"
@@ -35,14 +36,16 @@ func GitRepositoryController(
 			case "delete":
 				fluxState, err := flux.State(client, dynamicClient)
 				if err != nil {
-					panic(err.Error())
+					logrus.Warnf("could not marshal event: %s", err)
+					return nil
 				}
 				fluxStateBytes, err := json.Marshal(streaming.Envelope{
 					Type:    streaming.FLUX_STATE_RECEIVED,
 					Payload: fluxState,
 				})
 				if err != nil {
-					panic(err.Error())
+					logrus.Warnf("could not marshal event: %s", err)
+					return nil
 				}
 				clientHub.Broadcast <- fluxStateBytes
 			}

pkg/controllers/helmreleaseController.go

@@ -5,6 +5,7 @@ import (
 
 	"github.com/gimlet-io/capacitor/pkg/flux"
 	"github.com/gimlet-io/capacitor/pkg/streaming"
+	"github.com/sirupsen/logrus"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/apimachinery/pkg/runtime/schema"
 	"k8s.io/client-go/dynamic"
@@ -35,14 +36,16 @@ func HelmReleaseController(
 			case "delete":
 				fluxState, err := flux.State(client, dynamicClient)
 				if err != nil {
-					panic(err.Error())
+					logrus.Warnf("could not marshal event: %s", err)
+					return nil
 				}
 				fluxStateBytes, err := json.Marshal(streaming.Envelope{
 					Type:    streaming.FLUX_STATE_RECEIVED,
 					Payload: fluxState,
 				})
 				if err != nil {
-					panic(err.Error())
+					logrus.Warnf("could not marshal event: %s", err)
+					return nil
 				}
 				clientHub.Broadcast <- fluxStateBytes
 			}

pkg/controllers/ingressController.go

@@ -4,6 +4,7 @@ import (
 	"encoding/json"
 
 	"github.com/gimlet-io/capacitor/pkg/streaming"
+	"github.com/sirupsen/logrus"
 	v1 "k8s.io/api/core/v1"
 	networking_v1 "k8s.io/api/networking/v1"
 	meta_v1 "k8s.io/apimachinery/pkg/apis/meta/v1"
@@ -32,7 +33,8 @@ func IngressController(
 					Payload: createdIngress,
 				})
 				if err != nil {
-					panic(err.Error())
+					logrus.Warnf("could not marshal event: %s", err)
+					return nil
 				}
 				clientHub.Broadcast <- ingressBytes
 			case "update":
@@ -42,7 +44,8 @@ func IngressController(
 					Payload: ingress,
 				})
 				if err != nil {
-					panic(err.Error())
+					logrus.Warnf("could not marshal event: %s", err)
+					return nil
 				}
 				clientHub.Broadcast <- ingressBytes
 			case "delete":
@@ -51,7 +54,8 @@ func IngressController(
 					Payload: informerEvent.key,
 				})
 				if err != nil {
-					panic(err.Error())
+					logrus.Warnf("could not marshal event: %s", err)
+					return nil
 				}
 				clientHub.Broadcast <- ingressBytes
 			}

pkg/controllers/kustomizationController.go

@@ -5,6 +5,7 @@ import (
 
 	"github.com/gimlet-io/capacitor/pkg/flux"
 	"github.com/gimlet-io/capacitor/pkg/streaming"
+	"github.com/sirupsen/logrus"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/apimachinery/pkg/runtime/schema"
 	"k8s.io/client-go/dynamic"
@@ -35,14 +36,16 @@ func KustomizeController(
 			case "delete":
 				fluxState, err := flux.State(client, dynamicClient)
 				if err != nil {
-					panic(err.Error())
+					logrus.Warnf("could not marshal event: %s", err)
+					return nil
 				}
 				fluxStateBytes, err := json.Marshal(streaming.Envelope{
 					Type:    streaming.FLUX_STATE_RECEIVED,
 					Payload: fluxState,
 				})
 				if err != nil {
-					panic(err.Error())
+					logrus.Warnf("could not marshal event: %s", err)
+					return nil
 				}
 				clientHub.Broadcast <- fluxStateBytes
 			}

pkg/controllers/ocirepositoryController.go

@@ -5,6 +5,7 @@ import (
 
 	"github.com/gimlet-io/capacitor/pkg/flux"
 	"github.com/gimlet-io/capacitor/pkg/streaming"
+	"github.com/sirupsen/logrus"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/apimachinery/pkg/runtime/schema"
 	"k8s.io/client-go/dynamic"
@@ -35,14 +36,16 @@ func OciRepositoryController(
 			case "delete":
 				fluxState, err := flux.State(client, dynamicClient)
 				if err != nil {
-					panic(err.Error())
+					logrus.Warnf("could not get flux state: %s", err)
+					return nil
 				}
 				fluxStateBytes, err := json.Marshal(streaming.Envelope{
 					Type:    streaming.FLUX_STATE_RECEIVED,
 					Payload: fluxState,
 				})
 				if err != nil {
-					panic(err.Error())
+					logrus.Warnf("could not marshal event: %s", err)
+					return nil
 				}
 				clientHub.Broadcast <- fluxStateBytes
 			}

pkg/controllers/podController.go

@@ -4,6 +4,7 @@ import (
 	"encoding/json"
 
 	"github.com/gimlet-io/capacitor/pkg/streaming"
+	"github.com/sirupsen/logrus"
 	v1 "k8s.io/api/core/v1"
 	meta_v1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/apimachinery/pkg/fields"
@@ -31,7 +32,8 @@ func PodController(
 					Payload: createdPod,
 				})
 				if err != nil {
-					panic(err.Error())
+					logrus.Warnf("could not marshal event: %s", err)
+					return nil
 				}
 				clientHub.Broadcast <- podBytes
 			case "update":
@@ -41,7 +43,8 @@ func PodController(
 					Payload: pod,
 				})
 				if err != nil {
-					panic(err.Error())
+					logrus.Warnf("could not marshal event: %s", err)
+					return nil
 				}
 				clientHub.Broadcast <- podBytes
 			case "delete":
@@ -50,7 +53,8 @@ func PodController(
 					Payload: informerEvent.key,
 				})
 				if err != nil {
-					panic(err.Error())
+					logrus.Warnf("could not marshal event: %s", err)
+					return nil
 				}
 				clientHub.Broadcast <- podBytes
 			}

pkg/controllers/serviceController.go

@@ -4,6 +4,7 @@ import (
 	"encoding/json"
 
 	"github.com/gimlet-io/capacitor/pkg/streaming"
+	"github.com/sirupsen/logrus"
 	v1 "k8s.io/api/core/v1"
 	meta_v1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/apimachinery/pkg/fields"
@@ -31,7 +32,8 @@ func ServiceController(
 					Payload: createdService,
 				})
 				if err != nil {
-					panic(err.Error())
+					logrus.Warnf("could not marshal event: %s", err)
+					return nil
 				}
 				clientHub.Broadcast <- serviceBytes
 			case "update":
@@ -41,7 +43,8 @@ func ServiceController(
 					Payload: service,
 				})
 				if err != nil {
-					panic(err.Error())
+					logrus.Warnf("could not marshal event: %s", err)
+					return nil
 				}
 				clientHub.Broadcast <- serviceBytes
 			case "delete":
@@ -50,7 +53,8 @@ func ServiceController(
 					Payload: informerEvent.key,
 				})
 				if err != nil {
-					panic(err.Error())
+					logrus.Warnf("could not marshal event: %s", err)
+					return nil
 				}
 				clientHub.Broadcast <- serviceBytes
 			}

web/src/Service.jsx

@@ -280,6 +280,7 @@ export function Pod(props) {
       color = 'bg-blue-300';
       pulsar = 'animate-pulse';
       break;
+    case 'Succeeded':
     case 'Terminating':
       color = 'bg-neutral-500';
       pulsar = 'animate-pulse';

web/src/redux.js

@@ -74,6 +74,9 @@ export function rootReducer(state = initialState, action) {
     case ACTION_SERVICE_DELETED:
       return serviceEventHandlers.serviceDeleted(state, action.payload)
     default:
+      if (action.type && action.type.startsWith('@@redux/INIT')) { // Ignoring Redux ActionTypes.INIT action
+        return state
+      }
       console.log('Could not process redux event: ' + JSON.stringify(action));
       return state;
   }