[Kafka.DotNet.ksqlDB] - HttpResponseMessageExtensions.ToStatementResp…

…onses

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;
+    }
+  }
+}

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
 {