NetBackup module in go and its example

Author: sgupta03

snippets/go/README.md

@@ -0,0 +1,22 @@
+# NetBackup package for GO language
+
+This package gives a wrapper to call NetBackup APIs.
+There are few raw functions that can be used generically to 
+call NetBackup APIs. 
+There are also some specific call that creates the URL, calls the API, parse the output and return back the data.
+
+
+## Building and executing sample program
+Pre-requisites:
+- NetBackup 8.1.1 or higher
+- Go version 1.10.2
+
+Use the following commands to build and execute the sample program
+```sh
+$ cd netbackup
+$ # Build sample program
+$ go build example/sample.go
+$ # execute sample program
+$ ./sample
+```
+To use in your own Go program just import the package and use it as shown in the sample.go

snippets/go/example/sample.go

@@ -0,0 +1,35 @@
+package main
+
+import (
+	"bufio"
+	"fmt"
+	"netbackup"
+	"os"
+)
+
+func main() {
+	fmt.Printf("Welcome to sample Go program to call NetBackup APIs\n")
+	scanner := bufio.NewScanner(os.Stdin)
+	fmt.Printf("Enter the server to connect: ")
+	scanner.Scan()
+	server := scanner.Text()
+	fmt.Printf("Checking connectivity with NetBackup Server[%s]\n", server)
+	fmt.Printf("-----------------------\n")
+	fmt.Println(netbackup.Ping(server))
+	fmt.Printf("-----------------------\n")
+	fmt.Printf("Enter username for server:")
+	scanner.Scan()
+	username := scanner.Text()
+	fmt.Printf("Enter password for server:")
+	scanner.Scan()
+	password := scanner.Text()
+	fmt.Printf("Calling NetBackup Login\n")
+	fmt.Printf("-----------------------\n")
+	jwt := netbackup.Login(username, password, server)
+	fmt.Printf("-----------------------\n")
+	//    fmt.Printf(netbackup.MappingList(jwt , "V-067223A"))
+	fmt.Printf("Mapping List using jwt\n")
+	fmt.Printf("-----------------------\n")
+	netbackup.MappingList(jwt, server)
+	fmt.Printf("-----------------------\n")
+}

snippets/go/netbackup.go

@@ -0,0 +1,151 @@
+// Package netbackup provides functions for calling netbackup APIs and
+// get there response back in structured formata.
+package netbackup
+
+import (
+	"bytes"
+	"crypto/tls"
+	"encoding/json"
+	"fmt"
+	"io/ioutil"
+	"net/http"
+)
+
+// NetBackup structure to directly call raw APIs
+// or some predefined APIs
+type NetBackup struct {
+	jwt              string
+	baseURL          string
+	skipVerification bool
+}
+
+// ----------------------------------------
+//
+// Raw functions to call APIs and their helper functions
+//
+// ----------------------------------------
+
+// Get Raw function to call any GET APIs of NetBackup
+func Get(jwt string, url string) (jsonData map[string]interface{}, code int, err error) {
+
+	client := getHTTPClient()
+	req, err := http.NewRequest("GET", url, nil)
+	if jwt != "" {
+		req.Header.Add("Authorization", jwt)
+	}
+	req.Header.Add("ContentType", "application/vnd.netbackup+json; version=1.0")
+
+	response, err := client.Do(req)
+	if err == nil {
+		code = response.StatusCode
+		if code >= 200 && code <= 299 {
+			data, _ := ioutil.ReadAll(response.Body)
+			if err := json.Unmarshal(data, &jsonData); err != nil {
+				panic(err)
+			}
+		}
+	}
+	defer response.Body.Close()
+	return jsonData, response.StatusCode, err
+}
+
+// Post Raw function to call any POST APIs of NetBackup
+func Post(jwt string, url string, reqValue []byte) (jsonData map[string]interface{}, code int, err error) {
+
+	client := getHTTPClient()
+	req, err := http.NewRequest("POST", url, bytes.NewBuffer(reqValue))
+	if jwt != "" {
+		req.Header.Add("Authorization", jwt)
+	}
+	req.Header.Add("Content-Type", "application/vnd.netbackup+json; version=1.0")
+	response, err := client.Do(req)
+
+	if err == nil {
+		code = response.StatusCode
+		if code >= 200 && code <= 299 {
+			resData, _ := ioutil.ReadAll(response.Body)
+			if err := json.Unmarshal(resData, &jsonData); err != nil {
+				panic(err)
+			}
+		}
+	}
+	defer response.Body.Close()
+	return jsonData, code, err
+}
+
+// ----------------------------------------
+//
+// Some additional functions that you can directly call to
+// achieve some basic functionality.
+//
+// ----------------------------------------
+
+// Ping function call the netbackup ping API. This can be used
+// to check the connectivity to Master server web services
+func Ping(server string) string {
+	var data []byte
+	url := GetBaseURLString(server) + "/ping"
+	client := getHTTPClient()
+	response, err := client.Get(url)
+	if err != nil {
+		fmt.Printf("Request Failed %s \n", err)
+	} else {
+		data, _ = ioutil.ReadAll(response.Body)
+		return (string(data))
+	}
+	return (string(""))
+}
+
+//Login function
+func Login(username string, password string, server string) string {
+	url := GetBaseURLString(server) + "/login"
+	reqData := map[string]string{"userName": username, "password": password}
+	reqValue, _ := json.Marshal(reqData)
+
+	jsonData, code, err := Post("", url, reqValue)
+
+	if err != nil {
+		fmt.Printf("Request Failed %s \n", err)
+	} else {
+		fmt.Println(code)
+		if code != 201 {
+			fmt.Printf("Wrong response %d \n", code)
+			return ""
+		}
+	}
+	fmt.Printf("Login succesful. got jwt[%s]", jsonData["token"].(string))
+	return jsonData["token"].(string)
+}
+
+// MappingList Returns list of mappings for the server in JSON format
+func MappingList(jwt string, server string) {
+	url := GetBaseURLString(server) + "/config/hosts"
+
+	jsonData, code, err := Get(jwt, url)
+	if err != nil {
+		fmt.Printf("Request Failed %s \n", err)
+	} else {
+		if code != 200 {
+			fmt.Printf("Request returned wrong code %d \n", code)
+			return
+		}
+	}
+	fmt.Println(jsonData)
+}
+
+// GetBaseURLString This returns the base URL for netbackup
+func GetBaseURLString(server string) string {
+	return "https://" + server + ":1556/netbackup"
+}
+
+func getContentType() string {
+	return "application/vnd.netbackup+json; version=1.0"
+}
+
+func getHTTPClient() http.Client {
+	tr := &http.Transport{
+		TLSClientConfig: &tls.Config{InsecureSkipVerify: true},
+	}
+	client := &http.Client{Transport: tr}
+	return *client
+}