node/mesh/no_ingress_conn_alert.go

// Copyright (C) 2019-2025, Lux Industries Inc. All rights reserved.
// See the file LICENSE for licensing terms.

package mesh

import (
	"errors"

	"github.com/luxfi/constants"
	"github.com/luxfi/ids"
	validators "github.com/luxfi/validators"
)

// ErrNoIngressConnections denotes that no node is connected to this validator.
var ErrNoIngressConnections = errors.New("primary network validator has no inbound connections")

type ingressConnectionCounter interface {
	IngressConnCount() int
}

type validatorRetriever interface {
	GetValidator(netID ids.ID, nodeID ids.NodeID) (*validators.GetValidatorOutput, bool)
}

func checkNoIngressConnections(selfID ids.NodeID, ingressConnections ingressConnectionCounter, validators validatorRetriever) (interface{}, error) {
	connCount := ingressConnections.IngressConnCount()
	_, areWeValidator := validators.GetValidator(constants.PrimaryNetworkID, selfID)

	result := map[string]interface{}{
		"ingressConnectionCount":  connCount,
		"primaryNetworkValidator": areWeValidator,
	}

	if connCount > 0 || !areWeValidator {
		return result, nil
	}

	return result, ErrNoIngressConnections
}