feat: rollback on failure

natrontech · Aug 7, 2023 · bb96dd9 · bb96dd9
1 parent a404649
commit bb96dd9
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 0 deletions.
diff --git a/momentum-core/routers/application-router.go b/momentum-core/routers/application-router.go
@@ -118,6 +118,7 @@ func (a *ApplicationRouter) addApplication(c *gin.Context) {
 
 	application, err := a.applicationService.AddApplication(request, traceId)
 	if err != nil {
+		transaction.Rollback(ctx)
 		c.IndentedJSON(http.StatusBadRequest, models.NewApiError(err, http.StatusBadRequest, c, traceId))
 		config.LOGGER.LogError(err.Error(), err, traceId)
 		return

diff --git a/momentum-core/routers/deployment-router.go b/momentum-core/routers/deployment-router.go
@@ -98,6 +98,7 @@ func (d *DeploymentRouter) addDeployment(c *gin.Context) {
 
 	deployment, err := d.deploymentService.AddDeployment(request, traceId)
 	if err != nil {
+		transaction.Rollback(ctx)
 		c.IndentedJSON(http.StatusBadRequest, models.NewApiError(err, http.StatusBadRequest, c, traceId))
 		config.LOGGER.LogError(err.Error(), err, traceId)
 		return

diff --git a/momentum-core/routers/stage-router.go b/momentum-core/routers/stage-router.go
@@ -98,6 +98,7 @@ func (sr *StageRouter) addStage(c *gin.Context) {
 
 	stage, err := sr.stageService.AddStage(request, traceId)
 	if err != nil {
+		transaction.Rollback(ctx)
 		c.IndentedJSON(http.StatusBadRequest, models.NewApiError(err, http.StatusBadRequest, c, traceId))
 		config.LOGGER.LogError(err.Error(), err, traceId)
 		return