diff --git a/nucleus/gnmi_transport.go b/nucleus/gnmi_transport.go index 12d04505ea3da57f25bfb3c518376fe3430a028d..1834ce7e13e9acd6e5bf2ea7871b960f01bf3d98 100644 --- a/nucleus/gnmi_transport.go +++ b/nucleus/gnmi_transport.go @@ -4,9 +4,10 @@ import ( "context" "reflect" - ppb "code.fbi.h-da.de/cocsn/api/go/gosdn/pnd" "google.golang.org/grpc" + ppb "code.fbi.h-da.de/cocsn/api/go/gosdn/pnd" + "code.fbi.h-da.de/cocsn/gosdn/forks/goarista/gnmi" "code.fbi.h-da.de/cocsn/gosdn/nucleus/errors" "code.fbi.h-da.de/cocsn/gosdn/nucleus/types" diff --git a/nucleus/gnmi_transport_test.go b/nucleus/gnmi_transport_test.go index c32a269c65061a9dfdfc4ccefa329e4fe52d4623..2809e20967645351ce55ac30361dfc9965edb2ef 100644 --- a/nucleus/gnmi_transport_test.go +++ b/nucleus/gnmi_transport_test.go @@ -1,6 +1,7 @@ package nucleus import ( + tpb "code.fbi.h-da.de/cocsn/api/go/gosdn/transport" "context" "errors" "reflect" @@ -482,6 +483,37 @@ func TestNewGnmiTransport(t *testing.T) { Compression: "brotli", }, }}}, +<<<<<<< HEAD +======= + want: nil, + wantErr: true, + }, + { + name: "certificate error no key file", + args: args{ + opts: &tpb.TransportOption{ + TransportOption: &tpb.TransportOption_GnmiTransportOption{ + GnmiTransportOption: &tpb.GnmiTransportOption{ + GrpcDialOptions: map[string]string{ + "cert-file":"invalid", + }, + }, + }}}, + want: nil, + wantErr: true, + }, + { + name: "certificate error no ca file", + args: args{ + opts: &tpb.TransportOption{ + TransportOption: &tpb.TransportOption_GnmiTransportOption{ + GnmiTransportOption: &tpb.GnmiTransportOption{ + GrpcDialOptions: map[string]string{ + "ca-file":"invalid", + }, + }, + }}}, +>>>>>>> 55fb68b4 (moved transport options to proto) want: nil, wantErr: true, }, @@ -491,7 +523,11 @@ func TestNewGnmiTransport(t *testing.T) { if tt.name == "default" { startGnmiTarget <- gnmiConfig.Addr } +<<<<<<< HEAD got, err := NewGnmiTransport(tt.args.opts, NewSBI(spb.Type_OPENCONFIG)) +======= + got, err := NewGnmiTransport(tt.args.opts, &OpenConfig{}) +>>>>>>> 55fb68b4 (moved transport options to proto) if (err != nil) != tt.wantErr { t.Errorf("NewGnmiTransport() error = %v, wantErr %v", err, tt.wantErr) return diff --git a/nucleus/initialise_test.go b/nucleus/initialise_test.go index e412a631d0ea6f43169842a1b924a3db4f85ab62..f105c68693385ca54b6407bc9ea08a5f1b98dc8f 100644 --- a/nucleus/initialise_test.go +++ b/nucleus/initialise_test.go @@ -7,6 +7,8 @@ import ( tpb "code.fbi.h-da.de/cocsn/api/go/gosdn/transport" + tpb "code.fbi.h-da.de/cocsn/api/go/gosdn/transport" + "code.fbi.h-da.de/cocsn/gosdn/forks/goarista/gnmi" "code.fbi.h-da.de/cocsn/gosdn/mocks" "code.fbi.h-da.de/cocsn/gosdn/nucleus/util/proto" diff --git a/nucleus/transport.go b/nucleus/transport.go index dded3c4b299dcf9e9046b52e9c18c5f52dfe737e..62de98b5ecff9f7c0351ca82c9bd9856565a8734 100644 --- a/nucleus/transport.go +++ b/nucleus/transport.go @@ -1,10 +1,16 @@ package nucleus import ( +<<<<<<< HEAD "context" tpb "code.fbi.h-da.de/cocsn/api/go/gosdn/transport" "code.fbi.h-da.de/cocsn/gosdn/nucleus/errors" +======= + tpb "code.fbi.h-da.de/cocsn/api/go/gosdn/transport" + "code.fbi.h-da.de/cocsn/gosdn/nucleus/errors" + "context" +>>>>>>> 55fb68b4 (moved transport options to proto) "github.com/openconfig/ygot/ytypes" ) @@ -22,12 +28,15 @@ type Transport interface { // NewTransport receives TransportOptions and returns an appropriate Transport // implementation func NewTransport(opts *tpb.TransportOption, sbi SouthboundInterface) (Transport, error) { +<<<<<<< HEAD if opts == nil { return nil, &errors.ErrInvalidParameters{ Func: NewTransport, Param: "'opt' cannot be 'nil'", } } +======= +>>>>>>> 55fb68b4 (moved transport options to proto) switch o := opts.TransportOption.(type) { case *tpb.TransportOption_GnmiTransportOption: return NewGnmiTransport(opts, sbi)