Merge remote-tracking branch 'origin' into front-styles
This commit is contained in:
@@ -33,8 +33,8 @@
|
|||||||
"description": "Product listing and description endpoints (under /api/v1/restricted, requires authentication)"
|
"description": "Product listing and description endpoints (under /api/v1/restricted, requires authentication)"
|
||||||
},
|
},
|
||||||
{
|
{
|
||||||
"name": "Product Description",
|
"name": "Product Translation",
|
||||||
"description": "Product description management and translation endpoints (under /api/v1/restricted/product-description, requires authentication)"
|
"description": "Product description management and translation endpoints (under /api/v1/restricted/product-translation, requires authentication)"
|
||||||
},
|
},
|
||||||
{
|
{
|
||||||
"name": "Menu",
|
"name": "Menu",
|
||||||
@@ -915,9 +915,9 @@
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
"/api/v1/restricted/product-description/get-product-description": {
|
"/api/v1/restricted/product-translation/get-product-description": {
|
||||||
"get": {
|
"get": {
|
||||||
"tags": ["Product Description"],
|
"tags": ["Product Translation"],
|
||||||
"summary": "Get product description",
|
"summary": "Get product description",
|
||||||
"description": "Returns the product description for a given product ID and language. Requires authentication.",
|
"description": "Returns the product description for a given product ID and language. Requires authentication.",
|
||||||
"operationId": "getProductDescription",
|
"operationId": "getProductDescription",
|
||||||
@@ -982,9 +982,9 @@
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
"/api/v1/restricted/product-description/save-product-description": {
|
"/api/v1/restricted/product-translation/save-product-description": {
|
||||||
"post": {
|
"post": {
|
||||||
"tags": ["Product Description"],
|
"tags": ["Product Translation"],
|
||||||
"summary": "Save product description",
|
"summary": "Save product description",
|
||||||
"description": "Saves the product description for a given product ID in the specified language. Requires authentication.",
|
"description": "Saves the product description for a given product ID in the specified language. Requires authentication.",
|
||||||
"operationId": "saveProductDescription",
|
"operationId": "saveProductDescription",
|
||||||
@@ -1059,9 +1059,9 @@
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
"/api/v1/restricted/product-description/translate-product-description": {
|
"/api/v1/restricted/product-translation/translate-product-description": {
|
||||||
"get": {
|
"get": {
|
||||||
"tags": ["Product Description"],
|
"tags": ["Product Translation"],
|
||||||
"summary": "Translate product description",
|
"summary": "Translate product description",
|
||||||
"description": "Translates the product description from one language to another using AI (OpenAI or Google). Requires authentication.",
|
"description": "Translates the product description from one language to another using AI (OpenAI or Google). Requires authentication.",
|
||||||
"operationId": "translateProductDescription",
|
"operationId": "translateProductDescription",
|
||||||
@@ -1271,7 +1271,7 @@
|
|||||||
"name": "id_category",
|
"name": "id_category",
|
||||||
"in": "query",
|
"in": "query",
|
||||||
"description": "Filter by category ID",
|
"description": "Filter by category ID",
|
||||||
"required": true,
|
"required": false,
|
||||||
"schema": {
|
"schema": {
|
||||||
"type": "integer",
|
"type": "integer",
|
||||||
"format": "uint"
|
"format": "uint"
|
||||||
@@ -1281,7 +1281,7 @@
|
|||||||
"name": "price_lower_bound",
|
"name": "price_lower_bound",
|
||||||
"in": "query",
|
"in": "query",
|
||||||
"description": "Lower price bound",
|
"description": "Lower price bound",
|
||||||
"required": true,
|
"required": false,
|
||||||
"schema": {
|
"schema": {
|
||||||
"type": "number",
|
"type": "number",
|
||||||
"format": "double"
|
"format": "double"
|
||||||
@@ -1291,7 +1291,7 @@
|
|||||||
"name": "price_upper_bound",
|
"name": "price_upper_bound",
|
||||||
"in": "query",
|
"in": "query",
|
||||||
"description": "Upper price bound",
|
"description": "Upper price bound",
|
||||||
"required": true,
|
"required": false,
|
||||||
"schema": {
|
"schema": {
|
||||||
"type": "number",
|
"type": "number",
|
||||||
"format": "double"
|
"format": "double"
|
||||||
@@ -1336,7 +1336,7 @@
|
|||||||
"get": {
|
"get": {
|
||||||
"tags": ["Search"],
|
"tags": ["Search"],
|
||||||
"summary": "Create search index",
|
"summary": "Create search index",
|
||||||
"description": "Creates a MeiliSearch index for products. Requires superadmin access.",
|
"description": "Creates a MeiliSearch index for products. Must be removed before proper release.",
|
||||||
"operationId": "createSearchIndex",
|
"operationId": "createSearchIndex",
|
||||||
"security": [
|
"security": [
|
||||||
{
|
{
|
||||||
@@ -1381,7 +1381,7 @@
|
|||||||
"get": {
|
"get": {
|
||||||
"tags": ["Search"],
|
"tags": ["Search"],
|
||||||
"summary": "Test MeiliSearch",
|
"summary": "Test MeiliSearch",
|
||||||
"description": "Tests the MeiliSearch connection. Requires superadmin access.",
|
"description": "Tests the MeiliSearch search. Must be removed before proper release.",
|
||||||
"operationId": "testMeiliSearch",
|
"operationId": "testMeiliSearch",
|
||||||
"security": [
|
"security": [
|
||||||
{
|
{
|
||||||
|
|||||||
@@ -40,7 +40,6 @@ func AuthHandlerRoutes(r fiber.Router) fiber.Router {
|
|||||||
r.Post("/reset-password", handler.ResetPassword)
|
r.Post("/reset-password", handler.ResetPassword)
|
||||||
r.Post("/logout", handler.Logout)
|
r.Post("/logout", handler.Logout)
|
||||||
r.Post("/refresh", handler.RefreshToken)
|
r.Post("/refresh", handler.RefreshToken)
|
||||||
r.Post("/update-choice", handler.UpdateJWTToken)
|
|
||||||
|
|
||||||
// Google OAuth2
|
// Google OAuth2
|
||||||
r.Get("/google", handler.GoogleLogin)
|
r.Get("/google", handler.GoogleLogin)
|
||||||
@@ -48,6 +47,7 @@ func AuthHandlerRoutes(r fiber.Router) fiber.Router {
|
|||||||
|
|
||||||
authProtected := r.Group("", middleware.AuthMiddleware())
|
authProtected := r.Group("", middleware.AuthMiddleware())
|
||||||
authProtected.Get("/me", handler.Me)
|
authProtected.Get("/me", handler.Me)
|
||||||
|
authProtected.Post("/update-choice", handler.UpdateJWTToken)
|
||||||
|
|
||||||
return r
|
return r
|
||||||
}
|
}
|
||||||
@@ -345,9 +345,9 @@ func (h *AuthHandler) CompleteRegistration(c fiber.Ctx) error {
|
|||||||
return c.Status(fiber.StatusCreated).JSON(response)
|
return c.Status(fiber.StatusCreated).JSON(response)
|
||||||
}
|
}
|
||||||
|
|
||||||
// CompleteRegistration handles completion of registration with password
|
// Updates JWT Tokens
|
||||||
func (h *AuthHandler) UpdateJWTToken(c fiber.Ctx) error {
|
func (h *AuthHandler) UpdateJWTToken(c fiber.Ctx) error {
|
||||||
return h.UpdateJWTToken(c)
|
return h.authService.UpdateJWTToken(c)
|
||||||
}
|
}
|
||||||
|
|
||||||
// GoogleLogin redirects the user to Google's OAuth2 consent page
|
// GoogleLogin redirects the user to Google's OAuth2 consent page
|
||||||
|
|||||||
@@ -25,7 +25,7 @@ func NewMeiliSearchHandler() *MeiliSearchHandler {
|
|||||||
func MeiliSearchHandlerRoutes(r fiber.Router) fiber.Router {
|
func MeiliSearchHandlerRoutes(r fiber.Router) fiber.Router {
|
||||||
handler := NewMeiliSearchHandler()
|
handler := NewMeiliSearchHandler()
|
||||||
|
|
||||||
// for superadmin only
|
// for testing purposes only. Must be removed before proper release.
|
||||||
r.Get("/create-index", handler.CreateIndex)
|
r.Get("/create-index", handler.CreateIndex)
|
||||||
r.Get("/test", handler.Test)
|
r.Get("/test", handler.Test)
|
||||||
|
|
||||||
@@ -84,32 +84,32 @@ func (h *MeiliSearchHandler) Search(c fiber.Ctx) error {
|
|||||||
JSON(response.Make(nullable.GetNil(""), 0, responseErrors.GetErrorCode(c, responseErrors.ErrBadAttribute)))
|
JSON(response.Make(nullable.GetNil(""), 0, responseErrors.GetErrorCode(c, responseErrors.ErrBadAttribute)))
|
||||||
}
|
}
|
||||||
|
|
||||||
id_category_attribute := c.Query("id_category")
|
id_category_attribute := c.Query("id_category", "0")
|
||||||
id_category, err := strconv.Atoi(id_category_attribute)
|
id_category, err := strconv.Atoi(id_category_attribute)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return c.Status(responseErrors.GetErrorStatus(responseErrors.ErrBadAttribute)).
|
return c.Status(responseErrors.GetErrorStatus(responseErrors.ErrBadAttribute)).
|
||||||
JSON(response.Make(nullable.GetNil(""), 0, responseErrors.GetErrorCode(c, responseErrors.ErrBadAttribute)))
|
JSON(response.Make(nullable.GetNil(""), 0, responseErrors.GetErrorCode(c, responseErrors.ErrBadAttribute)))
|
||||||
}
|
}
|
||||||
|
|
||||||
price_lower_bound_attribute := c.Query("price_lower_bound")
|
price_lower_bound_attribute := c.Query("price_lower_bound", "-1.0")
|
||||||
price_lower_bound, err := strconv.ParseFloat(price_lower_bound_attribute, 64)
|
price_lower_bound, err := strconv.ParseFloat(price_lower_bound_attribute, 64)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return c.Status(responseErrors.GetErrorStatus(responseErrors.ErrBadAttribute)).
|
return c.Status(responseErrors.GetErrorStatus(responseErrors.ErrBadAttribute)).
|
||||||
JSON(response.Make(nullable.GetNil(""), 0, responseErrors.GetErrorCode(c, responseErrors.ErrBadAttribute)))
|
JSON(response.Make(nullable.GetNil(""), 0, responseErrors.GetErrorCode(c, responseErrors.ErrBadAttribute)))
|
||||||
}
|
}
|
||||||
|
|
||||||
price_upper_bound_attribute := c.Query("price_upper_bound")
|
price_upper_bound_attribute := c.Query("price_upper_bound", "-1.0")
|
||||||
price_upper_bound, err := strconv.ParseFloat(price_upper_bound_attribute, 64)
|
price_upper_bound, err := strconv.ParseFloat(price_upper_bound_attribute, 64)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return c.Status(responseErrors.GetErrorStatus(responseErrors.ErrBadAttribute)).
|
return c.Status(responseErrors.GetErrorStatus(responseErrors.ErrBadAttribute)).
|
||||||
JSON(response.Make(nullable.GetNil(""), 0, responseErrors.GetErrorCode(c, responseErrors.ErrBadAttribute)))
|
JSON(response.Make(nullable.GetNil(""), 0, responseErrors.GetErrorCode(c, responseErrors.ErrBadAttribute)))
|
||||||
}
|
}
|
||||||
|
|
||||||
test, err := h.meiliService.Search(id_lang, query, uint(limit), uint(id_category), price_lower_bound, price_upper_bound)
|
meili_response, err := h.meiliService.Search(id_lang, query, uint(limit), uint(id_category), price_lower_bound, price_upper_bound)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return c.Status(responseErrors.GetErrorStatus(err)).
|
return c.Status(responseErrors.GetErrorStatus(err)).
|
||||||
JSON(response.Make(nullable.GetNil(""), 0, responseErrors.GetErrorCode(c, err)))
|
JSON(response.Make(nullable.GetNil(""), 0, responseErrors.GetErrorCode(c, err)))
|
||||||
}
|
}
|
||||||
|
|
||||||
return c.JSON(response.Make(&test, 0, i18n.T_(c, response.Message_OK)))
|
return c.JSON(response.Make(&meili_response, 0, i18n.T_(c, response.Message_OK)))
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -4,7 +4,7 @@ import (
|
|||||||
"strconv"
|
"strconv"
|
||||||
|
|
||||||
"git.ma-al.com/goc_daniel/b2b/app/config"
|
"git.ma-al.com/goc_daniel/b2b/app/config"
|
||||||
"git.ma-al.com/goc_daniel/b2b/app/service/productDescriptionService"
|
"git.ma-al.com/goc_daniel/b2b/app/service/productTranslationService"
|
||||||
"git.ma-al.com/goc_daniel/b2b/app/utils/i18n"
|
"git.ma-al.com/goc_daniel/b2b/app/utils/i18n"
|
||||||
"git.ma-al.com/goc_daniel/b2b/app/utils/nullable"
|
"git.ma-al.com/goc_daniel/b2b/app/utils/nullable"
|
||||||
"git.ma-al.com/goc_daniel/b2b/app/utils/response"
|
"git.ma-al.com/goc_daniel/b2b/app/utils/response"
|
||||||
@@ -13,24 +13,24 @@ import (
|
|||||||
"github.com/gofiber/fiber/v3"
|
"github.com/gofiber/fiber/v3"
|
||||||
)
|
)
|
||||||
|
|
||||||
// ProductDescriptionHandler handles endpoints that receive, save and translate product descriptions.
|
// ProductTranslationHandler handles endpoints that receive, save and translate product descriptions.
|
||||||
type ProductDescriptionHandler struct {
|
type ProductTranslationHandler struct {
|
||||||
productDescriptionService *productDescriptionService.ProductDescriptionService
|
productTranslationService *productTranslationService.ProductTranslationService
|
||||||
config *config.Config
|
config *config.Config
|
||||||
}
|
}
|
||||||
|
|
||||||
// NewProductDescriptionHandler creates a new ProductDescriptionHandler instance
|
// NewProductTranslationHandler creates a new ProductTranslationHandler instance
|
||||||
func NewProductDescriptionHandler() *ProductDescriptionHandler {
|
func NewProductTranslationHandler() *ProductTranslationHandler {
|
||||||
productDescriptionService := productDescriptionService.New()
|
productTranslationService := productTranslationService.New()
|
||||||
return &ProductDescriptionHandler{
|
return &ProductTranslationHandler{
|
||||||
productDescriptionService: productDescriptionService,
|
productTranslationService: productTranslationService,
|
||||||
config: config.Get(),
|
config: config.Get(),
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// ProductDescriptionRoutes registers all product description routes
|
// ProductTranslationRoutes registers all product description routes
|
||||||
func ProductDescriptionHandlerRoutes(r fiber.Router) fiber.Router {
|
func ProductTranslationHandlerRoutes(r fiber.Router) fiber.Router {
|
||||||
handler := NewProductDescriptionHandler()
|
handler := NewProductTranslationHandler()
|
||||||
|
|
||||||
r.Get("/get-product-description", handler.GetProductDescription)
|
r.Get("/get-product-description", handler.GetProductDescription)
|
||||||
r.Post("/save-product-description", handler.SaveProductDescription)
|
r.Post("/save-product-description", handler.SaveProductDescription)
|
||||||
@@ -40,7 +40,7 @@ func ProductDescriptionHandlerRoutes(r fiber.Router) fiber.Router {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// GetProductDescription returns the product description for a given product ID
|
// GetProductDescription returns the product description for a given product ID
|
||||||
func (h *ProductDescriptionHandler) GetProductDescription(c fiber.Ctx) error {
|
func (h *ProductTranslationHandler) GetProductDescription(c fiber.Ctx) error {
|
||||||
userID, ok := c.Locals("userID").(uint)
|
userID, ok := c.Locals("userID").(uint)
|
||||||
if !ok {
|
if !ok {
|
||||||
return c.Status(responseErrors.GetErrorStatus(responseErrors.ErrInvalidBody)).
|
return c.Status(responseErrors.GetErrorStatus(responseErrors.ErrInvalidBody)).
|
||||||
@@ -61,7 +61,7 @@ func (h *ProductDescriptionHandler) GetProductDescription(c fiber.Ctx) error {
|
|||||||
JSON(response.Make(nullable.GetNil(""), 0, responseErrors.GetErrorCode(c, responseErrors.ErrBadAttribute)))
|
JSON(response.Make(nullable.GetNil(""), 0, responseErrors.GetErrorCode(c, responseErrors.ErrBadAttribute)))
|
||||||
}
|
}
|
||||||
|
|
||||||
description, err := h.productDescriptionService.GetProductDescription(userID, uint(productID), uint(productLangID))
|
description, err := h.productTranslationService.GetProductDescription(userID, uint(productID), uint(productLangID))
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return c.Status(responseErrors.GetErrorStatus(err)).
|
return c.Status(responseErrors.GetErrorStatus(err)).
|
||||||
JSON(response.Make(nullable.GetNil(""), 0, responseErrors.GetErrorCode(c, err)))
|
JSON(response.Make(nullable.GetNil(""), 0, responseErrors.GetErrorCode(c, err)))
|
||||||
@@ -71,7 +71,7 @@ func (h *ProductDescriptionHandler) GetProductDescription(c fiber.Ctx) error {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// SaveProductDescription saves the description for a given product ID, in given language
|
// SaveProductDescription saves the description for a given product ID, in given language
|
||||||
func (h *ProductDescriptionHandler) SaveProductDescription(c fiber.Ctx) error {
|
func (h *ProductTranslationHandler) SaveProductDescription(c fiber.Ctx) error {
|
||||||
userID, ok := c.Locals("userID").(uint)
|
userID, ok := c.Locals("userID").(uint)
|
||||||
if !ok {
|
if !ok {
|
||||||
return c.Status(responseErrors.GetErrorStatus(responseErrors.ErrInvalidBody)).
|
return c.Status(responseErrors.GetErrorStatus(responseErrors.ErrInvalidBody)).
|
||||||
@@ -98,7 +98,7 @@ func (h *ProductDescriptionHandler) SaveProductDescription(c fiber.Ctx) error {
|
|||||||
JSON(response.Make(nullable.GetNil(""), 0, responseErrors.GetErrorCode(c, responseErrors.ErrInvalidBody)))
|
JSON(response.Make(nullable.GetNil(""), 0, responseErrors.GetErrorCode(c, responseErrors.ErrInvalidBody)))
|
||||||
}
|
}
|
||||||
|
|
||||||
err = h.productDescriptionService.SaveProductDescription(userID, uint(productID), uint(productLangID), updates)
|
err = h.productTranslationService.SaveProductDescription(userID, uint(productID), uint(productLangID), updates)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return c.Status(responseErrors.GetErrorStatus(err)).
|
return c.Status(responseErrors.GetErrorStatus(err)).
|
||||||
JSON(response.Make(nullable.GetNil(""), 0, responseErrors.GetErrorCode(c, err)))
|
JSON(response.Make(nullable.GetNil(""), 0, responseErrors.GetErrorCode(c, err)))
|
||||||
@@ -108,7 +108,7 @@ func (h *ProductDescriptionHandler) SaveProductDescription(c fiber.Ctx) error {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// TranslateProductDescription returns translated product description
|
// TranslateProductDescription returns translated product description
|
||||||
func (h *ProductDescriptionHandler) TranslateProductDescription(c fiber.Ctx) error {
|
func (h *ProductTranslationHandler) TranslateProductDescription(c fiber.Ctx) error {
|
||||||
userID, ok := c.Locals("userID").(uint)
|
userID, ok := c.Locals("userID").(uint)
|
||||||
if !ok {
|
if !ok {
|
||||||
return c.Status(responseErrors.GetErrorStatus(responseErrors.ErrInvalidBody)).
|
return c.Status(responseErrors.GetErrorStatus(responseErrors.ErrInvalidBody)).
|
||||||
@@ -142,7 +142,7 @@ func (h *ProductDescriptionHandler) TranslateProductDescription(c fiber.Ctx) err
|
|||||||
JSON(response.Make(nullable.GetNil(""), 0, responseErrors.GetErrorCode(c, responseErrors.ErrBadAttribute)))
|
JSON(response.Make(nullable.GetNil(""), 0, responseErrors.GetErrorCode(c, responseErrors.ErrBadAttribute)))
|
||||||
}
|
}
|
||||||
|
|
||||||
description, err := h.productDescriptionService.TranslateProductDescription(userID, uint(productID), uint(productFromLangID), uint(productToLangID), aiModel)
|
description, err := h.productTranslationService.TranslateProductDescription(userID, uint(productID), uint(productFromLangID), uint(productToLangID), aiModel)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return c.Status(responseErrors.GetErrorStatus(err)).
|
return c.Status(responseErrors.GetErrorStatus(err)).
|
||||||
JSON(response.Make(nullable.GetNil(""), 0, responseErrors.GetErrorCode(c, err)))
|
JSON(response.Make(nullable.GetNil(""), 0, responseErrors.GetErrorCode(c, err)))
|
||||||
@@ -89,9 +89,9 @@ func (s *Server) Setup() error {
|
|||||||
auth := s.public.Group("/auth")
|
auth := s.public.Group("/auth")
|
||||||
public.AuthHandlerRoutes(auth)
|
public.AuthHandlerRoutes(auth)
|
||||||
|
|
||||||
// product description routes (restricted)
|
// product translation routes (restricted)
|
||||||
productDescription := s.restricted.Group("/product-description")
|
productTranslation := s.restricted.Group("/product-translation")
|
||||||
restricted.ProductDescriptionHandlerRoutes(productDescription)
|
restricted.ProductTranslationHandlerRoutes(productTranslation)
|
||||||
|
|
||||||
// listing products routes (restricted)
|
// listing products routes (restricted)
|
||||||
listProducts := s.restricted.Group("/list-products")
|
listProducts := s.restricted.Group("/list-products")
|
||||||
|
|||||||
@@ -6,8 +6,8 @@ type Country struct {
|
|||||||
Name string `gorm:"column:name" json:"name"`
|
Name string `gorm:"column:name" json:"name"`
|
||||||
Flag string `gorm:"size:16;not null;column:flag" json:"flag"`
|
Flag string `gorm:"size:16;not null;column:flag" json:"flag"`
|
||||||
CurrencyID uint `gorm:"column:id_currency" json:"currency_id"`
|
CurrencyID uint `gorm:"column:id_currency" json:"currency_id"`
|
||||||
CurrencyISOCode string `gorm:"column:iso_code" json:"currency_iso_code"`
|
CurrencyISOCode string `gorm:"column:currency_iso_code" json:"currency_iso_code"`
|
||||||
CurrencyName string `gorm:"column:name" json:"currency_name"`
|
CurrencyName string `gorm:"column:currency_name" json:"currency_name"`
|
||||||
}
|
}
|
||||||
|
|
||||||
func (Country) TableName() string {
|
func (Country) TableName() string {
|
||||||
|
|||||||
@@ -85,7 +85,7 @@ type ProductFilters struct {
|
|||||||
}
|
}
|
||||||
|
|
||||||
type ScannedCategory struct {
|
type ScannedCategory struct {
|
||||||
CategoryID uint `gorm:"column:ID;primaryKey"`
|
CategoryID uint `gorm:"column:category_id;primaryKey"`
|
||||||
Name string `gorm:"column:name"`
|
Name string `gorm:"column:name"`
|
||||||
Active uint `gorm:"column:active"`
|
Active uint `gorm:"column:active"`
|
||||||
Position uint `gorm:"column:position"`
|
Position uint `gorm:"column:position"`
|
||||||
|
|||||||
@@ -22,7 +22,7 @@ func (repo *CategoriesRepo) GetAllCategories(id_lang uint) ([]model.ScannedCateg
|
|||||||
err := db.DB.
|
err := db.DB.
|
||||||
Table("ps_category").
|
Table("ps_category").
|
||||||
Select(`
|
Select(`
|
||||||
ps_category.id_category AS id,
|
ps_category.id_category AS category_id,
|
||||||
ps_category_lang.name AS name,
|
ps_category_lang.name AS name,
|
||||||
ps_category.active AS active,
|
ps_category.active AS active,
|
||||||
ps_category_shop.position AS position,
|
ps_category_shop.position AS position,
|
||||||
|
|||||||
@@ -28,8 +28,9 @@ func (repo *LocaleSelectorRepo) GetCountriesAndCurrencies() ([]model.Country, er
|
|||||||
var countries []model.Country
|
var countries []model.Country
|
||||||
|
|
||||||
err := db.DB.
|
err := db.DB.
|
||||||
|
Table("b2b_countries").
|
||||||
Select("b2b_countries.id, b2b_countries.name, b2b_countries.flag, ps_currency.id_currency as id_currency, ps_currency.name as currency_name, ps_currency.iso_code as currency_iso_code").
|
Select("b2b_countries.id, b2b_countries.name, b2b_countries.flag, ps_currency.id_currency as id_currency, ps_currency.name as currency_name, ps_currency.iso_code as currency_iso_code").
|
||||||
Joins("JOIN ps_currency ON ps_currency.id_currency = b2b_countries.currency").
|
Joins("LEFT JOIN ps_currency ON ps_currency.id_currency = b2b_countries.currency_id").
|
||||||
Scan(&countries).Error
|
Scan(&countries).Error
|
||||||
|
|
||||||
return countries, err
|
return countries, err
|
||||||
|
|||||||
@@ -34,7 +34,7 @@ func New() *MeiliService {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// ==================================== FOR SUPERADMIN ONLY ====================================
|
// ==================================== FOR TESTING ONLY ====================================
|
||||||
func (s *MeiliService) CreateIndex(id_lang uint) error {
|
func (s *MeiliService) CreateIndex(id_lang uint) error {
|
||||||
indexName := "meili_products_shop" + strconv.FormatInt(constdata.SHOP_ID, 10) + "_lang" + strconv.FormatInt(int64(id_lang), 10)
|
indexName := "meili_products_shop" + strconv.FormatInt(constdata.SHOP_ID, 10) + "_lang" + strconv.FormatInt(int64(id_lang), 10)
|
||||||
|
|
||||||
@@ -130,7 +130,7 @@ func (s *MeiliService) CreateIndex(id_lang uint) error {
|
|||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
// ==================================== FOR DEBUG ONLY ====================================
|
// ==================================== FOR TESTING ONLY ====================================
|
||||||
func (s *MeiliService) Test(id_lang uint) (meilisearch.SearchResponse, error) {
|
func (s *MeiliService) Test(id_lang uint) (meilisearch.SearchResponse, error) {
|
||||||
indexName := "meili_products_shop" + strconv.FormatInt(constdata.SHOP_ID, 10) + "_lang" + strconv.FormatInt(int64(id_lang), 10)
|
indexName := "meili_products_shop" + strconv.FormatInt(constdata.SHOP_ID, 10) + "_lang" + strconv.FormatInt(int64(id_lang), 10)
|
||||||
|
|
||||||
|
|||||||
@@ -1,6 +1,7 @@
|
|||||||
package menuService
|
package menuService
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"fmt"
|
||||||
"sort"
|
"sort"
|
||||||
|
|
||||||
"git.ma-al.com/goc_daniel/b2b/app/model"
|
"git.ma-al.com/goc_daniel/b2b/app/model"
|
||||||
@@ -27,6 +28,10 @@ func (s *MenuService) GetMenu(id_lang uint) (*model.Category, error) {
|
|||||||
return &model.Category{}, err
|
return &model.Category{}, err
|
||||||
}
|
}
|
||||||
|
|
||||||
|
fmt.Printf("all_categories: %v\n", all_categories)
|
||||||
|
|
||||||
|
fmt.Printf("id_lang: %v\n", id_lang)
|
||||||
|
|
||||||
// find the root
|
// find the root
|
||||||
root_index := 0
|
root_index := 0
|
||||||
root_found := false
|
root_found := false
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
package productDescriptionService
|
package productTranslationService
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"context"
|
"context"
|
||||||
@@ -26,7 +26,7 @@ import (
|
|||||||
googleopt "google.golang.org/api/option"
|
googleopt "google.golang.org/api/option"
|
||||||
)
|
)
|
||||||
|
|
||||||
type ProductDescriptionService struct {
|
type ProductTranslationService struct {
|
||||||
productDescriptionRepo productDescriptionRepo.UIProductDescriptionRepo
|
productDescriptionRepo productDescriptionRepo.UIProductDescriptionRepo
|
||||||
ctx context.Context
|
ctx context.Context
|
||||||
googleCli translate.TranslationClient
|
googleCli translate.TranslationClient
|
||||||
@@ -34,7 +34,7 @@ type ProductDescriptionService struct {
|
|||||||
openAIClient openai.Client
|
openAIClient openai.Client
|
||||||
}
|
}
|
||||||
|
|
||||||
// New creates a ProductDescriptionService and authenticates against the
|
// New creates a ProductTranslationService and authenticates against the
|
||||||
// Google Cloud Translation API using a service account key file.
|
// Google Cloud Translation API using a service account key file.
|
||||||
//
|
//
|
||||||
// Required configuration (set in .env or environment):
|
// Required configuration (set in .env or environment):
|
||||||
@@ -44,14 +44,14 @@ type ProductDescriptionService struct {
|
|||||||
//
|
//
|
||||||
// The service account must have the "Cloud Translation API User" role
|
// The service account must have the "Cloud Translation API User" role
|
||||||
// (roles/cloudtranslate.user) granted in Google Cloud IAM.
|
// (roles/cloudtranslate.user) granted in Google Cloud IAM.
|
||||||
func New() *ProductDescriptionService {
|
func New() *ProductTranslationService {
|
||||||
ctx := context.Background()
|
ctx := context.Background()
|
||||||
cfg := config.Get()
|
cfg := config.Get()
|
||||||
|
|
||||||
// Read the service account key file whose path comes from config / env.
|
// Read the service account key file whose path comes from config / env.
|
||||||
data, err := os.ReadFile(cfg.GoogleTranslate.CredentialsFile)
|
data, err := os.ReadFile(cfg.GoogleTranslate.CredentialsFile)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Fatalf("productDescriptionService: cannot read credentials file %q: %v",
|
log.Fatalf("ProductTranslationService: cannot read credentials file %q: %v",
|
||||||
cfg.GoogleTranslate.CredentialsFile, err)
|
cfg.GoogleTranslate.CredentialsFile, err)
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -62,18 +62,18 @@ func New() *ProductDescriptionService {
|
|||||||
CredentialsJSON: data,
|
CredentialsJSON: data,
|
||||||
})
|
})
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Fatalf("productDescriptionService: cannot build Google credentials: %v", err)
|
log.Fatalf("ProductTranslationService: cannot build Google credentials: %v", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
googleCli, err := translate.NewTranslationClient(ctx, googleopt.WithAuthCredentials(creds))
|
googleCli, err := translate.NewTranslationClient(ctx, googleopt.WithAuthCredentials(creds))
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Fatalf("productDescriptionService: cannot create Translation client: %v", err)
|
log.Fatalf("ProductTranslationService: cannot create Translation client: %v", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
openAIClient := openai.NewClient(option.WithAPIKey(os.Getenv("OPENAI_KEY")),
|
openAIClient := openai.NewClient(option.WithAPIKey(os.Getenv("OPENAI_KEY")),
|
||||||
option.WithHTTPClient(&http.Client{Timeout: 300 * time.Second})) // five minutes timeout
|
option.WithHTTPClient(&http.Client{Timeout: 300 * time.Second})) // five minutes timeout
|
||||||
|
|
||||||
return &ProductDescriptionService{
|
return &ProductTranslationService{
|
||||||
productDescriptionRepo: productDescriptionRepo.New(),
|
productDescriptionRepo: productDescriptionRepo.New(),
|
||||||
ctx: ctx,
|
ctx: ctx,
|
||||||
openAIClient: openAIClient,
|
openAIClient: openAIClient,
|
||||||
@@ -82,12 +82,12 @@ func New() *ProductDescriptionService {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func (s *ProductDescriptionService) GetProductDescription(userID uint, productID uint, productLangID uint) (*model.ProductDescription, error) {
|
func (s *ProductTranslationService) GetProductDescription(userID uint, productID uint, productLangID uint) (*model.ProductDescription, error) {
|
||||||
return s.productDescriptionRepo.GetProductDescription(productID, productLangID)
|
return s.productDescriptionRepo.GetProductDescription(productID, productLangID)
|
||||||
}
|
}
|
||||||
|
|
||||||
// Updates relevant fields with the "updates" map
|
// Updates relevant fields with the "updates" map
|
||||||
func (s *ProductDescriptionService) SaveProductDescription(userID uint, productID uint, productLangID uint, updates map[string]string) error {
|
func (s *ProductTranslationService) SaveProductDescription(userID uint, productID uint, productLangID uint, updates map[string]string) error {
|
||||||
// only some fields can be affected
|
// only some fields can be affected
|
||||||
allowedFields := []string{"description", "description_short", "meta_description", "meta_title", "name", "available_now", "available_later", "usage"}
|
allowedFields := []string{"description", "description_short", "meta_description", "meta_title", "name", "available_now", "available_later", "usage"}
|
||||||
for key := range updates {
|
for key := range updates {
|
||||||
@@ -120,7 +120,7 @@ func (s *ProductDescriptionService) SaveProductDescription(userID uint, productI
|
|||||||
//
|
//
|
||||||
// The Google Cloud project must have the Cloud Translation API enabled and the
|
// The Google Cloud project must have the Cloud Translation API enabled and the
|
||||||
// service account must hold the "Cloud Translation API User" role.
|
// service account must hold the "Cloud Translation API User" role.
|
||||||
func (s *ProductDescriptionService) TranslateProductDescription(userID uint, productID uint, productFromLangID uint, productToLangID uint, aiModel string) (*model.ProductDescription, error) {
|
func (s *ProductTranslationService) TranslateProductDescription(userID uint, productID uint, productFromLangID uint, productToLangID uint, aiModel string) (*model.ProductDescription, error) {
|
||||||
|
|
||||||
productDescription, err := s.productDescriptionRepo.GetProductDescription(productID, productFromLangID)
|
productDescription, err := s.productDescriptionRepo.GetProductDescription(productID, productFromLangID)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
@@ -126,13 +126,13 @@ CREATE INDEX IF NOT EXISTS idx_refresh_tokens_customer_id ON b2b_refresh_tokens
|
|||||||
CREATE TABLE IF NOT EXISTS b2b_countries (
|
CREATE TABLE IF NOT EXISTS b2b_countries (
|
||||||
id INT AUTO_INCREMENT PRIMARY KEY,
|
id INT AUTO_INCREMENT PRIMARY KEY,
|
||||||
name VARCHAR(128) NOT NULL,
|
name VARCHAR(128) NOT NULL,
|
||||||
currency INT UNSIGNED NOT NULL,
|
currency_id INT UNSIGNED NOT NULL,
|
||||||
flag VARCHAR(16) NOT NULL,
|
flag VARCHAR(16) NOT NULL,
|
||||||
CONSTRAINT fk_countries_currency FOREIGN KEY (currency) REFERENCES ps_currency(id_currency) ON DELETE RESTRICT ON UPDATE RESTRICT
|
CONSTRAINT fk_countries_currency FOREIGN KEY (currency_id) REFERENCES ps_currency(id_currency) ON DELETE RESTRICT ON UPDATE RESTRICT
|
||||||
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;
|
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;
|
||||||
|
|
||||||
INSERT IGNORE INTO b2b_countries
|
INSERT IGNORE INTO b2b_countries
|
||||||
(id, name, currency, flag)
|
(id, name, currency_id, flag)
|
||||||
VALUES
|
VALUES
|
||||||
(1, 'Polska', 1, '🇵🇱'),
|
(1, 'Polska', 1, '🇵🇱'),
|
||||||
(2, 'England', 2, '🇬🇧'),
|
(2, 'England', 2, '🇬🇧'),
|
||||||
|
|||||||
Reference in New Issue
Block a user