From 1d58e55af736b32c7526d711161ef9509d6bb83f Mon Sep 17 00:00:00 2001
From: trunglt251292 <trunglt251292@gmail.com>
Date: Tue, 20 Sep 2022 10:28:35 +0700
Subject: [PATCH] [Update] Request news

---
 client/news.go         | 28 ++++++++++++++++++++++++++++
 model/news_request.go  |  6 ++++++
 model/news_response.go | 38 ++++++++++++++++++++++++++++++++++++++
 subject/config.go      |  2 ++
 subject/news.go        | 13 +++++++++++++
 5 files changed, 87 insertions(+)
 create mode 100644 client/news.go
 create mode 100644 model/news_request.go
 create mode 100644 model/news_response.go
 create mode 100644 subject/news.go

diff --git a/client/news.go b/client/news.go
new file mode 100644
index 0000000..162162d
--- /dev/null
+++ b/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
+}
diff --git a/model/news_request.go b/model/news_request.go
new file mode 100644
index 0000000..fb886e3
--- /dev/null
+++ b/model/news_request.go
@@ -0,0 +1,6 @@
+package model
+
+// GetProductNoticesByInventoryRequest ....
+type GetProductNoticesByInventoryRequest struct {
+	InventoryIds []string `json:"inventoryIds"`
+}
diff --git a/model/news_response.go b/model/news_response.go
new file mode 100644
index 0000000..4b496c4
--- /dev/null
+++ b/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"`
+}
diff --git a/subject/config.go b/subject/config.go
index dfeea56..259e7ba 100644
--- a/subject/config.go
+++ b/subject/config.go
@@ -3,12 +3,14 @@ package subject
 var prefixes = struct {
 	Communication string
 	Order         string
+	News          string
 	Warehouse     string
 	Location      string
 	Supplier      string
 }{
 	Communication: "communication",
 	Order:         "order",
+	News:          "news",
 	Warehouse:     "warehouse",
 	Location:      "location",
 	Supplier:      "supplier",
diff --git a/subject/news.go b/subject/news.go
new file mode 100644
index 0000000..3e96d25
--- /dev/null
+++ b/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"),
+}