Fix Handle error message (#3)

* chore: update restclientgo v1.1.0

* chore: handle error message

go.mod

@@ -2,4 +2,4 @@ module github.com/henomis/qdrant-go
 
 go 1.20
 
-require github.com/henomis/restclientgo v1.0.5
+require github.com/henomis/restclientgo v1.1.0

go.sum

@@ -1,2 +1,2 @@
-github.com/henomis/restclientgo v1.0.5 h1:xMuznJLagE8nGrmFPyBkzsDztJm2A7uMLNGMBY5iWSg=
-github.com/henomis/restclientgo v1.0.5/go.mod h1:xIeTCu2ZstvRn0fCukNpzXLN3m/kRTU0i0RwAbv7Zug=
+github.com/henomis/restclientgo v1.1.0 h1:qNhBpTwYXuwfy6SL2EWjbfTrlUw70PZYmqQ4jewdu5E=
+github.com/henomis/restclientgo v1.1.0/go.mod h1:xIeTCu2ZstvRn0fCukNpzXLN3m/kRTU0i0RwAbv7Zug=

qdrantgo.go

@@ -18,7 +18,7 @@ type Client struct {
 
 func New(endpoint, apiKey string) *Client {
 
-	restClient := restclientgo.New(endpoint)
+	restClient := restclientgo.New(endpoint).WithDecodeOnError(true)
 
 	if len(apiKey) > 0 {
 		restClient.SetRequestModifier(func(req *http.Request) *http.Request {

response/collectionCollectInfo.go

@@ -73,5 +73,11 @@ func (c *CollectionCollectInfo) AcceptContentType() string {
 }
 
 func (c *CollectionCollectInfo) Decode(body io.Reader) error {
-	return json.NewDecoder(body).Decode(c)
+	err := json.NewDecoder(body).Decode(c)
+	if err != nil {
+		return err
+	}
+
+	c.Response.SetStatusMessage()
+	return nil
 }

response/collectionCreate.go

@@ -15,5 +15,11 @@ func (c *CollectionCreate) AcceptContentType() string {
 }
 
 func (c *CollectionCreate) Decode(body io.Reader) error {
-	return json.NewDecoder(body).Decode(c)
+	err := json.NewDecoder(body).Decode(c)
+	if err != nil {
+		return err
+	}
+
+	c.Response.SetStatusMessage()
+	return nil
 }

response/collectionDelete.go

@@ -15,5 +15,11 @@ func (c *CollectionDelete) AcceptContentType() string {
 }
 
 func (c *CollectionDelete) Decode(body io.Reader) error {
-	return json.NewDecoder(body).Decode(c)
+	err := json.NewDecoder(body).Decode(c)
+	if err != nil {
+		return err
+	}
+
+	c.Response.SetStatusMessage()
+	return nil
 }

response/collectionList.go

@@ -23,5 +23,11 @@ func (c *CollectionList) AcceptContentType() string {
 }
 
 func (c *CollectionList) Decode(body io.Reader) error {
-	return json.NewDecoder(body).Decode(c)
+	err := json.NewDecoder(body).Decode(c)
+	if err != nil {
+		return err
+	}
+
+	c.Response.SetStatusMessage()
+	return nil
 }

response/collectionUpdate.go

@@ -15,5 +15,11 @@ func (c *CollectionUpdate) AcceptContentType() string {
 }
 
 func (c *CollectionUpdate) Decode(body io.Reader) error {
-	return json.NewDecoder(body).Decode(c)
+	err := json.NewDecoder(body).Decode(c)
+	if err != nil {
+		return err
+	}
+
+	c.Response.SetStatusMessage()
+	return nil
 }

response/indexCreate.go

@@ -15,5 +15,11 @@ func (c *IndexCreate) AcceptContentType() string {
 }
 
 func (c *IndexCreate) Decode(body io.Reader) error {
-	return json.NewDecoder(body).Decode(c)
+	err := json.NewDecoder(body).Decode(c)
+	if err != nil {
+		return err
+	}
+
+	c.Response.SetStatusMessage()
+	return nil
 }

response/pointDelete.go

@@ -15,5 +15,11 @@ func (p *PointDelete) AcceptContentType() string {
 }
 
 func (p *PointDelete) Decode(body io.Reader) error {
-	return json.NewDecoder(body).Decode(p)
+	err := json.NewDecoder(body).Decode(p)
+	if err != nil {
+		return err
+	}
+
+	p.Response.SetStatusMessage()
+	return nil
 }

response/pointGet.go

@@ -21,5 +21,11 @@ func (p *PointGet) AcceptContentType() string {
 }
 
 func (p *PointGet) Decode(body io.Reader) error {
-	return json.NewDecoder(body).Decode(p)
+	err := json.NewDecoder(body).Decode(p)
+	if err != nil {
+		return err
+	}
+
+	p.Response.SetStatusMessage()
+	return nil
 }

response/pointSearch.go

@@ -23,5 +23,11 @@ func (p *PointSearch) AcceptContentType() string {
 }
 
 func (p *PointSearch) Decode(body io.Reader) error {
-	return json.NewDecoder(body).Decode(p)
+	err := json.NewDecoder(body).Decode(p)
+	if err != nil {
+		return err
+	}
+
+	p.Response.SetStatusMessage()
+	return nil
 }

response/pointUpsert.go

@@ -27,5 +27,11 @@ func (p *PointUpsert) AcceptContentType() string {
 }
 
 func (p *PointUpsert) Decode(body io.Reader) error {
-	return json.NewDecoder(body).Decode(p)
+	err := json.NewDecoder(body).Decode(p)
+	if err != nil {
+		return err
+	}
+
+	p.Response.SetStatusMessage()
+	return nil
 }

response/pointsGet.go

@@ -21,5 +21,11 @@ func (p *PointsGet) AcceptContentType() string {
 }
 
 func (p *PointsGet) Decode(body io.Reader) error {
-	return json.NewDecoder(body).Decode(p)
+	err := json.NewDecoder(body).Decode(p)
+	if err != nil {
+		return err
+	}
+
+	p.Response.SetStatusMessage()
+	return nil
 }

response/response.go

@@ -7,10 +7,11 @@ import (
 )
 
 type Response struct {
-	Code    int     `json:"-"`
-	Time    float64 `json:"time"`
-	Status  string  `json:"status"`
-	RawBody *string `json:"-"`
+	Code      int     `json:"-"`
+	Time      float64 `json:"time"`
+	RawStatus any     `json:"status"`
+	Status    string  `json:"-"`
+	RawBody   *string `json:"-"`
 }
 
 type Detail struct {
@@ -43,3 +44,14 @@ func (r *Response) SetBody(body io.Reader) error {
 func (r *Response) SetHeaders(headers restclientgo.Headers) error {
 	return nil
 }
+
+func (r *Response) SetStatusMessage() {
+	switch status := r.RawStatus.(type) {
+	case string:
+		r.Status = status
+	case map[string]interface{}:
+		if errorMessage, ok := status["error"].(string); ok {
+			r.Status = errorMessage
+		}
+	}
+}