Streaming envelope

pkg/controllers/gitrepositoryController.go

@@ -37,7 +37,10 @@ func GitRepositoryController(
 				if err != nil {
 					panic(err.Error())
 				}
-				fluxStateBytes, err := json.Marshal(fluxState)
+				fluxStateBytes, err := json.Marshal(streaming.Envelope{
+					Type:    streaming.FLUX_STATE_RECEIVED,
+					Payload: fluxState,
+				})
 				if err != nil {
 					panic(err.Error())
 				}

pkg/streaming/types.go

@@ -0,0 +1,10 @@
+package streaming
+
+const (
+	FLUX_STATE_RECEIVED string = "FLUX_STATE_RECEIVED"
+)
+
+type Envelope struct {
+	Type    string      `json:"type"`
+	Payload interface{} `json:"payload"`
+}

web/src/redux.js

@@ -2,7 +2,7 @@ export const initialState = {
   fluxState: {}
 }
 
-export const ACTION_FLUX_STATE_RECEIVED = 'ACTION_FLUX_STATE_RECEIVED';
+export const ACTION_FLUX_STATE_RECEIVED = 'FLUX_STATE_RECEIVED';
 
 export function rootReducer(state = initialState, action) {
   switch (action.type) {