From d4ce234fa9c0d3dd59e7596ea9cd1e30dbefab47 Mon Sep 17 00:00:00 2001
From: satti-hari-krishna-reddy <hari.100.hks@outlook.com>
Date: Wed, 26 Jun 2024 16:34:19 +0530
Subject: [PATCH] adding endpoint option for syslog

---
 frontend/src/views/AngularWorkflow.jsx | 61 +++++++++++++++++++++++++-
 1 file changed, 60 insertions(+), 1 deletion(-)

diff --git a/frontend/src/views/AngularWorkflow.jsx b/frontend/src/views/AngularWorkflow.jsx
index 7a16c6e9..2ed1f493 100755
--- a/frontend/src/views/AngularWorkflow.jsx
+++ b/frontend/src/views/AngularWorkflow.jsx
@@ -1517,6 +1517,20 @@ const releaseToConnectLabel = "Release to Connect"
     }
   
     setTenzirConfigModalOpen(false);
+  } else if (selectedOption === "Syslog listener") {
+    trigger.parameters = []
+
+    const endpoint = document.getElementById('endpoint')?.value
+
+    if(endpoint) {
+      trigger.parameters.push({
+        name: "endpoint",
+        value: endpoint
+      })
+    } else {
+      toast("Please enter your endpoint");
+      return;
+    }
   }
 
   };
@@ -15587,7 +15601,28 @@ const releaseToConnectLabel = "Release to Connect"
                         start_node: "",
                       };
                       submitPipeline(selectedTrigger, selectedTriggerIndex, pipelineConfig);
-                    }}}
+                    } else if (selectedOption === "Syslog listener"){
+                      let command = ""
+                        const endpoint = (selectedTrigger?.parameters?.find(param => param.name === "endpoint")?.value) || ''
+                        if(endpoint) {
+                          command = `from tcp://${endpoint} | read syslog | import`
+                        } else {
+                          toast("please enter the topic name")
+                          return;
+                        }
+
+                        const pipelineConfig = {
+                          command: command,
+                          name: selectedTrigger.label,
+                          type: "create",
+                          environment: selectedTrigger.environment,
+                          workflow_id: workflow.id,
+                          trigger_id: selectedTrigger.id,
+                          start_node: "",
+                        };
+                        submitPipeline(selectedTrigger, selectedTriggerIndex, pipelineConfig);
+                    }
+                  }}
                     color="primary"
                   >
                     Start
@@ -21394,6 +21429,30 @@ const releaseToConnectLabel = "Release to Connect"
               />
             </div>
           ) : null}{" "}
+
+{selectedOption === "Syslog listener" ? (
+            <div>
+              <b>End Point</b>
+              <TextField
+                id="endpoint"
+                style={{
+                  backgroundColor: theme.palette.inputColor,
+                  borderRadius: theme.palette.borderRadius,
+                }}
+                InputProps={{
+                  style: {},
+                }}
+                fullWidth
+                color="primary"
+                placeholder={"0.0.0.0:5162"}
+                defaultValue={
+                  selectedTrigger?.parameters?.find(
+                    (param) => param.name === "endpoint",
+                  )?.value || ""
+                }
+              />
+            </div>
+          ) : null}{" "}
         </DialogContent>
   
         <DialogActions>