Add basic application framework and example application to show interaction between events an NBI

Depends on:

• !340 (merged)
• !344 (merged)
• !349 (merged)
• !342 (merged)

controller/northbound/server/auth_interceptor_test.go

@@ -5,23 +5,46 @@ import (
 	"log"
 	"net"
 	"testing"
+	"time"
 
 	apb "code.fbi.h-da.de/danet/gosdn/api/go/gosdn/rbac"
 	spb "code.fbi.h-da.de/danet/gosdn/api/go/gosdn/southbound"
+	"code.fbi.h-da.de/danet/gosdn/controller/nucleus"
+	"code.fbi.h-da.de/danet/gosdn/controller/rbac"
 	"google.golang.org/grpc"
 	"google.golang.org/grpc/credentials/insecure"
 	"google.golang.org/grpc/metadata"
 	"google.golang.org/grpc/test/bufconn"
 )
 
-func dialer() func(context.Context, string) (net.Conn, error) {
+func getTestAuthInterceptorServer(t *testing.T) (*AuthInterceptor, *User, *Role, *sbiServer) {
+	jwtManager := rbac.NewJWTManager("test", time.Minute)
+	userStore := rbac.NewMemoryUserStore()
+	userService := rbac.NewUserService(userStore)
+
+	roleStore := rbac.NewMemoryRoleStore()
+	roleService := rbac.NewRoleService(roleStore)
+
+	pndStore := nucleus.NewMemoryPndStore()
+
+	s := NewAuthInterceptor(jwtManager, userService, roleService)
+	u := NewUserServer(jwtManager, userService)
+	r := NewRoleServer(jwtManager, roleService)
+	sbi := NewSbiServer(pndStore)
+
+	clearAndCreateAuthTestSetup(userService, roleService)
+
+	return s, u, r, sbi
+}
+
+func dialer(interceptorServer *AuthInterceptor, userServer *User, roleServer *Role, sbiServer *sbiServer) func(context.Context, string) (net.Conn, error) {
 	listener := bufconn.Listen(1024 * 1024)
 
-	interceptor := NewAuthInterceptor(jwt)
+	interceptor := interceptorServer
 	server := grpc.NewServer(grpc.UnaryInterceptor(interceptor.Unary()), grpc.StreamInterceptor(interceptor.Stream()))
 
-	apb.RegisterUserServiceServer(server, &User{})
-	spb.RegisterSbiServiceServer(server, &sbiServer{})
+	apb.RegisterUserServiceServer(server, userServer)
+	spb.RegisterSbiServiceServer(server, sbiServer)
 
 	go func() {
 		if err := server.Serve(listener); err != nil {
@@ -35,20 +58,21 @@ func dialer() func(context.Context, string) (net.Conn, error) {
 }
 
 func TestAuthInterceptor_Unary(t *testing.T) {
-	validToken, err := createTestUserToken("testAdmin", true)
+	a, u, r, s := getTestAuthInterceptorServer(t)
+	validToken, err := createTestUserToken("testAdmin", true, a.userService, a.jwtManager)
 	if err != nil {
-		log.Fatal(err)
+		t.Fatal(err)
 	}
 
-	wrongUserToken, err := createTestUserToken("foo", false)
+	wrongUserToken, err := createTestUserToken("foo", false, a.userService, a.jwtManager)
 	if err != nil {
-		log.Fatal(err)
+		t.Fatal(err)
 	}
 
 	ctx := context.Background()
-	conn, err := grpc.DialContext(ctx, "", grpc.WithTransportCredentials(insecure.NewCredentials()), grpc.WithContextDialer(dialer()))
+	conn, err := grpc.DialContext(ctx, "", grpc.WithTransportCredentials(insecure.NewCredentials()), grpc.WithContextDialer(dialer(a, u, r, s)))
 	if err != nil {
-		log.Fatal(err)
+		t.Fatal(err)
 	}
 	defer conn.Close()
 
@@ -121,15 +145,16 @@ func TestAuthInterceptor_Unary(t *testing.T) {
 }
 
 func TestAuthInterceptor_Stream(t *testing.T) {
-	validToken, err := createTestUserToken("testAdmin", true)
+	a, u, r, s := getTestAuthInterceptorServer(t)
+	validToken, err := createTestUserToken("testAdmin", true, a.userService, a.jwtManager)
 	if err != nil {
-		log.Fatal(err)
+		t.Fatal(err)
 	}
 
 	ctx := context.Background()
-	conn, err := grpc.DialContext(ctx, "", grpc.WithTransportCredentials(insecure.NewCredentials()), grpc.WithContextDialer(dialer()))
+	conn, err := grpc.DialContext(ctx, "", grpc.WithTransportCredentials(insecure.NewCredentials()), grpc.WithContextDialer(dialer(a, u, r, s)))
 	if err != nil {
-		log.Fatal(err)
+		t.Fatal(err)
 	}
 	defer conn.Close()
 
@@ -186,14 +211,15 @@ func TestAuthInterceptor_Stream(t *testing.T) {
 }
 
 func TestAuthInterceptor_authorize(t *testing.T) {
-	validToken, err := createTestUserToken("testAdmin", true)
+	a, _, _, _ := getTestAuthInterceptorServer(t)
+	validToken, err := createTestUserToken("testAdmin", true, a.userService, a.jwtManager)
 	if err != nil {
-		log.Fatal(err)
+		t.Fatal(err)
 	}
 
-	wrongUserToken, err := createTestUserToken("foo", false)
+	wrongUserToken, err := createTestUserToken("foo", false, a.userService, a.jwtManager)
 	if err != nil {
-		log.Fatal(err)
+		t.Fatal(err)
 	}
 
 	type args struct {
@@ -232,11 +258,7 @@ func TestAuthInterceptor_authorize(t *testing.T) {
 	}
 	for _, tt := range tests {
 		t.Run(tt.name, func(t *testing.T) {
-			auth := &AuthInterceptor{
-				jwtManager: jwt,
-			}
-
-			if err := auth.authorize(tt.args.ctx, tt.args.method); (err != nil) != tt.wantErr {
+			if err := a.authorize(tt.args.ctx, tt.args.method); (err != nil) != tt.wantErr {
 				t.Errorf("AuthInterceptor.authorize() error = %v, wantErr %v", err, tt.wantErr)
 			}
 		})