From ef7c1788265ed794aa6dca03518e92bd6fa59970 Mon Sep 17 00:00:00 2001
From: Tomas Fabian <tomas.fabian@colosseoeas.com>
Date: Sun, 18 Apr 2021 12:23:35 +0200
Subject: [PATCH] [Kafka.DotNet.ksqlDB] -
 HttpResponseMessageExtensions.ToStatementResponses

---
 .../HttpResponseMessageExtensions.cs          | 27 +++++++++++++++++++
 .../RestApi/Statements/StatementResponse.cs   |  4 ++-
 2 files changed, 30 insertions(+), 1 deletion(-)
 create mode 100644 Joker.Kafka/KSql/RestApi/Extensions/HttpResponseMessageExtensions.cs

diff --git a/Joker.Kafka/KSql/RestApi/Extensions/HttpResponseMessageExtensions.cs b/Joker.Kafka/KSql/RestApi/Extensions/HttpResponseMessageExtensions.cs
new file mode 100644
index 00000000..259a64ec
--- /dev/null
+++ b/Joker.Kafka/KSql/RestApi/Extensions/HttpResponseMessageExtensions.cs
@@ -0,0 +1,27 @@
+using System.Net.Http;
+using System.Text.Json;
+using Kafka.DotNet.ksqlDB.KSql.RestApi.Statements;
+
+namespace Kafka.DotNet.ksqlDB.KSql.RestApi.Extensions
+{
+  public static class HttpResponseMessageExtensions
+  {
+    public static StatementResponse[] ToStatementResponses(this HttpResponseMessage httpResponseMessage)
+    {
+      string responseContent = httpResponseMessage.Content.ReadAsStringAsync().Result;
+      
+      var responseObjects = JsonSerializer.Deserialize<StatementResponse[]>(responseContent);
+
+      return responseObjects;
+    }
+
+    public static StatementResponse ToStatementResponse(this HttpResponseMessage httpResponseMessage)
+    {
+      string responseContent = httpResponseMessage.Content.ReadAsStringAsync().Result;
+      
+      var responseObject = JsonSerializer.Deserialize<StatementResponse>(responseContent);
+
+      return responseObject;
+    }
+  }
+}
\ No newline at end of file
diff --git a/Joker.Kafka/KSql/RestApi/Statements/StatementResponse.cs b/Joker.Kafka/KSql/RestApi/Statements/StatementResponse.cs
index a866ce9d..fbf366ef 100644
--- a/Joker.Kafka/KSql/RestApi/Statements/StatementResponse.cs
+++ b/Joker.Kafka/KSql/RestApi/Statements/StatementResponse.cs
@@ -1,4 +1,6 @@
-using System.Text.Json.Serialization;
+using System;
+using System.Net;
+using System.Text.Json.Serialization;
 
 namespace Kafka.DotNet.ksqlDB.KSql.RestApi.Statements
 {