Update elasticsearch client

xataio · Jan 17, 2025 · cb27bb2 · cb27bb2
1 parent 06abe69
commit cb27bb2
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/internal/searchstore/elasticsearch/elasticsearch_client.go b/internal/searchstore/elasticsearch/elasticsearch_client.go
@@ -422,13 +422,15 @@ func (ec *Client) SendBulkRequest(ctx context.Context, items []searchstore.BulkI
 		return nil, fmt.Errorf("perform: %w", err)
 	}
 	defer resp.Body.Close()
+
+	if resp.StatusCode > 299 {
+		return nil, fmt.Errorf("[SendBulkRequest] error response from Elasticsearch: %w", searchstore.ExtractResponseError(resp.Body, resp.StatusCode))
+	}
+
 	bodyBytes, err := io.ReadAll(resp.Body)
 	if err != nil {
 		return nil, fmt.Errorf("read body: %w", err)
 	}
-	if resp.StatusCode > 299 {
-		return nil, fmt.Errorf("error from Elasticsearch: %d: %s", resp.StatusCode, bodyBytes)
-	}
 
 	return searchstore.VerifyResponse(bodyBytes, items)
 }