Alter list topics to utilize json output

.envrc

@@ -0,0 +1 @@
+dotenv

server/makefile

@@ -5,7 +5,7 @@ build:
 	docker build -t $(IMAGE_NAME) .
 
 run:
-	docker run -it -p 3000:3000 --rm $(IMAGE_NAME)
+	docker run -it -p 3000:3000 --rm --env-file ../.env $(IMAGE_NAME)
 
 release: build
 	chmod +x ../scripts/push_container_image.sh && ../scripts/push_container_image.sh $(IMAGE_NAME) $(BUILD_NUMBER)

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

@@ -2,24 +2,33 @@ import { parse, parseTopicDescription } from "./../parser";
 import { executeCli } from "./executeCli";
 import { TopicAlreadyExistsException } from "../model/error";
 import { GetConfig } from "../../config";
+import { Deserializer, ConcatOutput } from "../utils";
+import ListTopics from "../model/topics";
+
 
 export class CcloudTopics implements Topics {
 
     async getTopics(): Promise<string[]> {
         let config = GetConfig();
 
-        let result = await executeCli(["kafka", "topic", "list", "--cluster", config.clusterId, "--environment", config.environmentId]);
-        result =
-            parse(result)
-                .filter(t => t.Name.startsWith("_confluent") === false)
-                .map(t => t.Name);
-
-        return result;
+        let result = await executeCli(["kafka", "topic", "list", "--cluster", config.clusterId, "--environment", config.environmentId, "--output", "json"]);
+
+        let combinedResult = ConcatOutput(result);
+        let deserializedResult : ListTopics;
+        try {
+            deserializedResult = Deserializer<ListTopics>(combinedResult);
+        } catch (error) {
+            return error;
+        }
+
+        return deserializedResult
+            .filter(t => t.name.startsWith("_confluent") === false)
+            .map(t => t.name);
     }
 
     async describeTopic(name: string): Promise<Topic> {
         let config = GetConfig();
-        let consoleLines = await executeCli(["kafka", "topic", "describe", name, "--cluster", config.clusterId, "--environment", config.environmentId]);
+        let consoleLines = await executeCli(["kafka", "topic", "describe", name, "--cluster", config.clusterId, "--environment", config.environmentId, "--output", "json"]);
 
         var topic = parseTopicDescription(consoleLines);
 

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

@@ -0,0 +1,9 @@
+export class ListTopic {
+    name: string
+}
+
+type ListTopics = Array<ListTopic>;
+
+export default ListTopics;
+
+