From b19fea04c8b9d76c66f1b3028d32af1ab3fceb1c Mon Sep 17 00:00:00 2001 From: Sinh Date: Mon, 26 Dec 2022 14:08:14 +0700 Subject: [PATCH] define nats product --- client/product.go | 35 +++++++++++++++++++++++++++++++++++ model/product_request.go | 5 +++++ subject/config.go | 2 ++ subject/product.go | 14 ++++++++++++++ 4 files changed, 56 insertions(+) create mode 100644 client/product.go create mode 100644 model/product_request.go create mode 100644 subject/product.go diff --git a/client/product.go b/client/product.go new file mode 100644 index 0000000..340ba21 --- /dev/null +++ b/client/product.go @@ -0,0 +1,35 @@ +package client + +import ( + "encoding/json" + "errors" + + "git.selly.red/Selly-Modules/natsio" + "git.selly.red/Selly-Modules/natsio/model" + "git.selly.red/Selly-Modules/natsio/subject" +) + +// Product ... +type Product struct{} + +// GetProduct ... +func GetProduct() Product { + return Product{} +} + +func (c Product) ApplyRequest(p model.ProductApplyRequestPayload) error { + msg, err := natsio.GetServer().Request(subject.Product.ApplyRequest, toBytes(p)) + if err != nil { + return err + } + var r struct { + Error string `json:"error"` + } + if err = json.Unmarshal(msg.Data, &r); err != nil { + return err + } + if r.Error != "" { + return errors.New(r.Error) + } + return nil +} diff --git a/model/product_request.go b/model/product_request.go new file mode 100644 index 0000000..1adbec5 --- /dev/null +++ b/model/product_request.go @@ -0,0 +1,5 @@ +package model + +type ProductApplyRequestPayload struct { + RequestID string `json:"requestId"` +} diff --git a/subject/config.go b/subject/config.go index 1954121..483f963 100644 --- a/subject/config.go +++ b/subject/config.go @@ -14,6 +14,7 @@ var prefixes = struct { SocialPost string Staff string Segment string + Product string Campaign string Affiliate string }{ @@ -30,6 +31,7 @@ var prefixes = struct { SocialPost: "social_post", Staff: "staff", Segment: "segment", + Product: "product", Campaign: "campaign", Affiliate: "affiliate", } diff --git a/subject/product.go b/subject/product.go new file mode 100644 index 0000000..3911ecb --- /dev/null +++ b/subject/product.go @@ -0,0 +1,14 @@ +package subject + +import "fmt" + +// getSegmentValue ... +func getProductValue(val string) string { + return fmt.Sprintf("%s.%s", prefixes.Product, val) +} + +var Product = struct { + ApplyRequest string +}{ + ApplyRequest: getProductValue("apply_request"), +}