client.go

package ciena

import (
	"code.fbi.h-da.de/cocsn/gosdn/database"
	"code.fbi.h-da.de/cocsn/gosdn/restconf/util"
	apiclient "code.fbi.h-da.de/cocsn/swagger/apis/mcp/client"
	"crypto/tls"
	"github.com/go-openapi/runtime"
	httptransport "github.com/go-openapi/runtime/client"
	"github.com/go-openapi/strfmt"
	"net/http"
)

//MCPClient handles requests to a Ciena MCP RESTCONF endpoint
type MCPClient struct {
	transport *httptransport.Runtime
	client    *apiclient.ServiceTopologyTAPI
	database  *database.Database
	buf       *[]byte
}

func (c MCPClient) GetConfig() string {
	//TODO: Fill with life
	return "..."
}

//NewMCPClient creates a client
func NewMCPClient(endpoint, username, password string, database *database.Database) MCPClient {
	// create the transport
	transport := httptransport.New(endpoint, "/", nil)
	transport.Transport.(*http.Transport).TLSClientConfig = &tls.Config{InsecureSkipVerify: true}
	transport.Debug = true
	// create the API client, with the transport
	basicAuth := httptransport.BasicAuth(username, password)
	// authenticate client
	transport.DefaultAuthentication = basicAuth
	client := apiclient.New(transport, strfmt.Default)

	buf := make([]byte, 0)
	transport.Consumers[runtime.JSONMime] = util.YANGConsumer{Data: &buf}

	return MCPClient{
		transport: transport,
		client:    client,
		database: database,
		buf:       &buf,
	}
}

func (c MCPClient) GetConnections() error {
	c.buf = nil
	_, err := c.client.TapiConnectivityCore.GetTapiCoreContextConnection(nil)
	c.database.StoreConnections(string(*c.buf))
	c.buf = nil
	return err
}

func (c MCPClient) GetNodes() error {
	c.buf = nil
	_, err := c.client.TapiTopologyCore.GetTapiCoreContextTopologyMcpBaseTopologyNode(nil)
	c.database.StoreNodes(string(*c.buf))
	c.buf = nil
	return err
}

func (c MCPClient) GetNodeEdgePoints() error {
	c.buf = nil
	_, err := c.client.TapiTopologyCore.GetTapiCoreContextTopologyMcpBaseTopologyNodeEdgePoint(nil)
	c.database.StoreNodeEdgePoints(string(*c.buf))
	c.buf = nil
	return err
}