Cleanup

realtime.go

@@ -24,12 +24,13 @@ type Subscription struct {
 }
 
 func (listener RealtimeListener) handlePbEvent(msg *sse.Event) {
-	var pbEvent = new(PBEvent)
+	pbEvent := new(PBEvent)
 	err := json.Unmarshal(msg.Data, &pbEvent)
 	if err != nil {
 		log.Printf("Error unmarshalling event: %v\n", err)
 		return
 	}
+	log.Printf("Received event: %++v", pbEvent)
 
 	if pbEvent.ClientId != "" {
 		listener.doSubscribe(pbEvent.ClientId)
@@ -58,6 +59,7 @@ func (listener RealtimeListener) doSubscribe(clientId string) {
 		ClientId:      clientId,
 		Subscriptions: listener.Collections,
 	}
+	log.Printf("Subscribing client: %v to %++v", clientId, subscription)
 
 	body, err := json.Marshal(subscription)
 	if err != nil {
@@ -81,7 +83,7 @@ func (listener *RealtimeListener) initialize() {
 	listener.Update = make(chan PBEvent, 32)
 	listener.Create = make(chan PBEvent, 32)
 	listener.Delete = make(chan PBEvent, 32)
-	log.Print("initialized")
+	log.Print("Initialized")
 	listener.client = sse.NewClient(listener.Url)
 	go listener.client.Subscribe("", listener.handlePbEvent)
 }