From 856de8023bf9a01013cccc16cbbdd4734d88c1bf Mon Sep 17 00:00:00 2001
From: Serhii Makogon <serhiimakogon@gmail.com>
Date: Tue, 27 Dec 2022 12:13:47 +0200
Subject: [PATCH] ksql client. check response status code

---
 examples/main.tf      | 12 +++++++-----
 ksql/client/client.go |  4 ++++
 2 files changed, 11 insertions(+), 5 deletions(-)

diff --git a/examples/main.tf b/examples/main.tf
index e192514..691625e 100644
--- a/examples/main.tf
+++ b/examples/main.tf
@@ -7,14 +7,16 @@ terraform {
   }
 }
 
-provider "ksql" {
-  url      = ""
-  username = ""
-  password = ""
-}
+provider "ksql" {}
 
 resource "ksql_query" "products_hot_table_table" {
   name  = "products_hot_table"
   type  = "table"
   query = "CREATE TABLE PRODUCTS_HOT_TABLE (ITEM_KEY STRING PRIMARY KEY) WITH (KAFKA_TOPIC = 'PRODUCTS_HOT',VALUE_FORMAT = 'AVRO');"
+
+  credentials {
+    url      = ""
+    username = ""
+    password = ""
+  }
 }
diff --git a/ksql/client/client.go b/ksql/client/client.go
index cf4ad6d..0b76615 100644
--- a/ksql/client/client.go
+++ b/ksql/client/client.go
@@ -98,6 +98,10 @@ func (c *Client) makePostKsqlRequest(ctx context.Context, query string) (Respons
 		return nil, err
 	}
 
+	if sc := resp.StatusCode; sc < 200 || sc > 300 {
+		return nil, fmt.Errorf("invalid response status code [%d], body [%s]", sc, string(body))
+	}
+
 	res := Response{}
 	err = json.Unmarshal(body, &res)
 	if err != nil {