Connector refactor

.devcontainer/docker-compose.yml

@@ -12,7 +12,15 @@ services:
       - ../..:/workspaces:cached
     # Overrides default command so things don't shut down after the process ends.
     entrypoint: /usr/local/share/docker-init.sh
-    command: sleep infinity 
+    command: sleep infinity
+  redis:
+    hostname: redis
+    image: redis
+    command: redis-server --include /usr/local/etc/redis/redis.conf
+    volumes:
+      - ./redis/redis.conf:/usr/local/etc/redis/redis.conf
+    ports:
+      - "6379:6379"
   zookeeper:
     image: wurstmeister/zookeeper
     ports:

client/package.json

@@ -25,13 +25,14 @@
         "react": "18.2.0",
         "react-dom": "18.2.0",
         "react-graph-vis": "^1.0.7",
+        "redis": "^4.6.8",
         "uuidv4": "^6.2.13"
     },
     "devDependencies": {
-        "typescript": "5.0.2",
-        "prettier": "^2.8.8",
         "@types/node": "18.15.5",
         "@types/react": "18.0.28",
-        "@types/react-dom": "18.0.11"
+        "@types/react-dom": "18.0.11",
+        "prettier": "^2.8.8",
+        "typescript": "5.0.2"
     }
 }

client/src/components/connectors-table.tsx

@@ -1,4 +1,4 @@
-import { Connector } from '@/models/connector';
+import { Connector, KafkaConnector, RedisConnector } from '@/models/connector';
 import { Accordion } from '@mantine/core';
 
 interface TableProps {
@@ -19,7 +19,11 @@ export default function PipelinesTable({ connector }: TableProps) {
             <Accordion.Item value="customization" key={connector.name}>
                 <Accordion.Control>Connector</Accordion.Control>
                 <Accordion.Panel>
-                    {connector.name} ({connector.type}), {connector.brokers} | {connector.group_id}
+                    {connector.name} ({connector.type}),
+                    {connector.type == 'kafka' ?
+                        `${(connector as KafkaConnector).brokers} | ${(connector as KafkaConnector).group_id}`
+                        : `${(connector as RedisConnector).host} | ${(connector as RedisConnector).port}`
+                    }
                 </Accordion.Panel>
             </Accordion.Item>
         </Accordion>

client/src/models/connector.ts

@@ -1,6 +1,14 @@
 export interface Connector {
     name: string;
-    type: string;
+    type: 'kafka' | 'redis';
+}
+
+export interface KafkaConnector extends Connector {
     brokers: string;
     group_id: string;
 }
+
+export interface RedisConnector extends Connector {
+    host: string;
+    port: number
+}

client/src/models/pipeline-list.ts

@@ -1,8 +1,8 @@
-import { Connector } from './connector';
+import { KafkaConnector, RedisConnector } from './connector';
 import { Pipeline } from './pipeline';
 
 export interface PipelineList {
     name: string;
     pipelines: Pipeline[];
-    connector: Connector;
+    connector: RedisConnector | KafkaConnector;
 }