added produce test message using redis connector

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/pages/api/test.ts

@@ -1,11 +1,8 @@
 import type { NextApiRequest, NextApiResponse } from 'next';
 import { Pipeline } from '@/models/pipeline';
-import { Connector, KafkaConnector } from '@/models/connector';
-import { produceTest } from '@/tools/kafka';
-
-const kafkaHandler = async (connector: KafkaConnector, pipeline: Pipeline, message: string) => {
-    await produceTest(connector, pipeline, message);
-}
+import { Connector, KafkaConnector, RedisConnector } from '@/models/connector';
+import { produceTest as kafkaHandler } from '@/tools/kafka';
+import { produceTest as redisHandler } from '@/tools/redis';
 
 export default async function handler(
     req: NextApiRequest,
@@ -19,6 +16,8 @@ export default async function handler(
 
         if (connector.type === 'kafka') {
             await kafkaHandler(connector as KafkaConnector, pipeline, message);
+        }else if(connector.type === 'redis'){
+            await redisHandler(connector as RedisConnector, pipeline, message);
         }
 
         res.status(200).json({ result: 'succeed' });

client/src/tools/redis.ts

@@ -0,0 +1,10 @@
+import redis from 'redis';
+import { RedisConnector } from "@/models/connector";
+import { Pipeline } from "@/models/pipeline";
+
+export const produceTest = async (connector: RedisConnector, pipeline: Pipeline, message: string) => {
+    const redisClient = redis.createClient({
+        url: `redis://${connector.host}:${connector.port}/0`
+    })
+    await redisClient.publish(pipeline.input.topic, message);
+}