internal/accessor/ads/delete.go

@@ -1,26 +0,0 @@
-package adsrepository
-
-import (
-	"errors"
-	"fmt"
-	adsdomain "legalgo-BE-go/internal/domain/ads"
-
-	"gorm.io/gorm"
-)
-
-func (a *accessor) Delete(id string) error {
-	var ads adsdomain.Ads
-	if err := a.db.First(&ads, "id = ?", id).Error; err != nil {
-		if errors.Is(err, gorm.ErrRecordNotFound) {
-			return fmt.Errorf("ads with id %s is not found", id)
-
-		}
-		return fmt.Errorf("failed to g ads %s : %v", id, err)
-	}
-
-	if err := a.db.Delete(&ads).Error; err != nil {
-		return fmt.Errorf("failed to delete ads %s : %v", id, err)
-	}
-
-	return nil
-}

internal/accessor/ads/impl.go

@@ -12,7 +12,6 @@ type accessor struct {
 type Ads interface {
 	Create(adsdomain.Ads) error
 	GetAll() ([]adsdomain.Ads, error)
-	Delete(string) error
 }
 
 func New(

internal/api/http/ads/create.go

@@ -1,53 +1,91 @@
 package adshttp
 
 import (
+	"fmt"
 	authmiddleware "legalgo-BE-go/internal/api/http/middleware/auth"
 	adsdomain "legalgo-BE-go/internal/domain/ads"
+	"legalgo-BE-go/internal/domain/oss"
 	adssvc "legalgo-BE-go/internal/services/ads"
 	"legalgo-BE-go/internal/utilities/response"
-	"legalgo-BE-go/internal/utilities/utils"
 	"net/http"
 
 	"github.com/go-chi/chi/v5"
-	"github.com/go-playground/validator/v10"
 )
 
+const _oneMB = 1 << 20
+const _maxUploadSize = 2 * _oneMB
+const _folderName = "/file"
+
 func Create(
 	router chi.Router,
 	adsSvc adssvc.Ads,
-	validate *validator.Validate,
 ) {
-	router.
+	router.With(authmiddleware.Authorize()).Post("/ads/create", func(w http.ResponseWriter, r *http.Request) {
-		With(authmiddleware.Authorize()).
-		Post("/ads/create", func(w http.ResponseWriter, r *http.Request) {
 		ctx := r.Context()
-			var spec adsdomain.AdsReq
 
-			if err := utils.UnmarshalBody(r, &spec); err != nil {
+		err := r.ParseMultipartForm(10 << 20) // 10 MB
+		if err != nil {
 			response.RespondJsonErrorWithCode(
 				ctx,
 				w,
 				err,
 				response.ErrBadRequest.Code,
 				response.ErrBadRequest.HttpCode,
-					"failed to unmarshal body",
+				"unable to parse form",
 			)
 			return
 		}
 
-			if err := validate.Struct(spec); err != nil {
+		url := r.FormValue("url")
-				response.ResponseWithErrorCode(
+		if url == "" {
+			response.RespondJsonErrorWithCode(
 				ctx,
 				w,
 				err,
 				response.ErrBadRequest.Code,
 				response.ErrBadRequest.HttpCode,
-					err.(validator.ValidationErrors).Error(),
+				"URL is missing",
 			)
 			return
 		}
 
-			if err := adsSvc.Create(spec); err != nil {
+		file, header, err := r.FormFile("image")
+		if err != nil {
+			response.RespondJsonErrorWithCode(
+				ctx,
+				w,
+				err,
+				response.ErrBadRequest.Code,
+				response.ErrBadRequest.HttpCode,
+				"unable to retrieve image",
+			)
+			return
+		}
+		defer file.Close()
+
+		if header.Size > int64(_maxUploadSize) {
+			response.ResponseWithErrorCode(
+				ctx,
+				w,
+				fmt.Errorf("file too big"),
+				response.ErrBadRequest.Code,
+				response.ErrBadRequest.HttpCode,
+				fmt.Sprintf("The file is too big. The maximum size is %d MB", _maxUploadSize/_oneMB),
+			)
+			return
+		}
+
+		imageRequest := &oss.UploadFileRequest{
+			FileHeader: header,
+			FolderName: _folderName,
+		}
+
+		adsReq := adsdomain.AdsReq{
+			Image: imageRequest,
+			Url:   url,
+		}
+
+		if err := adsSvc.Create(ctx, adsReq); err != nil {
 			response.RespondJsonErrorWithCode(
 				ctx,
 				w,

internal/api/http/ads/delete.go

@@ -1,53 +0,0 @@
-package adshttp
-
-import (
-	"fmt"
-	authmiddleware "legalgo-BE-go/internal/api/http/middleware/auth"
-	adssvc "legalgo-BE-go/internal/services/ads"
-	"legalgo-BE-go/internal/utilities/response"
-	"net/http"
-
-	"github.com/go-chi/chi/v5"
-)
-
-func Delete(
-	router chi.Router,
-	adsSvc adssvc.Ads,
-) {
-	router.
-		With(authmiddleware.Authorize()).
-		Delete("/ads/{ads_id}/delete", func(w http.ResponseWriter, r *http.Request) {
-			ctx := r.Context()
-			adsID := chi.URLParam(r, "ads_id")
-
-			if adsID == "" {
-				response.RespondJsonErrorWithCode(
-					ctx,
-					w,
-					fmt.Errorf("ads id is not provided"),
-					response.ErrBadRequest.Code,
-					response.ErrBadRequest.HttpCode,
-					"ads id is not provided",
-				)
-				return
-			}
-
-			if err := adsSvc.Delete(adsID); err != nil {
-				response.RespondJsonErrorWithCode(
-					ctx,
-					w,
-					err,
-					response.ErrBadRequest.Code,
-					response.ErrBadRequest.HttpCode,
-					err.Error(),
-				)
-				return
-			}
-
-			response.RespondJsonSuccess(ctx, w, struct {
-				Message string
-			}{
-				Message: "ads has been deleted",
-			})
-		})
-}

internal/api/http/ads/module.go

@@ -5,5 +5,4 @@ import "go.uber.org/fx"
 var Module = fx.Module("ads-http", fx.Invoke(
 	Create,
 	GetAll,
-	Delete,
 ))

internal/domain/ads/spec.go

@@ -1,6 +1,7 @@
 package adsdomain
 
 import (
+	"legalgo-BE-go/internal/domain/oss"
 	"time"
 )
 
@@ -13,6 +14,6 @@ type Ads struct {
 }
 
 type AdsReq struct {
-	Image string `json:"image" validate:"required"`
+	Image *oss.UploadFileRequest `json:"image"`
-	URL   string `json:"url" validate:"required"`
+	Url   string                 `json:"url"`
 }

internal/services/ads/create.go

@@ -1,27 +1,56 @@
 package adssvc
 
 import (
+	"context"
 	"fmt"
 	adsdomain "legalgo-BE-go/internal/domain/ads"
-	"strings"
+	"path"
 
 	"github.com/google/uuid"
 )
 
-func (i *impl) Create(spec adsdomain.AdsReq) error {
+func (i *impl) Create(ctx context.Context, spec adsdomain.AdsReq) error {
-	if !(strings.HasPrefix(spec.Image, "http")) {
+	id := uuid.NewString()
-		return fmt.Errorf("image url is not started with http")
+
+	file := spec.Image.FileHeader
+	spec.Image.FileSize = file.Size
+	spec.Image.Ext = path.Ext(file.Filename)
+
+	if err := i.validate.Struct(spec); err != nil {
+		return err
 	}
 
-	if !(strings.HasPrefix(spec.URL, "http")) {
+	// Open the file and read its content
-		return fmt.Errorf("url is not started with http")
+	srcFile, err := file.Open()
+	if err != nil {
+		return err
+	}
+	defer srcFile.Close()
+
+	fileContent := make([]byte, file.Size)
+	_, err = srcFile.Read(fileContent)
+	if err != nil {
+		return err
+	}
+
+	filePath := fmt.Sprintf("%v/%v%v", spec.Image.FolderName, id, spec.Image.Ext)
+	fileUrl, err := i.ossRepo.UploadFile(ctx, filePath, fileContent)
+	if err != nil {
+		return err
 	}
 
 	newSpec := adsdomain.Ads{
-		ID:       uuid.NewString(),
+		ID:       id,
-		ImageUrl: spec.Image,
+		ImageUrl: fileUrl,
-		Url:      spec.URL,
+		Url:      spec.Url,
 	}
 
-	return i.adsRepo.Create(newSpec)
+	if err := i.adsRepo.Create(newSpec); err != nil {
+		if err := i.ossRepo.DeleteObject(ctx, id); err != nil {
+			return err
+		}
+		return err
+	}
+
+	return nil
 }

internal/services/ads/delete.go

@@ -1,5 +0,0 @@
-package adssvc
-
-func (i *impl) Delete(id string) error {
-	return i.adsRepo.Delete(id)
-}

internal/services/ads/impl.go

@@ -1,24 +1,33 @@
 package adssvc
 
 import (
+	"context"
 	adsrepository "legalgo-BE-go/internal/accessor/ads"
+	"legalgo-BE-go/internal/accessor/oss"
 	adsdomain "legalgo-BE-go/internal/domain/ads"
+
+	"github.com/go-playground/validator/v10"
 )
 
 type impl struct {
+	ossRepo  oss.OSSRepository
 	adsRepo  adsrepository.Ads
+	validate *validator.Validate
 }
 
 type Ads interface {
-	Create(adsdomain.AdsReq) error
+	Create(context.Context, adsdomain.AdsReq) error
 	GetAll() ([]adsdomain.Ads, error)
-	Delete(string) error
 }
 
 func New(
+	ossRepo oss.OSSRepository,
 	adsRepo adsrepository.Ads,
+	validate *validator.Validate,
 ) Ads {
 	return &impl{
+		ossRepo,
 		adsRepo,
+		validate,
 	}
 }