58 lines
1.4 KiB
Go
58 lines
1.4 KiB
Go
// Package that contains all api routes of this microservice
|
|
package http
|
|
|
|
import (
|
|
"net/http"
|
|
"strconv"
|
|
|
|
"goji.io/pat"
|
|
|
|
"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"
|
|
"github.com/genofire/hs_master-kss-monolith/runtime"
|
|
)
|
|
|
|
// Function to add goods to the stock
|
|
func addGood(w http.ResponseWriter, r *http.Request) {
|
|
log := logger.HTTP(r)
|
|
id, err := strconv.ParseInt(pat.Param(r, "productid"), 10, 64)
|
|
if err != nil {
|
|
log.Warn("false productid format")
|
|
http.Error(w, "the product id is false", http.StatusNotAcceptable)
|
|
return
|
|
}
|
|
log = log.WithField("productid", id)
|
|
ok, err := runtime.ProductExists(id)
|
|
if err != nil {
|
|
log.Warn(err.Error())
|
|
http.Error(w, err.Error(), http.StatusGatewayTimeout)
|
|
return
|
|
}
|
|
if !ok {
|
|
log.Warn("false product, product not found")
|
|
http.Error(w, "the product was not found", http.StatusNotFound)
|
|
return
|
|
}
|
|
|
|
var obj models.Good
|
|
err = lib.Read(r, &obj)
|
|
if err != nil {
|
|
log.Warn(err.Error())
|
|
http.Error(w, err.Error(), http.StatusBadRequest)
|
|
return
|
|
}
|
|
|
|
obj.ProductID = id
|
|
|
|
db := database.Write.Create(&obj)
|
|
if db.Error != nil {
|
|
log.Error("database not able to write", db.Error)
|
|
http.Error(w, "the product could not be written into the database", http.StatusInternalServerError)
|
|
}
|
|
lib.Write(w, &obj)
|
|
|
|
log.Info("done")
|
|
}
|