fix(bulker): if bulker mode not provided - assume 'batch'

absorbb · absorbb · commit 5036d08941c5 · 2025-09-05T17:25:31.000+04:00
diff --git a/bulkerapp/app/router.go b/bulkerapp/app/router.go
@@ -142,7 +142,7 @@ func (r *Router) EventsHandler(c *gin.Context) {
 		rError = r.ResponseError(c, http.StatusNotFound, "destination not found", false, fmt.Errorf("destination not found: %s", destinationId), true, true, false)
 		return
 	}
-	mode = utils.DefaultString(modeOverride, string(destination.Mode()))
+	mode = utils.NvlString(modeOverride, string(destination.Mode()), string(bulker.Batch))
 	if mode != string(bulker.Batch) && mode != string(bulker.Stream) {
 		rError = r.ResponseError(c, http.StatusBadRequest, "invalid bulker mode", false, fmt.Errorf("invalid bulker mode: %s", mode), true, true, false)
 		return

Original file line number	Diff line number	Diff line change
`@@ -142,7 +142,7 @@ func (r Router) EventsHandler(c gin.Context) {`
`142`	`142`	`rError = r.ResponseError(c, http.StatusNotFound, "destination not found", false, fmt.Errorf("destination not found: %s", destinationId), true, true, false)`
`143`	`143`	`return`
`144`	`144`	`}`
`145`		`- mode = utils.DefaultString(modeOverride, string(destination.Mode()))`
	`145`	`+ mode = utils.NvlString(modeOverride, string(destination.Mode()), string(bulker.Batch))`
`146`	`146`	`if mode != string(bulker.Batch) && mode != string(bulker.Stream) {`
`147`	`147`	`rError = r.ResponseError(c, http.StatusBadRequest, "invalid bulker mode", false, fmt.Errorf("invalid bulker mode: %s", mode), true, true, false)`
`148`	`148`	`return`