Master PR

.github/workflows/test.yml

@@ -11,6 +11,7 @@ jobs:
       matrix:
         microservices:
           - user_service
+          - product_service
     steps:
       - uses: actions/checkout@v3
       - name: Set up Go

.gitignore

@@ -1,3 +1,2 @@
 .vscode/
-*.env
 *.exe

run_services.sh

@@ -1,10 +1,17 @@
 #!/bin/bash/
 
+# Create common networks for the services
+docker network create -d bridge shared-network
+echo "Shared network created for microservices communication"
+
 # Run User service
 docker-compose -f src/user_service/docker-compose.yml up -d
+echo "User services are up and running!"
 
 # Run Product service
-# docker-compose -f src/product_service/docker-compose.yml up -d
+docker-compose -f src/product_service/docker-compose.yml up -d
+echo "Product services are up and running!"
 
-# RUn Order service
-# docker-compose -f src/order_service/docker-compose.yml up -d
+# Run Order service
+#docker-compose -f src/order_service/docker-compose.yml up -d
+#echo "Order services are up and running!"

src/product_service/.env

@@ -0,0 +1,11 @@
+DB_NAME=products_db
+DB_USER=db_user
+DB_PASSWORD=1234
+DB_URL=postgres://db_user:1234@products-db/products_db?sslmode=disable
+
+CGO_ENABLED=1
+PORT=8002
+GIN_MODE=debug
+
+INTERNAL_API_SECRET=1234_secret_4321
+USER_SERVICE_HOST=user_service:8001

src/product_service/api/config.go

@@ -0,0 +1,37 @@
+// Common config modules
+
+package api
+
+import (
+	"database/sql"
+	"fmt"
+
+	"github.com/redis/go-redis/v9"
+	"github.com/thejasmeetsingh/go-ecommerce/product_service/internal/database"
+)
+
+type APIConfig struct {
+	DB      *sql.DB
+	Queries *database.Queries
+	Cache   *redis.Client
+}
+
+func GetDBConn(dbURL string) *sql.DB {
+	conn, err := sql.Open("postgres", dbURL)
+
+	if err != nil {
+		panic(fmt.Sprintf("Cannot connect to the database: %v", err))
+	}
+
+	return conn
+}
+
+func GetRedisClient() *redis.Client {
+	client := redis.NewClient(&redis.Options{
+		Addr:     "products_cache:6379",
+		Password: "",
+		DB:       0,
+	})
+
+	return client
+}

src/product_service/api/crud.go

@@ -0,0 +1,112 @@
+package api
+
+import (
+	"fmt"
+
+	"github.com/gin-gonic/gin"
+	"github.com/google/uuid"
+	log "github.com/sirupsen/logrus"
+	"github.com/thejasmeetsingh/go-ecommerce/product_service/internal/database"
+)
+
+// Create product
+func CreateProductDB(apiCfg *APIConfig, ctx *gin.Context, params database.CreateProductParams) (database.Product, error) {
+	// Begin DB transaction
+	tx, err := apiCfg.DB.Begin()
+	if err != nil {
+		log.Fatal(err)
+		return database.Product{}, fmt.Errorf("something went wrong")
+	}
+	defer tx.Rollback()
+	qtx := apiCfg.Queries.WithTx(tx)
+
+	dbProduct, err := qtx.CreateProduct(ctx, params)
+
+	if err != nil {
+		log.Errorln(err)
+		return database.Product{}, fmt.Errorf("something went wrong")
+	}
+
+	// Commit the transaction
+	err = tx.Commit()
+	if err != nil {
+		log.Fatal(err)
+		return database.Product{}, fmt.Errorf("something went wrong")
+	}
+
+	return dbProduct, nil
+}
+
+// Get list of products
+func GetProductListDB(apiCfg *APIConfig, ctx *gin.Context, params database.GetProductsParams) ([]database.GetProductsRow, error) {
+	products, err := apiCfg.Queries.GetProducts(ctx, params)
+	if err != nil {
+		return []database.GetProductsRow{}, fmt.Errorf("something went wrong")
+	}
+	return products, nil
+}
+
+// Get details of a specific product
+func GetProductDetailDB(apiCfg *APIConfig, ctx *gin.Context, productID uuid.UUID) (database.Product, error) {
+	product, err := apiCfg.Queries.GetProductById(ctx, productID)
+	if err != nil {
+		log.Errorln(err)
+		return database.Product{}, fmt.Errorf("something went wrong")
+	}
+	return product, nil
+}
+
+// Update product details
+func UpdateProductDetailDB(apiCfg *APIConfig, ctx *gin.Context, params database.UpdateProductDetailsParams) (database.Product, error) {
+	// Begin DB transaction
+	tx, err := apiCfg.DB.Begin()
+	if err != nil {
+		log.Fatal(err)
+		return database.Product{}, fmt.Errorf("something went wrong")
+	}
+	defer tx.Rollback()
+	qtx := apiCfg.Queries.WithTx(tx)
+
+	dbProduct, err := qtx.UpdateProductDetails(ctx, params)
+
+	if err != nil {
+		log.Errorln(err)
+		return database.Product{}, fmt.Errorf("something went wrong")
+	}
+
+	// Commit the transaction
+	err = tx.Commit()
+	if err != nil {
+		log.Fatal(err)
+		return database.Product{}, fmt.Errorf("something went wrong")
+	}
+
+	return dbProduct, nil
+}
+
+// Delete a product
+func DeleteProductDetailDB(apiCfg *APIConfig, ctx *gin.Context, productID uuid.UUID) error {
+	// Begin DB transaction
+	tx, err := apiCfg.DB.Begin()
+	if err != nil {
+		log.Fatal(err)
+		return fmt.Errorf("something went wrong")
+	}
+	defer tx.Rollback()
+	qtx := apiCfg.Queries.WithTx(tx)
+
+	err = qtx.DeleteProduct(ctx, productID)
+	if err != nil {
+		log.Errorln(err)
+		return fmt.Errorf("something went wrong")
+	}
+
+	// Commit the transaction
+	err = tx.Commit()
+	if err != nil {
+		log.Fatal(err)
+		return fmt.Errorf("something went wrong")
+	}
+
+	return nil
+}

