chore(multi-tenant): creating multi tenant middleware

Author: levysam

cmd/http/handlers/dummy.go

@@ -57,7 +57,7 @@ func (hs *DummyHandlers) HandleGetDummy(context echo.Context) error {
 	if errors := context.Bind(data); errors != nil {
 		return context.JSON(422, errors)
 	}
-	tenant := context.Request().Header.Get("Tenant")
+	tenant := context.Get("tenant").(string)
 	request := dummyGet.NewRequest(data)
 	ctx := requestContext.NewPrepareContext(tenant)
 	ctx.SetContext(request.Domain)
@@ -92,7 +92,7 @@ func (hs *DummyHandlers) HandleCreateDummy(context echo.Context) error {
 		return context.JSON(http.StatusBadRequest, errors)
 	}
 
-	tenant := context.Request().Header.Get("Tenant")
+	tenant := context.Get("tenant").(string)
 	request := dummyCreate.NewRequest(data, hs.validator)
 	ctx := requestContext.NewPrepareContext(tenant)
 	ctx.SetContext(request.Domain)
@@ -129,7 +129,7 @@ func (hs *DummyHandlers) HandleEditDummy(context echo.Context) error {
 		return context.JSON(http.StatusBadRequest, errors)
 	}
 
-	tenant := context.Request().Header.Get("Tenant")
+	tenant := context.Get("tenant").(string)
 	request := dummyEdit.NewRequest(id, data, hs.validator)
 	ctx := requestContext.NewPrepareContext(tenant)
 	ctx.SetContext(request.Domain)
@@ -178,7 +178,7 @@ func (hs *DummyHandlers) HandleListDummy(context echo.Context) error {
 
 	f := filters.NewFilters()
 
-	tenant := context.Request().Header.Get("Tenant")
+	tenant := context.Get("tenant").(string)
 	request := dummyList.NewRequest(data, f)
 	ctx := requestContext.NewPrepareContext(tenant)
 	ctx.SetContext(request.Domain)
@@ -212,8 +212,7 @@ func (hs *DummyHandlers) HandleDeleteDummy(context echo.Context) error {
 	if errors := context.Bind(data); errors != nil {
 		return context.JSON(http.StatusBadRequest, errors)
 	}
-
-	tenant := context.Request().Header.Get("Tenant")
+	tenant := context.Get("tenant").(string)
 	request := dummyDelete.NewRequest(data)
 	ctx := requestContext.NewPrepareContext(tenant)
 	ctx.SetContext(request.Domain)

cmd/http/middlewares/multi_tenant.go

@@ -0,0 +1,11 @@
+package middlewares
+
+import "github.com/labstack/echo/v4"
+
+func SetTenant(next echo.HandlerFunc) echo.HandlerFunc {
+	return func(c echo.Context) error {
+		c.Set("tenant", c.Request().Header.Get("Tenant"))
+		// tenant validation Ex: get token and verify data or get tenant from session
+		return next(c)
+	}
+}

cmd/http/server/server.go

@@ -3,6 +3,7 @@ package server
 import (
 	"fmt"
 	echoSwagger "github.com/swaggo/echo-swagger"
+	"go-skeleton/cmd/http/middlewares"
 	"go-skeleton/cmd/http/routes"
 	"go-skeleton/docs"
 	"go-skeleton/pkg/config"
@@ -42,6 +43,7 @@ func (hs *Server) Start() {
 	}
 
 	server.Use(middleware.Recover())
+	server.Use(middlewares.SetTenant)
 
 	public := server.Group("")
 	private := server.Group("")

internal/application/providers/pagination/pagination.go

@@ -1,7 +1,6 @@
 package pagination
 
 import (
-	"fmt"
 	"go-skeleton/internal/application/services"
 	"go-skeleton/internal/repositories/base_repository"
 	"math"
@@ -36,7 +35,6 @@ func NewPaginationProvider[Row base_repository.Domain](repo IPaginationRepositor
 func (pp *Provider[Row]) PaginationHandler(row Row, page int, limit int) (*services.Error, *Pagination[Row]) {
 	listData := &[]Row{}
 	offset := (page - 1) * limit
-	fmt.Println(row)
 	total, err := pp.repo.Count(row)
 	if err != nil {
 		return &services.Error{