From bded4de2ebe6c2077fe099df69b303636e54650f Mon Sep 17 00:00:00 2001
From: trunglt251292 <trunglt251292@gmail.com>
Date: Tue, 15 Mar 2022 15:03:26 +0700
Subject: [PATCH] [Add] Func delete document + index

---
 elasticsearch.go | 11 +++++++++--
 1 file changed, 9 insertions(+), 2 deletions(-)

diff --git a/elasticsearch.go b/elasticsearch.go
index 8a7a3ae..ac2ba6b 100644
--- a/elasticsearch.go
+++ b/elasticsearch.go
@@ -116,12 +116,19 @@ func (c *Client) CreateIndex(name string) (bool, error) {
 			ApiKey: c.Config.ApiKey,
 			Body:   toBytes(name),
 		}
+		res *Response
 	)
-	err := c.natsJetStream.Publish(JetStreamSearchService, SubjectCreateIndex, toBytes(req))
+	msg, err := c.natsServer.Request(SubjectCreateIndex, toBytes(req))
 	if err != nil {
 		return false, err
 	}
-	return true, nil
+	if err = json.Unmarshal(msg.Data, &res); err != nil {
+		return false, err
+	}
+	if res.Message != "" {
+		return false, errors.New(res.Message)
+	}
+	return res.Success, nil
 }
 
 func toBytes(data interface{}) []byte {