src/product_service/api/middleware.go

@@ -0,0 +1,44 @@
+package api
+
+import (
+	"net/http"
+	"strings"
+
+	"github.com/gin-gonic/gin"
+	log "github.com/sirupsen/logrus"
+	"github.com/thejasmeetsingh/go-ecommerce/product_service/shared"
+)
+
+func Auth(apiCfg *APIConfig) gin.HandlerFunc {
+	return func(ctx *gin.Context) {
+		headerAuthToken := ctx.GetHeader("Authorization")
+
+		if headerAuthToken == "" {
+			ctx.JSON(http.StatusForbidden, gin.H{"message": "Authentication required"})
+			ctx.Abort()
+			return
+		}
+
+		// Split the token string
+		authToken := strings.Split(headerAuthToken, " ")
+
+		// Validate the token string
+		if len(authToken) != 2 || authToken[0] != "Bearer" {
+			ctx.JSON(http.StatusForbidden, gin.H{"message": "Invalid authentication format"})
+			ctx.Abort()
+			return
+		}
+
+		// Fetch userID and set to the context
+		userID, err := shared.GetUserFromToken(apiCfg.Cache, ctx, authToken[1])
+		if err != nil {
+			log.Errorln(err)
+			ctx.JSON(http.StatusForbidden, gin.H{"message": "Something went"})
+			ctx.Abort()
+			return
+		}
+
+		ctx.Set("userID", userID)
+		ctx.Next()
+	}
+}

src/product_service/api/models.go

@@ -0,0 +1,49 @@
+package api
+
+import (
+	"time"
+
+	"github.com/google/uuid"
+	"github.com/thejasmeetsingh/go-ecommerce/product_service/internal/database"
+)
+
+type productDetail struct {
+	ID          uuid.UUID `json:"id"`
+	CreatedAt   time.Time `json:"created_at"`
+	ModifiedAt  time.Time `json:"modified_at"`
+	Name        string    `json:"name"`
+	Price       int32     `json:"price"`
+	Description string    `json:"description"`
+}
+
+type productList struct {
+	ID          uuid.UUID `json:"id"`
+	Name        string    `json:"name"`
+	Price       int32     `json:"price"`
+	Description string    `json:"description"`
+}
+
+func DatabaseProductToProduct(dbProduct database.Product) productDetail {
+	return productDetail{
+		ID:          dbProduct.ID,
+		CreatedAt:   dbProduct.CreatedAt,
+		ModifiedAt:  dbProduct.ModifiedAt,
+		Name:        dbProduct.Name,
+		Price:       dbProduct.Price,
+		Description: dbProduct.Description,
+	}
+}
+
+func DatabaseProductToProductList(dbProducts []database.GetProductsRow) []productList {
+	var products []productList
+
+	for _, dbProduct := range dbProducts {
+		products = append(products, productList{
+			ID:          dbProduct.ID,
+			Name:        dbProduct.Name,
+			Price:       dbProduct.Price,
+			Description: dbProduct.Description,
+		})
+	}
+	return products
+}