diff --git a/controller/api/api_test.go b/controller/api/api_test.go index 3f6e07fce06da04ba95c8761eea0f64dc3083b90..1ed6787c96999a62ec9bb290b792cc935413cc3e 100644 --- a/controller/api/api_test.go +++ b/controller/api/api_test.go @@ -9,10 +9,13 @@ import ( "code.fbi.h-da.de/danet/gosdn/controller/store" log "github.com/sirupsen/logrus" "github.com/spf13/viper" + "google.golang.org/grpc/resolver" ) func Test_Init(t *testing.T) { viper.SetConfigFile("./api_test.toml") + resolver.SetDefaultScheme("passthrough") + if err := Init(context.TODO(), bufnet); err != nil { t.Error(err) } diff --git a/controller/northbound/server/auth_interceptor_test.go b/controller/northbound/server/auth_interceptor_test.go index 4727af2df43067d9983d256ddf8faca0ed7d1538..5571d010f5bacfd31566a8b973aa623e36efaf23 100644 --- a/controller/northbound/server/auth_interceptor_test.go +++ b/controller/northbound/server/auth_interceptor_test.go @@ -18,6 +18,7 @@ import ( "google.golang.org/grpc/codes" "google.golang.org/grpc/credentials/insecure" "google.golang.org/grpc/metadata" + "google.golang.org/grpc/resolver" "google.golang.org/grpc/status" "google.golang.org/grpc/test/bufconn" ) @@ -68,6 +69,7 @@ func getTestAuthInterceptorServer(t *testing.T) (*AuthInterceptor, *UserServer, } func dialer(interceptorServer *AuthInterceptor, userServer *UserServer, roleServer *RoleServer, pluginServer *PluginInternalServer) func(context.Context, string) (net.Conn, error) { + resolver.SetDefaultScheme("passthrough") listener := bufconn.Listen(1024 * 1024) interceptor := interceptorServer @@ -99,16 +101,16 @@ func TestAuthInterceptor_Unary(t *testing.T) { t.Fatal(err) } - ctx := context.Background() - conn, err := grpc.DialContext( - ctx, - "", + dialerFunc := dialer(authServer, userServer, roleServer, pluginServer) + conn, err := grpc.NewClient("bufnet", grpc.WithTransportCredentials(insecure.NewCredentials()), - grpc.WithContextDialer(dialer(authServer, userServer, roleServer, pluginServer)), + grpc.WithContextDialer(dialerFunc), ) + if err != nil { t.Fatal(err) } + defer func() { if err := conn.Close(); err != nil { log.Fatal(err) @@ -197,16 +199,16 @@ func TestAuthInterceptor_Stream(t *testing.T) { t.Fatal(err) } - ctx := context.Background() - conn, err := grpc.DialContext( - ctx, - "", + dialerFunc := dialer(authServer, userServer, roleServer, pluginServer) + conn, err := grpc.NewClient("bufnet", grpc.WithTransportCredentials(insecure.NewCredentials()), - grpc.WithContextDialer(dialer(authServer, userServer, roleServer, pluginServer)), + grpc.WithContextDialer(dialerFunc), ) + if err != nil { t.Fatal(err) } + defer func() { if err := conn.Close(); err != nil { log.Fatal(err)