update endpoints

Author: Bulletdev

cmd/main.go

@@ -3,10 +3,12 @@ package main
 import (
 	"bullet-cloud-api/internal/addresses"
 	"bullet-cloud-api/internal/auth"
+	"bullet-cloud-api/internal/cart"
 	"bullet-cloud-api/internal/categories"
 	"bullet-cloud-api/internal/config"
 	"bullet-cloud-api/internal/database"
 	"bullet-cloud-api/internal/handlers"
+	"bullet-cloud-api/internal/orders"
 	"bullet-cloud-api/internal/products"
 	"bullet-cloud-api/internal/users"
 	"context"
@@ -36,13 +38,17 @@ func main() {
 	productRepo := products.NewPostgresProductRepository(dbPool)
 	categoryRepo := categories.NewPostgresCategoryRepository(dbPool)
 	addressRepo := addresses.NewPostgresAddressRepository(dbPool)
+	cartRepo := cart.NewPostgresCartRepository(dbPool)
+	orderRepo := orders.NewPostgresOrderRepository(dbPool)
 	authHandler := handlers.NewAuthHandler(userRepo, cfg.JWTSecret, defaultJWTExpiry)
 	userHandler := handlers.NewUserHandler(userRepo, addressRepo)
 	productHandler := handlers.NewProductHandler(productRepo)
 	categoryHandler := handlers.NewCategoryHandler(categoryRepo)
+	cartHandler := handlers.NewCartHandler(cartRepo, productRepo)
+	orderHandler := handlers.NewOrderHandler(orderRepo, cartRepo, addressRepo)
 	authMiddleware := auth.NewMiddleware(cfg.JWTSecret, userRepo)
 
-	r := setupRoutes(authHandler, userHandler, productHandler, categoryHandler, authMiddleware)
+	r := setupRoutes(authHandler, userHandler, productHandler, categoryHandler, cartHandler, orderHandler, authMiddleware)
 
 	port := os.Getenv("API_PORT")
 	if port == "" {
@@ -80,7 +86,7 @@ func main() {
 	log.Println("Server exited properly")
 }
 
-func setupRoutes(ah *handlers.AuthHandler, uh *handlers.UserHandler, ph *handlers.ProductHandler, ch *handlers.CategoryHandler, mw *auth.Middleware) *mux.Router {
+func setupRoutes(ah *handlers.AuthHandler, uh *handlers.UserHandler, ph *handlers.ProductHandler, ch *handlers.CategoryHandler, cartH *handlers.CartHandler, oh *handlers.OrderHandler, mw *auth.Middleware) *mux.Router {
 	r := mux.NewRouter()
 
 	apiV1 := r.PathPrefix("/api").Subrouter()
@@ -114,5 +120,20 @@ func setupRoutes(ah *handlers.AuthHandler, uh *handlers.UserHandler, ph *handler
 	protectedCategoryRoutes.HandleFunc("/{id:[0-9a-fA-F-]+}", ch.UpdateCategory).Methods("PUT")
 	protectedCategoryRoutes.HandleFunc("/{id:[0-9a-fA-F-]+}", ch.DeleteCategory).Methods("DELETE")
 
+	protectedCartRoutes := apiV1.PathPrefix("/cart").Subrouter()
+	protectedCartRoutes.Use(mw.Authenticate)
+	protectedCartRoutes.HandleFunc("", cartH.GetCart).Methods("GET")
+	protectedCartRoutes.HandleFunc("/items", cartH.AddItem).Methods("POST")
+	protectedCartRoutes.HandleFunc("/items/{productId:[0-9a-fA-F-]+}", cartH.UpdateItem).Methods("PUT")
+	protectedCartRoutes.HandleFunc("/items/{productId:[0-9a-fA-F-]+}", cartH.DeleteItem).Methods("DELETE")
+	protectedCartRoutes.HandleFunc("", cartH.ClearCart).Methods("DELETE")
+
+	protectedOrderRoutes := apiV1.PathPrefix("/orders").Subrouter()
+	protectedOrderRoutes.Use(mw.Authenticate)
+	protectedOrderRoutes.HandleFunc("", oh.CreateOrder).Methods("POST")
+	protectedOrderRoutes.HandleFunc("", oh.ListOrders).Methods("GET")
+	protectedOrderRoutes.HandleFunc("/{id:[0-9a-fA-F-]+}", oh.GetOrder).Methods("GET")
+	protectedOrderRoutes.HandleFunc("/{id:[0-9a-fA-F-]+}/cancel", oh.CancelOrder).Methods("PATCH")
+
 	return r
 }

internal/cart/repository.go

@@ -0,0 +1,219 @@
+package cart
+
+import (
+	"bullet-cloud-api/internal/models"
+	"context"
+	"errors"
+
+	"github.com/google/uuid"
+	"github.com/jackc/pgx/v5"
+	"github.com/jackc/pgx/v5/pgxpool"
+)
+
+var (
+	ErrCartNotFound     = errors.New("cart not found")
+	ErrCartItemNotFound = errors.New("cart item not found")
+	ErrProductNotInCart = errors.New("product not found in cart")
+)
+
+// CartRepository defines the interface for cart data operations.
+type CartRepository interface {
+	// GetOrCreateCartByUserID finds the cart for a user or creates one if it doesn't exist.
+	GetOrCreateCartByUserID(ctx context.Context, userID uuid.UUID) (*models.Cart, error)
+	// GetCartItems retrieves all items currently in the specified cart.
+	GetCartItems(ctx context.Context, cartID uuid.UUID) ([]models.CartItem, error)
+	// AddItem adds a product to the cart or updates its quantity if it already exists.
+	AddItem(ctx context.Context, cartID, productID uuid.UUID, quantity int, price float64) (*models.CartItem, error)
+	// UpdateItemQuantity changes the quantity of an existing item in the cart.
+	UpdateItemQuantity(ctx context.Context, cartID, productID uuid.UUID, quantity int) (*models.CartItem, error)
+	// RemoveItem removes a specific product from the cart.
+	RemoveItem(ctx context.Context, cartID, productID uuid.UUID) error
+	// ClearCart removes all items from a specific cart.
+	ClearCart(ctx context.Context, cartID uuid.UUID) error
+	// FindCartItem retrieves a specific item from a cart.
+	FindCartItem(ctx context.Context, cartID, productID uuid.UUID) (*models.CartItem, error)
+}
+
+// postgresCartRepository implements CartRepository using PostgreSQL.
+type postgresCartRepository struct {
+	db *pgxpool.Pool
+}
+
+// NewPostgresCartRepository creates a new instance of postgresCartRepository.
+func NewPostgresCartRepository(db *pgxpool.Pool) CartRepository {
+	return &postgresCartRepository{db: db}
+}
+
+// GetOrCreateCartByUserID finds or creates a cart for the user.
+func (r *postgresCartRepository) GetOrCreateCartByUserID(ctx context.Context, userID uuid.UUID) (*models.Cart, error) {
+	// Try to find existing cart
+	queryFind := `SELECT id, user_id, created_at, updated_at FROM carts WHERE user_id = $1`
+	cart := &models.Cart{}
+	err := r.db.QueryRow(ctx, queryFind, userID).Scan(
+		&cart.ID, &cart.UserID, &cart.CreatedAt, &cart.UpdatedAt,
+	)
+
+	if err == nil {
+		return cart, nil // Cart found
+	}
+
+	// If no cart found, create one
+	if errors.Is(err, pgx.ErrNoRows) {
+		queryCreate := `
+			INSERT INTO carts (user_id)
+			VALUES ($1)
+			RETURNING id, user_id, created_at, updated_at
+		`
+		errCreate := r.db.QueryRow(ctx, queryCreate, userID).Scan(
+			&cart.ID, &cart.UserID, &cart.CreatedAt, &cart.UpdatedAt,
+		)
+		if errCreate != nil {
+			// Handle potential unique constraint violation if called concurrently (unlikely with user_id unique)
+			return nil, errCreate
+		}
+		return cart, nil // Cart created
+	}
+
+	// Other unexpected error during find
+	return nil, err
+}
+
+// GetCartItems retrieves all items for a given cart ID.
+func (r *postgresCartRepository) GetCartItems(ctx context.Context, cartID uuid.UUID) ([]models.CartItem, error) {
+	// Query includes JOIN to get product details (optional, adjust fields as needed)
+	// query := `
+	// 	SELECT ci.id, ci.cart_id, ci.product_id, ci.quantity, ci.price, ci.created_at, ci.updated_at,
+	// 	       p.name as product_name, p.description as product_description -- Example JOIN
+	// 	FROM cart_items ci
+	// 	JOIN products p ON ci.product_id = p.id
+	// 	WHERE ci.cart_id = $1
+	// 	ORDER BY ci.created_at ASC
+	// `
+	query := `
+		SELECT id, cart_id, product_id, quantity, price, created_at, updated_at
+		FROM cart_items
+		WHERE cart_id = $1
+		ORDER BY created_at ASC
+	`
+	rows, err := r.db.Query(ctx, query, cartID)
+	if err != nil {
+		return nil, err
+	}
+	defer rows.Close()
+
+	items, err := pgx.CollectRows(rows, pgx.RowToStructByName[models.CartItem])
+	if err != nil {
+		return nil, err
+	}
+	return items, nil
+}
+
+// AddItem adds or updates a product in the cart.
+func (r *postgresCartRepository) AddItem(ctx context.Context, cartID, productID uuid.UUID, quantity int, price float64) (*models.CartItem, error) {
+	query := `
+		INSERT INTO cart_items (cart_id, product_id, quantity, price)
+		VALUES ($1, $2, $3, $4)
+		ON CONFLICT (cart_id, product_id) DO UPDATE SET
+			quantity = cart_items.quantity + EXCLUDED.quantity,
+			price = EXCLUDED.price, -- Update price in case it changed
+			updated_at = NOW()
+		RETURNING id, cart_id, product_id, quantity, price, created_at, updated_at
+	`
+	item := &models.CartItem{}
+	err := r.db.QueryRow(ctx, query, cartID, productID, quantity, price).Scan(
+		&item.ID,
+		&item.CartID,
+		&item.ProductID,
+		&item.Quantity,
+		&item.Price,
+		&item.CreatedAt,
+		&item.UpdatedAt,
+	)
+
+	if err != nil {
+		// Handle potential FK violations (cart_id or product_id invalid)
+		return nil, err
+	}
+	return item, nil
+}
+
+// UpdateItemQuantity updates the quantity of a specific item.
+func (r *postgresCartRepository) UpdateItemQuantity(ctx context.Context, cartID, productID uuid.UUID, quantity int) (*models.CartItem, error) {
+	if quantity <= 0 {
+		// If quantity is zero or less, remove the item instead
+		return nil, r.RemoveItem(ctx, cartID, productID)
+	}
+
+	query := `
+		UPDATE cart_items
+		SET quantity = $1, updated_at = NOW()
+		WHERE cart_id = $2 AND product_id = $3
+		RETURNING id, cart_id, product_id, quantity, price, created_at, updated_at
+	`
+	item := &models.CartItem{}
+	err := r.db.QueryRow(ctx, query, quantity, cartID, productID).Scan(
+		&item.ID,
+		&item.CartID,
+		&item.ProductID,
+		&item.Quantity,
+		&item.Price,
+		&item.CreatedAt,
+		&item.UpdatedAt,
+	)
+
+	if err != nil {
+		if errors.Is(err, pgx.ErrNoRows) {
+			return nil, ErrProductNotInCart
+		}
+		return nil, err
+	}
+	return item, nil
+}
+
+// RemoveItem deletes an item from the cart.
+func (r *postgresCartRepository) RemoveItem(ctx context.Context, cartID, productID uuid.UUID) error {
+	query := `DELETE FROM cart_items WHERE cart_id = $1 AND product_id = $2`
+	result, err := r.db.Exec(ctx, query, cartID, productID)
+	if err != nil {
+		return err
+	}
+	if result.RowsAffected() == 0 {
+		return ErrProductNotInCart // Item wasn't in the cart
+	}
+	return nil
+}
+
+// ClearCart removes all items from a given cart.
+func (r *postgresCartRepository) ClearCart(ctx context.Context, cartID uuid.UUID) error {
+	query := `DELETE FROM cart_items WHERE cart_id = $1`
+	_, err := r.db.Exec(ctx, query, cartID)
+	// We don't necessarily return an error if cart was already empty
+	return err
+}
+
+// FindCartItem retrieves a specific item from a cart.
+func (r *postgresCartRepository) FindCartItem(ctx context.Context, cartID, productID uuid.UUID) (*models.CartItem, error) {
+	query := `
+		SELECT id, cart_id, product_id, quantity, price, created_at, updated_at
+		FROM cart_items
+		WHERE cart_id = $1 AND product_id = $2
+	`
+	item := &models.CartItem{}
+	err := r.db.QueryRow(ctx, query, cartID, productID).Scan(
+		&item.ID,
+		&item.CartID,
+		&item.ProductID,
+		&item.Quantity,
+		&item.Price,
+		&item.CreatedAt,
+		&item.UpdatedAt,
+	)
+
+	if err != nil {
+		if errors.Is(err, pgx.ErrNoRows) {
+			return nil, ErrProductNotInCart
+		}
+		return nil, err
+	}
+	return item, nil
+}

internal/database/migrations/000005_create_cart_tables.down.sql

@@ -0,0 +1,21 @@
+-- +migrate Down
+-- SQL in this section is executed when the migration is rolled back.
+
+-- Drop trigger on cart_items
+DROP TRIGGER IF EXISTS update_cart_items_updated_at ON cart_items;
+
+-- Drop indices on cart_items
+DROP INDEX IF EXISTS idx_cart_items_product_id;
+DROP INDEX IF EXISTS idx_cart_items_cart_id;
+
+-- Drop the cart_items table (constraints/FKs are dropped with the table)
+DROP TABLE IF EXISTS cart_items;
+
+-- Drop trigger on carts
+DROP TRIGGER IF EXISTS update_carts_updated_at ON carts;
+
+-- Drop index on carts
+DROP INDEX IF EXISTS idx_carts_user_id;
+
+-- Drop the carts table
+DROP TABLE IF EXISTS carts;

internal/database/migrations/000005_create_cart_tables.up.sql

@@ -0,0 +1,59 @@
+-- +migrate Up
+-- SQL in this section is executed when the migration is applied.
+
+-- Create the carts table (one cart per user)
+CREATE TABLE IF NOT EXISTS carts (
+    id UUID PRIMARY KEY DEFAULT uuid_generate_v4(),
+    user_id UUID UNIQUE NOT NULL,
+    created_at TIMESTAMPTZ NOT NULL DEFAULT NOW(),
+    updated_at TIMESTAMPTZ NOT NULL DEFAULT NOW(),
+
+    CONSTRAINT fk_carts_user
+        FOREIGN KEY(user_id) REFERENCES users(id)
+        ON DELETE CASCADE -- If user is deleted, their cart is deleted
+);
+
+-- Index on user_id for faster lookup
+CREATE INDEX IF NOT EXISTS idx_carts_user_id ON carts(user_id);
+
+-- Trigger for updated_at on carts
+CREATE TRIGGER update_carts_updated_at
+BEFORE UPDATE ON carts
+FOR EACH ROW
+EXECUTE FUNCTION update_updated_at_column();
+
+-- Create the cart_items table
+CREATE TABLE IF NOT EXISTS cart_items (
+    id UUID PRIMARY KEY DEFAULT uuid_generate_v4(),
+    cart_id UUID NOT NULL,
+    product_id UUID NOT NULL,
+    quantity INT NOT NULL CHECK (quantity > 0),
+    price NUMERIC(10, 2) NOT NULL CHECK (price >= 0), -- Price at the time of adding
+    created_at TIMESTAMPTZ NOT NULL DEFAULT NOW(),
+    updated_at TIMESTAMPTZ NOT NULL DEFAULT NOW(),
+
+    CONSTRAINT fk_cart_items_cart
+        FOREIGN KEY(cart_id) REFERENCES carts(id)
+        ON DELETE CASCADE, -- If cart is deleted, items are deleted
+
+    CONSTRAINT fk_cart_items_product
+        FOREIGN KEY(product_id) REFERENCES products(id)
+        ON DELETE CASCADE, -- If product is deleted, remove item from cart
+
+    -- Ensure a product appears only once per cart (update quantity instead)
+    CONSTRAINT unique_cart_product UNIQUE (cart_id, product_id)
+);
+
+-- Indices for performance
+CREATE INDEX IF NOT EXISTS idx_cart_items_cart_id ON cart_items(cart_id);
+CREATE INDEX IF NOT EXISTS idx_cart_items_product_id ON cart_items(product_id);
+
+-- Trigger for updated_at on cart_items
+CREATE TRIGGER update_cart_items_updated_at
+BEFORE UPDATE ON cart_items
+FOR EACH ROW
+EXECUTE FUNCTION update_updated_at_column();
+
+
+-- +migrate Down
+-- SQL section moved to the .down.sql file

internal/database/migrations/000006_create_order_tables.down.sql

@@ -0,0 +1,25 @@
+-- +migrate Down
+-- SQL in this section is executed when the migration is rolled back.
+
+-- Drop trigger on order_items
+DROP TRIGGER IF EXISTS update_order_items_updated_at ON order_items;
+
+-- Drop indices on order_items
+DROP INDEX IF EXISTS idx_order_items_product_id;
+DROP INDEX IF EXISTS idx_order_items_order_id;
+
+-- Drop the order_items table
+DROP TABLE IF EXISTS order_items;
+
+-- Drop trigger on orders
+DROP TRIGGER IF EXISTS update_orders_updated_at ON orders;
+
+-- Drop indices on orders
+DROP INDEX IF EXISTS idx_orders_status;
+DROP INDEX IF EXISTS idx_orders_user_id;
+
+-- Drop the orders table
+DROP TABLE IF EXISTS orders;
+
+-- Optional: Drop the ENUM type if it was created
+-- DROP TYPE IF EXISTS order_status;