nbi.go

package server

import (
	"code.fbi.h-da.de/danet/gosdn/controller/interfaces/networkdomain"
	"code.fbi.h-da.de/danet/gosdn/controller/interfaces/rbac"
	"code.fbi.h-da.de/danet/gosdn/controller/metrics"
	"code.fbi.h-da.de/danet/gosdn/controller/topology"
	"code.fbi.h-da.de/danet/gosdn/controller/topology/nodes"
	"code.fbi.h-da.de/danet/gosdn/controller/topology/ports"
	"github.com/prometheus/client_golang/prometheus"
	log "github.com/sirupsen/logrus"
	"google.golang.org/grpc/codes"
	"google.golang.org/grpc/status"
)

var pndc networkdomain.PndStore
var userService rbac.UserService
var roleService rbac.RoleService
var topologyService topology.Service
var nodeService nodes.Service
var portService ports.Service

// NorthboundInterface is the representation of the
// gRPC services used provided.
type NorthboundInterface struct {
	Pnd      *pndServer
	Core     *core
	Csbi     *csbi
	Sbi      *sbiServer
	Auth     *Auth
	User     *User
	Role     *Role
	Topology *Topology
}

// NewNBI receives a PndStore and returns a new gRPC *NorthboundInterface
func NewNBI(
	pnds networkdomain.PndStore,
	users rbac.UserService,
	roles rbac.RoleService,
	topology topology.Service,
	node nodes.Service,
	port ports.Service,
) *NorthboundInterface {
	pndc = pnds
	userService = users
	roleService = roles
	topologyService = topology
	nodeService = node
	portService = port

	return &NorthboundInterface{
		Pnd:      &pndServer{},
		Core:     &core{},
		Csbi:     &csbi{},
		Sbi:      &sbiServer{},
		Auth:     &Auth{},
		User:     &User{},
		Role:     &Role{},
		Topology: &Topology{},
	}
}

func handleRPCError(labels prometheus.Labels, err error) error {
	log.Error(err)
	return status.Errorf(codes.Aborted, "%v", metrics.HandleError(labels, err, grpcAPIErrorsTotal))
}