Clean up error handling

component.go

@@ -6,6 +6,7 @@ package main
 
 import (
 	"encoding/json"
+	"log"
 	"strings"
 
 	"github.com/nats-io/nats"
@@ -29,17 +30,19 @@ func processComponent(msg *nats.Msg) {
 	c.Subject = msg.Subject
 
 	if err := json.Unmarshal(msg.Data, &c); err != nil {
-		panic(err)
+		log.Println(err)
+		return
 	}
 
 	id := c.getID()
 
 	data, err := json.Marshal(c)
 	if err != nil {
-		panic(err)
+		log.Println(err)
+		return
 	}
 
-	publishEvent(id, data)
+	ss.Publish(id, data)
 }
 
 func (c *Component) getID() string {

service.go

@@ -26,26 +26,26 @@ func processService(msg *nats.Msg) {
 	s.Subject = msg.Subject
 
 	if err := json.Unmarshal(msg.Data, &s); err != nil {
-		panic(err)
+		log.Println(err)
+		return
 	}
 
 	id := s.getID()
 
 	data, err := json.Marshal(s)
 	if err != nil {
-		panic(err)
+		log.Println(err)
+		return
 	}
 
 	switch msg.Subject {
 	case "service.create", "service.delete":
 		// Create new stream
 		log.Println("Creating stream: ", id)
 		ss.CreateStream(id)
-		publishEvent(id, data)
+		ss.Publish(id, data)
 	case "service.create.done", "service.create.error", "service.delete.done", "service.delete.error", "service.import.done", "service.import.error":
-		publishEvent(id, data)
-		// publishEvent(id, cliHangup)
-
+		ss.Publish(id, data)
 		time.Sleep(10 * time.Millisecond)
 		// Remove stream when the build completes
 		log.Println("Closing stream: ", id)