fix

Reviewed-on: #1

.drone.yml

@@ -4,17 +4,23 @@ name: default
 
 steps:
   - name: build
-    image: golang
+    image: golang:1.22
     commands:
-      - set GOOS=linux
-      - set GOARCH=amd64
-      - set CGO_ENABLED=0
-      - go build -a -ldflags '-extldflags "-static"' -o cake_crm cmd/cake_crm/main.go
+      - CGO_ENABLED=0 GOOS=linux GOARCH=amd64 go build -o cake_crm cmd/cake_crm/main.go
 
   - name: test
-    image: golang
+    image: golang:1.22
+    environment:
+      order_bot_token:
+        from_secret: order_bot_token
+      telegram_order_chat_id:
+        from_secret: telegram_order_chat_id
+    settings:
+      envs: [ order_bot_token, telegram_order_chat_id ]
     commands:
       - go test ./...
+      - echo $${order_bot_token} >> order_bot_token.txt
+      - echo $${telegram_order_chat_id} >> telegram_order_chat_id.txt
 
   - name: scp
     image: appleboy/drone-scp
@@ -30,6 +36,10 @@ steps:
       target:
         - deploys/cake_crm
       source:
+        - resources
+        - resources/images
+        - telegram_order_chat_id.txt
+        - order_bot_token.txt
         - cake_crm
         - docker-compose.yml
         - Dockerfile
@@ -49,8 +59,11 @@ steps:
       command_timeout: 10s
       script:
         - cd deploys/cake_crm
-        - docker-compose up -d --force-recreate
+        - mv order_bot_token.txt resources
+        - mv telegram_order_chat_id.txt resources
+        - docker-compose up -d --build --force-recreate
 
 trigger:
   event:
     - push
+

.gitignore

@@ -1 +1,8 @@
 .idea
+.vscode
+.DS_Store
+
+bin
+
+resources/order_bot_token.txt
+resources/telegram_order_chat_id.txt

Dockerfile

@@ -1,5 +1,5 @@
-FROM alpine:latest
-RUN apk add --no-cache ca-certificates
+FROM golang:1.22.3-alpine3.19
 COPY cake_crm /usr/local/bin/cake_crm
+COPY resources /go/resources
 RUN chmod +x /usr/local/bin/cake_crm
-CMD ["/usr/local/bin/cake_crm"]
+CMD ["cake_crm"]

Makefile

@@ -1,13 +1,17 @@
 generate:
 	rm -rf proto
 	mkdir -p proto
-
-	protoc -I ./api \
+	protoc \
+	  -I ./api \
+	  -I ./third_party \
       --go_out ./proto --go_opt paths=source_relative \
       --go-grpc_out ./proto --go-grpc_opt paths=source_relative \
       --grpc-gateway_out ./proto --grpc-gateway_opt paths=source_relative \
-      --swagger_out=allow_merge=true,merge_file_name=main:./proto \
+      --openapiv2_out=./resources \
       ./api/main.proto
 
 run:
 	go run ./cmd/cake_crm/main.go
+
+build:
+	go build -o bin/cake_crm cmd/cake_crm/main.go

README.md

@@ -1,5 +1,7 @@
 # cake_crm
 
