pnd_test.go

package server

//import (
//	"context"
//	"testing"
//	"time"
//
//	ppb "code.fbi.h-da.de/danet/gosdn/api/go/gosdn/pnd"
//	spb "code.fbi.h-da.de/danet/gosdn/api/go/gosdn/southbound"
//	"code.fbi.h-da.de/danet/gosdn/controller/mocks"
//	"code.fbi.h-da.de/danet/gosdn/controller/nucleus"
//	"code.fbi.h-da.de/danet/gosdn/models/generated/openconfig"
//	"github.com/google/uuid"
//	"github.com/openconfig/gnmi/proto/gnmi"
//	"github.com/stretchr/testify/mock"
//)
//
//func getTestPndServer(t *testing.T) *PndServer {
//	var err error
//	pndUUID, err = uuid.Parse(pndID)
//	if err != nil {
//		t.Fatal(err)
//	}
//
//	sbiUUID, err = uuid.Parse(sbiID)
//	if err != nil {
//		t.Fatal(err)
//	}
//
//	pendingChangeUUID, err = uuid.Parse(pendingChangeID)
//	if err != nil {
//		t.Fatal(err)
//	}
//
//	committedChangeUUID, err = uuid.Parse(committedChangeID)
//	if err != nil {
//		t.Fatal(err)
//	}
//
//	mneUUID, err = uuid.Parse(mneID)
//	if err != nil {
//		t.Fatal(err)
//	}
//
//	mockNetworkElement = &nucleus.CommonNetworkElement{
//		Plugin: &openconfig.Device{
//			System: &openconfig.OpenconfigSystem_System{
//				Config: &openconfig.OpenconfigSystem_System_Config{
//					Hostname:   &hostname,
//					DomainName: &domainname,
//				},
//			},
//		},
//		UUID: mneUUID,
//	}
//
//	sbi, err := nucleus.NewSBI(spb.Type_TYPE_OPENCONFIG, sbiUUID)
//	if err != nil {
//		t.Fatal(err)
//	}
//	mockNetworkElement.(*nucleus.CommonNetworkElement).SetTransport(&mocks.Transport{})
//	mockNetworkElement.(*nucleus.CommonNetworkElement).SetName(hostname)
//	sbiStore = nucleus.NewPluginStore(pndUUID)
//	if err := sbiStore.Add(mockNetworkElement.SBI()); err != nil {
//		t.Fatal(err)
//	}
//
//	mockChange := &mocks.Change{}
//	mockChange.On("Age").Return(time.Hour)
//	mockChange.On("State").Return(ppb.ChangeState_CHANGE_STATE_INCONSISTENT)
//
//	mockPnd = &mocks.NetworkDomain{}
//	mockPnd.On("ID").Return(pndUUID)
//	mockPnd.On("GetName").Return("test")
//	mockPnd.On("GetDescription").Return("test")
//	mockPnd.On("GetSBIs").Return(sbiStore)
//	mockPnd.On("GetSBI", mock.Anything).Return(mockNetworkElement.SBI(), nil)
//	mockPnd.On("NetworkElements").Return([]uuid.UUID{mneUUID})
//	mockPnd.On("PendingChanges").Return([]uuid.UUID{pendingChangeUUID})
//	mockPnd.On("CommittedChanges").Return([]uuid.UUID{committedChangeUUID})
//	mockPnd.On("GetChange", mock.Anything).Return(mockChange, nil)
//	mockPnd.On("AddNetworkElement", mock.Anything, mock.Anything, mock.Anything).Return(nil)
//	mockPnd.On("GetNetworkElement", mock.Anything).Return(mockNetworkElement, nil)
//	mockPnd.On("Commit", mock.Anything).Return(nil)
//	mockPnd.On("Confirm", mock.Anything).Return(nil)
//	mockPnd.On("ChangeMNE", mock.Anything, mock.Anything, mock.Anything, mock.Anything).Return(uuid.Nil, nil)
//	mockPnd.On("Request", mock.Anything, mock.Anything).Return(&gnmi.GetResponse{}, nil)
//
//	pndStore := nucleus.NewMemoryPndStore()
//	if err := pndStore.Add(mockPnd); err != nil {
//		t.Fatal(err)
//	}
//
//	c := NewPndServer(pndStore)
//
//	return c
//}
//
//// TODO: This test case does not make sense; needs to be adjusted.
//func Test_pnd_GetPath(t *testing.T) {
//	initUUIDs(t)
//
//	//opts := cmp.Options{
//	//	cmpopts.SortSlices(
//	//		func(x, y *gnmi.Update) bool {
//	//			return x.GetVal().String() < y.GetVal().String()
//	//		},
//	//	),
//	//	cmp.Comparer(proto.Equal),
//	//}
//
//	type args struct {
//		ctx     context.Context
//		request *ppb.GetPathRequest
//	}
//	tests := []struct {
//		name    string
//		args    args
//		want    []*gnmi.Notification
//		wantErr bool
//	}{
//		{
//			name: "get path: system/config/hostname",
//			args: args{
//				ctx: context.Background(),
//				request: &ppb.GetPathRequest{
//					Timestamp: time.Now().UnixNano(),
//					Mneid:     mneUUID.String(),
//					Path:      "system/config/hostname",
//					Pid:       pndUUID.String(),
//				},
//			},
//			want: []*gnmi.Notification{
//				{
//					Update: []*gnmi.Update{
//						{
//							Path: &gnmi.Path{
//								Elem: []*gnmi.PathElem{
//									{
//										Name: "system",
//									},
//									{
//										Name: "config",
//									},
//									{
//										Name: "hostname",
//									},
//								},
//							},
//							Val: &gnmi.TypedValue{
//								Value: &gnmi.TypedValue_StringVal{
//									StringVal: "manfred",
//								},
//							},
//						},
//					}},
//			},
//			wantErr: false,
//		},
//		{
//			name: "get path: system",
//			args: args{
//				ctx: context.Background(),
//				request: &ppb.GetPathRequest{
//					Timestamp: time.Now().UnixNano(),
//					Mneid:     mneUUID.String(),
//					Path:      "system",
//					Pid:       pndUUID.String(),
//				},
//			},
//			want: []*gnmi.Notification{
//				{
//					Update: []*gnmi.Update{
//						{
//							Path: &gnmi.Path{
//								Elem: []*gnmi.PathElem{
//									{
//										Name: "system",
//									},
//								},
//							},
//							Val: &gnmi.TypedValue{
//								Value: &gnmi.TypedValue_JsonIetfVal{
//									JsonIetfVal: []byte("{\n  \"openconfig-system:config\": {\n    \"domain-name\": \"uwe\",\n    \"hostname\": \"manfred\"\n  }\n}"),
//								},
//							},
//						},
//					}},
//			},
//			wantErr: false,
//		},
//		//{
//		//	name: "get path: this/path/is/not/valid",
//		//	args: args{
//		//		ctx: context.Background(),
//		//		request: &ppb.GetPathRequest{
//		//			Timestamp: time.Now().UnixNano(),
//		//			Mneid:     mneUUID.String(),
//		//			Path:      "this/path/is/not/valid",
//		//			Pid:       pndUUID.String(),
//		//		},
//		//	},
//		//	want:    []*gnmi.Notification{},
//		//	wantErr: true,
//		//},
//	}
//	for _, tt := range tests {
//		t.Run(tt.name, func(t *testing.T) {
//			s := getTestPndServer(t)
//			_, err := s.GetPath(tt.args.ctx, tt.args.request)
//			if (err != nil) != tt.wantErr {
//				t.Errorf("GetPath() error = %v, wantErr %v", err, tt.wantErr)
//				return
//			}
//
//			//got := resp.GetMneNotification()
//
//			//for i, n := range got {
//			//	if diff := cmp.Diff(n.GetUpdate(), tt.want[i].GetUpdate(), opts...); diff != "" {
//			//		t.Errorf("GetPath() diff in the received notification %d: \n%s", i+1, diff)
//			//	}
//			//}
//		})
//	}
//}
//
//func Test_pnd_Set(t *testing.T) {
//	// type args struct {
//	// 	ctx     context.Context
//	// 	request *ppb.SetRequest
//	// }
//	// tests := []struct {
//	// 	name    string
//	// 	args    args
//	// 	want    ppb.SetResponseStatus
//	// 	wantErr bool
//	// }{
//	// 	{
//	// 		name: "set mne",
//	// 		args: args{
//	// 			ctx: context.Background(),
//	// 			request: &ppb.SetRequest{
//	// 				Mne: []*ppb.SetMne{
//	// 					{
//	// 						Sbi: &spb.SouthboundInterface{
//	// 							Id:   sbiID,
//	// 							Type: spb.Type_TYPE_OPENCONFIG,
//	// 						},
//	// 						DeviceName: hostname,
//	// 						TransportOption: &transport.TransportOption{
//	// 							Address:  "test",
//	// 							Username: "test",
//	// 							Password: "test",
//	// 							TransportOption: &transport.TransportOption_GnmiTransportOption{
//	// 								GnmiTransportOption: &transport.GnmiTransportOption{},
//	// 							},
//	// 						},
//	// 					},
//	// 				},
//	// 				Pid: pndID,
//	// 			},
//	// 		},
//	// 		want: ppb.SetResponse_OK,
//	// 	},
//	// 	// {
//	// 	// 	name: "set change",
//	// 	// 	args: args{
//	// 	// 		ctx: context.Background(),
//	// 	// 		request: &ppb.SetRequest{
//	// 	// 			Pid: pndID,
//	// 	// 			Change: []*ppb.SetChange{
//	// 	// 				{
//	// 	// 					Cuid: pendingChangeID,
//	// 	// 					Op:   ppb.SetChange_COMMIT,
//	// 	// 				},
//	// 	// 				{
//	// 	// 					Cuid: committedChangeID,
//	// 	// 					Op:   ppb.SetChange_CONFIRM,
//	// 	// 				},
//	// 	// 			},
//	// 	// 		},
//	// 	// 	},
//	// 	// 	want: ppb.SetResponse_OK,
//	// 	// },
//	// 	// 	{
//	// 	// 		name: "change request",
//	// 	// 		args: args{
//	// 	// 			ctx: context.Background(),
//	// 	// 			request: &ppb.SetRequest{
//	// 	// 				Pid: pndID,
//	// 	// 				ChangeRequest: []*ppb.ChangeRequest{
//	// 	// 					{
//	// 	// 						Id:    mneID,
//	// 	// 						Path:  "/system/config/hostname",
//	// 	// 						Value: "herbert",
//	// 	// 						ApiOp: ppb.ApiOperation_UPDATE,
//	// 	// 					},
//	// 	// 					{
//	// 	// 						Id:    mneID,
//	// 	// 						Path:  "/system/config/hostname",
//	// 	// 						Value: "fridolin",
//	// 	// 						ApiOp: ppb.ApiOperation_REPLACE,
//	// 	// 					},
//	// 	// 					{
//	// 	// 						Id:    mneID,
//	// 	// 						Path:  "/system/config/hostname",
//	// 	// 						ApiOp: ppb.ApiOperation_DELETE,
//	// 	// 					},
//	// 	// 				},
//	// 	// 			},
//	// 	// 		},
//	// 	// 		want: ppb.SetResponse_OK,
//	// 	// 	},
//	// }
//	// for _, tt := range tests {
//	// 	t.Run(tt.name, func(t *testing.T) {
//	// 		p := pndServer{
//	// 			UnimplementedPndServiceServer: ppb.UnimplementedPndServiceServer{},
//	// 		}
//	// 		resp, err := p.Set(tt.args.ctx, tt.args.request)
//	// 		if (err != nil) != tt.wantErr {
//	// 			t.Errorf("Set() error = %v, wantErr %v", err, tt.wantErr)
//	// 			return
//	// 		}
//	// 		got := resp.Status
//	// 		if !reflect.DeepEqual(got, tt.want) {
//	// 			t.Errorf("Set() got = %v, want %v", got, tt.want)
//	// 		}
//	// 		for _, r := range resp.Responses {
//	// 			got = r.Status
//	// 			if !reflect.DeepEqual(got, tt.want) {
//	// 				t.Errorf("Set() got = %v, want %v", got, tt.want)
//	// 			}
//	// 		}
//	// 	})
//	// }
//}