Subscriber reconnect (#4776)

* Force infra/subscriber disconnection when is already connected

Signed-off-by: Bruno Ledesma <led.bruno@gmail.com>

* Force infra/subscriber disconnection when is already connected

Signed-off-by: Bruno Ledesma <led.bruno@gmail.com>

---------

Signed-off-by: Bruno Ledesma <led.bruno@gmail.com>

Author: ledbruno

chaoscenter/graphql/server/graph/chaos_infrastructure.resolvers.go

@@ -69,7 +69,7 @@ func (req *subscriberRequests) AgentConnect(infraData map[string]string) {
 	for {
 		_, message, err := c.ReadMessage()
 		if err != nil {
-			logrus.WithError(err).Fatal("Failed to read message")
+			logrus.WithError(err).Panic("Failed to read message")
 		}
 
 		var r types.RawData
@@ -87,6 +87,7 @@ func (req *subscriberRequests) AgentConnect(infraData map[string]string) {
 		}
 		if r.Payload.Errors != nil {
 			logrus.Error("Error response from the server : ", string(message))
+			panicWhen("ALREADY CONNECTED", message)
 			continue
 		}
 
@@ -97,6 +98,12 @@ func (req *subscriberRequests) AgentConnect(infraData map[string]string) {
 	}
 }
 
+func panicWhen(errorMessage string, message []byte) {
+	if strings.Contains(string(message), errorMessage) {
+		logrus.Panic("Server error: ", errorMessage)
+	}
+}
+
 func (req *subscriberRequests) RequestProcessor(infraData map[string]string, r types.RawData) error {
 	if strings.Index("kubeobject kubeobjects", strings.ToLower(r.Payload.Data.InfraConnect.Action.RequestType)) >= 0 {
 		KubeObjRequest := types.KubeObjRequest{