genofire/hs_monolith
genofire
/
hs_monolith
Archived
1
0
Fork 0
This repository has been archived on 2020-09-27. You can view files and clone it, but cannot push or open issues or pull requests.
hs_monolith/http/good_lock.go

172 lines
4.1 KiB
Go

// Package that contains all api routes of this microservice
package http
import (
"net/http"
"time"
"github.com/genofire/hs_master-kss-monolith/lib/database"
lib "github.com/genofire/hs_master-kss-monolith/lib/http"
logger "github.com/genofire/hs_master-kss-monolith/lib/log"
"github.com/genofire/hs_master-kss-monolith/models"
)
type LockGood struct {
ProductID int64 `json:"product_id"`
Count int `json:"count"`
}
// Function to lock goods
func lockGoods(w http.ResponseWriter, r *http.Request) {
log := logger.HTTP(r)
secret := r.Header.Get("secret")
if secret == "" {
log.Warn("no secred for locking given")
http.Error(w, "no secred for locking given", http.StatusBadRequest)
return
}
log = log.WithField("lSecret", secret)
var goods []*LockGood
err := lib.Read(r, &goods)
if err != nil {
log.Warn(err.Error())
http.Error(w, err.Error(), http.StatusBadRequest)
return
}
if len(goods) <= 0 {
log.Warn("tried to log nothing")
http.Error(w, "tried to log nothing", http.StatusBadRequest)
return
}
tx := database.Write.Begin()
defer tx.Rollback()
count := int64(0)
for _, good := range goods {
if good.ProductID <= 0 {
log.Warn("tried to log nothing")
http.Error(w, "tried to log nothing", http.StatusBadRequest)
return
}
for i := 0; i < good.Count; i++ {
g := &models.Good{ProductID: good.ProductID}
db := g.FilterAvailable(tx).First(g)
if db.RecordNotFound() {
log.Warn("good not found")
http.Error(w, "the good was not found in database", http.StatusNotFound)
return
}
g.Lock(secret)
db = tx.Save(g)
if db.Error != nil || db.RowsAffected != 1 {
http.Error(w, "the good was not found in database", http.StatusInternalServerError)
log.Panic("there is more than one good locked: ", db.Error)
return
}
count += 1
}
}
lib.Write(w, map[string]int64{"count": count})
tx.Commit()
log.Info("done")
}
// Function to release locked goods
func releaseGoods(w http.ResponseWriter, r *http.Request) {
log := logger.HTTP(r)
secret := r.Header.Get("secret")
if secret == "" {
log.Warn("no secred for locking given")
http.Error(w, "no secred for locking given", http.StatusBadRequest)
return
}
log = log.WithField("lSecret", secret)
var goods []*LockGood
err := lib.Read(r, &goods)
if err != nil {
log.Warn(err.Error())
http.Error(w, err.Error(), http.StatusBadRequest)
return
}
if len(goods) <= 0 {
log.Warn("tried to log nothing")
http.Error(w, "tried to log nothing", http.StatusBadRequest)
return
}
tx := database.Write.Begin()
defer tx.Rollback()
for _, good := range goods {
if good.ProductID <= 0 {
log.Warn("tried to log nothing")
http.Error(w, "tried to release nothing", http.StatusBadRequest)
return
}
for i := 0; i < good.Count; i++ {
g := &models.Good{}
db := tx.Where(map[string]interface{}{"product_id": good.ProductID, "locked_secret": secret}).First(g)
if db.RecordNotFound() {
log.Warn("good not found")
http.Error(w, "the good was not found in database", http.StatusNotFound)
return
}
g.Unlock(secret)
db = tx.Save(g)
if db.Error != nil || db.RowsAffected != 1 {
http.Error(w, "the good was not found in database", http.StatusInternalServerError)
log.Panic("there is more than one good released: ", db.Error)
return
}
}
}
lib.Write(w, true)
tx.Commit()
log.Info("done")
}
// Function to del locked goods
func delLockedGoods(w http.ResponseWriter, r *http.Request) {
log := logger.HTTP(r)
secret := r.Header.Get("secret")
log = log.WithField("lSecret", secret)
db := database.Write.Model(&models.Good{}).Where(&models.Good{LockedSecret: secret}).Updates(map[string]interface{}{"deleted_at": time.Now(), "locked_secret": ""})
err := db.Error
result := db.RowsAffected
if err != nil {
log.Warn("database error during the release of goods: ", err)
http.Error(w, "the secret could not be validated", http.StatusInternalServerError)
return
}
if result <= 0 {
log.Warn("no goods found")
http.Error(w, "there are no goods to buy", http.StatusNotFound)
return
}
log = log.WithField("count", result)
lib.Write(w, map[string]int64{"count": result})
log.Info("done")
}