Merge pull request #15 from metalice/adding-ip-filter-support

Adding filtering by ip support

Author: metalice

main.go

@@ -23,7 +23,7 @@ func main() {
 	server.GET("/health", cache.CacheByRequestURI(memoryStore, HEALTH_CACHE_TIME), handlers.HealthHandler)
 	server.GET("/apis/*path", cache.CacheByRequestURI(memoryStore, API_CACHE_TIME), handlers.RequestHandler)
 
-	log.Printf("listening for server 8080 - v0.0.8 - API cache time: %v", API_CACHE_TIME)
+	log.Printf("listening for server 8080 - v0.0.9 - API cache time: %v", API_CACHE_TIME)
 
 	err := server.RunTLS(":8080", "./cert/tls.crt", "./cert/tls.key") // listen and serve on 0.0.0.0:8080
 

util/util.go

@@ -182,6 +182,21 @@ func isMigratable(statuses []interface{}, search string) bool {
 	return true
 }
 
+func isIPExist(interfaces []interface{}, search string) bool {
+	result := false
+	for _, nic := range interfaces {
+		nicsArr := nic.(map[string]interface{})["ipAddresses"].([]interface{})
+		isExist := slices.ContainsFunc(nicsArr, func(ip interface{}) bool {
+			return strings.Contains(ip.(string), search)
+		})
+		if isExist {
+			result = true
+			break
+		}
+	}
+	return result
+}
+
 func FilterResponseQuery(bodyBytes []byte, query url.Values) map[string]interface{} {
 	items := gjson.ParseBytes(bodyBytes).Get("items").Array()
 	filteredJson := []interface{}{}
@@ -206,6 +221,13 @@ func FilterResponseQuery(bodyBytes []byte, query url.Values) map[string]interfac
 									}
 									continue
 								}
+								if key == "status.interfaces" {
+									isIP := isIPExist(itemValue.Value().([]interface{}), search)
+									if !isIP {
+										continue nextItem
+									}
+									continue
+								}
 								okInclude := labelsIncludes(itemValue.Value().(map[string]interface{}), search)
 								if !okInclude {
 									continue nextItem