mats/go-cart-actor
1
0
Fork 0
Code Issues Pull Requests 1 Actions 3 Packages Projects Releases Wiki Activity

manually fix json casing
All checks were successful
Build and Publish / BuildAndDeployAmd64 (push) Successful in 27s
Details
Build and Publish / BuildAndDeploy (push) Successful in 2m25s
Details

Browse Source
This commit is contained in:
matst80
2024-11-14 20:19:02 +01:00
parent 9a80d74325
commit 352c570f0b
2 changed files with 52 additions and 33 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
pool-server.go
View File

@@ -179,10 +179,29 @@ func (s *PoolServer) HandleQuantityChange(w http.ResponseWriter, r *http.Request
return s.WriteResult(w, reply) return s.WriteResult(w, reply)
} }
func (s *PoolServer) HandleAddRequest(w http.ResponseWriter, r *http.Request) error {
id := r.PathValue("id")
pickupPoint := messages.AddRequest{}
err := json.NewDecoder(r.Body).Decode(&pickupPoint)
if err != nil {
return err
}
reply, err := s.pool.Process(ToCartId(id), Message{
Type: AddRequestType,
Content: &pickupPoint,
})
if err != nil {
return err
}
return s.WriteResult(w, reply)
}
func (s *PoolServer) Serve() *http.ServeMux { func (s *PoolServer) Serve() *http.ServeMux {
mux := http.NewServeMux() mux := http.NewServeMux()
mux.HandleFunc("GET /{id}", ErrorHandler(s.HandleGet)) mux.HandleFunc("GET /{id}", ErrorHandler(s.HandleGet))
mux.HandleFunc("GET /{id}/add/{sku}", ErrorHandler(s.HandleAddSku)) mux.HandleFunc("GET /{id}/add/{sku}", ErrorHandler(s.HandleAddSku))
mux.HandleFunc("POST /{id}", ErrorHandler(s.HandleAddRequest))
mux.HandleFunc("DELETE /{id}/{itemId}", ErrorHandler(s.HandleDeleteItem)) mux.HandleFunc("DELETE /{id}/{itemId}", ErrorHandler(s.HandleDeleteItem))
mux.HandleFunc("PUT /{id}/{itemId}", ErrorHandler(s.HandleQuantityChange)) mux.HandleFunc("PUT /{id}/{itemId}", ErrorHandler(s.HandleQuantityChange))
mux.HandleFunc("POST /{id}/delivery", ErrorHandler(s.HandleSetDelivery)) mux.HandleFunc("POST /{id}/delivery", ErrorHandler(s.HandleSetDelivery))

66
proto/messages.pb.go
View File

@@ -25,8 +25,8 @@ type AddRequest struct {
sizeCache protoimpl.SizeCache sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields unknownFields protoimpl.UnknownFields
Quantity int32 `protobuf:"varint,1,opt,name=Quantity,proto3" json:"Quantity,omitempty"` Quantity int32 `protobuf:"varint,1,opt,name=Quantity,proto3" json:"quantity,omitempty"`
Sku string `protobuf:"bytes,2,opt,name=Sku,proto3" json:"Sku,omitempty"` Sku string `protobuf:"bytes,2,opt,name=Sku,proto3" json:"sku,omitempty"`
} }
func (x *AddRequest) Reset() { func (x *AddRequest) Reset() {
@@ -78,17 +78,17 @@ type AddItem struct {
sizeCache protoimpl.SizeCache sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields unknownFields protoimpl.UnknownFields
Quantity int32 `protobuf:"varint,2,opt,name=Quantity,proto3" json:"Quantity,omitempty"` Quantity int32 `protobuf:"varint,2,opt,name=Quantity,proto3" json:"quantity,omitempty"`
Price int64 `protobuf:"varint,3,opt,name=Price,proto3" json:"Price,omitempty"` Price int64 `protobuf:"varint,3,opt,name=Price,proto3" json:"price,omitempty"`
OrgPrice int64 `protobuf:"varint,9,opt,name=OrgPrice,proto3" json:"OrgPrice,omitempty"` OrgPrice int64 `protobuf:"varint,9,opt,name=OrgPrice,proto3" json:"orgPrice,omitempty"`
Sku string `protobuf:"bytes,4,opt,name=Sku,proto3" json:"Sku,omitempty"` Sku string `protobuf:"bytes,4,opt,name=Sku,proto3" json:"sku,omitempty"`
Name string `protobuf:"bytes,5,opt,name=Name,proto3" json:"Name,omitempty"` Name string `protobuf:"bytes,5,opt,name=Name,proto3" json:"name,omitempty"`
Image string `protobuf:"bytes,6,opt,name=Image,proto3" json:"Image,omitempty"` Image string `protobuf:"bytes,6,opt,name=Image,proto3" json:"image,omitempty"`
Stock int32 `protobuf:"varint,7,opt,name=Stock,proto3" json:"Stock,omitempty"` Stock int32 `protobuf:"varint,7,opt,name=Stock,proto3" json:"stock,omitempty"`
Tax int32 `protobuf:"varint,8,opt,name=Tax,proto3" json:"Tax,omitempty"` Tax int32 `protobuf:"varint,8,opt,name=Tax,proto3" json:"tax,omitempty"`
Disclaimer string `protobuf:"bytes,10,opt,name=Disclaimer,proto3" json:"Disclaimer,omitempty"` Disclaimer string `protobuf:"bytes,10,opt,name=Disclaimer,proto3" json:"disclaimer,omitempty"`
ArticleType string `protobuf:"bytes,11,opt,name=ArticleType,proto3" json:"ArticleType,omitempty"` ArticleType string `protobuf:"bytes,11,opt,name=ArticleType,proto3" json:"articleType,omitempty"`
Outlet *string `protobuf:"bytes,12,opt,name=Outlet,proto3,oneof" json:"Outlet,omitempty"` Outlet *string `protobuf:"bytes,12,opt,name=Outlet,proto3,oneof" json:"outlet,omitempty"`
} }
func (x *AddItem) Reset() { func (x *AddItem) Reset() {
@@ -203,7 +203,7 @@ type RemoveItem struct {
sizeCache protoimpl.SizeCache sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields unknownFields protoimpl.UnknownFields
Id int64 `protobuf:"varint,1,opt,name=Id,proto3" json:"Id,omitempty"` Id int64 `protobuf:"varint,1,opt,name=Id,proto3" json:"id,omitempty"`
} }
func (x *RemoveItem) Reset() { func (x *RemoveItem) Reset() {
@@ -248,8 +248,8 @@ type ChangeQuantity struct {
sizeCache protoimpl.SizeCache sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields unknownFields protoimpl.UnknownFields
Id int64 `protobuf:"varint,1,opt,name=Id,proto3" json:"Id,omitempty"` Id int64 `protobuf:"varint,1,opt,name=Id,proto3" json:"id,omitempty"`
Quantity int32 `protobuf:"varint,2,opt,name=Quantity,proto3" json:"Quantity,omitempty"` Quantity int32 `protobuf:"varint,2,opt,name=Quantity,proto3" json:"quantity,omitempty"`
} }
func (x *ChangeQuantity) Reset() { func (x *ChangeQuantity) Reset() {
@@ -301,9 +301,9 @@ type SetDelivery struct {
sizeCache protoimpl.SizeCache sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields unknownFields protoimpl.UnknownFields
Provider string `protobuf:"bytes,1,opt,name=Provider,proto3" json:"Provider,omitempty"` Provider string `protobuf:"bytes,1,opt,name=Provider,proto3" json:"provider,omitempty"`
Items []int64 `protobuf:"varint,2,rep,packed,name=Items,proto3" json:"Items,omitempty"` Items []int64 `protobuf:"varint,2,rep,packed,name=Items,proto3" json:"items,omitempty"`
PickupPoint *PickupPoint `protobuf:"bytes,3,opt,name=PickupPoint,proto3,oneof" json:"PickupPoint,omitempty"` PickupPoint *PickupPoint `protobuf:"bytes,3,opt,name=PickupPoint,proto3,oneof" json:"pickupPoint,omitempty"`
} }
func (x *SetDelivery) Reset() { func (x *SetDelivery) Reset() {
@@ -362,13 +362,13 @@ type SetPickupPoint struct {
sizeCache protoimpl.SizeCache sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields unknownFields protoimpl.UnknownFields
DeliveryId int64 `protobuf:"varint,1,opt,name=DeliveryId,proto3" json:"DeliveryId,omitempty"` DeliveryId int64 `protobuf:"varint,1,opt,name=DeliveryId,proto3" json:"deliveryId,omitempty"`
Id string `protobuf:"bytes,2,opt,name=Id,proto3" json:"Id,omitempty"` Id string `protobuf:"bytes,2,opt,name=Id,proto3" json:"id,omitempty"`
Name *string `protobuf:"bytes,3,opt,name=Name,proto3,oneof" json:"Name,omitempty"` Name *string `protobuf:"bytes,3,opt,name=Name,proto3,oneof" json:"name,omitempty"`
Address *string `protobuf:"bytes,4,opt,name=Address,proto3,oneof" json:"Address,omitempty"` Address *string `protobuf:"bytes,4,opt,name=Address,proto3,oneof" json:"address,omitempty"`
City *string `protobuf:"bytes,5,opt,name=City,proto3,oneof" json:"City,omitempty"` City *string `protobuf:"bytes,5,opt,name=City,proto3,oneof" json:"city,omitempty"`
Zip *string `protobuf:"bytes,6,opt,name=Zip,proto3,oneof" json:"Zip,omitempty"` Zip *string `protobuf:"bytes,6,opt,name=Zip,proto3,oneof" json:"zip,omitempty"`
Country *string `protobuf:"bytes,7,opt,name=Country,proto3,oneof" json:"Country,omitempty"` Country *string `protobuf:"bytes,7,opt,name=Country,proto3,oneof" json:"country,omitempty"`
} }
func (x *SetPickupPoint) Reset() { func (x *SetPickupPoint) Reset() {
@@ -455,12 +455,12 @@ type PickupPoint struct {
sizeCache protoimpl.SizeCache sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields unknownFields protoimpl.UnknownFields
Id string `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"` Id string `protobuf:"bytes,1,opt,name=Id,proto3" json:"id,omitempty"`
Name *string `protobuf:"bytes,2,opt,name=Name,proto3,oneof" json:"Name,omitempty"` Name *string `protobuf:"bytes,2,opt,name=Name,proto3,oneof" json:"name,omitempty"`
Address *string `protobuf:"bytes,3,opt,name=Address,proto3,oneof" json:"Address,omitempty"` Address *string `protobuf:"bytes,3,opt,name=Address,proto3,oneof" json:"address,omitempty"`
City *string `protobuf:"bytes,4,opt,name=City,proto3,oneof" json:"City,omitempty"` City *string `protobuf:"bytes,4,opt,name=City,proto3,oneof" json:"city,omitempty"`
Zip *string `protobuf:"bytes,5,opt,name=Zip,proto3,oneof" json:"Zip,omitempty"` Zip *string `protobuf:"bytes,5,opt,name=Zip,proto3,oneof" json:"zip,omitempty"`
Country *string `protobuf:"bytes,6,opt,name=Country,proto3,oneof" json:"Country,omitempty"` Country *string `protobuf:"bytes,6,opt,name=Country,proto3,oneof" json:"country,omitempty"`
} }
func (x *PickupPoint) Reset() { func (x *PickupPoint) Reset() {
@@ -540,7 +540,7 @@ type RemoveDelivery struct {
sizeCache protoimpl.SizeCache sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields unknownFields protoimpl.UnknownFields
Id int64 `protobuf:"varint,1,opt,name=Id,proto3" json:"Id,omitempty"` Id int64 `protobuf:"varint,1,opt,name=Id,proto3" json:"id,omitempty"`
} }
func (x *RemoveDelivery) Reset() { func (x *RemoveDelivery) Reset() {