netrunner/utils/nodeKeys.go

package utils

import (
	"encoding/base64"
	"fmt"
	"sync"

	"github.com/luxfi/crypto/bls/signer/localsigner"
	luxtls "github.com/luxfi/tls"
	"golang.org/x/sync/errgroup"
)

type EncodedNodeKeys struct {
	StakingKey  string
	StakingCert string
	BlsKey      string
}

type NodeKeys struct {
	StakingKey  []byte
	StakingCert []byte
	BlsKey      []byte
}

func EncodeNodeKeys(key *NodeKeys) *EncodedNodeKeys {
	return &EncodedNodeKeys{
		StakingKey:  string(key.StakingKey),
		StakingCert: string(key.StakingCert),
		BlsKey:      base64.StdEncoding.EncodeToString(key.BlsKey),
	}
}

func generateNodeKeys() (*NodeKeys, error) {
	stakingCert, stakingKey, err := luxtls.NewCertAndKeyBytes()
	if err != nil {
		return nil, fmt.Errorf("couldn't generate staking cert/key: %w", err)
	}
	key, err := localsigner.New()
	if err != nil {
		return nil, fmt.Errorf("couldn't generate new signing key: %w", err)
	}
	return &NodeKeys{
		StakingKey:  stakingKey,
		StakingCert: stakingCert,
		BlsKey:      key.ToBytes(),
	}, nil
}

func GenerateKeysForNodes(num int) ([]*NodeKeys, error) {
	nodesKeys := []*NodeKeys{}
	lock := sync.Mutex{}
	eg := errgroup.Group{}
	for i := 0; i < num; i++ {
		eg.Go(func() error {
			keys, err := generateNodeKeys()
			if err != nil {
				return err
			}
			lock.Lock()
			nodesKeys = append(nodesKeys, keys)
			lock.Unlock()
			return nil
		})
	}
	err := eg.Wait()
	return nodesKeys, err
}