fiber: implement add, update, and delete endpoints

Author: KenanBek

fiber/api_routes_entities.go

@@ -0,0 +1,97 @@
+package main
+
+import (
+	"strconv"
+
+	"github.com/CoderVlogger/go-web-frameworks/pkg"
+	"github.com/gofiber/fiber/v2"
+)
+
+func entitiesList(c *fiber.Ctx) error {
+	pageStr := c.Query("page", "1")
+	page, err := strconv.Atoi(pageStr)
+	if err != nil {
+		page = 1
+	}
+
+	entities, err := entitiesRepo.List(page, pageSize)
+	if err != nil {
+		// c.JSON(pkg.TextResponse{Message: err.Error()})
+		// return fiber.NewError(fiber.StatusInternalServerError, err.Error())
+
+		// TODO: Replace 500 error with 4xx for paging related errors.
+		errMsg := pkg.TextResponse{Message: err.Error()}
+		return c.Status(fiber.StatusInternalServerError).JSON(errMsg)
+	}
+
+	c.JSON(entities)
+	return nil
+}
+
+func entitiesGet(c *fiber.Ctx) error {
+	entityID := c.Params("id", "")
+
+	entity, err := entitiesRepo.Get(entityID)
+	if err != nil {
+		errMsg := pkg.TextResponse{Message: err.Error()}
+		return c.Status(fiber.StatusInternalServerError).JSON(errMsg)
+	}
+
+	if entity == nil {
+		return fiber.ErrNotFound
+	}
+
+	c.JSON(entity)
+	return nil
+}
+
+func entitiesAdd(c *fiber.Ctx) error {
+	var entity pkg.Entity
+
+	err := c.BodyParser(&entity)
+	if err != nil {
+		errMsg := pkg.TextResponse{Message: err.Error()}
+		return c.Status(fiber.StatusInternalServerError).JSON(errMsg)
+	}
+
+	err = entitiesRepo.Add(&entity)
+	if err != nil {
+		errMsg := pkg.TextResponse{Message: err.Error()}
+		return c.Status(fiber.StatusInternalServerError).JSON(errMsg)
+	}
+
+	c.JSON(entity)
+	return nil
+}
+
+func entitiesUpdate(c *fiber.Ctx) error {
+	var entity pkg.Entity
+
+	err := c.BodyParser(&entity)
+	if err != nil {
+		errMsg := pkg.TextResponse{Message: err.Error()}
+		return c.Status(fiber.StatusInternalServerError).JSON(errMsg)
+	}
+
+	err = entitiesRepo.Update(&entity)
+	if err != nil {
+		errMsg := pkg.TextResponse{Message: err.Error()}
+		return c.Status(fiber.StatusInternalServerError).JSON(errMsg)
+	}
+
+	c.JSON(entity)
+	return nil
+}
+
+func entitiesDelete(c *fiber.Ctx) error {
+	entityID := c.Params("id", "")
+
+	err := entitiesRepo.Delete(entityID)
+	if err != nil {
+		errMsg := pkg.TextResponse{Message: err.Error()}
+		return c.Status(fiber.StatusInternalServerError).JSON(errMsg)
+	}
+
+	c.JSON(pkg.TextResponse{Message: "entity deleted"})
+	return nil
+}

fiber/server.go

@@ -1,64 +1,30 @@
 package main
 
 import (
-	"strconv"
-
 	"github.com/gofiber/fiber/v2"
 
 	"github.com/CoderVlogger/go-web-frameworks/pkg"
 )
 
 var (
-	pageSize = 4
+	entitiesRepo pkg.EntityRepository = pkg.NewEntityMemoryRepository()
+	pageSize                          = 4
 )
 
 func main() {
 	app := fiber.New()
-
-	entitiesRepo := pkg.NewEntityMemoryRepository()
 	entitiesRepo.Init()
 
 	app.Get("/", func(c *fiber.Ctx) error {
 		return c.SendString("Hello, Fiber!")
 	})
 
 	entitiesAPI := app.Group("/entities")
-	entitiesAPI.Get("/", func(c *fiber.Ctx) error {
-		pageStr := c.Query("page", "1")
-		page, err := strconv.Atoi(pageStr)
-		if err != nil {
-			page = 1
-		}
-
-		entities, err := entitiesRepo.List(page, pageSize)
-		if err != nil {
-			// c.JSON(pkg.TextResponse{Message: err.Error()})
-			// return fiber.NewError(fiber.StatusInternalServerError, err.Error())
-
-			// TODO: Replace 500 error with 4xx for paging related errors.
-			errMsg := pkg.TextResponse{Message: err.Error()}
-			return c.Status(fiber.StatusInternalServerError).JSON(errMsg)
-		}
-
-		c.JSON(entities)
-		return nil
-	})
-	entitiesAPI.Get("/:id", func(c *fiber.Ctx) error {
-		entityID := c.Params("id", "")
-
-		entity, err := entitiesRepo.Get(entityID)
-		if err != nil {
-			errMsg := pkg.TextResponse{Message: err.Error()}
-			return c.Status(fiber.StatusInternalServerError).JSON(errMsg)
-		}
-
-		if entity == nil {
-			return fiber.ErrNotFound
-		}
-
-		c.JSON(entity)
-		return nil
-	})
+	entitiesAPI.Get("/", entitiesList)
+	entitiesAPI.Get("/:id", entitiesGet)
+	entitiesAPI.Post("/", entitiesAdd)
+	entitiesAPI.Put("/", entitiesUpdate)
+	entitiesAPI.Delete("/:id", entitiesDelete)
 
 	app.Listen(":8080")
 }