fix: implemented the product search functionality

  ✅ Added Search Endpoint:
  - Route: GET /api/products/search?q=<search_term>
  - Function: Searches products by name or description (case-insensitive)
  - Priority: Results with matching names appear first

  ✅ Implementation Details:
  1. Repository Layer: Added Search() method to ProductRepository interface
  2. Database Query: Uses ILIKE for case-insensitive search on name and description
  3. Handler Layer: Added SearchProducts() handler with query parameter validation
  4. Route Registration: Added search route to main.go (placed before the /{id} route to avoid conflicts)
  5. Mock Updated: Updated repository mock for testing

Author: Bulletdev

cmd/main.go

@@ -134,6 +134,7 @@ func setupRoutes(
 	apiV1.HandleFunc("/auth/register", ah.Register).Methods("POST")
 	apiV1.HandleFunc("/auth/login", ah.Login).Methods("POST")
 	apiV1.HandleFunc("/products", ph.GetAllProducts).Methods("GET")
+	apiV1.HandleFunc("/products/search", ph.SearchProducts).Methods("GET")
 	apiV1.HandleFunc("/products/{id:[0-9a-fA-F-]+}", ph.GetProduct).Methods("GET")
 	apiV1.HandleFunc("/categories", ch.GetAllCategories).Methods("GET")
 	apiV1.HandleFunc("/categories/{id:[0-9a-fA-F-]+}", ch.GetCategory).Methods("GET")

docker-compose.yml

@@ -0,0 +1,49 @@
+services:
+  app:
+    build: .
+    ports:
+      - "4444:4444"
+    environment:
+      - DATABASE_URL=postgres://postgres:password@db:5432/bulletcloud?sslmode=disable
+      - PORT=4444
+      - ENV=development
+      - JWT_SECRET=your-super-secret-jwt-key-change-this-in-production
+      - JWT_ACCESS_EXPIRY=15m
+      - JWT_REFRESH_EXPIRY=168h
+      - CORS_ALLOWED_ORIGINS=http://localhost:3000,http://localhost:3001,http://localhost:3002
+      - BCRYPT_COST=12
+      - MAX_LOGIN_ATTEMPTS=5
+      - LOCKOUT_DURATION=30m
+      - LOG_LEVEL=info
+      - LOG_FORMAT=json
+    depends_on:
+      db:
+        condition: service_healthy
+    networks:
+      - app-network
+
+  db:
+    image: postgres:15-alpine
+    environment:
+      - POSTGRES_DB=bulletcloud
+      - POSTGRES_USER=postgres
+      - POSTGRES_PASSWORD=password
+    ports:
+      - "5432:5432"
+    volumes:
+      - postgres_data:/var/lib/postgresql/data
+    healthcheck:
+      test: ["CMD-SHELL", "pg_isready -U postgres -d bulletcloud"]
+      interval: 10s
+      timeout: 5s
+      retries: 5
+      start_period: 30s
+    networks:
+      - app-network
+
+volumes:
+  postgres_data:
+
+networks:
+  app-network:
+    driver: bridge

go.mod

@@ -4,21 +4,25 @@ go 1.23.0
 
 toolchain go1.24.1
 
-require github.com/gorilla/mux v1.8.1
+require (
+	github.com/golang-jwt/jwt/v5 v5.2.2
+	github.com/google/uuid v1.6.0
+	github.com/gorilla/mux v1.8.1
+	github.com/jackc/pgx/v5 v5.7.4
+	github.com/joho/godotenv v1.5.1
+	github.com/stretchr/testify v1.10.0
+	golang.org/x/crypto v0.37.0
+)
 
 require (
 	github.com/davecgh/go-spew v1.1.1 // indirect
-	github.com/golang-jwt/jwt/v5 v5.2.2 // indirect
-	github.com/google/uuid v1.6.0 // indirect
 	github.com/jackc/pgpassfile v1.0.0 // indirect
 	github.com/jackc/pgservicefile v0.0.0-20240606120523-5a60cdf6a761 // indirect
-	github.com/jackc/pgx/v5 v5.7.4 // indirect
 	github.com/jackc/puddle/v2 v2.2.2 // indirect
-	github.com/joho/godotenv v1.5.1 // indirect
+	github.com/kr/text v0.2.0 // indirect
 	github.com/pmezard/go-difflib v1.0.0 // indirect
+	github.com/rogpeppe/go-internal v1.14.1 // indirect
 	github.com/stretchr/objx v0.5.2 // indirect
-	github.com/stretchr/testify v1.10.0 // indirect
-	golang.org/x/crypto v0.37.0 // indirect
 	golang.org/x/sync v0.13.0 // indirect
 	golang.org/x/text v0.24.0 // indirect
 	gopkg.in/yaml.v3 v3.0.1 // indirect

go.sum

@@ -1,3 +1,4 @@
+github.com/creack/pty v1.1.9/go.mod h1:oKZEueFk5CKHvIhNR5MUki03XCEU+Q6VDXinZuGJ33E=
 github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
 github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
@@ -17,28 +18,30 @@ github.com/jackc/puddle/v2 v2.2.2 h1:PR8nw+E/1w0GLuRFSmiioY6UooMp6KJv0/61nB7icHo
 github.com/jackc/puddle/v2 v2.2.2/go.mod h1:vriiEXHvEE654aYKXXjOvZM39qJ0q+azkZFrfEOc3H4=
 github.com/joho/godotenv v1.5.1 h1:7eLL/+HRGLY0ldzfGMeQkb7vMd0as4CfYvUVzLqw0N0=
 github.com/joho/godotenv v1.5.1/go.mod h1:f4LDr5Voq0i2e/R5DDNOoa2zzDfwtkZa6DnEwAbqwq4=
+github.com/kr/pretty v0.3.0 h1:WgNl7dwNpEZ6jJ9k1snq4pZsg7DOEN8hP9Xw0Tsjwk0=
+github.com/kr/pretty v0.3.0/go.mod h1:640gp4NfQd8pI5XOwp5fnNeVWj67G7CFk/SaSQn7NBk=
+github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY=
+github.com/kr/text v0.2.0/go.mod h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE=
 github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
 github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
+github.com/rogpeppe/go-internal v1.14.1 h1:UQB4HGPB6osV0SQTLymcB4TgvyWu6ZyliaW0tI/otEQ=
+github.com/rogpeppe/go-internal v1.14.1/go.mod h1:MaRKkUm5W0goXpeCfT7UZI6fk/L7L7so1lCWt35ZSgc=
 github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
 github.com/stretchr/objx v0.5.2 h1:xuMeJ0Sdp5ZMRXx/aWO6RZxdr3beISkG5/G/aIRr3pY=
 github.com/stretchr/objx v0.5.2/go.mod h1:FRsXN1f5AsAjCGJKqEizvkpNtU+EGNCLh3NxZ/8L+MA=
 github.com/stretchr/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UVUgZn+9EI=
 github.com/stretchr/testify v1.7.0/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
 github.com/stretchr/testify v1.10.0 h1:Xv5erBjTwe/5IxqUQTdXv5kgmIvbHo3QQyRwhJsOfJA=
 github.com/stretchr/testify v1.10.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY=
-golang.org/x/crypto v0.31.0 h1:ihbySMvVjLAeSH1IbfcRTkD/iNscyz8rGzjF/E5hV6U=
-golang.org/x/crypto v0.31.0/go.mod h1:kDsLvtWBEx7MV9tJOj9bnXsPbxwJQ6csT/x4KIN4Ssk=
 golang.org/x/crypto v0.37.0 h1:kJNSjF/Xp7kU0iB2Z+9viTPMW4EqqsrywMXLJOOsXSE=
 golang.org/x/crypto v0.37.0/go.mod h1:vg+k43peMZ0pUMhYmVAWysMK35e6ioLh3wB8ZCAfbVc=
-golang.org/x/sync v0.10.0 h1:3NQrjDixjgGwUOCaF8w2+VYHv0Ve/vGYSbdkTa98gmQ=
-golang.org/x/sync v0.10.0/go.mod h1:Czt+wKu1gCyEFDUtn0jG5QVvpJ6rzVqr5aXyt9drQfk=
 golang.org/x/sync v0.13.0 h1:AauUjRAJ9OSnvULf/ARrrVywoJDy0YS2AwQ98I37610=
 golang.org/x/sync v0.13.0/go.mod h1:1dzgHSNfp02xaA81J2MS99Qcpr2w7fw1gpm99rleRqA=
-golang.org/x/text v0.21.0 h1:zyQAAkrwaneQ066sspRyJaG9VNi/YJ1NfzcGB3hZ/qo=
-golang.org/x/text v0.21.0/go.mod h1:4IBbMaMmOPCJ8SecivzSH54+73PCFmPWxNTLm+vZkEQ=
 golang.org/x/text v0.24.0 h1:dd5Bzh4yt5KYA8f9CJHCP4FB4D51c2c6JvN37xJJkJ0=
 golang.org/x/text v0.24.0/go.mod h1:L8rBsPeo2pSS+xqN0d5u2ikmjtmoJbDBT1b7nHvFCdU=
 gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
+gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c h1:Hei/4ADfdWqJk1ZMxUNpqntNwaWcugrBjAiHlqqRiVk=
+gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c/go.mod h1:JHkPIbrfpd72SG/EVd6muEfDQjcINNoR0C8j2r3qZ4Q=
 gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
 gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
 gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=

internal/handlers/product_handler.go

@@ -92,6 +92,24 @@ func (h *ProductHandler) GetAllProducts(w http.ResponseWriter, r *http.Request)
 	webutils.WriteJSON(w, http.StatusOK, productList)
 }
 
+// SearchProducts handles GET requests to search products by query.
+// This is often a public endpoint.
+func (h *ProductHandler) SearchProducts(w http.ResponseWriter, r *http.Request) {
+	query := r.URL.Query().Get("q")
+	if query == "" {
+		webutils.ErrorJSON(w, errors.New("search query parameter 'q' is required"), http.StatusBadRequest)
+		return
+	}
+
+	productList, err := h.ProductRepo.Search(r.Context(), query)
+	if err != nil {
+		webutils.ErrorJSON(w, errors.New("failed to search products"), http.StatusInternalServerError)
+		return
+	}
+
+	webutils.WriteJSON(w, http.StatusOK, productList)
+}
+
 // GetProduct handles GET requests for a specific product by ID.
 // This is often a public endpoint.
 func (h *ProductHandler) GetProduct(w http.ResponseWriter, r *http.Request) {

internal/products/repository.go

@@ -19,6 +19,7 @@ type ProductRepository interface {
 	Create(ctx context.Context, product *models.Product) (*models.Product, error)
 	FindByID(ctx context.Context, id uuid.UUID) (*models.Product, error)
 	FindAll(ctx context.Context /* TODO: Add filtering/pagination params */) ([]models.Product, error)
+	Search(ctx context.Context, query string) ([]models.Product, error)
 	Update(ctx context.Context, id uuid.UUID, product *models.Product) (*models.Product, error)
 	Delete(ctx context.Context, id uuid.UUID) error
 }
@@ -120,6 +121,51 @@ func (r *postgresProductRepository) FindAll(ctx context.Context) ([]models.Produ
 	return products, nil
 }
 
+// Search retrieves products that match the search query (name or description).
+func (r *postgresProductRepository) Search(ctx context.Context, query string) ([]models.Product, error) {
+	searchQuery := `
+		SELECT id, name, description, price, category_id, created_at, updated_at
+		FROM products
+		WHERE name ILIKE $1 OR description ILIKE $1
+		ORDER BY
+			CASE
+				WHEN name ILIKE $1 THEN 1
+				ELSE 2
+			END,
+			created_at DESC
+	`
+	searchPattern := "%" + query + "%"
+	rows, err := r.db.Query(ctx, searchQuery, searchPattern)
+	if err != nil {
+		return nil, err
+	}
+	defer rows.Close()
+
+	products := make([]models.Product, 0)
+	for rows.Next() {
+		var product models.Product
+		err := rows.Scan(
+			&product.ID,
+			&product.Name,
+			&product.Description,
+			&product.Price,
+			&product.CategoryID,
+			&product.CreatedAt,
+			&product.UpdatedAt,
+		)
+		if err != nil {
+			return nil, err
+		}
+		products = append(products, product)
+	}
+
+	if rows.Err() != nil {
+		return nil, rows.Err()
+	}
+
+	return products, nil
+}
+
 // Update modifies an existing product in the database.
 func (r *postgresProductRepository) Update(ctx context.Context, id uuid.UUID, product *models.Product) (*models.Product, error) {
 	query := `

internal/products/repository_mock.go

@@ -82,6 +82,29 @@ func (_m *MockProductRepository) FindAll(ctx context.Context) ([]models.Product,
 	return r0, r1
 }
 
+// Search provides a mock function with given fields: ctx, query
+func (_m *MockProductRepository) Search(ctx context.Context, query string) ([]models.Product, error) {
+	ret := _m.Called(ctx, query)
+
+	var r0 []models.Product
+	if rf, ok := ret.Get(0).(func(context.Context, string) []models.Product); ok {
+		r0 = rf(ctx, query)
+	} else {
+		if ret.Get(0) != nil {
+			r0 = ret.Get(0).([]models.Product)
+		}
+	}
+
+	var r1 error
+	if rf, ok := ret.Get(1).(func(context.Context, string) error); ok {
+		r1 = rf(ctx, query)
+	} else {
+		r1 = ret.Error(1)
+	}
+
+	return r0, r1
+}
+
 // Update provides a mock function with given fields: ctx, id, product
 func (_m *MockProductRepository) Update(ctx context.Context, id uuid.UUID, product *models.Product) (*models.Product, error) {
 	ret := _m.Called(ctx, id, product)

internal/users/repository_mock.go

@@ -36,7 +36,6 @@ func (_m *MockUserRepository) Create(ctx context.Context, name string, email str
 	return r0, r1
 }
 
-// FindByEmail provides a mock function with given fields: ctx, email
 func (_m *MockUserRepository) FindByEmail(ctx context.Context, email string) (*models.User, error) {
 	ret := _m.Called(ctx, email)
 
@@ -59,7 +58,6 @@ func (_m *MockUserRepository) FindByEmail(ctx context.Context, email string) (*m
 	return r0, r1
 }
 
-// FindByID provides a mock function with given fields: ctx, id
 func (_m *MockUserRepository) FindByID(ctx context.Context, id uuid.UUID) (*models.User, error) {
 	ret := _m.Called(ctx, id)