Check preferred server

funcs.go

@@ -0,0 +1,26 @@
+package main
+
+import (
+    "fmt"
+	"net/http"
+	"os"
+)
+
+func restRequest(dcsserver string, restserver string, user string, passwd string, target string)  http.Request {
+	req, err := http.NewRequest("GET", "http://"+ restserver +"/RestService/rest.svc/1.0/"+ target, nil)
+	if err != nil {
+		fmt.Println("\nError when creating http request\nExit !")
+		os.Exit(0)
+	}
+	req.Header.Add("ServerHost", dcsserver)
+	req.Header.Add("Authorization", "Basic " + user +" "+ passwd)
+	return *req
+}
+
+func bToT(b float64) float64 {
+	return float64(b /1024 /1024 /1024 /1024)
+}
+
+func bToG(b float64) float64 {
+	return float64(b /1024 /1024 /1024)
+}

main.go

@@ -0,0 +1,113 @@
+package main
+
+import (
+    "fmt"
+    "io/ioutil"
+    "net/http"
+	"encoding/json"
+	"flag"
+	"os"
+	//"reflect"
+)
+
+
+func main() {
+	// Define flags
+	dcsserver := flag.String("dcsserver","","DataCore SANsymphony server")
+	restserver := flag.String("restserver","","DataCore SANsymphony REST api server")
+	user := flag.String("user","","DataCore SANsymphony user")
+	passwd := flag.String("passwd","","DataCore SANsymphony password")
+
+	//Parse
+	flag.Parse()
+
+	//Check flags
+	if *dcsserver == "" {
+		fmt.Println("\nError! No DataCore SANsymphony server set")
+		fmt.Println("Add -dcsserver=x where x is IP or DNS of DataCore SANsymphony server")
+		fmt.Println("Exit!")
+		os.Exit(0)
+	} else if *restserver == "" {
+		fmt.Println("\nWarning ! No DataCore SANsymphony REST api server set")
+		fmt.Println("Add -restserver=x where x is IP or DNS of DataCore SANsymphony REST api server")
+		fmt.Println("We will use DataCore SANsymphony server as REST api server")
+		restserver = dcsserver
+	}
+	if *user == "" {
+		fmt.Println("\nError ! No DataCore SANsymphony server user set")
+		fmt.Println("Add -user=x where x is user for DataCore SANsymphony server")
+		fmt.Println("\nExit!")
+		os.Exit(0)
+	}
+	if *passwd == "" {
+		fmt.Println("\nError ! No DataCore SANsymphony server password set")
+		fmt.Println("Add -passwd=x where x is password for DataCore SANsymphony server")
+		fmt.Println("\nExit!")
+		os.Exit(0)
+	}
+
+	req_hosts := restRequest(*dcsserver , *restserver , *user , *passwd , "hosts")
+	req_servers := restRequest(*dcsserver , *restserver , *user , *passwd , "servers")
+	//fmt.Println(reflect.TypeOf(*req))
+
+	client := &http.Client{
+	}
+	resp_hosts, err := client.Do(&req_hosts)
+	if err != nil {
+		fmt.Printf("The HTTP request failed with error %s\n", err)
+		os.Exit(0)
+	} else if resp_hosts.Status != "200 OK"{
+		fmt.Printf("The HTTP request failed with error %s\n", resp_hosts.Status)
+		os.Exit(0)
+	} 
+
+	data, _ := ioutil.ReadAll(resp_hosts.Body)
+	var hosts []host
+	json.Unmarshal([]byte(data), &hosts)
+
+
+
+
+	resp_servers, err := client.Do(&req_servers)
+	if err != nil {
+		fmt.Printf("The HTTP request failed with error %s\n", err)
+		os.Exit(0)
+	} else if resp_servers.Status != "200 OK"{
+		fmt.Printf("The HTTP request failed with error %s\n", resp_servers.Status)
+		os.Exit(0)
+	}
+
+	data, _ = ioutil.ReadAll(resp_servers.Body)
+	var servers []server
+	json.Unmarshal([]byte(data), &servers)
+
+
+	for _, item := range hosts{
+		client := &http.Client{
+		}
+		target_preffered := "hosts/" + item.Id + "/preferredservers"
+
+		req_preferredservers := restRequest(*dcsserver , *restserver , *user , *passwd , target_preffered)
+		resp_preferredservers, err := client.Do(&req_preferredservers)
+		data, err = ioutil.ReadAll(resp_preferredservers.Body)
+		if err != nil {
+			fmt.Printf("The HTTP request failed with error %s\n", err)
+		}
+
+		var preferredservers []preferredserver
+		json.Unmarshal([]byte(data), &preferredservers)
+		if len(preferredservers) > 0 {
+			fmt.Println(preferredservers[0].Caption)
+		} else {
+			fmt.Println(item.Caption, "|", "None")
+		}
+
+
+
+	}
+
+
+
+
+
+}