Besucher werden in den Datenbank gespeichert

app.go

@@ -31,10 +31,14 @@ func (a *App) start() {
 		}
 	}))
 
-	a.r.GET("/besucher", handlers.GetBesucherListHandler)
+	env := handlers.EnvHandler{
-	a.r.POST("/besucher", handlers.AddBesucherHandler)
+		DB: a.db,
-	a.r.DELETE("/besucher/:id", handlers.DeleteBesucherHandler)
+	}
-	a.r.PUT("/besucher", handlers.ComeBesucherHandler)
+
+	a.r.GET("/besucher", env.GetBesucherListHandler)
+	a.r.POST("/besucher", env.AddBesucherHandler)
+	//a.r.DELETE("/besucher/:id", env.DeleteBesucherHandler)
+	//a.r.PUT("/besucher", env.ComeBesucherHandler)
 
 	err := a.r.Run(":3001")
 	if err != nil {

handlers/handlers.go

@@ -8,27 +8,32 @@ import (
 
 	"git.cosysda.de/HuskyTeufel/Hochzeit/planner"
 	"github.com/gin-gonic/gin"
+	"github.com/jinzhu/gorm"
 )
 
-func GetBesucherListHandler(c *gin.Context) {
+type EnvHandler struct {
-	c.JSON(http.StatusOK, planner.Get())
+	DB *gorm.DB
 }
 
-func AddBesucherHandler(c *gin.Context) {
+func (e *EnvHandler) GetBesucherListHandler(c *gin.Context) {
+	c.JSON(http.StatusOK, planner.Get(e.DB))
+}
+
+func (e *EnvHandler) AddBesucherHandler(c *gin.Context) {
 	besucherItem, statusCode, err := convertHTTPBodyToBesucher(c.Request.Body)
 	if err != nil {
 		c.JSON(statusCode, err)
 		return
 	}
 
-	c.JSON(statusCode, gin.H{"id": planner.Add(besucherItem)})
+	c.JSON(statusCode, gin.H{"id": planner.Add(e.DB, besucherItem)})
 }
 
-func DeleteBesucherHandler(c *gin.Context) {
+func (e *EnvHandler) DeleteBesucherHandler(c *gin.Context) {
 
 }
 
-func ComeBesucherHandler(c *gin.Context) {
+func (e *EnvHandler) ComeBesucherHandler(c *gin.Context) {
 
 }
 

planner/planner.go

@@ -1,71 +1,29 @@
 package planner
 
 import (
-	"errors"
+	"github.com/jinzhu/gorm"
-	"sync"
-
 	"github.com/rs/xid"
 )
 
-var (
-	list []Besucher
-	mtx  sync.RWMutex
-	once sync.Once
-)
-
-func init() {
-	once.Do(initialiseList)
-}
-
-func initialiseList() {
-	list = []Besucher{}
-}
-
 // Get retrieves all elements from the Besucher list
-func Get() []Besucher {
+func Get(db *gorm.DB) []Besucher {
-	return list
+	var besucherlist []Besucher
+	db.Find(&besucherlist)
+	return besucherlist
 }
 
 // Add will add a new Besucher
-func Add(newClient Besucher) string {
+func Add(db *gorm.DB, newClient Besucher) string {
 	t := newBesucher(newClient)
-	mtx.Lock()
+	db.Create(&t)
-	list = append(list, t)
-	mtx.Unlock()
 	return t.ID
 }
 
 // Delete will remove a Besucher from the Besucher list
 func Delete(id string) error {
-	location, err := findBesucherLocation(id)
-	if err != nil {
-		return err
-	}
-	removeElementByLocation(location)
 	return nil
 }
 
-func removeElementByLocation(i int) {
-	mtx.Lock()
-	list = append(list[:i], list[i+1:]...)
-	mtx.Unlock()
-}
-
-func findBesucherLocation(id string) (int, error) {
-	mtx.RLock()
-	defer mtx.RUnlock()
-	for i, t := range list {
-		if isMatchingID(t.ID, id) {
-			return i, nil
-		}
-	}
-	return 0, errors.New("Could not find Besucher based on id")
-}
-
-func isMatchingID(a, b string) bool {
-	return a == b
-}
-
 func newBesucher(newBesucher Besucher) Besucher {
 	return Besucher{
 		ID:      xid.New().String(),