query init complete && fix config.yaml

Author: curiousyang

app/components/TransferColumns.tsx

@@ -135,13 +135,18 @@ const TransferColumns = React.memo(() => {
 
     }
     else{
+      console.log("healthData in else:", healthDataList.length);
+      console.log("eventData in else:", eventDataList.length);
       if(healthDataList && healthDataList.length >0 && eventDataList && eventDataList.length >0){
+        console.log("eventDataList:", eventDataList.length);
+        console.log("healthDataList", healthDataList.length);
         setMetricsPool(getMetrics('event',eventDataList).concat(getMetrics('health',healthDataList)));
       }
-      else{
+      else if(healthMetricsReady && eventMetricsReady){
         console.log("set concat metrics:", JSON.stringify(eventMetrics.concat(healthMetrics)));
         setMetricsPool(eventMetrics.concat(healthMetrics));
       }
+      console.log("here");
 
 
     }

app/containers/GraphsContainer.tsx

@@ -66,21 +66,27 @@ const GraphsContainer: React.FC<GraphsContainerProps> = React.memo(props => {
 
   useEffect(() => {
     const serviceArray = service.split(' ');
-
-
+    const healthServiceArray = serviceArray.filter((value : string) => value !== 'kafkametrics');
+    // console.log("service array:", JSON.stringify(serviceArray));
+    // console.log("health service array:", JSON.stringify(healthServiceArray));
     if (live) {
       setIntervalID(
         setInterval(() => {
           fetchCommsData(app, live);
-          fetchHealthData(serviceArray);
-          fetchEventData(serviceArray[0]);
+          fetchHealthData(healthServiceArray);
+          if(service.includes('kafkametrics')){
+            fetchEventData('kafkametrics');
+          }
+          
         }, 3000)
       );
     } else {
       if (intervalID) clearInterval(intervalID);
       fetchCommsData(app, live);
-      fetchHealthData(serviceArray);
-      fetchEventData(serviceArray[0]);
+      fetchHealthData(healthServiceArray);
+      if(service.includes('kafkametrics')){
+        fetchEventData();
+      }
     }
 
     return () => {

app/context/EventContext.tsx

@@ -19,7 +19,7 @@ const EventContextProvider: React.FC = React.memo(({ children }) => {
 
   function tryParseJSON(jsonString: any) {
     try {
-     // console.log("jsonString at EventContext:", jsonString);
+     console.log("jsonString at EventContext:", jsonString);
       const o = JSON.parse(jsonString);
       if (o && typeof o === 'object') {
         return true;
@@ -30,8 +30,8 @@ const EventContextProvider: React.FC = React.memo(({ children }) => {
     return false;
   }
 
-  const fetchEventData = useCallback((serv) => {
-    if(serv === 'kafkametrics'){
+  const fetchEventData = useCallback(() => {
+    // if(serv === 'kafkametrics'){
      // console.log("in fetchEventData in EventContext!!");
       ipcRenderer.removeAllListeners('kafkaResponse');
       ipcRenderer.send('kafkaRequest');
@@ -49,7 +49,7 @@ const EventContextProvider: React.FC = React.memo(({ children }) => {
 
       });
 
-    }
+    // }
 
 
   }, []);

app/context/HealthContext.tsx

@@ -18,8 +18,6 @@ export const HealthContext = React.createContext<any>(null);
 const HealthContextProvider: React.FC = React.memo(({ children }) => {
   const [healthData, setHealthData] = useState<any>({"healthDataList":[], "healthTimeList":[]});
   const [services, setServices] = useState<Array<string>>([]);
-  // const [datalist, setDataList] = useState<Array<any>>([]);
-  // const [timelist, setTimeList] = useState<Array<any>>([]);
 
   function tryParseJSON(jsonString: any) {
     try {
@@ -36,7 +34,7 @@ const HealthContextProvider: React.FC = React.memo(({ children }) => {
   }
 
   const fetchHealthData = useCallback(serv => {
-    //setServices(serv);
+    
     ipcRenderer.removeAllListeners('healthResponse');
 
     let temp: any[] = [];
@@ -63,10 +61,10 @@ const HealthContextProvider: React.FC = React.memo(({ children }) => {
           });
 
         }).then((dt: any) => {
-          if(service !== 'kafkametrics'){
+        
             temp.push(dt);
           //  console.log("temp is:", JSON.stringify(temp));
-          }
+          
           if (checkServicesComplete(temp, serv)) {
 
             setServices(serv);

config.yaml

@@ -1,4 +1,4 @@
-hostPort: 9000
+hostPort: localhost:9000
 lowercaseOutputName: true
 rules:
 - pattern: kafka.server<type=ReplicaManager, name=UnderReplicatedPartitions><>Value