client/news.go

@@ -0,0 +1,28 @@
+package client
+
+import (
+	"encoding/json"
+	"errors"
+	"github.com/Selly-Modules/natsio"
+	"github.com/Selly-Modules/natsio/model"
+	"github.com/Selly-Modules/natsio/subject"
+)
+
+// GetProductNoticesByInventory ...
+func (w Warehouse) GetProductNoticesByInventory(p model.GetProductNoticesByInventoryRequest) (*model.GetProductNoticesByInventoryResponse, error) {
+	msg, err := natsio.GetServer().Request(subject.News.GetProductNoticesByInventory, bsonToBytes(p))
+	if err != nil {
+		return nil, err
+	}
+	var r struct {
+		Data  *model.GetProductNoticesByInventoryResponse `json:"data"`
+		Error string                                      `json:"error"`
+	}
+	if err = json.Unmarshal(msg.Data, &r); err != nil {
+		return nil, err
+	}
+	if r.Error != "" {
+		return nil, errors.New(r.Error)
+	}
+	return r.Data, nil
+}

model/news_request.go

@@ -0,0 +1,6 @@
+package model
+
+// GetProductNoticesByInventoryRequest ....
+type GetProductNoticesByInventoryRequest struct {
+	InventoryIds []string `json:"inventoryIds"`
+}

model/news_response.go

@@ -0,0 +1,38 @@
+package model
+
+// GetProductNoticesByInventoryResponse ....
+type GetProductNoticesByInventoryResponse struct {
+	Notices []NewsAppResponse `json:"notices"`
+}
+
+// NewsAppResponse ...
+type NewsAppResponse struct {
+	ID           string        `json:"_id"`
+	Title        string        `json:"title,omitempty"`
+	Target       *TargetNewDoc `json:"target,omitempty"`
+	ActionType   *ActionType   `json:"action"`
+	ShortDesc    string        `json:"shortDesc,omitempty"`
+	Type         string        `json:"type"`
+	ShortTitle   string        `json:"shortTitle,omitempty"`
+	Color        string        `json:"color"`
+	Options      *NewsOptions  `json:"options,omitempty"`
+	DisplayStyle string        `json:"displayStyle"`
+}
+
+// NewsOptions ...
+type NewsOptions struct {
+	Category string `json:"category"`
+}
+
+// TargetNewDoc ...
+type TargetNewDoc struct {
+	Type  string `json:"type,omitempty"`
+	Value string `json:"value,omitempty"`
+}
+
+// ActionType ...
+type ActionType struct {
+	Type  string `json:"type"`
+	Value string `json:"value"`
+	Text  string `json:"text,omitempty"`
+}

subject/config.go

@@ -3,6 +3,7 @@ package subject
 var prefixes = struct {
 	Communication string
 	Order         string
+	News          string
 	Warehouse     string
 	Location      string
 	Bank          string
@@ -11,6 +12,7 @@ var prefixes = struct {
 }{
 	Communication: "communication",
 	Order:         "order",
+	News:          "news",
 	Warehouse:     "warehouse",
 	Location:      "location",
 	Supplier:      "supplier",

subject/news.go

@@ -0,0 +1,13 @@
+package subject
+
+import "fmt"
+
+func getNewsValue(val string) string {
+	return fmt.Sprintf("%s.%s", prefixes.Order, val)
+}
+
+var News = struct {
+	GetProductNoticesByInventory string
+}{
+	GetProductNoticesByInventory: getNewsValue("get_product_notices_by_inventory"),
+}