update to use new filewriter status

Author: ggoneiESS

config/ymir.csv

@@ -65,8 +65,8 @@ AKHQ,          3, 0, 10.100.211.94,            8443, 0, -450, -20, https://10.10
 graylog,       3, 0, ymir-graylog.daq.esss.dk, 9000, 0, -450, -5,  http://ymir-graylog.daq.esss.dk:9000/search
 forwarder01,   2, 0, 10.102.10.244,            8093, 0, -450, 10,  none
 #
-filewriter0625,        5, 0, 10.100.6.25, 3490, 0, -355, -50,    https://10.100.211.93:3000/d/kafka-to-nexus/kafka-to-nexus-filewriter?orgId=1&refresh=5s
-filewriter0627,        5, 0, 10.100.6.27, 3490, 0, -355, -35,    https://10.100.211.93:3000/d/kafka-to-nexus/kafka-to-nexus-filewriter?orgId=1&refresh=5s
+filewriter0625,        5, 0, 10.100.6.25, 9999, 0, -355, -50,    https://10.100.211.93:3000/d/kafka-to-nexus/kafka-to-nexus-filewriter?orgId=1&refresh=5s
+filewriter0627,        5, 0, 10.100.6.27, 9999, 0, -355, -35,    https://10.100.211.93:3000/d/kafka-to-nexus/kafka-to-nexus-filewriter?orgId=1&refresh=5s
 nicosserver01,         2, 0, 10.102.10.238, 14869, 0, -355, -20, none
 #
 Kafka   Brokers,  4, 64, 0.0.0.0, 65535, 0, -450, -160, none

dashboard/generate.py

@@ -145,11 +145,17 @@ def check_fw_pipeline(self, ipaddr, port):
         try:
             s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
             s.connect((ipaddr, port))
-            s.send(b"getstatus")
-            data = s.recv(256)
-            data2 = int(data.decode("utf-8").split()[1][0])
-            s.close()
-            return data2
+            s.shutdown(socket.SHUT_WR) # no data sent
+            data = b""
+            while True:
+                chunk = s.recv(4096)
+                if not chunk:
+                    break
+                data += chunk
+            lines = data.decode("utf-8", errors="ignore").strip().splitlines()
+            if lines:
+                return int(lines[-1].split()[1][0]) * 5 # will be either 0 or 1
+            return data
         except:
             self.dprint("connection reset (by peer?)")
             return 0