Alter describe topics to utilize json output

server/src/server/wrapper/connected/CCloudTopics.ts

@@ -3,7 +3,7 @@ import { executeCli } from "./executeCli";
 import { TopicAlreadyExistsException } from "../model/error";
 import { GetConfig } from "../../config";
 import { Deserializer, ConcatOutput } from "../utils";
-import ListTopics from "../model/topics";
+import { ListTopics, DescribeTopic } from "../model/topics";
 
 
 export class CcloudTopics implements Topics {
@@ -28,9 +28,21 @@ export class CcloudTopics implements Topics {
 
     async describeTopic(name: string): Promise<Topic> {
         let config = GetConfig();
-        let consoleLines = await executeCli(["kafka", "topic", "describe", name, "--cluster", config.clusterId, "--environment", config.environmentId, "--output", "json"]);
+        let result = await executeCli(["kafka", "topic", "describe", name, "--cluster", config.clusterId, "--environment", config.environmentId, "--output", "json"]);
 
-        var topic = parseTopicDescription(consoleLines);
+        let combinedResult = ConcatOutput(result);
+        let deserializedResult : DescribeTopic;
+        try {
+            deserializedResult = Deserializer<DescribeTopic>(combinedResult);
+        } catch (error) {
+            return error;
+        }
+
+        let topic = {
+            Name: deserializedResult.topic_name,
+            PartitionCount: deserializedResult.config["num.partitions"], // might be an issue that partitionCount is present twice
+            Configurations: deserializedResult.config // might be an issue that partitionCount is present twice
+        };
 
         return topic;
     }

server/src/server/wrapper/model/topics.ts

@@ -2,8 +2,9 @@ export class ListTopic {
     name: string
 }
 
-type ListTopics = Array<ListTopic>;
-
-export default ListTopics;
-
+export type ListTopics = Array<ListTopic>;
 
+export class DescribeTopic {
+    topic_name: string
+    config: {[key: string]: any}
+}