swagger docs update

api.env

@@ -8,6 +8,9 @@ APP_ALLOWED_ORIGINS=http://localhost:5173,
 GRPC_SERVER_PORT=9050
 GRPC_CLIENT_PORT=9060
 
+IMAGE_STORAGE_HOST=
+IMAGE_STORAGE_PORT=
+
 MEDIA_STORAGE_ENDPOINT=
 MEDIA_STORAGE_USER=
 MEDIA_STORAGE_PASSWORD=

cmd/main.go

@@ -9,6 +9,7 @@ import (
 	"merch-parser-api/internal/api/user"
 	"merch-parser-api/internal/app"
 	"merch-parser-api/internal/grpcService"
+	"merch-parser-api/internal/imagesProvider"
 	"merch-parser-api/internal/interfaces"
 	"merch-parser-api/internal/mediaStorage"
 	"merch-parser-api/internal/provider/auth"
@@ -62,6 +63,8 @@ func main() {
 		"provider": mediaProvider,
 	}).Debug("Media storage | Minio client created")
 
+	imageProvider := imagesProvider.NewClient(c.ImageConf.Host + ":" + c.ImageConf.Port)
+
 	//deps providers
 	routerHandler := router.NewRouter(router.Deps{
 		ApiPrefix:      c.AppConf.ApiPrefix,
@@ -94,6 +97,7 @@ func main() {
 		DB:           database,
 		Utils:        utilsProvider,
 		Media:        mediaProvider,
+		ImageStorage: imageProvider,
 	})
 
 	//collect modules

config/config.go

@@ -8,6 +8,7 @@ type Config struct {
 	JWTConf   JWTConfig
 	GrpcConf  GrpcConfig
 	MediaConf MediaConfig
+	ImageConf ImageStorageConfig
 }
 
 type AppConfig struct {
@@ -48,6 +49,11 @@ type MediaConfig struct {
 	Secure   string
 }
 
+type ImageStorageConfig struct {
+	Host string
+	Port string
+}
+
 func NewConfig() *Config {
 	return &Config{
 		AppConf: AppConfig{
@@ -87,5 +93,10 @@ func NewConfig() *Config {
 			Password: getEnv("MEDIA_STORAGE_PASSWORD", ""),
 			Secure:   getEnv("MEDIA_STORAGE_SECURE", ""),
 		},
+
+		ImageConf: ImageStorageConfig{
+			Host: getEnv("IMAGE_STORAGE_HOST", ""),
+			Port: getEnv("IMAGE_STORAGE_PORT", ""),
+		},
 	}
 }

docs/docs.go

@@ -192,7 +192,7 @@ const docTemplate = `{
                         "BearerAuth": []
                     }
                 ],
-                "description": "Загрузить картинки по merch_uuid и query параметрам",
+                "description": "Загрузить картинку по merch_uuid. В ответ будут выданы ссылки на созданные картинки.",
                 "consumes": [
                     "multipart/form-data"
                 ],
@@ -202,7 +202,7 @@ const docTemplate = `{
                 "tags": [
                     "Merch images"
                 ],
-                "summary": "Загрузить картинки по merch_uuid и query параметрам",
+                "summary": "Загрузить картинку по merch_uuid",
                 "parameters": [
                     {
                         "type": "string",
@@ -217,23 +217,14 @@ const docTemplate = `{
                         "name": "file",
                         "in": "formData",
                         "required": true
-                    },
-                    {
-                        "enum": [
-                            "thumbnail",
-                            "full",
-                            "all"
-                        ],
-                        "type": "string",
-                        "description": "Image type: thumbnail, full or all",
-                        "name": "imageType",
-                        "in": "formData",
-                        "required": true
                     }
                 ],
                 "responses": {
                     "200": {
-                        "description": "OK"
+                        "description": "OK",
+                        "schema": {
+                            "$ref": "#/definitions/imageStorage.UploadMerchImageResponse"
+                        }
                     },
                     "400": {
                         "description": "Bad Request",
@@ -255,11 +246,11 @@ const docTemplate = `{
                         "BearerAuth": []
                     }
                 ],
-                "description": "Удалить (безвозвратно) картинки по merch_uuid и query параметрам",
+                "description": "Удалить (безвозвратно) картинки по merch_uuid",
                 "tags": [
                     "Merch images"
                 ],
-                "summary": "Удалить (безвозвратно) картинки по merch_uuid и query параметрам",
+                "summary": "Удалить (безвозвратно) картинки по merch_uuid",
                 "parameters": [
                     {
                         "type": "string",
@@ -768,6 +759,17 @@ const docTemplate = `{
         }
     },
     "definitions": {
+        "imageStorage.UploadMerchImageResponse": {
+            "type": "object",
+            "properties": {
+                "fullImage": {
+                    "type": "string"
+                },
+                "thumbnail": {
+                    "type": "string"
+                }
+            }
+        },
         "merch.ImageLink": {
             "type": "object",
             "properties": {

docs/swagger.json

@@ -184,7 +184,7 @@
                         "BearerAuth": []
                     }
                 ],
-                "description": "Загрузить картинки по merch_uuid и query параметрам",
+                "description": "Загрузить картинку по merch_uuid. В ответ будут выданы ссылки на созданные картинки.",
                 "consumes": [
                     "multipart/form-data"
                 ],
@@ -194,7 +194,7 @@
                 "tags": [
                     "Merch images"
                 ],
-                "summary": "Загрузить картинки по merch_uuid и query параметрам",
+                "summary": "Загрузить картинку по merch_uuid",
                 "parameters": [
                     {
                         "type": "string",
@@ -209,23 +209,14 @@
                         "name": "file",
                         "in": "formData",
                         "required": true
-                    },
-                    {
-                        "enum": [
-                            "thumbnail",
-                            "full",
-                            "all"
-                        ],
-                        "type": "string",
-                        "description": "Image type: thumbnail, full or all",
-                        "name": "imageType",
-                        "in": "formData",
-                        "required": true
                     }
                 ],
                 "responses": {
                     "200": {
-                        "description": "OK"
+                        "description": "OK",
+                        "schema": {
+                            "$ref": "#/definitions/imageStorage.UploadMerchImageResponse"
+                        }
                     },
                     "400": {
                         "description": "Bad Request",
@@ -247,11 +238,11 @@
                         "BearerAuth": []
                     }
                 ],
-                "description": "Удалить (безвозвратно) картинки по merch_uuid и query параметрам",
+                "description": "Удалить (безвозвратно) картинки по merch_uuid",
                 "tags": [
                     "Merch images"
                 ],
-                "summary": "Удалить (безвозвратно) картинки по merch_uuid и query параметрам",
+                "summary": "Удалить (безвозвратно) картинки по merch_uuid",
                 "parameters": [
                     {
                         "type": "string",
@@ -760,6 +751,17 @@
         }
     },
     "definitions": {
+        "imageStorage.UploadMerchImageResponse": {
+            "type": "object",
+            "properties": {
+                "fullImage": {
+                    "type": "string"
+                },
+                "thumbnail": {
+                    "type": "string"
+                }
+            }
+        },
         "merch.ImageLink": {
             "type": "object",
             "properties": {

docs/swagger.yaml

@@ -1,5 +1,12 @@
 basePath: /api/v2
 definitions:
+  imageStorage.UploadMerchImageResponse:
+    properties:
+      fullImage:
+        type: string
+      thumbnail:
+        type: string
+    type: object
   merch.ImageLink:
     properties:
       etag:
@@ -271,7 +278,7 @@ paths:
       - Merch
   /merch/images/{uuid}:
     delete:
-      description: Удалить (безвозвратно) картинки по merch_uuid и query параметрам
+      description: Удалить (безвозвратно) картинки по merch_uuid
       parameters:
       - description: merch_uuid
         in: path
@@ -291,7 +298,7 @@ paths:
             $ref: '#/definitions/responses.ErrorResponse500'
       security:
       - BearerAuth: []
-      summary: Удалить (безвозвратно) картинки по merch_uuid и query параметрам
+      summary: Удалить (безвозвратно) картинки по merch_uuid
       tags:
       - Merch images
     get:
@@ -328,7 +335,8 @@ paths:
     post:
       consumes:
       - multipart/form-data
-      description: Загрузить картинки по merch_uuid и query параметрам
+      description: Загрузить картинку по merch_uuid. В ответ будут выданы ссылки на
+        созданные картинки.
       parameters:
       - description: Merch UUID
         in: path
@@ -340,20 +348,13 @@ paths:
         name: file
         required: true
         type: file
-      - description: 'Image type: thumbnail, full or all'
-        enum:
-        - thumbnail
-        - full
-        - all
-        in: formData
-        name: imageType
-        required: true
-        type: string
       produces:
       - application/json
       responses:
         "200":
           description: OK
+          schema:
+            $ref: '#/definitions/imageStorage.UploadMerchImageResponse'
         "400":
           description: Bad Request
           schema:
@@ -364,7 +365,7 @@ paths:
             $ref: '#/definitions/responses.ErrorResponse500'
       security:
       - BearerAuth: []
-      summary: Загрузить картинки по merch_uuid и query параметрам
+      summary: Загрузить картинку по merch_uuid
       tags:
       - Merch images
   /prices:

go.mod

@@ -52,7 +52,7 @@ require (
 	github.com/jinzhu/inflection v1.0.0 // indirect
 	github.com/jinzhu/now v1.1.5 // indirect
 	github.com/json-iterator/go v1.1.12 // indirect
-	github.com/klauspost/compress v1.18.0 // indirect
+	github.com/klauspost/compress v1.18.1 // indirect
 	github.com/klauspost/cpuid/v2 v2.3.0 // indirect
 	github.com/leodido/go-urn v1.4.0 // indirect
 	github.com/mattn/go-isatty v0.0.20 // indirect
@@ -79,5 +79,5 @@ require (
 	golang.org/x/sys v0.37.0 // indirect
 	golang.org/x/text v0.30.0 // indirect
 	golang.org/x/tools v0.38.0 // indirect
-	google.golang.org/genproto/googleapis/rpc v0.0.0-20251014184007-4626949a642f // indirect
+	google.golang.org/genproto/googleapis/rpc v0.0.0-20251022142026-3a174f9686a8 // indirect
 )

go.sum

@@ -89,8 +89,8 @@ github.com/jinzhu/now v1.1.5 h1:/o9tlHleP7gOFmsnYNz3RGnqzefHA47wQpKrrdTIwXQ=
 github.com/jinzhu/now v1.1.5/go.mod h1:d3SSVoowX0Lcu0IBviAWJpolVfI5UJVZZ7cO71lE/z8=
 github.com/json-iterator/go v1.1.12 h1:PV8peI4a0ysnczrg+LtxykD8LfKY9ML6u2jnxaEnrnM=
 github.com/json-iterator/go v1.1.12/go.mod h1:e30LSqwooZae/UwlEbR2852Gd8hjQvJoHmT4TnhNGBo=
-github.com/klauspost/compress v1.18.0 h1:c/Cqfb0r+Yi+JtIEq73FWXVkRonBlf0CRNYc8Zttxdo=
+github.com/klauspost/compress v1.18.1 h1:bcSGx7UbpBqMChDtsF28Lw6v/G94LPrrbMbdC3JH2co=
-github.com/klauspost/compress v1.18.0/go.mod h1:2Pp+KzxcywXVXMr50+X0Q/Lsb43OQHYWRCY2AiWywWQ=
+github.com/klauspost/compress v1.18.1/go.mod h1:ZQFFVG+MdnR0P+l6wpXgIL4NTtwiKIdBnrBd8Nrxr+0=
 github.com/klauspost/cpuid/v2 v2.0.1/go.mod h1:FInQzS24/EEf25PyTYn52gqo7WaD8xa0213Md/qVLRg=
 github.com/klauspost/cpuid/v2 v2.3.0 h1:S4CRMLnYUhGeDFDqkGriYKdfoFlDnMtqTiI/sFzhA9Y=
 github.com/klauspost/cpuid/v2 v2.3.0/go.mod h1:hqwkgyIinND0mEev00jJYCxPNVRVXFQeu1XKlok6oO0=
@@ -217,8 +217,8 @@ golang.org/x/tools v0.38.0/go.mod h1:yEsQ/d/YK8cjh0L6rZlY8tgtlKiBNTL14pGDJPJpYQs
 golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
 gonum.org/v1/gonum v0.16.0 h1:5+ul4Swaf3ESvrOnidPp4GZbzf0mxVQpDCYUQE7OJfk=
 gonum.org/v1/gonum v0.16.0/go.mod h1:fef3am4MQ93R2HHpKnLk4/Tbh/s0+wqD5nfa6Pnwy4E=
-google.golang.org/genproto/googleapis/rpc v0.0.0-20251014184007-4626949a642f h1:1FTH6cpXFsENbPR5Bu8NQddPSaUUE6NA2XdZdDSAJK4=
+google.golang.org/genproto/googleapis/rpc v0.0.0-20251022142026-3a174f9686a8 h1:M1rk8KBnUsBDg1oPGHNCxG4vc1f49epmTO7xscSajMk=
-google.golang.org/genproto/googleapis/rpc v0.0.0-20251014184007-4626949a642f/go.mod h1:7i2o+ce6H/6BluujYR+kqX3GKH+dChPTQU19wjRPiGk=
+google.golang.org/genproto/googleapis/rpc v0.0.0-20251022142026-3a174f9686a8/go.mod h1:7i2o+ce6H/6BluujYR+kqX3GKH+dChPTQU19wjRPiGk=
 google.golang.org/grpc v1.76.0 h1:UnVkv1+uMLYXoIz6o7chp59WfQUYA2ex/BXQ9rHZu7A=
 google.golang.org/grpc v1.76.0/go.mod h1:Ju12QI8M6iQJtbcsV+awF5a4hfJMLi4X0JLo94ULZ6c=
 google.golang.org/protobuf v1.36.10 h1:AYd7cD/uASjIL6Q9LiTjz8JLcrh/88q5UObnmY3aOOE=

internal/api/merch/controller.go

@@ -266,16 +266,15 @@ func (co *controller) getDistinctPrices(c *gin.Context) {
 	c.JSON(http.StatusOK, response)
 }
 
-// @Summary		Загрузить картинки по merch_uuid и query параметрам
+// @Summary		Загрузить картинку по merch_uuid
-// @Description	Загрузить картинки по merch_uuid и query параметрам
+// @Description	Загрузить картинку по merch_uuid. В ответ будут выданы ссылки на созданные картинки.
 // @Tags			Merch images
 // @Security		BearerAuth
 // @Accept			multipart/form-data
 // @Produce		json
 // @Param			uuid					path		string	true	"Merch UUID"
 // @Param			file					formData	file	true	"Image file"
-// @Param			imageType	formData	string	true	"Image type: thumbnail, full or all"	Enums(thumbnail, full, all)
+// @Success		200						{object}	imageStorage.UploadMerchImageResponse
-// @Success		200
 // @Failure		400						{object}	responses.ErrorResponse400
 // @Failure		500						{object}	responses.ErrorResponse500
 // @Router			/merch/images/{uuid}	[post]
@@ -294,13 +293,14 @@ func (co *controller) uploadMerchImage(c *gin.Context) {
 		return
 	}
 
-	imageType := c.PostForm("imageType")
+	//Uncomment for MinIO use
-	types := map[string]struct{}{"thumbnail": {}, "full": {}, "all": {}}
+	//imageType := c.PostForm("imageType")
-	if _, allowed := types[imageType]; !allowed {
+	//types := map[string]struct{}{"thumbnail": {}, "full": {}, "all": {}}
-		c.JSON(http.StatusBadRequest, responses.ErrorResponse400{Error: "imageType must be one of: thumbnail, full, all"})
+	//if _, allowed := types[imageType]; !allowed {
-		log.WithError(err).Error("Merch | imageType must be one of: thumbnail, full, all")
+	//	c.JSON(http.StatusBadRequest, responses.ErrorResponse400{Error: "imageType must be one of: thumbnail, full, all"})
-		return
+	//	log.WithError(err).Error("Merch | imageType must be one of: thumbnail, full, all")
-	}
+	//	return
+	//}
 
 	file, err := c.FormFile("file")
 	if err != nil {
@@ -312,14 +312,17 @@ func (co *controller) uploadMerchImage(c *gin.Context) {
 	ctx, cancel := context.WithTimeout(c.Request.Context(), co.expires)
 	defer cancel()
 
-	err = co.service.uploadMerchImage(ctx, userUuid, merchUuid, imageType, file)
+	//Uncomment for MinIO use
+	//err = co.service.uploadMerchImage(ctx, userUuid, merchUuid, imageType, file)
+	response, err := co.service.mtUploadMerchImage(ctx, userUuid, merchUuid, file)
 	if err != nil {
 		c.JSON(http.StatusInternalServerError, responses.ErrorResponse500{Error: err.Error()})
 		log.WithError(err).Error("Merch | Failed to upload merch image")
 		return
 	}
 
-	c.Status(http.StatusOK)
+	//c.Status(http.StatusOK)
+	c.JSON(http.StatusOK, response)
 }
 
 // @Summary		Получить картинки по merch_uuid и query параметрам
@@ -333,40 +336,50 @@ func (co *controller) uploadMerchImage(c *gin.Context) {
 // @Failure		500						{object}	responses.ErrorResponse500
 // @Router			/merch/images/{uuid}	[get]
 func (co *controller) getMerchImage(c *gin.Context) {
-	typeQuery := strings.ToLower(c.Query("type"))
+	//Uncomment for MinIO use
-	if typeQuery == "" {
-		c.JSON(http.StatusBadRequest, responses.ErrorResponse400{Error: "Image type query param is empty"})
-		return
-	}
 
-	userUuid, err := co.utils.GetUserUuidFromContext(c)
+	//typeQuery := strings.ToLower(c.Query("type"))
-	if err != nil {
+	//if typeQuery == "" {
-		c.JSON(http.StatusInternalServerError, responses.ErrorResponse500{Error: err.Error()})
+	//	c.JSON(http.StatusBadRequest, responses.ErrorResponse400{Error: "Image type query param is empty"})
-		log.WithError(err).Error("Merch | Failed to get user uuid from context")
+	//	return
-		return
+	//}
-	}
+	//
-
+	//userUuid, err := co.utils.GetUserUuidFromContext(c)
-	merchUuid := c.Param("uuid")
+	//if err != nil {
-	if merchUuid == "" {
+	//	c.JSON(http.StatusInternalServerError, responses.ErrorResponse500{Error: err.Error()})
-		c.JSON(http.StatusBadRequest, responses.ErrorResponse400{Error: "MerchUuid is empty"})
+	//	log.WithError(err).Error("Merch | Failed to get user uuid from context")
-		log.WithError(err).Error("Merch | Failed to get single merch")
+	//	return
-		return
+	//}
-	}
+	//
-
+	//merchUuid := c.Param("uuid")
-	ctx, cancel := context.WithTimeout(c.Request.Context(), co.expires)
+	//if merchUuid == "" {
-	defer cancel()
+	//	c.JSON(http.StatusBadRequest, responses.ErrorResponse400{Error: "MerchUuid is empty"})
-
+	//	log.WithError(err).Error("Merch | Failed to get single merch")
-	link, err := co.service.getPublicImageLink(ctx, userUuid, merchUuid, typeQuery)
+	//	return
-	if err != nil {
+	//}
-		c.JSON(http.StatusInternalServerError, responses.ErrorResponse500{Error: err.Error()})
+	//
-		log.WithError(err).Error("Merch | Failed to get merch image")
+	//ctx, cancel := context.WithTimeout(c.Request.Context(), co.expires)
-		return
+	//defer cancel()
-	}
+	//
-	c.JSON(http.StatusOK, link)
+	//link, err := co.service.getPublicImageLink(ctx, userUuid, merchUuid, typeQuery)
+	//if err != nil {
+	//	c.JSON(http.StatusInternalServerError, responses.ErrorResponse500{Error: err.Error()})
+	//	log.WithError(err).Error("Merch | Failed to get merch image")
+	//	return
+	//}
+	//
+	//if link.Link == "" {
+	//	log.Debug("Merch | No image")
+	//	c.Status(http.StatusNoContent)
+	//	return
+	//}
+	//
+	//c.JSON(http.StatusOK, link)
+	c.JSON(http.StatusNotImplemented, gin.H{"msg": "Method deprecated. Request images from image storage."})
 }
 
-// @Summary		Удалить (безвозвратно) картинки по merch_uuid и query параметрам
+// @Summary		Удалить (безвозвратно) картинки по merch_uuid
-// @Description	Удалить (безвозвратно) картинки по merch_uuid и query параметрам
+// @Description	Удалить (безвозвратно) картинки по merch_uuid
 // @Tags			Merch images
 // @Security		BearerAuth
 // @Param			uuid	path	string	true	"merch_uuid"
@@ -385,14 +398,17 @@ func (co *controller) deleteMerchImage(c *gin.Context) {
 	merchUuid := c.Param("uuid")
 	if merchUuid == "" {
 		c.JSON(http.StatusBadRequest, responses.ErrorResponse400{Error: "MerchUuid is empty"})
-		log.WithError(err).Error("Merch | Failed to get single merch")
+		log.WithError(err).Error("Merch | Failed to get merch uuid")
 		return
 	}
 
 	ctx, cancel := context.WithTimeout(c.Request.Context(), co.expires)
 	defer cancel()
 
-	if err := co.service.deleteMerchImage(ctx, userUuid, merchUuid); err != nil {
+	//Uncomment for MinIO use
+	//if err := co.service.deleteMerchImage(ctx, userUuid, merchUuid); err != nil {
+
+	if err := co.service.mtDeleteMerchImage(ctx, userUuid, merchUuid); err != nil {
 		c.JSON(http.StatusInternalServerError, responses.ErrorResponse500{Error: err.Error()})
 		log.WithError(err).Error("Merch | Failed to delete merch image")
 		return

internal/api/merch/handler.go

@@ -4,6 +4,7 @@ import (
 	log "github.com/sirupsen/logrus"
 	"gorm.io/gorm"
 	"merch-parser-api/internal/interfaces"
+	is "merch-parser-api/proto/imageStorage"
 	"time"
 )
 
@@ -17,6 +18,7 @@ type Deps struct {
 	DB           *gorm.DB
 	Utils        interfaces.Utils
 	Media        interfaces.MediaStorage
+	ImageStorage is.ImageStorageClient
 }
 
 func NewHandler(deps Deps) *Handler {
@@ -24,7 +26,13 @@ func NewHandler(deps Deps) *Handler {
 	expires := time.Minute * 5
 
 	r := NewRepo(deps.DB)
-	s := newService(r, deps.Media, packageBucketName, expires)
+	s := newService(serviceDeps{
+		repo:         r,
+		media:        deps.Media,
+		bucketName:   packageBucketName,
+		expires:      expires,
+		imageStorage: deps.ImageStorage,
+	})
 	c := newController(s, deps.Utils, expires)
 
 	media := deps.Media

internal/api/merch/repository.go

@@ -63,6 +63,7 @@ func (r *Repo) merchRecordExists(userUuid, merchUuid string) (bool, error) {
 			FROM merch
 			WHERE user_uuid = ?
 			AND merch_uuid = ?
+			AND deleted_at IS NULL
 		);`, userUuid, merchUuid).Scan(&exists).Error
 
 	return exists, err

internal/api/merch/service.go

@@ -13,6 +13,7 @@ import (
 	"image/jpeg"
 	"io"
 	"merch-parser-api/internal/interfaces"
+	is "merch-parser-api/proto/imageStorage"
 	"mime/multipart"
 	"path/filepath"
 	"strings"
@@ -24,14 +25,24 @@ type service struct {
 	media        interfaces.MediaStorage
 	bucketName   string
 	expires      time.Duration
+	imageStorage is.ImageStorageClient
 }
 
-func newService(repo repository, media interfaces.MediaStorage, bucketName string, expires time.Duration) *service {
+type serviceDeps struct {
+	repo         repository
+	media        interfaces.MediaStorage
+	bucketName   string
+	expires      time.Duration
+	imageStorage is.ImageStorageClient
+}
+
+func newService(deps serviceDeps) *service {
 	return &service{
-		repo:       repo,
+		repo:         deps.repo,
-		media:      media,
+		media:        deps.media,
-		bucketName: bucketName,
+		bucketName:   deps.bucketName,
-		expires:    expires,
+		expires:      deps.expires,
+		imageStorage: deps.imageStorage,
 	}
 }
 
@@ -210,6 +221,9 @@ func (s *service) getDistinctPrices(userUuid, merchUuid, days string) (PricesRes
 	}, nil
 }
 
+// uploadMerchImage
+// Deprecated.
+// Use only with MinIO storage. Use mtUploadMerchImage for merch-tracker images storage.
 func (s *service) uploadMerchImage(ctx context.Context, userUuid, merchUuid, imageType string, file *multipart.FileHeader) error {
 	exists, err := s.repo.merchRecordExists(userUuid, merchUuid)
 	if err != nil {
@@ -303,6 +317,9 @@ func (s *service) uploadMerchImage(ctx context.Context, userUuid, merchUuid, ima
 	return nil
 }
 
+// getPublicImageLink
+// Deprecated.
+// Use only with MinIO storage.
 func (s *service) getPublicImageLink(ctx context.Context, userUuid, merchUuid, imageType string) (ImageLink, error) {
 	object, err := s.makeObject(userUuid, merchUuid, imageType)
 	if err != nil {
@@ -320,6 +337,9 @@ func (s *service) getPublicImageLink(ctx context.Context, userUuid, merchUuid, i
 	}, nil
 }
 
+// getPresignedImageLink
+// Deprecated.
+// Use only with MinIO storage.
 func (s *service) getPresignedImageLink(ctx context.Context, userUuid, merchUuid, imageType string) (ImageLink, error) {
 	exists, err := s.repo.merchRecordExists(userUuid, merchUuid)
 	if err != nil {
@@ -351,6 +371,9 @@ func (s *service) getPresignedImageLink(ctx context.Context, userUuid, merchUuid
 	}, nil
 }
 
+// deleteMerchImage
+// Deprecated.
+// Use only with MinIO storage.
 func (s *service) deleteMerchImage(ctx context.Context, userUuid, merchUuid string) error {
 	exists, err := s.repo.merchRecordExists(userUuid, merchUuid)
 	if err != nil {
@@ -398,3 +421,65 @@ func (s *service) _uploadToStorage(params uploadImageParams) error {
 
 	return nil
 }
+
+// mtUploadMerchImage
+// Upload new/rewrite existing image to merch-tracker images storage
+func (s *service) mtUploadMerchImage(ctx context.Context, userUuid, merchUuid string, file *multipart.FileHeader) (*is.UploadMerchImageResponse, error) {
+	const uploadMerchImage = "Merch service | Upload merch image"
+
+	exists, err := s.repo.merchRecordExists(userUuid, merchUuid)
+	if err != nil {
+		log.WithError(err).Error(uploadMerchImage)
+		return nil, err
+	}
+
+	if !exists {
+		err = fmt.Errorf("no merch found for user %s with uuid %s", userUuid, merchUuid)
+		log.WithError(err).Error(uploadMerchImage)
+		return nil, err
+	}
+
+	f, err := file.Open()
+	if err != nil {
+		log.WithError(err).Error(uploadMerchImage)
+		return nil, err
+	}
+	defer f.Close()
+
+	data, err := io.ReadAll(f)
+	if err != nil {
+		log.WithError(err).Error(uploadMerchImage)
+		return nil, err
+	}
+
+	response, err := s.imageStorage.UploadImage(ctx, &is.UploadMerchImageRequest{
+		ImageData: data,
+		UserUuid:  userUuid,
+		MerchUuid: merchUuid,
+	})
+	if err != nil {
+		log.WithError(err).Error(uploadMerchImage)
+		return nil, err
+	}
+
+	return response, nil
+}
+
+// mtDeleteMerchImage
+// Delete all merch images for given user and merch uuid-s from merch-tracker images storage
+func (s *service) mtDeleteMerchImage(ctx context.Context, userUuid, merchUuid string) error {
+	exists, err := s.repo.merchRecordExists(userUuid, merchUuid)
+	if err != nil {
+		return err
+	}
+
+	if !exists {
+		return fmt.Errorf("no merch found for user %s with uuid %s", userUuid, merchUuid)
+	}
+
+	s.imageStorage.DeleteImage(ctx, &is.DeleteImageRequest{
+		UserUuid:  userUuid,
+		MerchUuid: merchUuid,
+	})
+	return nil
+}

internal/grpcService/handler.go

@@ -1,106 +1,18 @@
 package grpcService
 
 import (
-	log "github.com/sirupsen/logrus"
 	"google.golang.org/grpc"
-	"google.golang.org/protobuf/types/known/emptypb"
-	"io"
 	"merch-parser-api/internal/interfaces"
-	"merch-parser-api/internal/shared"
 	pb "merch-parser-api/proto/taskProcessor"
-	"time"
 )
 
-type repoServer struct {
-	pb.UnimplementedTaskProcessorServer
-	taskProvider interfaces.TaskProvider
-}
-
 func NewGrpcServer(taskProvider interfaces.TaskProvider) *grpc.Server {
 	srv := grpc.NewServer()
+
 	repoSrv := &repoServer{
 		taskProvider: taskProvider,
 	}
-
 	pb.RegisterTaskProcessorServer(srv, repoSrv)
+
 	return srv
 }
-
-func (r *repoServer) RequestTask(_ *emptypb.Empty, stream pb.TaskProcessor_RequestTaskServer) error {
-	tasks, err := r.taskProvider.PrepareTasks()
-	if err != nil {
-		log.WithField("err", err).Error("gRPC Server | Request task error")
-		return err
-	}
-
-	for _, task := range tasks {
-		if err = stream.Send(&pb.Task{
-			MerchUuid:           task.MerchUuid,
-			OriginSurugayaLink:  task.OriginSurugayaLink,
-			OriginMandarakeLink: task.OriginMandarakeLink,
-		}); err != nil {
-			log.WithField("err", err).Error("gRPC Server | Stream send error")
-			return err
-		}
-	}
-	return nil
-}
-
-func (r *repoServer) SendResult(stream pb.TaskProcessor_SendResultServer) error {
-	saveInterval := time.Second * 2
-	batch := make([]shared.TaskResult, 0)
-
-	ticker := time.NewTicker(saveInterval)
-	defer ticker.Stop()
-
-	done := make(chan struct{})
-
-	go func() {
-		for {
-			select {
-			case <-done:
-				return
-			case <-ticker.C:
-				if len(batch) > 0 {
-					err := r.taskProvider.InsertPrices(batch)
-					if err != nil {
-						log.WithField("err", err).Error("gRPC Server | Batch insert")
-					}
-				}
-			}
-		}
-	}()
-
-	for {
-		response, err := stream.Recv()
-		if err == io.EOF {
-			log.Debug("gRPC EOF")
-			break
-		}
-
-		if err != nil {
-			log.WithField("err", err).Error("gRPC Server | Receive")
-			return err
-		}
-
-		entry := shared.TaskResult{
-			MerchUuid: response.MerchUuid,
-			Origin:    response.OriginName,
-			Price:     response.Price,
-		}
-
-		batch = append(batch, entry)
-		log.WithField("response", entry).Debug("gRPC Server | Receive success")
-	}
-
-	close(done)
-	if len(batch) > 0 {
-		err := r.taskProvider.InsertPrices(batch)
-		if err != nil {
-			log.WithField("err", err).Error("gRPC Server | Last data batch insert")
-			return err
-		}
-	}
-
-	return nil
-}

internal/grpcService/taskProcessor.go

@@ -0,0 +1,95 @@
+package grpcService
+
+import (
+	log "github.com/sirupsen/logrus"
+	"google.golang.org/protobuf/types/known/emptypb"
+	"io"
+	"merch-parser-api/internal/interfaces"
+	"merch-parser-api/internal/shared"
+	pb "merch-parser-api/proto/taskProcessor"
+	"time"
+)
+
+type repoServer struct {
+	pb.UnimplementedTaskProcessorServer
+	taskProvider interfaces.TaskProvider
+}
+
+func (r *repoServer) RequestTask(_ *emptypb.Empty, stream pb.TaskProcessor_RequestTaskServer) error {
+	tasks, err := r.taskProvider.PrepareTasks()
+	if err != nil {
+		log.WithField("err", err).Error("gRPC Server | Request task error")
+		return err
+	}
+
+	for _, task := range tasks {
+		if err = stream.Send(&pb.Task{
+			MerchUuid:           task.MerchUuid,
+			OriginSurugayaLink:  task.OriginSurugayaLink,
+			OriginMandarakeLink: task.OriginMandarakeLink,
+		}); err != nil {
+			log.WithField("err", err).Error("gRPC Server | Stream send error")
+			return err
+		}
+	}
+	return nil
+}
+
+func (r *repoServer) SendResult(stream pb.TaskProcessor_SendResultServer) error {
+	saveInterval := time.Second * 2
+	batch := make([]shared.TaskResult, 0)
+
+	ticker := time.NewTicker(saveInterval)
+	defer ticker.Stop()
+
+	done := make(chan struct{})
+
+	go func() {
+		for {
+			select {
+			case <-done:
+				return
+			case <-ticker.C:
+				if len(batch) > 0 {
+					err := r.taskProvider.InsertPrices(batch)
+					if err != nil {
+						log.WithField("err", err).Error("gRPC Server | Batch insert")
+					}
+				}
+			}
+		}
+	}()
+
+	for {
+		response, err := stream.Recv()
+		if err == io.EOF {
+			log.Debug("gRPC EOF")
+			break
+		}
+
+		if err != nil {
+			log.WithField("err", err).Error("gRPC Server | Receive")
+			return err
+		}
+
+		entry := shared.TaskResult{
+			MerchUuid: response.MerchUuid,
+			Origin:    response.OriginName,
+			Price:     response.Price,
+		}
+
+		batch = append(batch, entry)
+		log.WithField("response", entry).Debug("gRPC Server | Receive success")
+	}
+
+	close(done)
+	if len(batch) > 0 {
+		err := r.taskProvider.InsertPrices(batch)
+		if err != nil {
+			log.WithField("err", err).Error("gRPC Server | Last data batch insert")
+			return err
+		}
+	}
+
+	return nil
+}

internal/imagesProvider/handler.go

@@ -0,0 +1,27 @@
+package imagesProvider
+
+import (
+	log "github.com/sirupsen/logrus"
+	"google.golang.org/grpc"
+	"google.golang.org/grpc/credentials/insecure"
+	is "merch-parser-api/proto/imageStorage"
+)
+
+type Handler struct{}
+
+func NewClient(address string) is.ImageStorageClient {
+	var opts []grpc.DialOption
+	insec := grpc.WithTransportCredentials(insecure.NewCredentials())
+	opts = append(opts, insec)
+
+	conn, err := grpc.NewClient(address, opts...)
+	if err != nil {
+		log.Fatal(err)
+	}
+
+	log.WithFields(log.Fields{
+		"address": address,
+	}).Debug("gRPC | API client")
+
+	return is.NewImageStorageClient(conn)
+}

internal/interfaces/mediaStorage.go

@@ -7,6 +7,8 @@ import (
 	"time"
 )
 
+// MinIO service replaced by imagesProvider
+
 type MediaStorage interface {
 	CheckBucketExists(bucketName string) (bool, error)
 	Upload(ctx context.Context, bucket, object string, reader io.Reader, size int64) error

internal/mediaStorage/service.go

@@ -44,6 +44,9 @@ func (s *Service) Upload(ctx context.Context, bucket, object string, reader io.R
 func (s *Service) GetPublicLink(ctx context.Context, bucket, object string) (string, string, error) {
 	stat, err := s.client.StatObject(ctx, bucket, object, minio.StatObjectOptions{})
 	if err != nil {
+		if err.Error() == minio.ToErrorResponse(err).Error() {
+			return "", "", nil
+		}
 		log.WithFields(log.Fields{
 			"error": err,
 			"key":   bucket + "/" + object,

proto/imageStorage.proto

@@ -0,0 +1,27 @@
+syntax="proto3";
+
+import "google/protobuf/empty.proto";
+
+package imageStorage;
+option go_package = "imageStorage/pkg/proto/imageStorage";
+
+message UploadMerchImageRequest{
+  bytes imageData = 1;
+  string userUuid = 2;
+  string merchUuid = 3;
+}
+
+message UploadMerchImageResponse {
+  string fullImage = 1;
+  string thumbnail = 2;
+}
+
+message DeleteImageRequest {
+  string userUuid = 1;
+  string merchUuid = 2;
+}
+
+service ImageStorage {
+  rpc UploadImage(UploadMerchImageRequest) returns (UploadMerchImageResponse);
+  rpc DeleteImage(DeleteImageRequest) returns (google.protobuf.Empty);
+}

proto/imageStorage/imageStorage.pb.go

@@ -0,0 +1,261 @@
+// Code generated by protoc-gen-go. DO NOT EDIT.
+// versions:
+// 	protoc-gen-go v1.36.8
+// 	protoc        v6.32.1
+// source: imageStorage.proto
+
+package imageStorage
+
+import (
+	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
+	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
+	emptypb "google.golang.org/protobuf/types/known/emptypb"
+	reflect "reflect"
+	sync "sync"
+	unsafe "unsafe"
+)
+
+const (
+	// Verify that this generated code is sufficiently up-to-date.
+	_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
+	// Verify that runtime/protoimpl is sufficiently up-to-date.
+	_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
+)
+
+type UploadMerchImageRequest struct {
+	state         protoimpl.MessageState `protogen:"open.v1"`
+	ImageData     []byte                 `protobuf:"bytes,1,opt,name=imageData,proto3" json:"imageData,omitempty"`
+	UserUuid      string                 `protobuf:"bytes,2,opt,name=userUuid,proto3" json:"userUuid,omitempty"`
+	MerchUuid     string                 `protobuf:"bytes,3,opt,name=merchUuid,proto3" json:"merchUuid,omitempty"`
+	unknownFields protoimpl.UnknownFields
+	sizeCache     protoimpl.SizeCache
+}
+
+func (x *UploadMerchImageRequest) Reset() {
+	*x = UploadMerchImageRequest{}
+	mi := &file_imageStorage_proto_msgTypes[0]
+	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+	ms.StoreMessageInfo(mi)
+}
+
+func (x *UploadMerchImageRequest) String() string {
+	return protoimpl.X.MessageStringOf(x)
+}
+
+func (*UploadMerchImageRequest) ProtoMessage() {}
+
+func (x *UploadMerchImageRequest) ProtoReflect() protoreflect.Message {
+	mi := &file_imageStorage_proto_msgTypes[0]
+	if x != nil {
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		if ms.LoadMessageInfo() == nil {
+			ms.StoreMessageInfo(mi)
+		}
+		return ms
+	}
+	return mi.MessageOf(x)
+}
+
+// Deprecated: Use UploadMerchImageRequest.ProtoReflect.Descriptor instead.
+func (*UploadMerchImageRequest) Descriptor() ([]byte, []int) {
+	return file_imageStorage_proto_rawDescGZIP(), []int{0}
+}
+
+func (x *UploadMerchImageRequest) GetImageData() []byte {
+	if x != nil {
+		return x.ImageData
+	}
+	return nil
+}
+
+func (x *UploadMerchImageRequest) GetUserUuid() string {
+	if x != nil {
+		return x.UserUuid
+	}
+	return ""
+}
+
+func (x *UploadMerchImageRequest) GetMerchUuid() string {
+	if x != nil {
+		return x.MerchUuid
+	}
+	return ""
+}
+
+type UploadMerchImageResponse struct {
+	state         protoimpl.MessageState `protogen:"open.v1"`
+	FullImage     string                 `protobuf:"bytes,1,opt,name=fullImage,proto3" json:"fullImage,omitempty"`
+	Thumbnail     string                 `protobuf:"bytes,2,opt,name=thumbnail,proto3" json:"thumbnail,omitempty"`
+	unknownFields protoimpl.UnknownFields
+	sizeCache     protoimpl.SizeCache
+}
+
+func (x *UploadMerchImageResponse) Reset() {
+	*x = UploadMerchImageResponse{}
+	mi := &file_imageStorage_proto_msgTypes[1]
+	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+	ms.StoreMessageInfo(mi)
+}
+
+func (x *UploadMerchImageResponse) String() string {
+	return protoimpl.X.MessageStringOf(x)
+}
+
+func (*UploadMerchImageResponse) ProtoMessage() {}
+
+func (x *UploadMerchImageResponse) ProtoReflect() protoreflect.Message {
+	mi := &file_imageStorage_proto_msgTypes[1]
+	if x != nil {
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		if ms.LoadMessageInfo() == nil {
+			ms.StoreMessageInfo(mi)
+		}
+		return ms
+	}
+	return mi.MessageOf(x)
+}
+
+// Deprecated: Use UploadMerchImageResponse.ProtoReflect.Descriptor instead.
+func (*UploadMerchImageResponse) Descriptor() ([]byte, []int) {
+	return file_imageStorage_proto_rawDescGZIP(), []int{1}
+}
+
+func (x *UploadMerchImageResponse) GetFullImage() string {
+	if x != nil {
+		return x.FullImage
+	}
+	return ""
+}
+
+func (x *UploadMerchImageResponse) GetThumbnail() string {
+	if x != nil {
+		return x.Thumbnail
+	}
+	return ""
+}
+
+type DeleteImageRequest struct {
+	state         protoimpl.MessageState `protogen:"open.v1"`
+	UserUuid      string                 `protobuf:"bytes,1,opt,name=userUuid,proto3" json:"userUuid,omitempty"`
+	MerchUuid     string                 `protobuf:"bytes,2,opt,name=merchUuid,proto3" json:"merchUuid,omitempty"`
+	unknownFields protoimpl.UnknownFields
+	sizeCache     protoimpl.SizeCache
+}
+
+func (x *DeleteImageRequest) Reset() {
+	*x = DeleteImageRequest{}
+	mi := &file_imageStorage_proto_msgTypes[2]
+	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+	ms.StoreMessageInfo(mi)
+}
+
+func (x *DeleteImageRequest) String() string {
+	return protoimpl.X.MessageStringOf(x)
+}
+
+func (*DeleteImageRequest) ProtoMessage() {}
+
+func (x *DeleteImageRequest) ProtoReflect() protoreflect.Message {
+	mi := &file_imageStorage_proto_msgTypes[2]
+	if x != nil {
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		if ms.LoadMessageInfo() == nil {
+			ms.StoreMessageInfo(mi)
+		}
+		return ms
+	}
+	return mi.MessageOf(x)
+}
+
+// Deprecated: Use DeleteImageRequest.ProtoReflect.Descriptor instead.
+func (*DeleteImageRequest) Descriptor() ([]byte, []int) {
+	return file_imageStorage_proto_rawDescGZIP(), []int{2}
+}
+
+func (x *DeleteImageRequest) GetUserUuid() string {
+	if x != nil {
+		return x.UserUuid
+	}
+	return ""
+}
+
+func (x *DeleteImageRequest) GetMerchUuid() string {
+	if x != nil {
+		return x.MerchUuid
+	}
+	return ""
+}
+
+var File_imageStorage_proto protoreflect.FileDescriptor
+
+const file_imageStorage_proto_rawDesc = "" +
+	"\n" +
+	"\x12imageStorage.proto\x12\fimageStorage\x1a\x1bgoogle/protobuf/empty.proto\"q\n" +
+	"\x17UploadMerchImageRequest\x12\x1c\n" +
+	"\timageData\x18\x01 \x01(\fR\timageData\x12\x1a\n" +
+	"\buserUuid\x18\x02 \x01(\tR\buserUuid\x12\x1c\n" +
+	"\tmerchUuid\x18\x03 \x01(\tR\tmerchUuid\"V\n" +
+	"\x18UploadMerchImageResponse\x12\x1c\n" +
+	"\tfullImage\x18\x01 \x01(\tR\tfullImage\x12\x1c\n" +
+	"\tthumbnail\x18\x02 \x01(\tR\tthumbnail\"N\n" +
+	"\x12DeleteImageRequest\x12\x1a\n" +
+	"\buserUuid\x18\x01 \x01(\tR\buserUuid\x12\x1c\n" +
+	"\tmerchUuid\x18\x02 \x01(\tR\tmerchUuid2\xb5\x01\n" +
+	"\fImageStorage\x12\\\n" +
+	"\vUploadImage\x12%.imageStorage.UploadMerchImageRequest\x1a&.imageStorage.UploadMerchImageResponse\x12G\n" +
+	"\vDeleteImage\x12 .imageStorage.DeleteImageRequest\x1a\x16.google.protobuf.EmptyB%Z#imageStorage/pkg/proto/imageStorageb\x06proto3"
+
+var (
+	file_imageStorage_proto_rawDescOnce sync.Once
+	file_imageStorage_proto_rawDescData []byte
+)
+
+func file_imageStorage_proto_rawDescGZIP() []byte {
+	file_imageStorage_proto_rawDescOnce.Do(func() {
+		file_imageStorage_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_imageStorage_proto_rawDesc), len(file_imageStorage_proto_rawDesc)))
+	})
+	return file_imageStorage_proto_rawDescData
+}
+
+var file_imageStorage_proto_msgTypes = make([]protoimpl.MessageInfo, 3)
+var file_imageStorage_proto_goTypes = []any{
+	(*UploadMerchImageRequest)(nil),  // 0: imageStorage.UploadMerchImageRequest
+	(*UploadMerchImageResponse)(nil), // 1: imageStorage.UploadMerchImageResponse
+	(*DeleteImageRequest)(nil),       // 2: imageStorage.DeleteImageRequest
+	(*emptypb.Empty)(nil),            // 3: google.protobuf.Empty
+}
+var file_imageStorage_proto_depIdxs = []int32{
+	0, // 0: imageStorage.ImageStorage.UploadImage:input_type -> imageStorage.UploadMerchImageRequest
+	2, // 1: imageStorage.ImageStorage.DeleteImage:input_type -> imageStorage.DeleteImageRequest
+	1, // 2: imageStorage.ImageStorage.UploadImage:output_type -> imageStorage.UploadMerchImageResponse
+	3, // 3: imageStorage.ImageStorage.DeleteImage:output_type -> google.protobuf.Empty
+	2, // [2:4] is the sub-list for method output_type
+	0, // [0:2] is the sub-list for method input_type
+	0, // [0:0] is the sub-list for extension type_name
+	0, // [0:0] is the sub-list for extension extendee
+	0, // [0:0] is the sub-list for field type_name
+}
+
+func init() { file_imageStorage_proto_init() }
+func file_imageStorage_proto_init() {
+	if File_imageStorage_proto != nil {
+		return
+	}
+	type x struct{}
+	out := protoimpl.TypeBuilder{
+		File: protoimpl.DescBuilder{
+			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
+			RawDescriptor: unsafe.Slice(unsafe.StringData(file_imageStorage_proto_rawDesc), len(file_imageStorage_proto_rawDesc)),
+			NumEnums:      0,
+			NumMessages:   3,
+			NumExtensions: 0,
+			NumServices:   1,
+		},
+		GoTypes:           file_imageStorage_proto_goTypes,
+		DependencyIndexes: file_imageStorage_proto_depIdxs,
+		MessageInfos:      file_imageStorage_proto_msgTypes,
+	}.Build()
+	File_imageStorage_proto = out.File
+	file_imageStorage_proto_goTypes = nil
+	file_imageStorage_proto_depIdxs = nil
+}

proto/imageStorage/imageStorage_grpc.pb.go

@@ -0,0 +1,160 @@
+// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
+// versions:
+// - protoc-gen-go-grpc v1.5.1
+// - protoc             v6.32.1
+// source: imageStorage.proto
+
+package imageStorage
+
+import (
+	context "context"
+	grpc "google.golang.org/grpc"
+	codes "google.golang.org/grpc/codes"
+	status "google.golang.org/grpc/status"
+	emptypb "google.golang.org/protobuf/types/known/emptypb"
+)
+
+// This is a compile-time assertion to ensure that this generated file
+// is compatible with the grpc package it is being compiled against.
+// Requires gRPC-Go v1.64.0 or later.
+const _ = grpc.SupportPackageIsVersion9
+
+const (
+	ImageStorage_UploadImage_FullMethodName = "/imageStorage.ImageStorage/UploadImage"
+	ImageStorage_DeleteImage_FullMethodName = "/imageStorage.ImageStorage/DeleteImage"
+)
+
+// ImageStorageClient is the client API for ImageStorage service.
+//
+// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
+type ImageStorageClient interface {
+	UploadImage(ctx context.Context, in *UploadMerchImageRequest, opts ...grpc.CallOption) (*UploadMerchImageResponse, error)
+	DeleteImage(ctx context.Context, in *DeleteImageRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
+}
+
+type imageStorageClient struct {
+	cc grpc.ClientConnInterface
+}
+
+func NewImageStorageClient(cc grpc.ClientConnInterface) ImageStorageClient {
+	return &imageStorageClient{cc}
+}
+
+func (c *imageStorageClient) UploadImage(ctx context.Context, in *UploadMerchImageRequest, opts ...grpc.CallOption) (*UploadMerchImageResponse, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
+	out := new(UploadMerchImageResponse)
+	err := c.cc.Invoke(ctx, ImageStorage_UploadImage_FullMethodName, in, out, cOpts...)
+	if err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (c *imageStorageClient) DeleteImage(ctx context.Context, in *DeleteImageRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
+	out := new(emptypb.Empty)
+	err := c.cc.Invoke(ctx, ImageStorage_DeleteImage_FullMethodName, in, out, cOpts...)
+	if err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+// ImageStorageServer is the server API for ImageStorage service.
+// All implementations must embed UnimplementedImageStorageServer
+// for forward compatibility.
+type ImageStorageServer interface {
+	UploadImage(context.Context, *UploadMerchImageRequest) (*UploadMerchImageResponse, error)
+	DeleteImage(context.Context, *DeleteImageRequest) (*emptypb.Empty, error)
+	mustEmbedUnimplementedImageStorageServer()
+}
+
+// UnimplementedImageStorageServer must be embedded to have
+// forward compatible implementations.
+//
+// NOTE: this should be embedded by value instead of pointer to avoid a nil
+// pointer dereference when methods are called.
+type UnimplementedImageStorageServer struct{}
+
+func (UnimplementedImageStorageServer) UploadImage(context.Context, *UploadMerchImageRequest) (*UploadMerchImageResponse, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method UploadImage not implemented")
+}
+func (UnimplementedImageStorageServer) DeleteImage(context.Context, *DeleteImageRequest) (*emptypb.Empty, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method DeleteImage not implemented")
+}
+func (UnimplementedImageStorageServer) mustEmbedUnimplementedImageStorageServer() {}
+func (UnimplementedImageStorageServer) testEmbeddedByValue()                      {}
+
+// UnsafeImageStorageServer may be embedded to opt out of forward compatibility for this service.
+// Use of this interface is not recommended, as added methods to ImageStorageServer will
+// result in compilation errors.
+type UnsafeImageStorageServer interface {
+	mustEmbedUnimplementedImageStorageServer()
+}
+
+func RegisterImageStorageServer(s grpc.ServiceRegistrar, srv ImageStorageServer) {
+	// If the following call pancis, it indicates UnimplementedImageStorageServer was
+	// embedded by pointer and is nil.  This will cause panics if an
+	// unimplemented method is ever invoked, so we test this at initialization
+	// time to prevent it from happening at runtime later due to I/O.
+	if t, ok := srv.(interface{ testEmbeddedByValue() }); ok {
+		t.testEmbeddedByValue()
+	}
+	s.RegisterService(&ImageStorage_ServiceDesc, srv)
+}
+
+func _ImageStorage_UploadImage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+	in := new(UploadMerchImageRequest)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	if interceptor == nil {
+		return srv.(ImageStorageServer).UploadImage(ctx, in)
+	}
+	info := &grpc.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: ImageStorage_UploadImage_FullMethodName,
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		return srv.(ImageStorageServer).UploadImage(ctx, req.(*UploadMerchImageRequest))
+	}
+	return interceptor(ctx, in, info, handler)
+}
+
+func _ImageStorage_DeleteImage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+	in := new(DeleteImageRequest)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	if interceptor == nil {
+		return srv.(ImageStorageServer).DeleteImage(ctx, in)
+	}
+	info := &grpc.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: ImageStorage_DeleteImage_FullMethodName,
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		return srv.(ImageStorageServer).DeleteImage(ctx, req.(*DeleteImageRequest))
+	}
+	return interceptor(ctx, in, info, handler)
+}
+
+// ImageStorage_ServiceDesc is the grpc.ServiceDesc for ImageStorage service.
+// It's only intended for direct use with grpc.RegisterService,
+// and not to be introspected or modified (even as a copy)
+var ImageStorage_ServiceDesc = grpc.ServiceDesc{
+	ServiceName: "imageStorage.ImageStorage",
+	HandlerType: (*ImageStorageServer)(nil),
+	Methods: []grpc.MethodDesc{
+		{
+			MethodName: "UploadImage",
+			Handler:    _ImageStorage_UploadImage_Handler,
+		},
+		{
+			MethodName: "DeleteImage",
+			Handler:    _ImageStorage_DeleteImage_Handler,
+		},
+	},
+	Streams:  []grpc.StreamDesc{},
+	Metadata: "imageStorage.proto",
+}