From aee7b01b40e3f27cc1a7ac9d29aa948969a321a5 Mon Sep 17 00:00:00 2001
From: Sinh <luuvansinh555@gmail.com>
Date: Wed, 1 Mar 2023 10:42:54 +0700
Subject: [PATCH] notify change price product

---
 client/product.go        | 17 +++++++++++++++++
 model/product_request.go |  5 +++++
 subject/product.go       |  2 ++
 3 files changed, 24 insertions(+)

diff --git a/client/product.go b/client/product.go
index a581b9d..3dc259d 100644
--- a/client/product.go
+++ b/client/product.go
@@ -50,3 +50,20 @@ func (c Product) ProcessApplyRequest(p model.ProductApplyRequestPayload) error {
 	}
 	return nil
 }
+
+func (c Product) RequestChangeStatus(p model.ProductRequestChangeStatus) error {
+	msg, err := natsio.GetServer().Request(subject.Product.RequestChangeStatus, 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
index 1adbec5..d2dcb91 100644
--- a/model/product_request.go
+++ b/model/product_request.go
@@ -3,3 +3,8 @@ package model
 type ProductApplyRequestPayload struct {
 	RequestID string `json:"requestId"`
 }
+
+type ProductRequestChangeStatus struct {
+	RequestID string `json:"requestId"`
+	Status    string `json:"status"`
+}
diff --git a/subject/product.go b/subject/product.go
index 348aca9..5ca822e 100644
--- a/subject/product.go
+++ b/subject/product.go
@@ -10,7 +10,9 @@ func getProductValue(val string) string {
 var Product = struct {
 	ApplyRequest        string
 	ProcessApplyRequest string
+	RequestChangeStatus string
 }{
 	ApplyRequest:        getProductValue("apply_request"),
 	ProcessApplyRequest: getProductValue("process_apply_request"),
+	RequestChangeStatus: getProductValue("request_change_status"),
 }