1 files changed, 51 insertions, 0 deletions
diff --git a/test/security/sslendpoints/main.go b/test/security/sslendpoints/main.go
new file mode 100644
index 000000000..44f250940
--- /dev/null
+++ b/test/security/sslendpoints/main.go
@@ -0,0 +1,51 @@
+package main
+
+import (
+	"flag"
+	"log"
+	"os"
+	"path/filepath"
+
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	"k8s.io/client-go/kubernetes"
+	"k8s.io/client-go/tools/clientcmd"
+
+	"onap.local/sslendpoints/ports"
+)
+
+func main() {
+	var kubeconfig *string
+	if home := os.Getenv("HOME"); home != "" {
+		kubeconfig = flag.String("kubeconfig", filepath.Join(home, ".kube", "config"), "(optional) absolute path to the kubeconfig file")
+	} else {
+		kubeconfig = flag.String("kubeconfig", "", "absolute path to the kubeconfig file")
+	}
+	flag.Parse()
+
+	// use the current context in kubeconfig
+	config, err := clientcmd.BuildConfigFromFlags("", *kubeconfig)
+	if err != nil {
+		log.Panicf("Unable to build cluster config: %v", err)
+	}
+
+	// create the clientset
+	clientset, err := kubernetes.NewForConfig(config)
+	if err != nil {
+		log.Panicf("Unable to build client: %v", err)
+	}
+
+	// get list of services to extract nodeport information
+	services, err := clientset.CoreV1().Services("").List(metav1.ListOptions{})
+	if err != nil {
+		log.Panicf("Unable to get list of services: %v", err)
+	}
+
+	// filter out nodeports with corresponding services from service list
+	nodeports, ok := ports.FilterNodePorts(services)
+	if !ok {
+		log.Println("There are no NodePorts in the cluster")
+		os.Exit(0)
+	}
+	log.Printf("There are %d NodePorts in the cluster\n", len(nodeports))
+	os.Exit(len(nodeports))
+}