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"
	"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

// 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
}

// NewNBI receives a PndStore and returns a new gRPC *NorthboundInterface
func NewNBI(pnds networkdomain.PndStore, users rbac.UserService, roles rbac.RoleService) *NorthboundInterface {
	pndc = pnds
	userService = users
	roleService = roles
	return &NorthboundInterface{
		Pnd:  &pndServer{},
		Core: &core{},
		Csbi: &csbi{},
		Sbi:  &sbiServer{},
		Auth: &Auth{},
		User: &User{},
		Role: &Role{},
	}
}

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