<Gateway>|added product front store handler and category handler|<Pooja>

gateway/.env

@@ -0,0 +1,9 @@
+PORT=8000
+AUTH_SERVICE_URI=http://34.228.112.42:8001
+USER_SERVICE_URI=http://34.228.112.42:8002
+PRODUCT_FRONT_STORE_SERVICE_URI=http://34.228.112.42:8003
+PRODUCT_ADMIN_SERVICE_URI=http://34.228.112.42:8004
+CATEGORY_SERVICE_URI=http://34.228.112.42:8005
+ORDER_SERVICE_URI=http://34.228.112.42:8007
+PAYMENT_SERVICE_URI=http://34.228.112.42:8008
+SHIPPING_SERVICE_URI=http://34.228.112.42:8012

gateway/Dockerfile

@@ -0,0 +1,31 @@
+##
+## Build
+##
+
+FROM golang:1.18-alpine AS build
+
+WORKDIR /app
+
+COPY go.mod .
+COPY go.sum .
+RUN go mod download
+
+COPY . .
+
+RUN go build -o gateway-app main.go
+
+##
+## Deploy
+##
+
+FROM alpine
+
+WORKDIR /
+
+COPY --from=build /app/gateway-app /gateway-app
+
+COPY .env .env
+
+EXPOSE 8000
+
+ENTRYPOINT ["/gateway-app"]

gateway/app/app.go

@@ -0,0 +1,36 @@
+package app
+
+import (
+	"fmt"
+	"log"
+	"os"
+
+	"github.com/joho/godotenv"
+)
+
+func Start() {
+	RegisterUserRoutes()
+	RegisterOrderRoutes()
+	RegisterShippingRoutes()
+	RegisterProductAdminRoutes()
+	RegisterProductFrontStoreRoutes()
+	RegisterCategoryRoutes()
+	RegisterPaymentRoutes()
+
+	err := godotenv.Load(".env")
+	if err != nil {
+		log.Fatal(err)
+		return
+	}
+
+	if err != nil {
+		log.Fatalf("Error loading .env file")
+	}
+	PORT := os.Getenv("PORT")
+	fmt.Print(PORT)
+
+	err = Router.Run(":8000")
+	if err != nil {
+		return
+	}
+}

gateway/app/authMiddleware.go

@@ -0,0 +1,96 @@
+package app
+
+import (
+	"context"
+	"encoding/json"
+	"github.com/gin-gonic/gin"
+	"github.com/swiggy-2022-bootcamp/cdp-team4/gateway/utils/errs"
+	"log"
+	"net/http"
+	"os"
+	"time"
+)
+
+type AuthModel struct {
+	UserId string
+	Role   int
+}
+
+type ValidationDTO struct {
+	UserId string `json:"user_id"`
+	Role   int    `json:"role"`
+}
+
+func ValidateToken(authorizationHeader string) (*AuthModel, *errs.AppError) {
+	authServiceUri := os.Getenv("AUTH_SERVICE_URI")
+	validateTokenApi := "/api/v1/validate"
+
+	req, err := http.NewRequest("GET", authServiceUri+validateTokenApi, nil)
+	if err != nil {
+		log.Fatalf("%v", err)
+	}
+
+	ctx, cancel := context.WithTimeout(req.Context(), 1*time.Minute)
+	defer cancel()
+
+	req = req.WithContext(ctx)
+	req.Header.Set("Authorization", authorizationHeader)
+	client := http.DefaultClient
+	res, err := client.Do(req)
+	if err != nil {
+		//log.Fatalf("%v", err)
+		return nil, errs.NewAuthenticationError(err.Error())
+	}
+
+	var resDTO ResponseDTO
+	err = json.NewDecoder(res.Body).Decode(&resDTO)
+
+	if err != nil {
+		//log.Fatalf("unable to decode response %v", err)
+		return nil, errs.NewUnexpectedError(err.Error())
+	}
+
+	if resDTO.Status == http.StatusUnauthorized {
+		return nil, errs.NewAuthenticationError(resDTO.Message)
+	}
+
+	var valDTO ValidationDTO
+	marshalledData, _ := json.Marshal(resDTO.Data)
+	err = json.Unmarshal(marshalledData, &valDTO)
+	if err != nil {
+		return nil, errs.NewAuthenticationError(err.Error())
+	}
+
+	return &AuthModel{
+		UserId: valDTO.UserId,
+		Role:   valDTO.Role,
+	}, nil
+}
+
+func ValidateAuthToken() gin.HandlerFunc {
+	return func(c *gin.Context) {
+		res, err := ValidateToken(c.Request.Header.Get("Authorization"))
+
+		if err != nil {
+			response := ResponseDTO{
+				Status:  err.Code,
+				Message: err.Message,
+			}
+			c.JSON(response.Status, response)
+			c.Abort()
+			return
+		}
+
+		c.Params = append(c.Params, gin.Param{
+			Key:   "userId",
+			Value: res.UserId,
+		})
+
+		isAdmin := "false"
+		if res.Role == 1 {
+			isAdmin = "true"
+		}
+
+		c.Request.Header.Set("admin", isAdmin)
+	}
+}