refactor: add validate to command/query level

internal/services/catalog_read_service/internal/products/features/creating_product/v1/commands/create_product.go

@@ -1,9 +1,9 @@
 package commands
 
 import (
+	validation "github.com/go-ozzo/ozzo-validation"
 	"time"
 
-	"github.com/mehdihadeli/go-ecommerce-microservices/internal/pkg/utils/validator"
 	uuid "github.com/satori/go.uuid"
 )
 
@@ -32,10 +32,19 @@ func NewCreateProduct(
 		Price:       price,
 		CreatedAt:   createdAt,
 	}
-	err := validator.Validate(command)
+	err := command.Validate()
 	if err != nil {
 		return nil, err
 	}
 
 	return command, nil
 }
+
+func (p *CreateProduct) Validate() error {
+	return validation.ValidateStruct(p, validation.Field(&p.Id, validation.Required),
+		validation.Field(&p.ProductId, validation.Required),
+		validation.Field(&p.Name, validation.Required, validation.Length(3, 250)),
+		validation.Field(&p.Description, validation.Required, validation.Length(3, 500)),
+		validation.Field(&p.Price, validation.Required),
+		validation.Field(&p.CreatedAt, validation.Required))
+}

internal/services/catalog_read_service/internal/products/features/get_product_by_id/v1/queries/get_product_by_id.go

@@ -8,6 +8,8 @@ type GetProductById struct {
 	Id uuid.UUID `validate:"required"`
 }
 
+// TODO
+// this function seems doesn't validate if the id is empty, should I refactor this func and handle the error where NewGetProductByID called?
 func NewGetProductById(id uuid.UUID) *GetProductById {
 	return &GetProductById{Id: id}
 }

internal/services/catalog_read_service/internal/products/features/searching_products/v1/endpoints/search_products_endpoint.go

@@ -79,7 +79,9 @@ func (ep *searchProductsEndpoint) handler() echo.HandlerFunc {
 			ListQuery:  request.ListQuery,
 		}
 
-		if err := ep.Validator.StructCtx(ctx, query); err != nil {
+		// Am I right?  this one is a validator.StructCtx with   ctx, can I just make it to query.Validate?
+		//if err := ep.Validator.StructCtx(ctx, query); err != nil {
+		if err := query.Validate(); err != nil {
 			validationErr := customErrors.NewValidationErrorWrap(
 				err,
 				"[searchProductsEndpoint_handler.StructCtx]  query validation failed",

internal/services/catalog_read_service/internal/products/features/searching_products/v1/queries/search_products.go

@@ -1,8 +1,15 @@
 package queries
 
-import "github.com/mehdihadeli/go-ecommerce-microservices/internal/pkg/utils"
+import (
+	validation "github.com/go-ozzo/ozzo-validation"
+	"github.com/mehdihadeli/go-ecommerce-microservices/internal/pkg/utils"
+)
 
 type SearchProducts struct {
 	SearchText string `validate:"required"`
 	*utils.ListQuery
 }
+
+func (s *SearchProducts) Validate() error {
+	return validation.ValidateStruct(s, validation.Field(&s.SearchText, validation.Required))
+}