connector_inspect.go

package client

import (
	"fmt"
	"io/ioutil"

	"github.com/ajssmith/skupper-exp/api/types"
	"github.com/ajssmith/skupper-exp/pkg/qdr"
)

func (cli *VanClient) ConnectorInspect(name string) (*types.ConnectorInspectResponse, error) {
	vci := &types.ConnectorInspectResponse{}
	var role types.ConnectorRole
	var suffix string

	sc, err := cli.SiteConfigInspect(types.DefaultBridgeName)
	if err != nil {
		return vci, fmt.Errorf("Unable to retrieve site config: %w", err)
	}

	err = cli.Init(sc.Spec.ContainerEngineDriver)
	if err != nil {
		return vci, fmt.Errorf("Failed to intialize client: %w", err)
	}

	_, err = cli.CeDriver.ContainerInspect("skupper-router")
	if err != nil {
		// TODO: is not found versus error
		return vci, fmt.Errorf("Unable to retrieve transport container (need init?): %w", err)
	}

	current, err := qdr.GetRouterConfigFromFile(types.GetSkupperPath(types.ConfigPath) + "/qdrouterd.json")
	if err != nil {
		return vci, fmt.Errorf("Failed to retrieve router config: %w", err)
	}

	if current.IsEdge() {
		role = types.ConnectorRoleEdge
		suffix = "/edge-"
	} else {
		role = types.ConnectorRoleInterRouter
		suffix = "/inter-router-"
	}

	host, err := ioutil.ReadFile(types.GetSkupperPath(types.ConnectionsPath) + "/" + name + suffix + "host")
	if err != nil {
		return vci, fmt.Errorf("Could not retrieve connection-token files: %w", err)
	}
	port, err := ioutil.ReadFile(types.GetSkupperPath(types.ConnectionsPath) + "/" + name + suffix + "port")
	if err != nil {
		return vci, fmt.Errorf("Could not retrieve connection-token files: %w", err)
	}
	vci.Connector = &types.Connector{
		Name: name,
		Host: string(host),
		Port: string(port),
		Role: string(role),
	}

	connections, err := qdr.GetConnections(cli.CeDriver)

	if err == nil {
		connection := qdr.GetInterRouterOrEdgeConnection(vci.Connector.Host+":"+vci.Connector.Port, connections)
		if connection == nil || !connection.Active {
			vci.Connected = false
		} else {
			vci.Connected = true
		}
		return vci, nil
	} else {
		return vci, fmt.Errorf("Unable to get connections from transport: %w", err)
	}
}