diff options
Diffstat (limited to 'controller')
| -rw-r--r-- | controller/recipe.go | 45 |
1 files changed, 42 insertions, 3 deletions
diff --git a/controller/recipe.go b/controller/recipe.go index 09f65a7..da58d35 100644 --- a/controller/recipe.go +++ b/controller/recipe.go @@ -18,7 +18,20 @@ func RecipeCreate(w http.ResponseWriter, r *http.Request) { recipe.LastChanged = fmt.Sprint(time.Now().Unix()) recipe.Created = recipe.LastChanged - err := recipe.Create() + tx, err := model.NewTx() + if err != nil { + http.Error(w, err.Error(), http.StatusInternalServerError) + return + } + + err = recipe.Create(tx) + if err != nil { + model.Rollback(tx) + http.Error(w, err.Error(), http.StatusInternalServerError) + return + } + + err = tx.Commit() if err != nil { http.Error(w, err.Error(), http.StatusInternalServerError) return @@ -48,7 +61,20 @@ func RecipeUpdate(w http.ResponseWriter, r *http.Request) { recipe.LastChanged = fmt.Sprint(time.Now().Unix()) - err = recipe.Update() + tx, err := model.NewTx() + if err != nil { + http.Error(w, err.Error(), http.StatusInternalServerError) + return + } + + err = recipe.Update(tx) + if err != nil { + model.Rollback(tx) + http.Error(w, err.Error(), http.StatusInternalServerError) + return + } + + err = tx.Commit() if err != nil { http.Error(w, err.Error(), http.StatusInternalServerError) return @@ -61,7 +87,20 @@ func RecipeDelete(w http.ResponseWriter, r *http.Request) { recipe := model.Recipe{} recipe.Id = mux.Vars(r)[`id`] - err := recipe.Delete() + tx, err := model.NewTx() + if err != nil { + http.Error(w, err.Error(), http.StatusInternalServerError) + return + } + + err = recipe.Delete(tx) + if err != nil { + model.Rollback(tx) + http.Error(w, err.Error(), http.StatusInternalServerError) + return + } + + err = tx.Commit() if err != nil { http.Error(w, err.Error(), http.StatusInternalServerError) return |