netmaker/netclient/functions/list.go

package functions

import (
	"encoding/json"
	"fmt"

	"github.com/gravitl/netmaker/logger"
	"github.com/gravitl/netmaker/netclient/config"
	"github.com/gravitl/netmaker/netclient/ncutils"
)

// Peer - the peer struct for list
type Peer struct {
	Name           string `json:"name"`
	Interface      string `json:"interface,omitempty"`
	PrivateIPv4    string `json:"private_ipv4,omitempty"`
	PrivateIPv6    string `json:"private_ipv6,omitempty"`
	PublicEndpoint string `json:"public_endpoint,omitempty"`
}

// Network - the local node network representation for list command
type Network struct {
	Name        string `json:"name"`
	ID          string `json:"node_id"`
	CurrentNode Peer   `json:"current_node"`
	Peers       []Peer `json:"peers"`
}

// List - lists the current peers for the local node with name and node ID
func List(network string) error {
	nets := []Network{}
	var err error
	var networks []string
	if network == "all" {
		networks, err = ncutils.GetSystemNetworks()
		if err != nil {
			return err
		}
	} else {
		networks = append(networks, network)
	}

	for _, network := range networks {
		net, err := getNetwork(network)
		if err != nil {
			logger.Log(1, network+": Could not retrieve network configuration.")
			return err
		}
		nets = append(nets, net)
	}

	jsoncfg, _ := json.Marshal(struct {
		Networks []Network `json:"networks"`
	}{nets})
	fmt.Println(string(jsoncfg))

	return nil
}

func getNetwork(network string) (Network, error) {
	cfg, err := config.ReadConfig(network)
	if err != nil {
		return Network{}, fmt.Errorf("reading configuration for network %v: %w", network, err)
	}
	//peers, err := getPeers(network)
	peers := []Peer{}
	if err != nil {
		return Network{}, fmt.Errorf("listing peers for network %v: %w", network, err)
	}
	return Network{
		Name:  network,
		ID:    cfg.Node.ID,
		Peers: peers,
		CurrentNode: Peer{
			Name:           cfg.Node.Name,
			Interface:      cfg.Node.Interface,
			PrivateIPv4:    cfg.Node.Address,
			PrivateIPv6:    cfg.Node.Address6,
			PublicEndpoint: cfg.Node.Endpoint,
		},
	}, nil
}

// func getPeers(network string) ([]Peer, error) {
// cfg, err := config.ReadConfig(network)
// if err != nil {
// return []Peer{}, err
// }
// nodecfg := cfg.Node
// var nodes []models.Node
//
// var wcclient nodepb.NodeServiceClient
// conn, err := grpc.Dial(cfg.Server.GRPCAddress,
// ncutils.GRPCRequestOpts(cfg.Server.GRPCSSL))
//
// if err != nil {
// return []Peer{}, fmt.Errorf("connecting to %v: %w", cfg.Server.GRPCAddress, err)
// }
// defer conn.Close()
//	Instantiate the BlogServiceClient with our client connection to the server
// wcclient = nodepb.NewNodeServiceClient(conn)
//
// nodeData, err := json.Marshal(&nodecfg)
// if err != nil {
// return []Peer{}, fmt.Errorf("could not parse config node on network %s : %w", network, err)
// }
//
// req := &nodepb.Object{
// Data: string(nodeData),
// Type: nodepb.NODE_TYPE,
// }
//
// ctx, err := auth.SetJWT(wcclient, network)
// if err != nil {
// return []Peer{}, fmt.Errorf("authenticating: %w", err)
// }
// var header metadata.MD
//
// response, err := wcclient.GetPeers(ctx, req, grpc.Header(&header))
// if err != nil {
// return []Peer{}, fmt.Errorf("retrieving peers: %w", err)
// }
// if err := json.Unmarshal([]byte(response.GetData()), &nodes); err != nil {
// return []Peer{}, fmt.Errorf("unmarshaling data for peers: %w", err)
// }
//
// peers := []Peer{}
// for _, node := range nodes {
// if node.Name != cfg.Node.Name {
// peers = append(peers, Peer{Name: fmt.Sprintf("%v.%v", node.Name, network), PrivateIPv4: node.Address, PrivateIPv6: node.Address6})
// }
// }
//
// return peers, nil
// }