Compare commits

..

No commits in common. "0960f3e9dcf495c205ee3b886b2236eb76669dbd" and "286048d06860f473ce41d807dd14d228d33dacc7" have entirely different histories.

5 changed files with 28 additions and 74 deletions

View File

@ -1,8 +1,6 @@
package main
import (
"cake_crm/internal/app"
"cake_crm/internal/models/storage/storage_file"
crm "cake_crm/proto"
"context"
"github.com/grpc-ecosystem/grpc-gateway/v2/runtime"
@ -13,12 +11,30 @@ import (
"net/http"
)
type server struct {
crm.UnimplementedCRMServer
}
func NewServer() *server {
return &server{}
}
func (s *server) GetCatalog(ctx context.Context, req *crm.GetCatalogReq) (*crm.CatalogRsp, error) {
return nil, nil
}
func main() {
//ctx, cancel := context.WithCancel(context.Background())
//defer cancel()
storage := storage_file.NewStorageFile()
_ = storage
//
//storage := storage_file.NewStorageFile("resources/db.json")
//_ = storage
//
//server := server_web.NewServer(storage, 8080)
//err := server.Run(ctx)
//if err != nil {
// panic(err)
//}
// Create a listener on TCP port
lis, err := net.Listen("tcp", ":8080")
@ -29,7 +45,7 @@ func main() {
// Create a gRPC server object
s := grpc.NewServer()
// Attach the Greeter service to the server
crm.RegisterCRMServer(s, app.NewServer(storage))
crm.RegisterCRMServer(s, &server{})
// Serve gRPC server
log.Println("Serving gRPC on 0.0.0.0:8080")
go func() {

View File

@ -1,26 +0,0 @@
package app
import (
"cake_crm/internal/models/storage"
crm "cake_crm/proto"
"context"
)
type Server struct {
crm.UnimplementedCRMServer
storage storage.IStorage
}
func NewServer(storage storage.IStorage) *Server {
return &Server{
storage: storage,
}
}
func (s *Server) GetCatalog(ctx context.Context, _ *crm.GetCatalogReq) (*crm.CatalogRsp, error) {
categories, err := s.storage.GetCatalog(ctx)
if err != nil {
return nil, err
}
return &crm.CatalogRsp{Categories: categories}, nil
}

View File

@ -1,9 +1,6 @@
package storage
import (
crm "cake_crm/proto"
"context"
)
import "context"
type Product struct {
ID int `json:"id"`
@ -20,5 +17,4 @@ type IStorage interface {
GetAllProducts(ctx context.Context) ([]Product, error)
GetProductByID(ctx context.Context, id int) (Product, error)
GetBreadcrumbs(ctx context.Context, id int) ([]Breadcrumb, error)
GetCatalog(ctx context.Context) ([]*crm.CatalogRsp_Category, error)
}

View File

@ -2,28 +2,17 @@ package storage_file
import (
"cake_crm/internal/models/storage"
crm "cake_crm/proto"
"context"
"encoding/json"
"os"
)
type storageFile struct{}
func NewStorageFile() storage.IStorage {
return &storageFile{}
type storageFile struct {
filepath string
}
func (s *storageFile) GetCatalog(_ context.Context) ([]*crm.CatalogRsp_Category, error) {
data, err := os.ReadFile("resources/catalog.json")
if err != nil {
return nil, err
func NewStorageFile(filepath string) storage.IStorage {
return &storageFile{
filepath: filepath,
}
var res []*crm.CatalogRsp_Category
if err := json.Unmarshal(data, &res); err != nil {
return nil, err
}
return res, nil
}
func (s *storageFile) GetAllProducts(ctx context.Context) ([]storage.Product, error) {

View File

@ -1,21 +0,0 @@
[
{
"id": 0,
"name": "Главная",
"uri": "/categories/0",
"children": [
{
"id": 1,
"name": "Пряники",
"uri": "/categories/1",
"children": []
},
{
"id": 2,
"name": "Пахлава",
"uri": "/categories/2",
"children": []
}
]
}
]