+Маленький магазин
+
 Генерация контракта
 
 ```shell

api/main.proto

@@ -3,8 +3,12 @@ syntax = "proto3";
 package crabs.crm;
 
 import "google/api/annotations.proto";
+import "google/api/httpbody.proto";
+import "protoc-gen-openapiv2/options/annotations.proto";
 
-option go_package = "pkg/crm";
+option go_package = "pkg/proto";
+
+option (grpc.gateway.protoc_gen_openapiv2.options.openapiv2_swagger) = {};
 
 service CRM {
   rpc GetCatalog(GetCatalogReq) returns (CatalogRsp) {
@@ -24,7 +28,29 @@ service CRM {
   }
   rpc GetBreadcrumbs(GetBreadcrumbsReq) returns (BreadcrumbsRsp) {
     option (google.api.http) = {
-      get: "/breadcrumbs/{id}"
+      get: "/products/{id}/breadcrumbs"
+    };
+  }
+  rpc Order(OrderReq) returns (OrderRsp) {
+    option (google.api.http) = {
+      post: "/orders"
+      body: "order"
+    };
+  }
+  rpc GetCart(CartReq) returns (CartRsp) {
+    option (google.api.http) = {
+      post: "/cart"
+      body: "items"
+    };
+  }
+  rpc GetImage(GetImageReq) returns (google.api.HttpBody) {
+    option (google.api.http) = {
+      get: "/images/{name}"
+    };
+  }
+  rpc Search(SearchReq) returns (PositionsRsp) {
+    option (google.api.http) = {
+      get: "/search"
     };
   }
 }
@@ -63,6 +89,7 @@ message Product {
   repeated Variant variants = 10;
   repeated Characteristic characteristics = 11;
   int64 category = 12;
+  repeated Label labels = 13;
 }
 
 message GroupedProduct {
@@ -74,6 +101,7 @@ message GroupedProduct {
 message Variant {
   int64 price = 1;
   repeated Property properties = 2;
+  bool active = 3;
 }
 
 message Property {
@@ -86,6 +114,10 @@ message Characteristic {
   string value = 2;
 }
 
+message Label {
+  string name = 1;
+}
+
 message GetProductReq {
   int64 id = 1;
 }
@@ -101,3 +133,55 @@ message GetBreadcrumbsReq {
 message BreadcrumbsRsp {
   repeated Category categories = 1;
 }
+
+message OrderReq {
+  Order order = 1;
+}
+
+message OrderRsp {}
+
+message Order {
+  string name = 2;
+  string phone = 3;
+  repeated OrderItem items = 1;
+}
+
+message OrderItem {
+  int64 product_id = 1;
+  int64 count = 2;
+}
+
+message CartItem {
+  int64 id = 1;
+  string article = 2;
+  string name = 3;
+  string uri = 4;
+  repeated string images = 5;
+  string unit = 8;
+  double inventory = 9;
+  int64 count = 10;
+  int64 amount = 11;
+  int64 amountOld = 12;
+  int64 discount = 13;
+  repeated Variant variants = 14;
+  repeated Label labels = 15;
+}
+
+message CartReq {
+  repeated OrderItem items = 1;
+}
+
+message CartRsp {
+  repeated CartItem items = 1;
+  int64 amount = 2;
+  int64 amountOld = 3;
+  int64 discount = 4;
+}
+
+message GetImageReq {
+  string name = 1;
+}
+
+message SearchReq {
+  string text = 1;
+}

api/request.http

@@ -0,0 +1,56 @@
+GET http://localhost:8090/catalog
+User-Agent: crabs/1.0.0
+
+###
+
+# prod
+GET http://cake-api.3crabs.ru/catalog
+User-Agent: crabs/1.0.0
+
+###
+
+GET http://localhost:8090/products/1
+User-Agent: crabs/1.0.0
+
+###
+
+POST http://localhost:8090/cart
+User-Agent: crabs/1.0.0
+Content-Type: application/json
+
+[
+  {
+    "product_id": 1,
+    "count": 7
+  },
+  {
+    "product_id": 20,
+    "count": 15
+  }
+]
+
+###
+
+POST http://localhost:8090/orders
+User-Agent: crabs/1.0.0
+Content-Type: application/json
+
+{
+  "name": "Иванов Иван",
+  "phone": "+7-000-000-00-00",
+  "items": [
+    {
+      "product_id": 1,
+      "count": 7
+    },
+    {
+      "product_id": 20,
+      "count": 15
+    }
+  ]
+}
+
+###
+
+GET http://localhost:8090/search?text=Лимон
+User-Agent: crabs/1.0.0

cmd/cake_crm/main.go

@@ -1,24 +1,52 @@
 package main
 
 import (
-	"cake_crm/internal/app"
-	"cake_crm/internal/models/storage/storage_file"
-	proto "cake_crm/proto"
 	"context"
-	"github.com/grpc-ecosystem/grpc-gateway/v2/runtime"
-	"google.golang.org/grpc"
-	"google.golang.org/grpc/credentials/insecure"
 	"log"
 	"net"
 	"net/http"
+	"os"
+	"strconv"
+	"strings"
+
+	"github.com/grpc-ecosystem/grpc-gateway/v2/runtime"
+	"google.golang.org/grpc"
+	"google.golang.org/grpc/credentials/insecure"
+
+	"cake_crm/internal/app"
+	"cake_crm/internal/modules/messenger/telegram"
+	"cake_crm/internal/modules/storage/storage_file"
+	"cake_crm/internal/services/cart"
+	"cake_crm/internal/services/order"
+	proto "cake_crm/proto"
 )
 
 func main() {
-	//ctx, cancel := context.WithCancel(context.Background())
-	//defer cancel()
-
 	storage := storage_file.NewStorageFile()
-	_ = storage
+
+	cartService := cart.NewService(storage)
+
+	orderService := order.NewService()
+
+	tokenData, err := os.ReadFile("resources/order_bot_token.txt")
+	if err != nil {
+		panic(err)
+	}
+	token := strings.TrimSpace(string(tokenData))
+
+	chatIdData, err := os.ReadFile("resources/telegram_order_chat_id.txt")
+	if err != nil {
+		panic(err)
+	}
+	chatID, err := strconv.ParseInt(strings.TrimSpace(string(chatIdData)), 10, 64)
+	if err != nil {
+		panic(err)
+	}
+
+	messenger, err := telegram.NewMessenger(chatID, token)
+	if err != nil {
+		panic(err)
+	}
 
 	// Create a listener on TCP port
 	lis, err := net.Listen("tcp", ":8080")
@@ -29,7 +57,7 @@ func main() {
 	// Create a gRPC server object
 	s := grpc.NewServer()
 	// Attach the Greeter service to the server
-	proto.RegisterCRMServer(s, app.NewServer(storage))
+	proto.RegisterCRMServer(s, app.NewServer(storage, messenger, cartService, orderService))
 	// Serve gRPC server
 	log.Println("Serving gRPC on 0.0.0.0:8080")
 	go func() {
@@ -46,18 +74,48 @@ func main() {
 		log.Fatalln("Failed to dial server:", err)
 	}
 
-	gwmux := runtime.NewServeMux()
+	mux := runtime.NewServeMux()
 	// Register Greeter
-	err = proto.RegisterCRMHandler(context.Background(), gwmux, conn)
+	err = proto.RegisterCRMHandler(context.Background(), mux, conn)
 	if err != nil {
 		log.Fatalln("Failed to register gateway:", err)
 	}
 
+	err = mux.HandlePath("GET", "/swagger", func(w http.ResponseWriter, r *http.Request, pathParams map[string]string) {
+		data, err := os.ReadFile("resources/main.swagger.json")
+		if err != nil {
+			w.WriteHeader(http.StatusInternalServerError)
+		}
+		_, _ = w.Write(data)
+	})
+	if err != nil {
+		panic(err)
+	}
+	log.Println("Serving swagger json on http://0.0.0.0:8090/swagger")
+
 	gwServer := &http.Server{
 		Addr:    ":8090",
-		Handler: gwmux,
+		Handler: cors(mux),
 	}
 
 	log.Println("Serving gRPC-Gateway on http://0.0.0.0:8090")
 	log.Fatalln(gwServer.ListenAndServe())
 }
+
+func cors(h http.Handler) http.Handler {
+	return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+		// ua := r.Header.Get("User-Agent")
+		// if !strings.HasPrefix(ua, "crabs") {
+		// 	w.WriteHeader(403)
+		// 	return
+		// }
+
+		w.Header().Set("Access-Control-Allow-Origin", "*")
+		w.Header().Set("Access-Control-Allow-Methods", "GET, POST, PATCH, DELETE")
+		w.Header().Set("Access-Control-Allow-Headers", "Accept, Content-Type, Content-Length, Accept-Encoding, Authorization, ResponseType")
+		if r.Method == "OPTIONS" {
+			return
+		}
+		h.ServeHTTP(w, r)
+	})
+}

docker-compose.yml

@@ -6,7 +6,5 @@ services:
       context: .
       dockerfile: Dockerfile
     ports:
-      - "8080:8080"
-#    environment:
-#      - ENV_VAR_NAME=env_var_value
+      - "8080:8090"
 

go.mod

@@ -3,8 +3,9 @@ module cake_crm
 go 1.22
 
 require (
-	github.com/go-pkgz/routegroup v1.1.1
+	github.com/go-telegram-bot-api/telegram-bot-api/v5 v5.5.1
 	github.com/grpc-ecosystem/grpc-gateway/v2 v2.20.0
+	github.com/patrickmn/go-cache v2.1.0+incompatible
 	google.golang.org/genproto/googleapis/api v0.0.0-20240513163218-0867130af1f8
 	google.golang.org/grpc v1.64.0
 	google.golang.org/protobuf v1.34.1

go.sum

@@ -1,9 +1,11 @@
-github.com/go-pkgz/routegroup v1.1.1 h1:Dm5IBiEmUbQT+3rliBimhX0SifnZp/uRF/WOu3XPmms=
-github.com/go-pkgz/routegroup v1.1.1/go.mod h1:kDDPDRLRiRY1vnENrZJw1jQAzQX7fvsbsHGRQFNQfKc=
+github.com/go-telegram-bot-api/telegram-bot-api/v5 v5.5.1 h1:wG8n/XJQ07TmjbITcGiUaOtXxdrINDz1b0J1w0SzqDc=
+github.com/go-telegram-bot-api/telegram-bot-api/v5 v5.5.1/go.mod h1:A2S0CWkNylc2phvKXWBBdD3K0iGnDBGbzRpISP2zBl8=
 github.com/google/go-cmp v0.6.0 h1:ofyhxvXcZhMsU5ulbFiLKl/XBFqE1GSq7atu8tAmTRI=
 github.com/google/go-cmp v0.6.0/go.mod h1:17dUlkBOakJ0+DkrSSNjCkIjxS6bF9zb3elmeNGIjoY=
 github.com/grpc-ecosystem/grpc-gateway/v2 v2.20.0 h1:bkypFPDjIYGfCYD5mRBvpqxfYX1YCS1PXdKYWi8FsN0=
 github.com/grpc-ecosystem/grpc-gateway/v2 v2.20.0/go.mod h1:P+Lt/0by1T8bfcF3z737NnSbmxQAppXMRziHUxPOC8k=
+github.com/patrickmn/go-cache v2.1.0+incompatible h1:HRMgzkcYKYpi3C8ajMPV8OFXaaRUnok+kx1WdO15EQc=
+github.com/patrickmn/go-cache v2.1.0+incompatible/go.mod h1:3Qf8kWWT7OJRJbdiICTKqZju1ZixQ/KpMGzzAfe6+WQ=
 golang.org/x/net v0.23.0 h1:7EYJ93RZ9vYSZAIb2x3lnuvqO5zneoD6IvWjuhfxjTs=
 golang.org/x/net v0.23.0/go.mod h1:JKghWKKOSdJwpW2GEx0Ja7fmaKnMsbu+MWVZTokSYmg=
 golang.org/x/sys v0.18.0 h1:DBdB3niSjOA/O0blCZBqDefyWNYveAYMNF1Wum0DYQ4=

internal/app/server.go

@@ -1,19 +1,36 @@
 package app
 
 import (
-	"cake_crm/internal/models/storage"
+	"cake_crm/internal/modules/messenger"
+	"cake_crm/internal/modules/storage"
+	"cake_crm/internal/services/cart"
+	"cake_crm/internal/services/order"
 	proto "cake_crm/proto"
 	"context"
+	"fmt"
+	"google.golang.org/genproto/googleapis/api/httpbody"
+	"os"
 )
 
 type Server struct {
-	proto.UnimplementedCRMServer
-	storage storage.IStorage
+	proto.UnsafeCRMServer
+	storage      storage.IStorage
+	messenger    messenger.IMessenger
+	cartService  *cart.Service
+	orderService *order.Service
 }
 
-func NewServer(storage storage.IStorage) *Server {
+func NewServer(
+	storage storage.IStorage,
+	messenger messenger.IMessenger,
+	cartService *cart.Service,
+	orderService *order.Service,
+) proto.CRMServer {
 	return &Server{
-		storage: storage,
+		storage:      storage,
+		messenger:    messenger,
+		cartService:  cartService,
+		orderService: orderService,
 	}
 }
 
@@ -48,3 +65,42 @@ func (s *Server) GetBreadcrumbs(ctx context.Context, req *proto.GetBreadcrumbsRe
 	}
 	return &proto.BreadcrumbsRsp{Categories: breadcrumbs}, nil
 }
+
+func (s *Server) Order(ctx context.Context, req *proto.OrderReq) (*proto.OrderRsp, error) {
+	enrichItems, err := s.cartService.GetCart(ctx, req.Order.Items)
+	if err != nil {
+		return nil, err
+	}
+	text, err := s.orderService.CreateOrderText(req, enrichItems)
+	if err != nil {
+		return nil, err
+	}
+	return &proto.OrderRsp{}, s.messenger.SendMessage(text)
+}
+
+func (s *Server) GetCart(ctx context.Context, req *proto.CartReq) (*proto.CartRsp, error) {
+	resp, err := s.cartService.GetCart(ctx, req.Items)
+	if err != nil {
+		return nil, err
+	}
+	return resp, nil
+}
+
+func (s *Server) GetImage(_ context.Context, req *proto.GetImageReq) (*httpbody.HttpBody, error) {
+	data, err := os.ReadFile(fmt.Sprintf("resources/images/%s", req.Name))
+	if err != nil {
+		return nil, err
+	}
+	return &httpbody.HttpBody{
+		ContentType: "image/jpeg",
+		Data:        data,
+	}, nil
+}
+
+func (s *Server) Search(ctx context.Context, req *proto.SearchReq) (*proto.PositionsRsp, error) {
+	products, err := s.storage.GetPositionsByText(ctx, req.Text)
+	if err != nil {
+		return nil, err
+	}
+	return &proto.PositionsRsp{Products: products}, nil
+}

internal/models/storage/storage_file/storage.go

@@ -1,97 +0,0 @@
-package storage_file
-
-import (
-	"cake_crm/internal/models/storage"
-	crm "cake_crm/proto"
-	"context"
-	"encoding/json"
-	"errors"
-	"os"
-)
-
-var (
-	ErrProductNotFound = errors.New("product not found")
-)
-
-type storageFile struct{}
-
-func NewStorageFile() storage.IStorage {
-	return &storageFile{}
-}
-
-func (s *storageFile) GetCatalog(_ context.Context) ([]*crm.Category, error) {
-	data, err := os.ReadFile("resources/catalog.json")
-	if err != nil {
-		return nil, err
-	}
-	var res []*crm.Category
-	if err := json.Unmarshal(data, &res); err != nil {
-		return nil, err
-	}
-	return res, nil
-}
-
-func (s *storageFile) GetPositions(_ context.Context, id int64) ([]*crm.Product, error) {
-	data, err := os.ReadFile("resources/products.json")
-	if err != nil {
-		return nil, err
-	}
-	var products []*crm.Product
-	if err := json.Unmarshal(data, &products); err != nil {
-		return nil, err
-	}
-	res := make([]*crm.Product, 0, len(products))
-	for _, product := range products {
-		if id == 0 || product.Category == id {
-			res = append(res, product)
-		}
-	}
-	return res, nil
-}
-
-func (s *storageFile) GetProduct(_ context.Context, id int64) (*crm.Product, error) {
-	data, err := os.ReadFile("resources/products.json")
-	if err != nil {
-		return nil, err
-	}
-	var products []*crm.Product
-	if err := json.Unmarshal(data, &products); err != nil {
-		return nil, err
-	}
-	for _, product := range products {
-		if product.Id == id {
-			return product, nil
-		}
-	}
-	return nil, ErrProductNotFound
-}
-
-func (s *storageFile) GetBreadcrumbs(_ context.Context, id int64) ([]*crm.Category, error) {
-	data, err := os.ReadFile("resources/catalog.json")
-	if err != nil {
-		return nil, err
-	}
-	var categories []*crm.Category
-	if err := json.Unmarshal(data, &categories); err != nil {
-		return nil, err
-	}
-	return getBreadcrumbs(categories, id), nil
-}
-
-func getBreadcrumbs(categories []*crm.Category, id int64) []*crm.Category {
-	for _, category := range categories {
-		if category.Id == id {
-			category.Children = nil
-			return []*crm.Category{category}
-		}
-		breadcrumbs := getBreadcrumbs(category.Children, id)
-		if len(breadcrumbs) != 0 {
-			res := make([]*crm.Category, 0, len(breadcrumbs)+1)
-			category.Children = nil
-			res = append(res, category)
-			res = append(res, breadcrumbs...)
-			return res
-		}
-	}
-	return nil
-}

internal/modules/messenger/interface.go

@@ -0,0 +1,5 @@
+package messenger
+
+type IMessenger interface {
+	SendMessage(message string) error
+}

internal/modules/messenger/telegram/messenger.go

@@ -0,0 +1,30 @@
+package telegram
+
+import (
+	"cake_crm/internal/modules/messenger"
+	tgbotapi "github.com/go-telegram-bot-api/telegram-bot-api/v5"
+)
+
+type messengerTelegram struct {
+	chatID int64
+	bot    *tgbotapi.BotAPI
+}
+
+func NewMessenger(
+	chatID int64,
+	token string,
+) (messenger.IMessenger, error) {
+	bot, err := tgbotapi.NewBotAPI(token)
+	if err != nil {
+		return nil, err
+	}
+	return &messengerTelegram{
+		chatID: chatID,
+		bot:    bot,
+	}, nil
+}
+
+func (m *messengerTelegram) SendMessage(message string) error {
+	_, err := m.bot.Send(tgbotapi.NewMessage(m.chatID, message))
+	return err
+}

internal/modules/storage/interface.go

@@ -10,4 +10,5 @@ type IStorage interface {
 	GetPositions(ctx context.Context, id int64) ([]*crm.Product, error)
 	GetProduct(ctx context.Context, id int64) (*crm.Product, error)
 	GetBreadcrumbs(ctx context.Context, id int64) ([]*crm.Category, error)
+	GetPositionsByText(ctx context.Context, text string) ([]*crm.Product, error)
 }

internal/modules/storage/storage_file/storage.go

@@ -0,0 +1,204 @@
+package storage_file
+
+import (
+	"cake_crm/internal/modules/storage"
+	crm "cake_crm/proto"
+	"context"
+	"encoding/json"
+	"errors"
+	"fmt"
+	"github.com/patrickmn/go-cache"
+	"os"
+	"strings"
+	"time"
+)
+
+type Product struct {
+	Id              int64                 `json:"id"`
+	Article         string                `json:"article"`
+	Name            string                `json:"name"`
+	Uri             string                `json:"uri"`
+	Images          []string              `json:"images"`
+	Description     string                `json:"description"`
+	Group           int64                 `json:"group"`
+	Unit            string                `json:"unit"`
+	Inventory       float64               `json:"inventory"`
+	Variants        []*crm.Variant        `json:"variants"`
+	Characteristics []*crm.Characteristic `json:"characteristics"`
+	Category        int64                 `json:"category"`
+	Labels          []*crm.Label          `json:"labels"`
+}
+
+var (
+	ErrProductNotFound = errors.New("product not found")
+)
+
+type storageFile struct {
+	cache *cache.Cache
+}
+
+func NewStorageFile() storage.IStorage {
+	return &storageFile{
+		cache: cache.New(24*time.Hour, time.Hour),
+	}
+}
+
+func (s *storageFile) GetCatalog(_ context.Context) ([]*crm.Category, error) {
+	data, err := s.readFile("catalog")
+	if err != nil {
+		return nil, err
+	}
+	var res []*crm.Category
+	if err := json.Unmarshal(data, &res); err != nil {
+		return nil, err
+	}
+	return res, nil
+}
+
+func (s *storageFile) GetPositions(_ context.Context, id int64) ([]*crm.Product, error) {
+	data, err := s.readFile("products")
+	if err != nil {
+		return nil, err
+	}
+	var products []*crm.Product
+	if err := json.Unmarshal(data, &products); err != nil {
+		return nil, err
+	}
+	res := make([]*crm.Product, 0, len(products))
+	for _, product := range products {
+		if id == 0 || product.Category == id {
+			s.enrichedProduct(product)
+			res = append(res, product)
+		}
+	}
+	return res, nil
+}
+
+func (s *storageFile) GetProduct(_ context.Context, id int64) (*crm.Product, error) {
+	data, err := s.readFile("products")
+	if err != nil {
+		return nil, err
+	}
+	var products []*Product
+	if err := json.Unmarshal(data, &products); err != nil {
+		return nil, err
+	}
+	var product *Product
+	for _, p := range products {
+		if p.Id == id {
+			product = p
+			break
+		}
+	}
+	if product == nil {
+		return nil, ErrProductNotFound
+	}
+	res := &crm.Product{
+		Id:              product.Id,
+		Article:         product.Article,
+		Name:            product.Name,
+		Uri:             product.Uri,
+		Images:          product.Images,
+		Description:     product.Description,
+		GroupedProducts: nil,
+		Unit:            product.Unit,
+		Inventory:       product.Inventory,
+		Variants:        product.Variants,
+		Characteristics: product.Characteristics,
+		Category:        product.Category,
+		Labels:          product.Labels,
+	}
+	s.enrichedProduct(res)
+	for _, p := range products {
+		if p.Group == product.Group {
+			image := ""
+			if len(product.Images) > 0 {
+				image = p.Images[0]
+			}
+			res.GroupedProducts = append(res.GroupedProducts, &crm.GroupedProduct{
+				Name:  p.Name,
+				Uri:   p.Uri,
+				Image: image,
+			})
+		}
+	}
+	return res, nil
+}
+
+func (s *storageFile) GetBreadcrumbs(ctx context.Context, id int64) ([]*crm.Category, error) {
+	product, err := s.GetProduct(ctx, id)
+	if err != nil {
+		return nil, err
+	}
+	data, err := s.readFile("catalog")
+	if err != nil {
+		return nil, err
+	}
+	var categories []*crm.Category
+	if err := json.Unmarshal(data, &categories); err != nil {
+		return nil, err
+	}
+	breadcrumbs := getBreadcrumbs(categories, product.Id)
+	breadcrumbs = append(breadcrumbs, &crm.Category{
+		Name: product.Name,
+	})
+	return breadcrumbs, nil
+}
+
+func (s *storageFile) enrichedProduct(product *crm.Product) {
+	if len(product.Variants) > 1 {
+		product.Labels = append(product.Labels, &crm.Label{Name: "Оптом дешевле"})
+	}
+}
+
+func getBreadcrumbs(categories []*crm.Category, id int64) []*crm.Category {
+	for _, category := range categories {
+		if category.Id == id {
+			category.Children = nil
+			return []*crm.Category{category}
+		}
+		breadcrumbs := getBreadcrumbs(category.Children, id)
+		if len(breadcrumbs) != 0 {
+			res := make([]*crm.Category, 0, len(breadcrumbs)+1)
+			category.Children = nil
+			res = append(res, category)
+			res = append(res, breadcrumbs...)
+			return res
+		}
+	}
+	return nil
+}
+
+func (s *storageFile) GetPositionsByText(_ context.Context, text string) ([]*crm.Product, error) {
+	data, err := s.readFile("products")
+	if err != nil {
+		return nil, err
+	}
+	var products []*crm.Product
+	if err := json.Unmarshal(data, &products); err != nil {
+		return nil, err
+	}
+	res := make([]*crm.Product, 0, len(products))
+	searchText := strings.TrimSpace(strings.ToLower(text))
+	for _, product := range products {
+		name := strings.ToLower(product.Name)
+		if strings.Contains(name, searchText) {
+			s.enrichedProduct(product)
+			res = append(res, product)
+		}
+	}
+	return res, nil
+}
+
+func (s *storageFile) readFile(name string) ([]byte, error) {
+	cacheData, found := s.cache.Get(name)
+	if found {
+		return cacheData.([]byte), nil
+	}
+	data, err := os.ReadFile(fmt.Sprintf("resources/%s.json", name))
+	if err != nil {
+		return nil, err
+	}
+	s.cache.Set(name, data, cache.DefaultExpiration)
+	return data, nil
+}

internal/services/cart/cart.go

@@ -0,0 +1,109 @@
+package cart
+
+import (
+	"context"
+	"errors"
+	"strconv"
+
+	"cake_crm/internal/modules/storage"
+	"cake_crm/proto"
+)
+
+type ProductAndCount struct {
+	product *proto.Product
+	count   int64
+}
+
+type Service struct {
+	storage storage.IStorage
+}
+
+func NewService(storage storage.IStorage) *Service {
+	return &Service{
+		storage: storage,
+	}
+}
+
+func (s *Service) GetCart(ctx context.Context, items []*proto.OrderItem) (*proto.CartRsp, error) {
+	var cartAmount int64
+	var cartAmountOld int64
+	res := make([]*proto.CartItem, 0, len(items))
+	for _, item := range items {
+		product, err := s.storage.GetProduct(ctx, item.ProductId)
+		if err != nil {
+			return nil, err
+		}
+		amount, amountOld, err := calcItemAmount(
+			&ProductAndCount{
+				product: product,
+				count:   item.Count,
+			},
+		)
+		if err != nil {
+			return nil, err
+		}
+		res = append(
+			res,
+			&proto.CartItem{
+				Id:        product.Id,
+				Article:   product.Article,
+				Name:      product.Name,
+				Uri:       product.Uri,
+				Images:    product.Images,
+				Unit:      product.Unit,
+				Inventory: product.Inventory,
+				Count:     item.Count,
+				Amount:    amount,
+				AmountOld: amountOld,
+				Discount:  amountOld - amount,
+				Variants:  product.Variants,
+				Labels:    product.Labels,
+			},
+		)
+		cartAmount += amount
+		cartAmountOld += amountOld
+	}
+	return &proto.CartRsp{
+		Items:     res,
+		Amount:    cartAmount,
+		AmountOld: cartAmountOld,
+		Discount:  cartAmountOld - cartAmount,
+	}, nil
+}
+
+func calcItemAmount(item *ProductAndCount) (int64, int64, error) {
+	variantOld := item.product.Variants[0]
+	var variant *proto.Variant
+	for _, v := range item.product.Variants {
+		check := true
+		for _, property := range v.Properties {
+			if property.Name == "min" {
+				minBorder, err := strconv.ParseInt(property.Value, 10, 64)
+				if err != nil {
+					return 0, 0, err
+				}
+				if item.count < minBorder {
+					check = false
+				}
+			}
+			if property.Name == "max" {
+				maxBorder, err := strconv.ParseInt(property.Value, 10, 64)
+				if err != nil {
+					return 0, 0, err
+				}
+				if item.count > maxBorder {
+					check = false
+				}
+			}
+			if check {
+				variant = v
+				break
+			}
+		}
+	}
+	variant.Active = true
+	if variant == nil {
+		return 0, 0, errors.New("variant not found")
+	}
+	return variant.Price * item.count, variantOld.Price * item.count, nil
+}

internal/services/order/order.go

@@ -0,0 +1,44 @@
+package order
+
+import (
+	"bytes"
+	"cake_crm/proto"
+	"errors"
+	"fmt"
+)
+
+type Service struct{}
+
+func NewService() *Service {
+	return &Service{}
+}
+
+func (s *Service) CreateOrderText(req *proto.OrderReq, cart *proto.CartRsp) (string, error) {
+	buffer := bytes.Buffer{}
+	buffer.WriteString(fmt.Sprintf("Заказ от:\n%s\n%s\n", req.Order.Name, req.Order.Phone))
+	buffer.WriteString("\n")
+	for _, item := range cart.Items {
+		buffer.WriteString(item.Name)
+		buffer.WriteString("\n")
+		unit, err := unitToText(item.Unit)
+		if err != nil {
+			return "", err
+		}
+		buffer.WriteString(fmt.Sprintf("Количество: %d%s\n", item.Count, unit))
+		buffer.WriteString(fmt.Sprintf("Сумма: %.00fр\n", float64(item.Amount)/100))
+		buffer.WriteString("\n")
+	}
+	buffer.WriteString("\n")
+	buffer.WriteString(fmt.Sprintf("ИТОГО: %.00fр\n", float64(cart.Amount)/100))
+	return buffer.String(), nil
+}
+
+func unitToText(unit string) (string, error) {
+	switch unit {
+	case "kg":
+		return "кг", nil
+	case "piece":
+		return "шт", nil
+	}
+	return "", errors.New("unit not found")
+}

internal/services/server_web/interface.go

@@ -1,8 +0,0 @@
-package server_web
-
-import "context"
-
-type IServer interface {
-	Run(ctx context.Context) error
-	Stop(ctx context.Context) error
-}

internal/services/server_web/server.go

@@ -1,43 +0,0 @@
-package server_web
-
-import (
-	"cake_crm/internal/models/storage"
-	"context"
-	"fmt"
-	"github.com/go-pkgz/routegroup"
-	"net/http"
-)
-
-type server struct {
-	storage storage.IStorage
-	port    int
-}
-
-func NewServer(
-	storage storage.IStorage,
-	port int,
-) IServer {
-	return &server{
-		storage: storage,
-		port:    port,
-	}
-}
-
-func (s *server) Run(ctx context.Context) error {
-	router := routegroup.New(http.NewServeMux())
-	router.HandleFunc("GET /products", s.getAllProductsHandler)
-	router.HandleFunc("GET /products/:id", s.getProductById)
-	router.HandleFunc("GET /category/:id/breadcrumbs", s.getBreadcrumbsByCategoryId)
-	return http.ListenAndServe(fmt.Sprintf(":%d", s.port), router)
-}
-
-func (s *server) Stop(ctx context.Context) error {
-	//TODO implement me
-	panic("implement me")
-}
-
-func (s *server) getAllProductsHandler(w http.ResponseWriter, r *http.Request) {}
-
-func (s *server) getProductById(w http.ResponseWriter, r *http.Request) {}
-
-func (s *server) getBreadcrumbsByCategoryId(w http.ResponseWriter, r *http.Request) {}

proto/main.pb.gw.go

@@ -2,11 +2,11 @@
 // source: main.proto
 
 /*
-Package crm is a reverse proxy.
+Package proto is a reverse proxy.
 
 It translates gRPC into RESTful JSON APIs.
 */
-package crm
+package proto
 
 import (
 	"context"
@@ -205,6 +205,146 @@ func local_request_CRM_GetBreadcrumbs_0(ctx context.Context, marshaler runtime.M
 
 }
 
+func request_CRM_Order_0(ctx context.Context, marshaler runtime.Marshaler, client CRMClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
+	var protoReq OrderReq
+	var metadata runtime.ServerMetadata
+
+	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq.Order); err != nil && err != io.EOF {
+		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
+	}
+
+	msg, err := client.Order(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
+	return msg, metadata, err
+
+}
+
+func local_request_CRM_Order_0(ctx context.Context, marshaler runtime.Marshaler, server CRMServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
+	var protoReq OrderReq
+	var metadata runtime.ServerMetadata
+
+	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq.Order); err != nil && err != io.EOF {
+		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
+	}
+
+	msg, err := server.Order(ctx, &protoReq)
+	return msg, metadata, err
+
+}
+
+func request_CRM_GetCart_0(ctx context.Context, marshaler runtime.Marshaler, client CRMClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
+	var protoReq CartReq
+	var metadata runtime.ServerMetadata
+
+	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq.Items); err != nil && err != io.EOF {
+		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
+	}
+
+	msg, err := client.GetCart(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
+	return msg, metadata, err
+
+}
+
+func local_request_CRM_GetCart_0(ctx context.Context, marshaler runtime.Marshaler, server CRMServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
+	var protoReq CartReq
+	var metadata runtime.ServerMetadata
+
+	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq.Items); err != nil && err != io.EOF {
+		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
+	}
+
+	msg, err := server.GetCart(ctx, &protoReq)
+	return msg, metadata, err
+
+}
+
+func request_CRM_GetImage_0(ctx context.Context, marshaler runtime.Marshaler, client CRMClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
+	var protoReq GetImageReq
+	var metadata runtime.ServerMetadata
+
+	var (
+		val string
+		ok  bool
+		err error
+		_   = err
+	)
+
+	val, ok = pathParams["name"]
+	if !ok {
+		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "name")
+	}
+
+	protoReq.Name, err = runtime.String(val)
+	if err != nil {
+		return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "name", err)
+	}
+
+	msg, err := client.GetImage(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
+	return msg, metadata, err
+
+}
+
+func local_request_CRM_GetImage_0(ctx context.Context, marshaler runtime.Marshaler, server CRMServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
+	var protoReq GetImageReq
+	var metadata runtime.ServerMetadata
+
+	var (
+		val string
+		ok  bool
+		err error
+		_   = err
+	)
+
+	val, ok = pathParams["name"]
+	if !ok {
+		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "name")
+	}
+
+	protoReq.Name, err = runtime.String(val)
+	if err != nil {
+		return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "name", err)
+	}
+
+	msg, err := server.GetImage(ctx, &protoReq)
+	return msg, metadata, err
+
+}
+
+var (
+	filter_CRM_Search_0 = &utilities.DoubleArray{Encoding: map[string]int{}, Base: []int(nil), Check: []int(nil)}
+)
+
+func request_CRM_Search_0(ctx context.Context, marshaler runtime.Marshaler, client CRMClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
+	var protoReq SearchReq
+	var metadata runtime.ServerMetadata
+
+	if err := req.ParseForm(); err != nil {
+		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
+	}
+	if err := runtime.PopulateQueryParameters(&protoReq, req.Form, filter_CRM_Search_0); err != nil {
+		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
+	}
+
+	msg, err := client.Search(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
+	return msg, metadata, err
+
+}
+
+func local_request_CRM_Search_0(ctx context.Context, marshaler runtime.Marshaler, server CRMServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
+	var protoReq SearchReq
+	var metadata runtime.ServerMetadata
+
+	if err := req.ParseForm(); err != nil {
+		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
+	}
+	if err := runtime.PopulateQueryParameters(&protoReq, req.Form, filter_CRM_Search_0); err != nil {
+		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
+	}
+
+	msg, err := server.Search(ctx, &protoReq)
+	return msg, metadata, err
+
+}
+
 // RegisterCRMHandlerServer registers the http handlers for service CRM to "mux".
 // UnaryRPC     :call CRMServer directly.
 // StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.
@@ -294,7 +434,7 @@ func RegisterCRMHandlerServer(ctx context.Context, mux *runtime.ServeMux, server
 		inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
 		var err error
 		var annotatedContext context.Context
-		annotatedContext, err = runtime.AnnotateIncomingContext(ctx, mux, req, "/crabs.crm.CRM/GetBreadcrumbs", runtime.WithHTTPPathPattern("/breadcrumbs/{id}"))
+		annotatedContext, err = runtime.AnnotateIncomingContext(ctx, mux, req, "/crabs.crm.CRM/GetBreadcrumbs", runtime.WithHTTPPathPattern("/products/{id}/breadcrumbs"))
 		if err != nil {
 			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
 			return
@@ -311,6 +451,106 @@ func RegisterCRMHandlerServer(ctx context.Context, mux *runtime.ServeMux, server
 
 	})
 
+	mux.Handle("POST", pattern_CRM_Order_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
+		ctx, cancel := context.WithCancel(req.Context())
+		defer cancel()
+		var stream runtime.ServerTransportStream
+		ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
+		inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
+		var err error
+		var annotatedContext context.Context
+		annotatedContext, err = runtime.AnnotateIncomingContext(ctx, mux, req, "/crabs.crm.CRM/Order", runtime.WithHTTPPathPattern("/orders"))
+		if err != nil {
+			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
+			return
+		}
+		resp, md, err := local_request_CRM_Order_0(annotatedContext, inboundMarshaler, server, req, pathParams)
+		md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
+		annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
+		if err != nil {
+			runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
+			return
+		}
+
+		forward_CRM_Order_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
+
+	})
+
+	mux.Handle("POST", pattern_CRM_GetCart_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
+		ctx, cancel := context.WithCancel(req.Context())
+		defer cancel()
+		var stream runtime.ServerTransportStream
+		ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
+		inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
+		var err error
+		var annotatedContext context.Context
+		annotatedContext, err = runtime.AnnotateIncomingContext(ctx, mux, req, "/crabs.crm.CRM/GetCart", runtime.WithHTTPPathPattern("/cart"))
+		if err != nil {
+			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
+			return
+		}
+		resp, md, err := local_request_CRM_GetCart_0(annotatedContext, inboundMarshaler, server, req, pathParams)
+		md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
+		annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
+		if err != nil {
+			runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
+			return
+		}
+
+		forward_CRM_GetCart_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
+
+	})
+
+	mux.Handle("GET", pattern_CRM_GetImage_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
+		ctx, cancel := context.WithCancel(req.Context())
+		defer cancel()
+		var stream runtime.ServerTransportStream
+		ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
+		inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
+		var err error
+		var annotatedContext context.Context
+		annotatedContext, err = runtime.AnnotateIncomingContext(ctx, mux, req, "/crabs.crm.CRM/GetImage", runtime.WithHTTPPathPattern("/images/{name}"))
+		if err != nil {
+			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
+			return
+		}
+		resp, md, err := local_request_CRM_GetImage_0(annotatedContext, inboundMarshaler, server, req, pathParams)
+		md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
+		annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
+		if err != nil {
+			runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
+			return
+		}
+
+		forward_CRM_GetImage_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
+
+	})
+
+	mux.Handle("GET", pattern_CRM_Search_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
+		ctx, cancel := context.WithCancel(req.Context())
+		defer cancel()
+		var stream runtime.ServerTransportStream
+		ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
+		inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
+		var err error
+		var annotatedContext context.Context
+		annotatedContext, err = runtime.AnnotateIncomingContext(ctx, mux, req, "/crabs.crm.CRM/Search", runtime.WithHTTPPathPattern("/search"))
+		if err != nil {
+			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
+			return
+		}
+		resp, md, err := local_request_CRM_Search_0(annotatedContext, inboundMarshaler, server, req, pathParams)
+		md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
+		annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
+		if err != nil {
+			runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
+			return
+		}
+
+		forward_CRM_Search_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
+
+	})
+
 	return nil
 }
 
@@ -424,7 +664,7 @@ func RegisterCRMHandlerClient(ctx context.Context, mux *runtime.ServeMux, client
 		inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
 		var err error
 		var annotatedContext context.Context
-		annotatedContext, err = runtime.AnnotateContext(ctx, mux, req, "/crabs.crm.CRM/GetBreadcrumbs", runtime.WithHTTPPathPattern("/breadcrumbs/{id}"))
+		annotatedContext, err = runtime.AnnotateContext(ctx, mux, req, "/crabs.crm.CRM/GetBreadcrumbs", runtime.WithHTTPPathPattern("/products/{id}/breadcrumbs"))
 		if err != nil {
 			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
 			return
@@ -440,6 +680,94 @@ func RegisterCRMHandlerClient(ctx context.Context, mux *runtime.ServeMux, client
 
 	})
 
+	mux.Handle("POST", pattern_CRM_Order_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
+		ctx, cancel := context.WithCancel(req.Context())
+		defer cancel()
+		inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
+		var err error
+		var annotatedContext context.Context
+		annotatedContext, err = runtime.AnnotateContext(ctx, mux, req, "/crabs.crm.CRM/Order", runtime.WithHTTPPathPattern("/orders"))
+		if err != nil {
+			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
+			return
+		}
+		resp, md, err := request_CRM_Order_0(annotatedContext, inboundMarshaler, client, req, pathParams)
+		annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
+		if err != nil {
+			runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
+			return
+		}
+
+		forward_CRM_Order_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
+
+	})
+
+	mux.Handle("POST", pattern_CRM_GetCart_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
+		ctx, cancel := context.WithCancel(req.Context())
+		defer cancel()
+		inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
+		var err error
+		var annotatedContext context.Context
+		annotatedContext, err = runtime.AnnotateContext(ctx, mux, req, "/crabs.crm.CRM/GetCart", runtime.WithHTTPPathPattern("/cart"))
+		if err != nil {
+			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
+			return
+		}
+		resp, md, err := request_CRM_GetCart_0(annotatedContext, inboundMarshaler, client, req, pathParams)
+		annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
+		if err != nil {
+			runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
+			return
+		}
+
+		forward_CRM_GetCart_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
+
+	})
+
+	mux.Handle("GET", pattern_CRM_GetImage_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
+		ctx, cancel := context.WithCancel(req.Context())
+		defer cancel()
+		inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
+		var err error
+		var annotatedContext context.Context
+		annotatedContext, err = runtime.AnnotateContext(ctx, mux, req, "/crabs.crm.CRM/GetImage", runtime.WithHTTPPathPattern("/images/{name}"))
+		if err != nil {
+			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
+			return
+		}
+		resp, md, err := request_CRM_GetImage_0(annotatedContext, inboundMarshaler, client, req, pathParams)
+		annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
+		if err != nil {
+			runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
+			return
+		}
+
+		forward_CRM_GetImage_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
+
+	})
+
+	mux.Handle("GET", pattern_CRM_Search_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
+		ctx, cancel := context.WithCancel(req.Context())
+		defer cancel()
+		inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
+		var err error
+		var annotatedContext context.Context
+		annotatedContext, err = runtime.AnnotateContext(ctx, mux, req, "/crabs.crm.CRM/Search", runtime.WithHTTPPathPattern("/search"))
+		if err != nil {
+			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
+			return
+		}
+		resp, md, err := request_CRM_Search_0(annotatedContext, inboundMarshaler, client, req, pathParams)
+		annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
+		if err != nil {
+			runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
+			return
+		}
+
+		forward_CRM_Search_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
+
+	})
+
 	return nil
 }
 
@@ -450,7 +778,15 @@ var (
 
 	pattern_CRM_GetProduct_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 1, 0, 4, 1, 5, 1}, []string{"products", "id"}, ""))
 
-	pattern_CRM_GetBreadcrumbs_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 1, 0, 4, 1, 5, 1}, []string{"breadcrumbs", "id"}, ""))
+	pattern_CRM_GetBreadcrumbs_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 1, 0, 4, 1, 5, 1, 2, 2}, []string{"products", "id", "breadcrumbs"}, ""))
+
+	pattern_CRM_Order_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0}, []string{"orders"}, ""))
+
+	pattern_CRM_GetCart_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0}, []string{"cart"}, ""))
+
+	pattern_CRM_GetImage_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 1, 0, 4, 1, 5, 1}, []string{"images", "name"}, ""))
+
+	pattern_CRM_Search_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0}, []string{"search"}, ""))
 )
 
 var (
@@ -461,4 +797,12 @@ var (
 	forward_CRM_GetProduct_0 = runtime.ForwardResponseMessage
 
 	forward_CRM_GetBreadcrumbs_0 = runtime.ForwardResponseMessage
+
+	forward_CRM_Order_0 = runtime.ForwardResponseMessage
+
+	forward_CRM_GetCart_0 = runtime.ForwardResponseMessage
+
+	forward_CRM_GetImage_0 = runtime.ForwardResponseMessage
+
+	forward_CRM_Search_0 = runtime.ForwardResponseMessage
 )

proto/main.swagger.json

@@ -1,334 +0,0 @@
-{
-  "swagger": "2.0",
-  "info": {
-    "title": "main.proto",
-    "version": "version not set"
-  },
-  "consumes": [
-    "application/json"
-  ],
-  "produces": [
-    "application/json"
-  ],
-  "paths": {
-    "/breadcrumbs/{id}": {
-      "get": {
-        "operationId": "CRM_GetBreadcrumbs",
-        "responses": {
-          "200": {
-            "description": "A successful response.",
-            "schema": {
-              "$ref": "#/definitions/crmBreadcrumbsRsp"
-            }
-          },
-          "default": {
-            "description": "An unexpected error response.",
-            "schema": {
-              "$ref": "#/definitions/runtimeError"
-            }
-          }
-        },
-        "parameters": [
-          {
-            "name": "id",
-            "in": "path",
-            "required": true,
-            "type": "string",
-            "format": "int64"
-          }
-        ],
-        "tags": [
-          "CRM"
-        ]
-      }
-    },
-    "/catalog": {
-      "get": {
-        "operationId": "CRM_GetCatalog",
-        "responses": {
-          "200": {
-            "description": "A successful response.",
-            "schema": {
-              "$ref": "#/definitions/crmCatalogRsp"
-            }
-          },
-          "default": {
-            "description": "An unexpected error response.",
-            "schema": {
-              "$ref": "#/definitions/runtimeError"
-            }
-          }
-        },
-        "tags": [
-          "CRM"
-        ]
-      }
-    },
-    "/positions/{id}": {
-      "get": {
-        "operationId": "CRM_GetPositions",
-        "responses": {
-          "200": {
-            "description": "A successful response.",
-            "schema": {
-              "$ref": "#/definitions/crmPositionsRsp"
-            }
-          },
-          "default": {
-            "description": "An unexpected error response.",
-            "schema": {
-              "$ref": "#/definitions/runtimeError"
-            }
-          }
-        },
-        "parameters": [
-          {
-            "name": "id",
-            "in": "path",
-            "required": true,
-            "type": "string",
-            "format": "int64"
-          }
-        ],
-        "tags": [
-          "CRM"
-        ]
-      }
-    },
-    "/products/{id}": {
-      "get": {
-        "operationId": "CRM_GetProduct",
-        "responses": {
-          "200": {
-            "description": "A successful response.",
-            "schema": {
-              "$ref": "#/definitions/crmProductRsp"
-            }
-          },
-          "default": {
-            "description": "An unexpected error response.",
-            "schema": {
-              "$ref": "#/definitions/runtimeError"
-            }
-          }
-        },
-        "parameters": [
-          {
-            "name": "id",
-            "in": "path",
-            "required": true,
-            "type": "string",
-            "format": "int64"
-          }
-        ],
-        "tags": [
-          "CRM"
-        ]
-      }
-    }
-  },
-  "definitions": {
-    "crmBreadcrumbsRsp": {
-      "type": "object",
-      "properties": {
-        "categories": {
-          "type": "array",
-          "items": {
-            "$ref": "#/definitions/crmCategory"
-          }
-        }
-      }
-    },
-    "crmCatalogRsp": {
-      "type": "object",
-      "properties": {
-        "categories": {
-          "type": "array",
-          "items": {
-            "$ref": "#/definitions/crmCategory"
-          }
-        }
-      }
-    },
-    "crmCategory": {
-      "type": "object",
-      "properties": {
-        "id": {
-          "type": "string",
-          "format": "int64"
-        },
-        "name": {
-          "type": "string"
-        },
-        "uri": {
-          "type": "string"
-        },
-        "children": {
-          "type": "array",
-          "items": {
-            "$ref": "#/definitions/crmCategory"
-          }
-        }
-      }
-    },
-    "crmCharacteristic": {
-      "type": "object",
-      "properties": {
-        "name": {
-          "type": "string"
-        },
-        "value": {
-          "type": "string"
-        }
-      }
-    },
-    "crmGroupedProduct": {
-      "type": "object",
-      "properties": {
-        "name": {
-          "type": "string"
-        },
-        "uri": {
-          "type": "string"
-        },
-        "image": {
-          "type": "string"
-        }
-      }
-    },
-    "crmPositionsRsp": {
-      "type": "object",
-      "properties": {
-        "products": {
-          "type": "array",
-          "items": {
-            "$ref": "#/definitions/crmProduct"
-          }
-        }
-      }
-    },
-    "crmProduct": {
-      "type": "object",
-      "properties": {
-        "id": {
-          "type": "string",
-          "format": "int64"
-        },
-        "article": {
-          "type": "string"
-        },
-        "name": {
-          "type": "string"
-        },
-        "uri": {
-          "type": "string"
-        },
-        "images": {
-          "type": "array",
-          "items": {
-            "type": "string"
-          }
-        },
-        "description": {
-          "type": "string"
-        },
-        "grouped_products": {
-          "type": "array",
-          "items": {
-            "$ref": "#/definitions/crmGroupedProduct"
-          }
-        },
-        "unit": {
-          "type": "string"
-        },
-        "inventory": {
-          "type": "number",
-          "format": "double"
-        },
-        "variants": {
-          "type": "array",
-          "items": {
-            "$ref": "#/definitions/crmVariant"
-          }
-        },
-        "characteristics": {
-          "type": "array",
-          "items": {
-            "$ref": "#/definitions/crmCharacteristic"
-          }
-        },
-        "category": {
-          "type": "string",
-          "format": "int64"
-        }
-      }
-    },
-    "crmProductRsp": {
-      "type": "object",
-      "properties": {
-        "product": {
-          "$ref": "#/definitions/crmProduct"
-        }
-      }
-    },
-    "crmProperty": {
-      "type": "object",
-      "properties": {
-        "name": {
-          "type": "string"
-        },
-        "value": {
-          "type": "string"
-        }
-      }
-    },
-    "crmVariant": {
-      "type": "object",
-      "properties": {
-        "price": {
-          "type": "string",
-          "format": "int64"
-        },
-        "properties": {
-          "type": "array",
-          "items": {
-            "$ref": "#/definitions/crmProperty"
-          }
-        }
-      }
-    },
-    "protobufAny": {
-      "type": "object",
-      "properties": {
-        "type_url": {
-          "type": "string"
-        },
-        "value": {
-          "type": "string",
-          "format": "byte"
-        }
-      }
-    },
-    "runtimeError": {
-      "type": "object",
-      "properties": {
-        "error": {
-          "type": "string"
-        },
-        "code": {
-          "type": "integer",
-          "format": "int32"
-        },
-        "message": {
-          "type": "string"
-        },
-        "details": {
-          "type": "array",
-          "items": {
-            "$ref": "#/definitions/protobufAny"
-          }
-        }
-      }
-    }
-  }
-}

proto/main_grpc.pb.go

@@ -4,10 +4,11 @@
 // - protoc             v5.26.1
 // source: main.proto
 
-package crm
+package proto
 
 import (
 	context "context"
+	httpbody "google.golang.org/genproto/googleapis/api/httpbody"
 	grpc "google.golang.org/grpc"
 	codes "google.golang.org/grpc/codes"
 	status "google.golang.org/grpc/status"
@@ -23,6 +24,10 @@ const (
 	CRM_GetPositions_FullMethodName   = "/crabs.crm.CRM/GetPositions"
 	CRM_GetProduct_FullMethodName     = "/crabs.crm.CRM/GetProduct"
 	CRM_GetBreadcrumbs_FullMethodName = "/crabs.crm.CRM/GetBreadcrumbs"
+	CRM_Order_FullMethodName          = "/crabs.crm.CRM/Order"
+	CRM_GetCart_FullMethodName        = "/crabs.crm.CRM/GetCart"
+	CRM_GetImage_FullMethodName       = "/crabs.crm.CRM/GetImage"
+	CRM_Search_FullMethodName         = "/crabs.crm.CRM/Search"
 )
 
 // CRMClient is the client API for CRM service.
@@ -33,6 +38,10 @@ type CRMClient interface {
 	GetPositions(ctx context.Context, in *GetPositionsReq, opts ...grpc.CallOption) (*PositionsRsp, error)
 	GetProduct(ctx context.Context, in *GetProductReq, opts ...grpc.CallOption) (*ProductRsp, error)
 	GetBreadcrumbs(ctx context.Context, in *GetBreadcrumbsReq, opts ...grpc.CallOption) (*BreadcrumbsRsp, error)
+	Order(ctx context.Context, in *OrderReq, opts ...grpc.CallOption) (*OrderRsp, error)
+	GetCart(ctx context.Context, in *CartReq, opts ...grpc.CallOption) (*CartRsp, error)
+	GetImage(ctx context.Context, in *GetImageReq, opts ...grpc.CallOption) (*httpbody.HttpBody, error)
+	Search(ctx context.Context, in *SearchReq, opts ...grpc.CallOption) (*PositionsRsp, error)
 }
 
 type cRMClient struct {
@@ -79,6 +88,42 @@ func (c *cRMClient) GetBreadcrumbs(ctx context.Context, in *GetBreadcrumbsReq, o
 	return out, nil
 }
 
+func (c *cRMClient) Order(ctx context.Context, in *OrderReq, opts ...grpc.CallOption) (*OrderRsp, error) {
+	out := new(OrderRsp)
+	err := c.cc.Invoke(ctx, CRM_Order_FullMethodName, in, out, opts...)
+	if err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (c *cRMClient) GetCart(ctx context.Context, in *CartReq, opts ...grpc.CallOption) (*CartRsp, error) {
+	out := new(CartRsp)
+	err := c.cc.Invoke(ctx, CRM_GetCart_FullMethodName, in, out, opts...)
+	if err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (c *cRMClient) GetImage(ctx context.Context, in *GetImageReq, opts ...grpc.CallOption) (*httpbody.HttpBody, error) {
+	out := new(httpbody.HttpBody)
+	err := c.cc.Invoke(ctx, CRM_GetImage_FullMethodName, in, out, opts...)
+	if err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (c *cRMClient) Search(ctx context.Context, in *SearchReq, opts ...grpc.CallOption) (*PositionsRsp, error) {
+	out := new(PositionsRsp)
+	err := c.cc.Invoke(ctx, CRM_Search_FullMethodName, in, out, opts...)
+	if err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
 // CRMServer is the server API for CRM service.
 // All implementations must embed UnimplementedCRMServer
 // for forward compatibility
@@ -87,6 +132,10 @@ type CRMServer interface {
 	GetPositions(context.Context, *GetPositionsReq) (*PositionsRsp, error)
 	GetProduct(context.Context, *GetProductReq) (*ProductRsp, error)
 	GetBreadcrumbs(context.Context, *GetBreadcrumbsReq) (*BreadcrumbsRsp, error)
+	Order(context.Context, *OrderReq) (*OrderRsp, error)
+	GetCart(context.Context, *CartReq) (*CartRsp, error)
+	GetImage(context.Context, *GetImageReq) (*httpbody.HttpBody, error)
+	Search(context.Context, *SearchReq) (*PositionsRsp, error)
 	mustEmbedUnimplementedCRMServer()
 }
 
@@ -106,6 +155,18 @@ func (UnimplementedCRMServer) GetProduct(context.Context, *GetProductReq) (*Prod
 func (UnimplementedCRMServer) GetBreadcrumbs(context.Context, *GetBreadcrumbsReq) (*BreadcrumbsRsp, error) {
 	return nil, status.Errorf(codes.Unimplemented, "method GetBreadcrumbs not implemented")
 }
+func (UnimplementedCRMServer) Order(context.Context, *OrderReq) (*OrderRsp, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method Order not implemented")
+}
+func (UnimplementedCRMServer) GetCart(context.Context, *CartReq) (*CartRsp, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method GetCart not implemented")
+}
+func (UnimplementedCRMServer) GetImage(context.Context, *GetImageReq) (*httpbody.HttpBody, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method GetImage not implemented")
+}
+func (UnimplementedCRMServer) Search(context.Context, *SearchReq) (*PositionsRsp, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method Search not implemented")
+}
 func (UnimplementedCRMServer) mustEmbedUnimplementedCRMServer() {}
 
 // UnsafeCRMServer may be embedded to opt out of forward compatibility for this service.
@@ -191,6 +252,78 @@ func _CRM_GetBreadcrumbs_Handler(srv interface{}, ctx context.Context, dec func(
 	return interceptor(ctx, in, info, handler)
 }
 
+func _CRM_Order_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+	in := new(OrderReq)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	if interceptor == nil {
+		return srv.(CRMServer).Order(ctx, in)
+	}
+	info := &grpc.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: CRM_Order_FullMethodName,
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		return srv.(CRMServer).Order(ctx, req.(*OrderReq))
+	}
+	return interceptor(ctx, in, info, handler)
+}
+
+func _CRM_GetCart_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+	in := new(CartReq)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	if interceptor == nil {
+		return srv.(CRMServer).GetCart(ctx, in)
+	}
+	info := &grpc.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: CRM_GetCart_FullMethodName,
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		return srv.(CRMServer).GetCart(ctx, req.(*CartReq))
+	}
+	return interceptor(ctx, in, info, handler)
+}
+
+func _CRM_GetImage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+	in := new(GetImageReq)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	if interceptor == nil {
+		return srv.(CRMServer).GetImage(ctx, in)
+	}
+	info := &grpc.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: CRM_GetImage_FullMethodName,
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		return srv.(CRMServer).GetImage(ctx, req.(*GetImageReq))
+	}
+	return interceptor(ctx, in, info, handler)
+}
+
+func _CRM_Search_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+	in := new(SearchReq)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	if interceptor == nil {
+		return srv.(CRMServer).Search(ctx, in)
+	}
+	info := &grpc.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: CRM_Search_FullMethodName,
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		return srv.(CRMServer).Search(ctx, req.(*SearchReq))
+	}
+	return interceptor(ctx, in, info, handler)
+}
+
 // CRM_ServiceDesc is the grpc.ServiceDesc for CRM service.
 // It's only intended for direct use with grpc.RegisterService,
 // and not to be introspected or modified (even as a copy)
@@ -214,6 +347,22 @@ var CRM_ServiceDesc = grpc.ServiceDesc{
 			MethodName: "GetBreadcrumbs",
 			Handler:    _CRM_GetBreadcrumbs_Handler,
 		},
+		{
+			MethodName: "Order",
+			Handler:    _CRM_Order_Handler,
+		},
+		{
+			MethodName: "GetCart",
+			Handler:    _CRM_GetCart_Handler,
+		},
+		{
+			MethodName: "GetImage",
+			Handler:    _CRM_GetImage_Handler,
+		},
+		{
+			MethodName: "Search",
+			Handler:    _CRM_Search_Handler,
+		},
 	},
 	Streams:  []grpc.StreamDesc{},
 	Metadata: "main.proto",

resources/catalog.json

@@ -2,18 +2,30 @@
   {
     "id": 0,
     "name": "Главная",
-    "uri": "/categories/0",
+    "uri": "/positions/0",
     "children": [
       {
         "id": 1,
         "name": "Пряники",
-        "uri": "/categories/1",
+        "uri": "/positions/1",
         "children": []
       },
       {
         "id": 2,
-        "name": "Пахлава",
-        "uri": "/categories/2",
+        "name": "Печенье бисквитное",
+        "uri": "/positions/2",
+        "children": []
+      },
+      {
+        "id": 3,
+        "name": "Печенье песочное",
+        "uri": "/positions/3",
+        "children": []
+      },
+      {
+        "id": 4,
+        "name": "Восточные сладости",
+        "uri": "/positions/4",
         "children": []
       }
     ]

resources/main.swagger.json

@@ -0,0 +1,632 @@
+{
+  "swagger": "2.0",
+  "info": {
+    "title": "main.proto",
+    "version": "version not set"
+  },
+  "tags": [
+    {
+      "name": "CRM"
+    }
+  ],
+  "consumes": [
+    "application/json"
+  ],
+  "produces": [
+    "application/json"
+  ],
+  "paths": {
+    "/cart": {
+      "post": {
+        "operationId": "CRM_GetCart",
+        "responses": {
+          "200": {
+            "description": "A successful response.",
+            "schema": {
+              "$ref": "#/definitions/crmCartRsp"
+            }
+          },
+          "default": {
+            "description": "An unexpected error response.",
+            "schema": {
+              "$ref": "#/definitions/rpcStatus"
+            }
+          }
+        },
+        "parameters": [
+          {
+            "name": "items",
+            "in": "body",
+            "required": true,
+            "schema": {
+              "type": "array",
+              "items": {
+                "type": "object",
+                "$ref": "#/definitions/crmOrderItem"
+              }
+            }
+          }
+        ],
+        "tags": [
+          "CRM"
+        ]
+      }
+    },
+    "/catalog": {
+      "get": {
+        "operationId": "CRM_GetCatalog",
+        "responses": {
+          "200": {
+            "description": "A successful response.",
+            "schema": {
+              "$ref": "#/definitions/crmCatalogRsp"
+            }
+          },
+          "default": {
+            "description": "An unexpected error response.",
+            "schema": {
+              "$ref": "#/definitions/rpcStatus"
+            }
+          }
+        },
+        "tags": [
+          "CRM"
+        ]
+      }
+    },
+    "/images/{name}": {
+      "get": {
+        "operationId": "CRM_GetImage",
+        "responses": {
+          "200": {
+            "description": "A successful response.",
+            "schema": {
+              "$ref": "#/definitions/apiHttpBody"
+            }
+          },
+          "default": {
+            "description": "An unexpected error response.",
+            "schema": {
+              "$ref": "#/definitions/rpcStatus"
+            }
+          }
+        },
+        "parameters": [
+          {
+            "name": "name",
+            "in": "path",
+            "required": true,
+            "type": "string"
+          }
+        ],
+        "tags": [
+          "CRM"
+        ]
+      }
+    },
+    "/orders": {
+      "post": {
+        "operationId": "CRM_Order",
+        "responses": {
+          "200": {
+            "description": "A successful response.",
+            "schema": {
+              "$ref": "#/definitions/crmOrderRsp"
+            }
+          },
+          "default": {
+            "description": "An unexpected error response.",
+            "schema": {
+              "$ref": "#/definitions/rpcStatus"
+            }
+          }
+        },
+        "parameters": [
+          {
+            "name": "order",
+            "in": "body",
+            "required": true,
+            "schema": {
+              "$ref": "#/definitions/crabscrmOrder"
+            }
+          }
+        ],
+        "tags": [
+          "CRM"
+        ]
+      }
+    },
+    "/positions/{id}": {
+      "get": {
+        "operationId": "CRM_GetPositions",
+        "responses": {
+          "200": {
+            "description": "A successful response.",
+            "schema": {
+              "$ref": "#/definitions/crmPositionsRsp"
+            }
+          },
+          "default": {
+            "description": "An unexpected error response.",
+            "schema": {
+              "$ref": "#/definitions/rpcStatus"
+            }
+          }
+        },
+        "parameters": [
+          {
+            "name": "id",
+            "in": "path",
+            "required": true,
+            "type": "string",
+            "format": "int64"
+          }
+        ],
+        "tags": [
+          "CRM"
+        ]
+      }
+    },
+    "/products/{id}": {
+      "get": {
+        "operationId": "CRM_GetProduct",
+        "responses": {
+          "200": {
+            "description": "A successful response.",
+            "schema": {
+              "$ref": "#/definitions/crmProductRsp"
+            }
+          },
+          "default": {
+            "description": "An unexpected error response.",
+            "schema": {
+              "$ref": "#/definitions/rpcStatus"
+            }
+          }
+        },
+        "parameters": [
+          {
+            "name": "id",
+            "in": "path",
+            "required": true,
+            "type": "string",
+            "format": "int64"
+          }
+        ],
+        "tags": [
+          "CRM"
+        ]
+      }
+    },
+    "/products/{id}/breadcrumbs": {
+      "get": {
+        "operationId": "CRM_GetBreadcrumbs",
+        "responses": {
+          "200": {
+            "description": "A successful response.",
+            "schema": {
+              "$ref": "#/definitions/crmBreadcrumbsRsp"
+            }
+          },
+          "default": {
+            "description": "An unexpected error response.",
+            "schema": {
+              "$ref": "#/definitions/rpcStatus"
+            }
+          }
+        },
+        "parameters": [
+          {
+            "name": "id",
+            "in": "path",
+            "required": true,
+            "type": "string",
+            "format": "int64"
+          }
+        ],
+        "tags": [
+          "CRM"
+        ]
+      }
+    },
+    "/search": {
+      "get": {
+        "operationId": "CRM_Search",
+        "responses": {
+          "200": {
+            "description": "A successful response.",
+            "schema": {
+              "$ref": "#/definitions/crmPositionsRsp"
+            }
+          },
+          "default": {
+            "description": "An unexpected error response.",
+            "schema": {
+              "$ref": "#/definitions/rpcStatus"
+            }
+          }
+        },
+        "parameters": [
+          {
+            "name": "text",
+            "in": "query",
+            "required": false,
+            "type": "string"
+          }
+        ],
+        "tags": [
+          "CRM"
+        ]
+      }
+    }
+  },
+  "definitions": {
+    "apiHttpBody": {
+      "type": "object",
+      "properties": {
+        "contentType": {
+          "type": "string",
+          "description": "The HTTP Content-Type header value specifying the content type of the body."
+        },
+        "data": {
+          "type": "string",
+          "format": "byte",
+          "description": "The HTTP request/response body as raw binary."
+        },
+        "extensions": {
+          "type": "array",
+          "items": {
+            "type": "object",
+            "$ref": "#/definitions/protobufAny"
+          },
+          "description": "Application specific response metadata. Must be set in the first response\nfor streaming APIs."
+        }
+      },
+      "description": "Message that represents an arbitrary HTTP body. It should only be used for\npayload formats that can't be represented as JSON, such as raw binary or\nan HTML page.\n\n\nThis message can be used both in streaming and non-streaming API methods in\nthe request as well as the response.\n\nIt can be used as a top-level request field, which is convenient if one\nwants to extract parameters from either the URL or HTTP template into the\nrequest fields and also want access to the raw HTTP body.\n\nExample:\n\n    message GetResourceRequest {\n      // A unique request id.\n      string request_id = 1;\n\n      // The raw HTTP body is bound to this field.\n      google.api.HttpBody http_body = 2;\n\n    }\n\n    service ResourceService {\n      rpc GetResource(GetResourceRequest)\n        returns (google.api.HttpBody);\n      rpc UpdateResource(google.api.HttpBody)\n        returns (google.protobuf.Empty);\n\n    }\n\nExample with streaming methods:\n\n    service CaldavService {\n      rpc GetCalendar(stream google.api.HttpBody)\n        returns (stream google.api.HttpBody);\n      rpc UpdateCalendar(stream google.api.HttpBody)\n        returns (stream google.api.HttpBody);\n\n    }\n\nUse of this type only changes how the request and response bodies are\nhandled, all other features will continue to work unchanged."
+    },
+    "crabscrmLabel": {
+      "type": "object",
+      "properties": {
+        "name": {
+          "type": "string"
+        }
+      }
+    },
+    "crabscrmOrder": {
+      "type": "object",
+      "properties": {
+        "name": {
+          "type": "string"
+        },
+        "phone": {
+          "type": "string"
+        },
+        "items": {
+          "type": "array",
+          "items": {
+            "type": "object",
+            "$ref": "#/definitions/crmOrderItem"
+          }
+        }
+      }
+    },
+    "crmBreadcrumbsRsp": {
+      "type": "object",
+      "properties": {
+        "categories": {
+          "type": "array",
+          "items": {
+            "type": "object",
+            "$ref": "#/definitions/crmCategory"
+          }
+        }
+      }
+    },
+    "crmCartItem": {
+      "type": "object",
+      "properties": {
+        "id": {
+          "type": "string",
+          "format": "int64"
+        },
+        "article": {
+          "type": "string"
+        },
+        "name": {
+          "type": "string"
+        },
+        "uri": {
+          "type": "string"
+        },
+        "images": {
+          "type": "array",
+          "items": {
+            "type": "string"
+          }
+        },
+        "unit": {
+          "type": "string"
+        },
+        "inventory": {
+          "type": "number",
+          "format": "double"
+        },
+        "count": {
+          "type": "string",
+          "format": "int64"
+        },
+        "amount": {
+          "type": "string",
+          "format": "int64"
+        },
+        "amountOld": {
+          "type": "string",
+          "format": "int64"
+        },
+        "discount": {
+          "type": "string",
+          "format": "int64"
+        },
+        "variants": {
+          "type": "array",
+          "items": {
+            "type": "object",
+            "$ref": "#/definitions/crmVariant"
+          }
+        },
+        "labels": {
+          "type": "array",
+          "items": {
+            "type": "object",
+            "$ref": "#/definitions/crabscrmLabel"
+          }
+        }
+      }
+    },
+    "crmCartRsp": {
+      "type": "object",
+      "properties": {
+        "items": {
+          "type": "array",
+          "items": {
+            "type": "object",
+            "$ref": "#/definitions/crmCartItem"
+          }
+        },
+        "amount": {
+          "type": "string",
+          "format": "int64"
+        },
+        "amountOld": {
+          "type": "string",
+          "format": "int64"
+        },
+        "discount": {
+          "type": "string",
+          "format": "int64"
+        }
+      }
+    },
+    "crmCatalogRsp": {
+      "type": "object",
+      "properties": {
+        "categories": {
+          "type": "array",
+          "items": {
+            "type": "object",
+            "$ref": "#/definitions/crmCategory"
+          }
+        }
+      }
+    },
+    "crmCategory": {
+      "type": "object",
+      "properties": {
+        "id": {
+          "type": "string",
+          "format": "int64"
+        },
+        "name": {
+          "type": "string"
+        },
+        "uri": {
+          "type": "string"
+        },
+        "children": {
+          "type": "array",
+          "items": {
+            "type": "object",
+            "$ref": "#/definitions/crmCategory"
+          }
+        }
+      }
+    },
+    "crmCharacteristic": {
+      "type": "object",
+      "properties": {
+        "name": {
+          "type": "string"
+        },
+        "value": {
+          "type": "string"
+        }
+      }
+    },
+    "crmGroupedProduct": {
+      "type": "object",
+      "properties": {
+        "name": {
+          "type": "string"
+        },
+        "uri": {
+          "type": "string"
+        },
+        "image": {
+          "type": "string"
+        }
+      }
+    },
+    "crmOrderItem": {
+      "type": "object",
+      "properties": {
+        "productId": {
+          "type": "string",
+          "format": "int64"
+        },
+        "count": {
+          "type": "string",
+          "format": "int64"
+        }
+      }
+    },
+    "crmOrderRsp": {
+      "type": "object"
+    },
+    "crmPositionsRsp": {
+      "type": "object",
+      "properties": {
+        "products": {
+          "type": "array",
+          "items": {
+            "type": "object",
+            "$ref": "#/definitions/crmProduct"
+          }
+        }
+      }
+    },
+    "crmProduct": {
+      "type": "object",
+      "properties": {
+        "id": {
+          "type": "string",
+          "format": "int64"
+        },
+        "article": {
+          "type": "string"
+        },
+        "name": {
+          "type": "string"
+        },
+        "uri": {
+          "type": "string"
+        },
+        "images": {
+          "type": "array",
+          "items": {
+            "type": "string"
+          }
+        },
+        "description": {
+          "type": "string"
+        },
+        "groupedProducts": {
+          "type": "array",
+          "items": {
+            "type": "object",
+            "$ref": "#/definitions/crmGroupedProduct"
+          }
+        },
+        "unit": {
+          "type": "string"
+        },
+        "inventory": {
+          "type": "number",
+          "format": "double"
+        },
+        "variants": {
+          "type": "array",
+          "items": {
+            "type": "object",
+            "$ref": "#/definitions/crmVariant"
+          }
+        },
+        "characteristics": {
+          "type": "array",
+          "items": {
+            "type": "object",
+            "$ref": "#/definitions/crmCharacteristic"
+          }
+        },
+        "category": {
+          "type": "string",
+          "format": "int64"
+        },
+        "labels": {
+          "type": "array",
+          "items": {
+            "type": "object",
+            "$ref": "#/definitions/crabscrmLabel"
+          }
+        }
+      }
+    },
+    "crmProductRsp": {
+      "type": "object",
+      "properties": {
+        "product": {
+          "$ref": "#/definitions/crmProduct"
+        }
+      }
+    },
+    "crmProperty": {
+      "type": "object",
+      "properties": {
+        "name": {
+          "type": "string"
+        },
+        "value": {
+          "type": "string"
+        }
+      }
+    },
+    "crmVariant": {
+      "type": "object",
+      "properties": {
+        "price": {
+          "type": "string",
+          "format": "int64"
+        },
+        "properties": {
+          "type": "array",
+          "items": {
+            "type": "object",
+            "$ref": "#/definitions/crmProperty"
+          }
+        },
+        "active": {
+          "type": "boolean"
+        }
+      }
+    },
+    "protobufAny": {
+      "type": "object",
+      "properties": {
+        "@type": {
+          "type": "string",
+          "description": "A URL/resource name that uniquely identifies the type of the serialized\nprotocol buffer message. This string must contain at least\none \"/\" character. The last segment of the URL's path must represent\nthe fully qualified name of the type (as in\n`path/google.protobuf.Duration`). The name should be in a canonical form\n(e.g., leading \".\" is not accepted).\n\nIn practice, teams usually precompile into the binary all types that they\nexpect it to use in the context of Any. However, for URLs which use the\nscheme `http`, `https`, or no scheme, one can optionally set up a type\nserver that maps type URLs to message definitions as follows:\n\n* If no scheme is provided, `https` is assumed.\n* An HTTP GET on the URL must yield a [google.protobuf.Type][]\n  value in binary format, or produce an error.\n* Applications are allowed to cache lookup results based on the\n  URL, or have them precompiled into a binary to avoid any\n  lookup. Therefore, binary compatibility needs to be preserved\n  on changes to types. (Use versioned type names to manage\n  breaking changes.)\n\nNote: this functionality is not currently available in the official\nprotobuf release, and it is not used for type URLs beginning with\ntype.googleapis.com. As of May 2023, there are no widely used type server\nimplementations and no plans to implement one.\n\nSchemes other than `http`, `https` (or the empty scheme) might be\nused with implementation specific semantics."
+        }
+      },
+      "additionalProperties": {},
+      "description": "`Any` contains an arbitrary serialized protocol buffer message along with a\nURL that describes the type of the serialized message.\n\nProtobuf library provides support to pack/unpack Any values in the form\nof utility functions or additional generated methods of the Any type.\n\nExample 1: Pack and unpack a message in C++.\n\n    Foo foo = ...;\n    Any any;\n    any.PackFrom(foo);\n    ...\n    if (any.UnpackTo(\u0026foo)) {\n      ...\n    }\n\nExample 2: Pack and unpack a message in Java.\n\n    Foo foo = ...;\n    Any any = Any.pack(foo);\n    ...\n    if (any.is(Foo.class)) {\n      foo = any.unpack(Foo.class);\n    }\n    // or ...\n    if (any.isSameTypeAs(Foo.getDefaultInstance())) {\n      foo = any.unpack(Foo.getDefaultInstance());\n    }\n\n Example 3: Pack and unpack a message in Python.\n\n    foo = Foo(...)\n    any = Any()\n    any.Pack(foo)\n    ...\n    if any.Is(Foo.DESCRIPTOR):\n      any.Unpack(foo)\n      ...\n\n Example 4: Pack and unpack a message in Go\n\n     foo := \u0026pb.Foo{...}\n     any, err := anypb.New(foo)\n     if err != nil {\n       ...\n     }\n     ...\n     foo := \u0026pb.Foo{}\n     if err := any.UnmarshalTo(foo); err != nil {\n       ...\n     }\n\nThe pack methods provided by protobuf library will by default use\n'type.googleapis.com/full.type.name' as the type URL and the unpack\nmethods only use the fully qualified type name after the last '/'\nin the type URL, for example \"foo.bar.com/x/y.z\" will yield type\nname \"y.z\".\n\nJSON\n====\nThe JSON representation of an `Any` value uses the regular\nrepresentation of the deserialized, embedded message, with an\nadditional field `@type` which contains the type URL. Example:\n\n    package google.profile;\n    message Person {\n      string first_name = 1;\n      string last_name = 2;\n    }\n\n    {\n      \"@type\": \"type.googleapis.com/google.profile.Person\",\n      \"firstName\": \u003cstring\u003e,\n      \"lastName\": \u003cstring\u003e\n    }\n\nIf the embedded message type is well-known and has a custom JSON\nrepresentation, that representation will be embedded adding a field\n`value` which holds the custom JSON in addition to the `@type`\nfield. Example (for message [google.protobuf.Duration][]):\n\n    {\n      \"@type\": \"type.googleapis.com/google.protobuf.Duration\",\n      \"value\": \"1.212s\"\n    }"
+    },
+    "rpcStatus": {
+      "type": "object",
+      "properties": {
+        "code": {
+          "type": "integer",
+          "format": "int32"
+        },
+        "message": {
+          "type": "string"
+        },
+        "details": {
+          "type": "array",
+          "items": {
+            "type": "object",
+            "$ref": "#/definitions/protobufAny"
+          }
+        }
+      }
+    }
+  }
+}

third_party/google/api/httpbody.proto

@@ -0,0 +1,81 @@
+// Copyright 2024 Google LLC
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+syntax = "proto3";
+
+package google.api;
+
+import "google/protobuf/any.proto";
+
+option cc_enable_arenas = true;
+option go_package = "google.golang.org/genproto/googleapis/api/httpbody;httpbody";
+option java_multiple_files = true;
+option java_outer_classname = "HttpBodyProto";
+option java_package = "com.google.api";
+option objc_class_prefix = "GAPI";
+
+// Message that represents an arbitrary HTTP body. It should only be used for
+// payload formats that can't be represented as JSON, such as raw binary or
+// an HTML page.
+//
+//
+// This message can be used both in streaming and non-streaming API methods in
+// the request as well as the response.
+//
+// It can be used as a top-level request field, which is convenient if one
+// wants to extract parameters from either the URL or HTTP template into the
+// request fields and also want access to the raw HTTP body.
+//
+// Example:
+//
+//     message GetResourceRequest {
+//       // A unique request id.
+//       string request_id = 1;
+//
+//       // The raw HTTP body is bound to this field.
+//       google.api.HttpBody http_body = 2;
+//
+//     }
+//
+//     service ResourceService {
+//       rpc GetResource(GetResourceRequest)
+//         returns (google.api.HttpBody);
+//       rpc UpdateResource(google.api.HttpBody)
+//         returns (google.protobuf.Empty);
+//
+//     }
+//
+// Example with streaming methods:
+//
+//     service CaldavService {
+//       rpc GetCalendar(stream google.api.HttpBody)
+//         returns (stream google.api.HttpBody);
+//       rpc UpdateCalendar(stream google.api.HttpBody)
+//         returns (stream google.api.HttpBody);
+//
+//     }
+//
+// Use of this type only changes how the request and response bodies are
+// handled, all other features will continue to work unchanged.
+message HttpBody {
+  // The HTTP Content-Type header value specifying the content type of the body.
+  string content_type = 1;
+
+  // The HTTP request/response body as raw binary.
+  bytes data = 2;
+
+  // Application specific response metadata. Must be set in the first response
+  // for streaming APIs.
+  repeated google.protobuf.Any extensions = 3;
+}

third_party/protoc-gen-openapiv2/options/annotations.proto

@@ -0,0 +1,44 @@
+syntax = "proto3";
+
+package grpc.gateway.protoc_gen_openapiv2.options;
+
+import "google/protobuf/descriptor.proto";
+import "protoc-gen-openapiv2/options/openapiv2.proto";
+
+option go_package = "github.com/grpc-ecosystem/grpc-gateway/v2/protoc-gen-openapiv2/options";
+
+extend google.protobuf.FileOptions {
+  // ID assigned by protobuf-global-extension-registry@google.com for gRPC-Gateway project.
+  //
+  // All IDs are the same, as assigned. It is okay that they are the same, as they extend
+  // different descriptor messages.
+  Swagger openapiv2_swagger = 1042;
+}
+extend google.protobuf.MethodOptions {
+  // ID assigned by protobuf-global-extension-registry@google.com for gRPC-Gateway project.
+  //
+  // All IDs are the same, as assigned. It is okay that they are the same, as they extend
+  // different descriptor messages.
+  Operation openapiv2_operation = 1042;
+}
+extend google.protobuf.MessageOptions {
+  // ID assigned by protobuf-global-extension-registry@google.com for gRPC-Gateway project.
+  //
+  // All IDs are the same, as assigned. It is okay that they are the same, as they extend
+  // different descriptor messages.
+  Schema openapiv2_schema = 1042;
+}
+extend google.protobuf.ServiceOptions {
+  // ID assigned by protobuf-global-extension-registry@google.com for gRPC-Gateway project.
+  //
+  // All IDs are the same, as assigned. It is okay that they are the same, as they extend
+  // different descriptor messages.
+  Tag openapiv2_tag = 1042;
+}
+extend google.protobuf.FieldOptions {
+  // ID assigned by protobuf-global-extension-registry@google.com for gRPC-Gateway project.
+  //
+  // All IDs are the same, as assigned. It is okay that they are the same, as they extend
+  // different descriptor messages.
+  JSONSchema openapiv2_field = 1042;
+}

third_party/protoc-gen-openapiv2/options/openapiv2.proto

@@ -0,0 +1,720 @@
+syntax = "proto3";
+
+package grpc.gateway.protoc_gen_openapiv2.options;
+
+import "google/protobuf/struct.proto";
+
+option go_package = "github.com/grpc-ecosystem/grpc-gateway/v2/protoc-gen-openapiv2/options";
+
+// Scheme describes the schemes supported by the OpenAPI Swagger
+// and Operation objects.
+enum Scheme {
+  UNKNOWN = 0;
+  HTTP = 1;
+  HTTPS = 2;
+  WS = 3;
+  WSS = 4;
+}
+
+// `Swagger` is a representation of OpenAPI v2 specification's Swagger object.
+//
+// See: https://github.com/OAI/OpenAPI-Specification/blob/3.0.0/versions/2.0.md#swaggerObject
+//
+// Example:
+//
+//  option (grpc.gateway.protoc_gen_openapiv2.options.openapiv2_swagger) = {
+//    info: {
+//      title: "Echo API";
+//      version: "1.0";
+//      description: "";
+//      contact: {
+//        name: "gRPC-Gateway project";
+//        url: "https://github.com/grpc-ecosystem/grpc-gateway";
+//        email: "none@example.com";
+//      };
+//      license: {
+//        name: "BSD 3-Clause License";
+//        url: "https://github.com/grpc-ecosystem/grpc-gateway/blob/main/LICENSE";
+//      };
+//    };
+//    schemes: HTTPS;
+//    consumes: "application/json";
+//    produces: "application/json";
+//  };
+//
+message Swagger {
+  // Specifies the OpenAPI Specification version being used. It can be
+  // used by the OpenAPI UI and other clients to interpret the API listing. The
+  // value MUST be "2.0".
+  string swagger = 1;
+  // Provides metadata about the API. The metadata can be used by the
+  // clients if needed.
+  Info info = 2;
+  // The host (name or ip) serving the API. This MUST be the host only and does
+  // not include the scheme nor sub-paths. It MAY include a port. If the host is
+  // not included, the host serving the documentation is to be used (including
+  // the port). The host does not support path templating.
+  string host = 3;
+  // The base path on which the API is served, which is relative to the host. If
+  // it is not included, the API is served directly under the host. The value
+  // MUST start with a leading slash (/). The basePath does not support path
+  // templating.
+  // Note that using `base_path` does not change the endpoint paths that are
+  // generated in the resulting OpenAPI file. If you wish to use `base_path`
+  // with relatively generated OpenAPI paths, the `base_path` prefix must be
+  // manually removed from your `google.api.http` paths and your code changed to
+  // serve the API from the `base_path`.
+  string base_path = 4;
+  // The transfer protocol of the API. Values MUST be from the list: "http",
+  // "https", "ws", "wss". If the schemes is not included, the default scheme to
+  // be used is the one used to access the OpenAPI definition itself.
+  repeated Scheme schemes = 5;
+  // A list of MIME types the APIs can consume. This is global to all APIs but
+  // can be overridden on specific API calls. Value MUST be as described under
+  // Mime Types.
+  repeated string consumes = 6;
+  // A list of MIME types the APIs can produce. This is global to all APIs but
+  // can be overridden on specific API calls. Value MUST be as described under
+  // Mime Types.
+  repeated string produces = 7;
+  // field 8 is reserved for 'paths'.
+  reserved 8;
+  // field 9 is reserved for 'definitions', which at this time are already
+  // exposed as and customizable as proto messages.
+  reserved 9;
+  // An object to hold responses that can be used across operations. This
+  // property does not define global responses for all operations.
+  map<string, Response> responses = 10;
+  // Security scheme definitions that can be used across the specification.
+  SecurityDefinitions security_definitions = 11;
+  // A declaration of which security schemes are applied for the API as a whole.
+  // The list of values describes alternative security schemes that can be used
+  // (that is, there is a logical OR between the security requirements).
+  // Individual operations can override this definition.
+  repeated SecurityRequirement security = 12;
+  // A list of tags for API documentation control. Tags can be used for logical
+  // grouping of operations by resources or any other qualifier.
+  repeated Tag tags = 13;
+  // Additional external documentation.
+  ExternalDocumentation external_docs = 14;
+  // Custom properties that start with "x-" such as "x-foo" used to describe
+  // extra functionality that is not covered by the standard OpenAPI Specification.
+  // See: https://swagger.io/docs/specification/2-0/swagger-extensions/
+  map<string, google.protobuf.Value> extensions = 15;
+}
+
+// `Operation` is a representation of OpenAPI v2 specification's Operation object.
+//
+// See: https://github.com/OAI/OpenAPI-Specification/blob/3.0.0/versions/2.0.md#operationObject
+//
+// Example:
+//
+//  service EchoService {
+//    rpc Echo(SimpleMessage) returns (SimpleMessage) {
+//      option (google.api.http) = {
+//        get: "/v1/example/echo/{id}"
+//      };
+//
+//      option (grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation) = {
+//        summary: "Get a message.";
+//        operation_id: "getMessage";
+//        tags: "echo";
+//        responses: {
+//          key: "200"
+//            value: {
+//            description: "OK";
+//          }
+//        }
+//      };
+//    }
+//  }
+message Operation {
+  // A list of tags for API documentation control. Tags can be used for logical
+  // grouping of operations by resources or any other qualifier.
+  repeated string tags = 1;
+  // A short summary of what the operation does. For maximum readability in the
+  // swagger-ui, this field SHOULD be less than 120 characters.
+  string summary = 2;
+  // A verbose explanation of the operation behavior. GFM syntax can be used for
+  // rich text representation.
+  string description = 3;
+  // Additional external documentation for this operation.
+  ExternalDocumentation external_docs = 4;
+  // Unique string used to identify the operation. The id MUST be unique among
+  // all operations described in the API. Tools and libraries MAY use the
+  // operationId to uniquely identify an operation, therefore, it is recommended
+  // to follow common programming naming conventions.
+  string operation_id = 5;
+  // A list of MIME types the operation can consume. This overrides the consumes
+  // definition at the OpenAPI Object. An empty value MAY be used to clear the
+  // global definition. Value MUST be as described under Mime Types.
+  repeated string consumes = 6;
+  // A list of MIME types the operation can produce. This overrides the produces
+  // definition at the OpenAPI Object. An empty value MAY be used to clear the
+  // global definition. Value MUST be as described under Mime Types.
+  repeated string produces = 7;
+  // field 8 is reserved for 'parameters'.
+  reserved 8;
+  // The list of possible responses as they are returned from executing this
+  // operation.
+  map<string, Response> responses = 9;
+  // The transfer protocol for the operation. Values MUST be from the list:
+  // "http", "https", "ws", "wss". The value overrides the OpenAPI Object
+  // schemes definition.
+  repeated Scheme schemes = 10;
+  // Declares this operation to be deprecated. Usage of the declared operation
+  // should be refrained. Default value is false.
+  bool deprecated = 11;
+  // A declaration of which security schemes are applied for this operation. The
+  // list of values describes alternative security schemes that can be used
+  // (that is, there is a logical OR between the security requirements). This
+  // definition overrides any declared top-level security. To remove a top-level
+  // security declaration, an empty array can be used.
+  repeated SecurityRequirement security = 12;
+  // Custom properties that start with "x-" such as "x-foo" used to describe
+  // extra functionality that is not covered by the standard OpenAPI Specification.
+  // See: https://swagger.io/docs/specification/2-0/swagger-extensions/
+  map<string, google.protobuf.Value> extensions = 13;
+  // Custom parameters such as HTTP request headers.
+  // See: https://swagger.io/docs/specification/2-0/describing-parameters/
+  // and https://swagger.io/specification/v2/#parameter-object.
+  Parameters parameters = 14;
+}
+
+// `Parameters` is a representation of OpenAPI v2 specification's parameters object.
+// Note: This technically breaks compatibility with the OpenAPI 2 definition structure as we only
+// allow header parameters to be set here since we do not want users specifying custom non-header
+// parameters beyond those inferred from the Protobuf schema.
+// See: https://swagger.io/specification/v2/#parameter-object
+message Parameters {
+  // `Headers` is one or more HTTP header parameter.
+  // See: https://swagger.io/docs/specification/2-0/describing-parameters/#header-parameters
+  repeated HeaderParameter headers = 1;
+}
+
+// `HeaderParameter` a HTTP header parameter.
+// See: https://swagger.io/specification/v2/#parameter-object
+message HeaderParameter {
+  // `Type` is a supported HTTP header type.
+  // See https://swagger.io/specification/v2/#parameterType.
+  enum Type {
+    UNKNOWN = 0;
+    STRING = 1;
+    NUMBER = 2;
+    INTEGER = 3;
+    BOOLEAN = 4;
+  }
+
+  // `Name` is the header name.
+  string name = 1;
+  // `Description` is a short description of the header.
+  string description = 2;
+  // `Type` is the type of the object. The value MUST be one of "string", "number", "integer", or "boolean". The "array" type is not supported.
+  // See: https://swagger.io/specification/v2/#parameterType.
+  Type type = 3;
+  // `Format` The extending format for the previously mentioned type.
+  string format = 4;
+  // `Required` indicates if the header is optional
+  bool required = 5;
+  // field 6 is reserved for 'items', but in OpenAPI-specific way.
+  reserved 6;
+  // field 7 is reserved `Collection Format`. Determines the format of the array if type array is used.
+  reserved 7;
+}
+
+// `Header` is a representation of OpenAPI v2 specification's Header object.
+//
+// See: https://github.com/OAI/OpenAPI-Specification/blob/3.0.0/versions/2.0.md#headerObject
+//
+message Header {
+  // `Description` is a short description of the header.
+  string description = 1;
+  // The type of the object. The value MUST be one of "string", "number", "integer", or "boolean". The "array" type is not supported.
+  string type = 2;
+  // `Format` The extending format for the previously mentioned type.
+  string format = 3;
+  // field 4 is reserved for 'items', but in OpenAPI-specific way.
+  reserved 4;
+  // field 5 is reserved `Collection Format` Determines the format of the array if type array is used.
+  reserved 5;
+  // `Default` Declares the value of the header that the server will use if none is provided.
+  // See: https://tools.ietf.org/html/draft-fge-json-schema-validation-00#section-6.2.
+  // Unlike JSON Schema this value MUST conform to the defined type for the header.
+  string default = 6;
+  // field 7 is reserved for 'maximum'.
+  reserved 7;
+  // field 8 is reserved for 'exclusiveMaximum'.
+  reserved 8;
+  // field 9 is reserved for 'minimum'.
+  reserved 9;
+  // field 10 is reserved for 'exclusiveMinimum'.
+  reserved 10;
+  // field 11 is reserved for 'maxLength'.
+  reserved 11;
+  // field 12 is reserved for 'minLength'.
+  reserved 12;
+  // 'Pattern' See https://tools.ietf.org/html/draft-fge-json-schema-validation-00#section-5.2.3.
+  string pattern = 13;
+  // field 14 is reserved for 'maxItems'.
+  reserved 14;
+  // field 15 is reserved for 'minItems'.
+  reserved 15;
+  // field 16 is reserved for 'uniqueItems'.
+  reserved 16;
+  // field 17 is reserved for 'enum'.
+  reserved 17;
+  // field 18 is reserved for 'multipleOf'.
+  reserved 18;
+}
+
+// `Response` is a representation of OpenAPI v2 specification's Response object.
+//
+// See: https://github.com/OAI/OpenAPI-Specification/blob/3.0.0/versions/2.0.md#responseObject
+//
+message Response {
+  // `Description` is a short description of the response.
+  // GFM syntax can be used for rich text representation.
+  string description = 1;
+  // `Schema` optionally defines the structure of the response.
+  // If `Schema` is not provided, it means there is no content to the response.
+  Schema schema = 2;
+  // `Headers` A list of headers that are sent with the response.
+  // `Header` name is expected to be a string in the canonical format of the MIME header key
+  // See: https://golang.org/pkg/net/textproto/#CanonicalMIMEHeaderKey
+  map<string, Header> headers = 3;
+  // `Examples` gives per-mimetype response examples.
+  // See: https://github.com/OAI/OpenAPI-Specification/blob/3.0.0/versions/2.0.md#example-object
+  map<string, string> examples = 4;
+  // Custom properties that start with "x-" such as "x-foo" used to describe
+  // extra functionality that is not covered by the standard OpenAPI Specification.
+  // See: https://swagger.io/docs/specification/2-0/swagger-extensions/
+  map<string, google.protobuf.Value> extensions = 5;
+}
+
+// `Info` is a representation of OpenAPI v2 specification's Info object.
+//
+// See: https://github.com/OAI/OpenAPI-Specification/blob/3.0.0/versions/2.0.md#infoObject
+//
+// Example:
+//
+//  option (grpc.gateway.protoc_gen_openapiv2.options.openapiv2_swagger) = {
+//    info: {
+//      title: "Echo API";
+//      version: "1.0";
+//      description: "";
+//      contact: {
+//        name: "gRPC-Gateway project";
+//        url: "https://github.com/grpc-ecosystem/grpc-gateway";
+//        email: "none@example.com";
+//      };
+//      license: {
+//        name: "BSD 3-Clause License";
+//        url: "https://github.com/grpc-ecosystem/grpc-gateway/blob/main/LICENSE";
+//      };
+//    };
+//    ...
+//  };
+//
+message Info {
+  // The title of the application.
+  string title = 1;
+  // A short description of the application. GFM syntax can be used for rich
+  // text representation.
+  string description = 2;
+  // The Terms of Service for the API.
+  string terms_of_service = 3;
+  // The contact information for the exposed API.
+  Contact contact = 4;
+  // The license information for the exposed API.
+  License license = 5;
+  // Provides the version of the application API (not to be confused
+  // with the specification version).
+  string version = 6;
+  // Custom properties that start with "x-" such as "x-foo" used to describe
+  // extra functionality that is not covered by the standard OpenAPI Specification.
+  // See: https://swagger.io/docs/specification/2-0/swagger-extensions/
+  map<string, google.protobuf.Value> extensions = 7;
+}
+
+// `Contact` is a representation of OpenAPI v2 specification's Contact object.
+//
+// See: https://github.com/OAI/OpenAPI-Specification/blob/3.0.0/versions/2.0.md#contactObject
+//
+// Example:
+//
+//  option (grpc.gateway.protoc_gen_openapiv2.options.openapiv2_swagger) = {
+//    info: {
+//      ...
+//      contact: {
+//        name: "gRPC-Gateway project";
+//        url: "https://github.com/grpc-ecosystem/grpc-gateway";
+//        email: "none@example.com";
+//      };
+//      ...
+//    };
+//    ...
+//  };
+//
+message Contact {
+  // The identifying name of the contact person/organization.
+  string name = 1;
+  // The URL pointing to the contact information. MUST be in the format of a
+  // URL.
+  string url = 2;
+  // The email address of the contact person/organization. MUST be in the format
+  // of an email address.
+  string email = 3;
+}
+
+// `License` is a representation of OpenAPI v2 specification's License object.
+//
+// See: https://github.com/OAI/OpenAPI-Specification/blob/3.0.0/versions/2.0.md#licenseObject
+//
+// Example:
+//
+//  option (grpc.gateway.protoc_gen_openapiv2.options.openapiv2_swagger) = {
+//    info: {
+//      ...
+//      license: {
+//        name: "BSD 3-Clause License";
+//        url: "https://github.com/grpc-ecosystem/grpc-gateway/blob/main/LICENSE";
+//      };
+//      ...
+//    };
+//    ...
+//  };
+//
+message License {
+  // The license name used for the API.
+  string name = 1;
+  // A URL to the license used for the API. MUST be in the format of a URL.
+  string url = 2;
+}
+
+// `ExternalDocumentation` is a representation of OpenAPI v2 specification's
+// ExternalDocumentation object.
+//
+// See: https://github.com/OAI/OpenAPI-Specification/blob/3.0.0/versions/2.0.md#externalDocumentationObject
+//
+// Example:
+//
+//  option (grpc.gateway.protoc_gen_openapiv2.options.openapiv2_swagger) = {
+//    ...
+//    external_docs: {
+//      description: "More about gRPC-Gateway";
+//      url: "https://github.com/grpc-ecosystem/grpc-gateway";
+//    }
+//    ...
+//  };
+//
+message ExternalDocumentation {
+  // A short description of the target documentation. GFM syntax can be used for
+  // rich text representation.
+  string description = 1;
+  // The URL for the target documentation. Value MUST be in the format
+  // of a URL.
+  string url = 2;
+}
+
+// `Schema` is a representation of OpenAPI v2 specification's Schema object.
+//
+// See: https://github.com/OAI/OpenAPI-Specification/blob/3.0.0/versions/2.0.md#schemaObject
+//
+message Schema {
+  JSONSchema json_schema = 1;
+  // Adds support for polymorphism. The discriminator is the schema property
+  // name that is used to differentiate between other schema that inherit this
+  // schema. The property name used MUST be defined at this schema and it MUST
+  // be in the required property list. When used, the value MUST be the name of
+  // this schema or any schema that inherits it.
+  string discriminator = 2;
+  // Relevant only for Schema "properties" definitions. Declares the property as
+  // "read only". This means that it MAY be sent as part of a response but MUST
+  // NOT be sent as part of the request. Properties marked as readOnly being
+  // true SHOULD NOT be in the required list of the defined schema. Default
+  // value is false.
+  bool read_only = 3;
+  // field 4 is reserved for 'xml'.
+  reserved 4;
+  // Additional external documentation for this schema.
+  ExternalDocumentation external_docs = 5;
+  // A free-form property to include an example of an instance for this schema in JSON.
+  // This is copied verbatim to the output.
+  string example = 6;
+}
+
+// `JSONSchema` represents properties from JSON Schema taken, and as used, in
+// the OpenAPI v2 spec.
+//
+// This includes changes made by OpenAPI v2.
+//
+// See: https://github.com/OAI/OpenAPI-Specification/blob/3.0.0/versions/2.0.md#schemaObject
+//
+// See also: https://cswr.github.io/JsonSchema/spec/basic_types/,
+// https://github.com/json-schema-org/json-schema-spec/blob/master/schema.json
+//
+// Example:
+//
+//  message SimpleMessage {
+//    option (grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema) = {
+//      json_schema: {
+//        title: "SimpleMessage"
+//        description: "A simple message."
+//        required: ["id"]
+//      }
+//    };
+//
+//    // Id represents the message identifier.
+//    string id = 1; [
+//        (grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field) = {
+//          description: "The unique identifier of the simple message."
+//        }];
+//  }
+//
+message JSONSchema {
+  // field 1 is reserved for '$id', omitted from OpenAPI v2.
+  reserved 1;
+  // field 2 is reserved for '$schema', omitted from OpenAPI v2.
+  reserved 2;
+  // Ref is used to define an external reference to include in the message.
+  // This could be a fully qualified proto message reference, and that type must
+  // be imported into the protofile. If no message is identified, the Ref will
+  // be used verbatim in the output.
+  // For example:
+  //  `ref: ".google.protobuf.Timestamp"`.
+  string ref = 3;
+  // field 4 is reserved for '$comment', omitted from OpenAPI v2.
+  reserved 4;
+  // The title of the schema.
+  string title = 5;
+  // A short description of the schema.
+  string description = 6;
+  string default = 7;
+  bool read_only = 8;
+  // A free-form property to include a JSON example of this field. This is copied
+  // verbatim to the output swagger.json. Quotes must be escaped.
+  // This property is the same for 2.0 and 3.0.0 https://github.com/OAI/OpenAPI-Specification/blob/3.0.0/versions/3.0.0.md#schemaObject  https://github.com/OAI/OpenAPI-Specification/blob/3.0.0/versions/2.0.md#schemaObject
+  string example = 9;
+  double multiple_of = 10;
+  // Maximum represents an inclusive upper limit for a numeric instance. The
+  // value of MUST be a number,
+  double maximum = 11;
+  bool exclusive_maximum = 12;
+  // minimum represents an inclusive lower limit for a numeric instance. The
+  // value of MUST be a number,
+  double minimum = 13;
+  bool exclusive_minimum = 14;
+  uint64 max_length = 15;
+  uint64 min_length = 16;
+  string pattern = 17;
+  // field 18 is reserved for 'additionalItems', omitted from OpenAPI v2.
+  reserved 18;
+  // field 19 is reserved for 'items', but in OpenAPI-specific way.
+  // TODO(ivucica): add 'items'?
+  reserved 19;
+  uint64 max_items = 20;
+  uint64 min_items = 21;
+  bool unique_items = 22;
+  // field 23 is reserved for 'contains', omitted from OpenAPI v2.
+  reserved 23;
+  uint64 max_properties = 24;
+  uint64 min_properties = 25;
+  repeated string required = 26;
+  // field 27 is reserved for 'additionalProperties', but in OpenAPI-specific
+  // way. TODO(ivucica): add 'additionalProperties'?
+  reserved 27;
+  // field 28 is reserved for 'definitions', omitted from OpenAPI v2.
+  reserved 28;
+  // field 29 is reserved for 'properties', but in OpenAPI-specific way.
+  // TODO(ivucica): add 'additionalProperties'?
+  reserved 29;
+  // following fields are reserved, as the properties have been omitted from
+  // OpenAPI v2:
+  // patternProperties, dependencies, propertyNames, const
+  reserved 30 to 33;
+  // Items in 'array' must be unique.
+  repeated string array = 34;
+
+  enum JSONSchemaSimpleTypes {
+    UNKNOWN = 0;
+    ARRAY = 1;
+    BOOLEAN = 2;
+    INTEGER = 3;
+    NULL = 4;
+    NUMBER = 5;
+    OBJECT = 6;
+    STRING = 7;
+  }
+
+  repeated JSONSchemaSimpleTypes type = 35;
+  // `Format`
+  string format = 36;
+  // following fields are reserved, as the properties have been omitted from
+  // OpenAPI v2: contentMediaType, contentEncoding, if, then, else
+  reserved 37 to 41;
+  // field 42 is reserved for 'allOf', but in OpenAPI-specific way.
+  // TODO(ivucica): add 'allOf'?
+  reserved 42;
+  // following fields are reserved, as the properties have been omitted from
+  // OpenAPI v2:
+  // anyOf, oneOf, not
+  reserved 43 to 45;
+  // Items in `enum` must be unique https://tools.ietf.org/html/draft-fge-json-schema-validation-00#section-5.5.1
+  repeated string enum = 46;
+
+  // Additional field level properties used when generating the OpenAPI v2 file.
+  FieldConfiguration field_configuration = 1001;
+
+  // 'FieldConfiguration' provides additional field level properties used when generating the OpenAPI v2 file.
+  // These properties are not defined by OpenAPIv2, but they are used to control the generation.
+  message FieldConfiguration {
+    // Alternative parameter name when used as path parameter. If set, this will
+    // be used as the complete parameter name when this field is used as a path
+    // parameter. Use this to avoid having auto generated path parameter names
+    // for overlapping paths.
+    string path_param_name = 47;
+  }
+  // Custom properties that start with "x-" such as "x-foo" used to describe
+  // extra functionality that is not covered by the standard OpenAPI Specification.
+  // See: https://swagger.io/docs/specification/2-0/swagger-extensions/
+  map<string, google.protobuf.Value> extensions = 48;
+}
+
+// `Tag` is a representation of OpenAPI v2 specification's Tag object.
+//
+// See: https://github.com/OAI/OpenAPI-Specification/blob/3.0.0/versions/2.0.md#tagObject
+//
+message Tag {
+  // The name of the tag. Use it to allow override of the name of a
+  // global Tag object, then use that name to reference the tag throughout the
+  // OpenAPI file.
+  string name = 1;
+  // A short description for the tag. GFM syntax can be used for rich text
+  // representation.
+  string description = 2;
+  // Additional external documentation for this tag.
+  ExternalDocumentation external_docs = 3;
+  // Custom properties that start with "x-" such as "x-foo" used to describe
+  // extra functionality that is not covered by the standard OpenAPI Specification.
+  // See: https://swagger.io/docs/specification/2-0/swagger-extensions/
+  map<string, google.protobuf.Value> extensions = 4;
+}
+
+// `SecurityDefinitions` is a representation of OpenAPI v2 specification's
+// Security Definitions object.
+//
+// See: https://github.com/OAI/OpenAPI-Specification/blob/3.0.0/versions/2.0.md#securityDefinitionsObject
+//
+// A declaration of the security schemes available to be used in the
+// specification. This does not enforce the security schemes on the operations
+// and only serves to provide the relevant details for each scheme.
+message SecurityDefinitions {
+  // A single security scheme definition, mapping a "name" to the scheme it
+  // defines.
+  map<string, SecurityScheme> security = 1;
+}
+
+// `SecurityScheme` is a representation of OpenAPI v2 specification's
+// Security Scheme object.
+//
+// See: https://github.com/OAI/OpenAPI-Specification/blob/3.0.0/versions/2.0.md#securitySchemeObject
+//
+// Allows the definition of a security scheme that can be used by the
+// operations. Supported schemes are basic authentication, an API key (either as
+// a header or as a query parameter) and OAuth2's common flows (implicit,
+// password, application and access code).
+message SecurityScheme {
+  // The type of the security scheme. Valid values are "basic",
+  // "apiKey" or "oauth2".
+  enum Type {
+    TYPE_INVALID = 0;
+    TYPE_BASIC = 1;
+    TYPE_API_KEY = 2;
+    TYPE_OAUTH2 = 3;
+  }
+
+  // The location of the API key. Valid values are "query" or "header".
+  enum In {
+    IN_INVALID = 0;
+    IN_QUERY = 1;
+    IN_HEADER = 2;
+  }
+
+  // The flow used by the OAuth2 security scheme. Valid values are
+  // "implicit", "password", "application" or "accessCode".
+  enum Flow {
+    FLOW_INVALID = 0;
+    FLOW_IMPLICIT = 1;
+    FLOW_PASSWORD = 2;
+    FLOW_APPLICATION = 3;
+    FLOW_ACCESS_CODE = 4;
+  }
+
+  // The type of the security scheme. Valid values are "basic",
+  // "apiKey" or "oauth2".
+  Type type = 1;
+  // A short description for security scheme.
+  string description = 2;
+  // The name of the header or query parameter to be used.
+  // Valid for apiKey.
+  string name = 3;
+  // The location of the API key. Valid values are "query" or
+  // "header".
+  // Valid for apiKey.
+  In in = 4;
+  // The flow used by the OAuth2 security scheme. Valid values are
+  // "implicit", "password", "application" or "accessCode".
+  // Valid for oauth2.
+  Flow flow = 5;
+  // The authorization URL to be used for this flow. This SHOULD be in
+  // the form of a URL.
+  // Valid for oauth2/implicit and oauth2/accessCode.
+  string authorization_url = 6;
+  // The token URL to be used for this flow. This SHOULD be in the
+  // form of a URL.
+  // Valid for oauth2/password, oauth2/application and oauth2/accessCode.
+  string token_url = 7;
+  // The available scopes for the OAuth2 security scheme.
+  // Valid for oauth2.
+  Scopes scopes = 8;
+  // Custom properties that start with "x-" such as "x-foo" used to describe
+  // extra functionality that is not covered by the standard OpenAPI Specification.
+  // See: https://swagger.io/docs/specification/2-0/swagger-extensions/
+  map<string, google.protobuf.Value> extensions = 9;
+}
+
+// `SecurityRequirement` is a representation of OpenAPI v2 specification's
+// Security Requirement object.
+//
+// See: https://github.com/OAI/OpenAPI-Specification/blob/3.0.0/versions/2.0.md#securityRequirementObject
+//
+// Lists the required security schemes to execute this operation. The object can
+// have multiple security schemes declared in it which are all required (that
+// is, there is a logical AND between the schemes).
+//
+// The name used for each property MUST correspond to a security scheme
+// declared in the Security Definitions.
+message SecurityRequirement {
+  // If the security scheme is of type "oauth2", then the value is a list of
+  // scope names required for the execution. For other security scheme types,
+  // the array MUST be empty.
+  message SecurityRequirementValue {
+    repeated string scope = 1;
+  }
+  // Each name must correspond to a security scheme which is declared in
+  // the Security Definitions. If the security scheme is of type "oauth2",
+  // then the value is a list of scope names required for the execution.
+  // For other security scheme types, the array MUST be empty.
+  map<string, SecurityRequirementValue> security_requirement = 1;
+}
+
+// `Scopes` is a representation of OpenAPI v2 specification's Scopes object.
+//
+// See: https://github.com/OAI/OpenAPI-Specification/blob/3.0.0/versions/2.0.md#scopesObject
+//
+// Lists the available scopes for an OAuth2 security scheme.
+message Scopes {
+  // Maps between a name of a scope to a short description of it (as the value
+  // of the property).
+  map<string, string> scope = 1;
+}