Merge branch 'master' of github.com:rudderlabs/rudder-server

config/sample.env

@@ -29,5 +29,5 @@ ALERT_PROVIDER=pagerduty
 PG_ROUTING_KEY=<your_integration/routing_key>
 
 # Alerting VictorOps Config
-#ALERT_PROVIDER="victorops"
+#ALERT_PROVIDER=victorops
 #VICTOROPS_ROUTING_KEY=<your_victorops_routing_key>

release.sh

@@ -0,0 +1,17 @@
+if [ "$#" -ne 1 ]; then
+  echo "Usage: $0 <overrides_existing_version>" >&2
+  exit 1
+fi
+
+read -p "Are you sure to release? " -n 1 -r
+echo    # (optional) move to a new line
+if [[ $REPLY =~ ^[Yy]$ ]]
+then
+  git tag -d $1
+  git push origin :refs/tags/$1
+
+  git tag -a $1 -m "Release $1"
+  git push origin $1
+
+  goreleaser --rm-dist
+fi

services/source-debugger/source-debugger.go

@@ -102,7 +102,11 @@ func uploadEvents(eventBuffer []*EventSchemaT) {
 	for _, event := range eventBuffer {
 		batchedEvent := EventT{}
 		err := json.Unmarshal([]byte(event.eventBatch), &batchedEvent)
-		misc.AssertError(err)
+		if err != nil {
+			logger.Debugf(string(event.eventBatch))
+			misc.AssertErrorIfDev(err)
+			continue
+		}
 
 		receivedAtTS, err := time.Parse(time.RFC3339, batchedEvent.ReceivedAt)
 		if err != nil {
@@ -140,7 +144,11 @@ func uploadEvents(eventBuffer []*EventSchemaT) {
 	}
 
 	rawJSON, err := json.Marshal(res)
-	misc.AssertError(err)
+	if err != nil {
+		logger.Debugf(string(rawJSON))
+		misc.AssertErrorIfDev(err)
+		return
+	}
 
 	tr := &http.Transport{}
 	client := &http.Client{Transport: tr}

utils/misc/misc.go

@@ -29,6 +29,21 @@ func AssertError(err error) {
 	}
 }
 
+func AssertErrorIfDev(err error) {
+
+	goEnv := os.Getenv("GO_ENV")
+	if goEnv == "production" {
+		return
+	}
+
+	if err != nil {
+		// debug.SetTraceback("all")
+		debug.PrintStack()
+		defer bugsnag.AutoNotify()
+		panic(err)
+	}
+}
+
 //Assert panics if false
 func Assert(cond bool) {
 	if !cond {