From ce72c5673cf721ef3d82ed265e689e6e21b0a5fd Mon Sep 17 00:00:00 2001
From: trunglt251292 <trunglt251292@gmail.com>
Date: Mon, 22 Aug 2022 09:45:56 +0700
Subject: [PATCH 1/2] [Update] struct query es

---
 struct.go | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/struct.go b/struct.go
index 1f8f737..26f9b85 100644
--- a/struct.go
+++ b/struct.go
@@ -43,6 +43,8 @@ type ESQuery struct {
 	Keyword               string
 	ProvinceCode          int
 	Active                string
+	Display               string
+	ShopID                string
 	IsOutOfStock          string
 	CanIssueInvoice       string
 	PendingInactive       string
-- 
2.34.1


From 4b7175bd2b75e320867422357964ffd56401c210 Mon Sep 17 00:00:00 2001
From: trunglt251292 <trunglt251292@gmail.com>
Date: Mon, 22 Aug 2022 10:06:29 +0700
Subject: [PATCH 2/2] [Update] struct query es

---
 constants.go |  5 +++++
 pull.go      |  5 +++++
 request.go   | 15 +++++++++++++++
 3 files changed, 25 insertions(+)

diff --git a/constants.go b/constants.go
index dabd903..d5cab07 100644
--- a/constants.go
+++ b/constants.go
@@ -6,6 +6,11 @@ const (
 	SubjectRequestProductSkuSearch      = "selly.request.product_sku.search"
 	SubjectRequestProductSkuCreateIndex = "selly.request.product_sku.create_index"
 
+	SubjectRequestShopProductUpsert      = "selly.request.shop_product.upsert"
+	SubjectPullShopProductUpsert         = "selly.pull.shop_product.upsert"
+	SubjectRequestShopProductSearch      = "selly.request.shop_product.search"
+	SubjectRequestShopProductCreateIndex = "selly.request.shop_product.create_index"
+
 	SubjectRequestProductUpsert      = "selly.request.product.upsert"
 	SubjectPullProductUpsert         = "selly.pull.product.upsert"
 	SubjectRequestProductSearch      = "selly.request.product.search"
diff --git a/pull.go b/pull.go
index cb02ba9..1314383 100644
--- a/pull.go
+++ b/pull.go
@@ -28,3 +28,8 @@ func (Pull) KeywordUpsert(payload Payload) (bool, error) {
 func (Pull) ProductSkuUpsert(payload Payload) (bool, error) {
 	return publishWithJetStream(JetStreamSearchService, SubjectPullProductSkuUpsert, toBytes(payload))
 }
+
+// ProductShopUpsert ...
+func (Pull) ProductShopUpsert(payload Payload) (bool, error) {
+	return publishWithJetStream(JetStreamSearchService, SubjectPullShopProductUpsert, toBytes(payload))
+}
diff --git a/request.go b/request.go
index cb21ffe..543f680 100644
--- a/request.go
+++ b/request.go
@@ -4,6 +4,21 @@ package elasticsearch
 type Request struct {
 }
 
+// ProductShopSearch ...
+func (Request) ProductShopSearch(query ESQuery) (*Response, error) {
+	return requestNats(SubjectRequestShopProductSearch, toBytes(query))
+}
+
+// ProductShopUpsert ...
+func (Request) ProductShopUpsert(payload Payload) (*Response, error) {
+	return requestNats(SubjectRequestShopProductUpsert, toBytes(payload))
+}
+
+// ProductShopCreateIndex ...
+func (Request) ProductShopCreateIndex() (*Response, error) {
+	return requestNats(SubjectRequestShopProductCreateIndex, toBytes(Payload{}))
+}
+
 // ProductSkuSearch ...
 func (Request) ProductSkuSearch(query ESQuery) (*Response, error) {
 	return requestNats(SubjectRequestProductSkuSearch, toBytes(query))
-- 
2.34.1