add debug logs and fix casing for global stream

provisioner/integrations/redis_stream/global.go

@@ -160,10 +160,10 @@ func GlobalStreamListener(
 				continue
 			}
 
+			config.Logger.Debug().Msg(fmt.Sprintf("pushing state and log file for %s with status %v", workspaceID, statusVal))
+
 			switch fmt.Sprintf("%v", statusVal) {
-			case "created":
-			case "error":
-			case "destroyed":
+			case "created", "error", "destroyed":
 				err := cleanupOperation(config, client, infra, operation, workspaceID)
 
 				if err != nil {
@@ -177,24 +177,33 @@ func GlobalStreamListener(
 }
 
 func cleanupOperation(config *config.Config, client *redis.Client, infra *models.Infra, operation *models.Operation, workspaceID string) error {
+	l := config.Logger
+	l.Debug().Msg(fmt.Sprintf("pushing state for %s", workspaceID))
+
 	err := pushNewStateToStorage(config, client, infra, operation, workspaceID)
 
 	if err != nil {
 		return err
 	}
 
+	l.Debug().Msg(fmt.Sprintf("cleaning state stream for %s", workspaceID))
+
 	err = cleanupStateStream(config, client, workspaceID)
 
 	if err != nil {
 		return nil
 	}
 
+	l.Debug().Msg(fmt.Sprintf("pushing logs for %s", workspaceID))
+
 	err = pushLogsToStorage(config, client, infra, workspaceID)
 
 	if err != nil {
 		return err
 	}
 
+	l.Debug().Msg(fmt.Sprintf("cleaning logs for %s", workspaceID))
+
 	err = cleanupLogStream(config, client, infra, workspaceID)
 
 	if err != nil {