[INLONG-11379][Dashboard] Redis sink Properties saving problem

wohainilaodou · Oct 21, 2024 · 0f9054b · 0f9054b
1 parent 8c7d31d
commit 0f9054b
Showing 1 changed file with 19 additions and 0 deletions.
diff --git a/inlong-dashboard/src/ui/pages/GroupDetail/DataStorage/DetailModal.tsx b/inlong-dashboard/src/ui/pages/GroupDetail/DataStorage/DetailModal.tsx
@@ -73,6 +73,12 @@ const Comp: React.FC<DetailModalProps> = ({
       formatResult: result => new Entity()?.parse(result) || result,
       onSuccess: result => {
         setSinkType(result.sinkType);
+        if (result.sinkType === 'REDIS') {
+          result.properties = Object.entries(result.properties).map(([key, value]) => ({
+            keyName: key,
+            keyValue: value,
+          }));
+        }
         form.setFieldsValue(result);
       },
     },
@@ -158,6 +164,19 @@ const Comp: React.FC<DetailModalProps> = ({
     if (startProcess) {
       submitData.startProcess = true;
     }
+    if (sinkType === 'REDIS') {
+      if (Array.isArray(submitData.properties) && submitData.properties.length > 0) {
+        const propertiesObject = submitData.properties.reduce((acc, item) => {
+          if (item.keyName && item.keyValue !== undefined) {
+            acc[item.keyName] = item.keyValue;
+          }
+          return acc;
+        }, {});
+        submitData.properties = propertiesObject;
+      } else {
+        submitData.properties = {};
+      }
+    }
     await request({
       url: isUpdate ? '/sink/update' : '/sink/save',
       method: 'POST',