+func TestUpdateAppDataFail1(t *testing.T) {
+ var reg models.RegisterRequest
+ var tEndpoint string = "10.104.237.59"
+ reg.HTTPEndpoint = &tEndpoint
+ rh.UpdateAppData(reg, false)
+}
+
+func TestUpdateAppDataFail2(t *testing.T) {
+ var mockSdlRetOk error
+ var params models.RegisterRequest
+
+ mSdl := new(SdlMock)
+ mSdl2 := new(SdlMock)
+ mockSdlRetNok := errors.New("some SDL error")
+ var tEndpoint1 string = "10.104.237.59:8087"
+ params.HTTPEndpoint = &tEndpoint1
+ serializedSubsReq2, err := json.Marshal(params)
+ if err != nil {
+ t.Logf("error in marshal .. %v", err)
+ }
+
+ subsReq := createSubscription(models.EventTypeCreated, int64(5), int64(10), "http://localhost:8087/xapps_hook")
+ serializedSubsReq, err := json.Marshal(subsReq)
+ assert.Nil(t, err)
+
+ key := "key-1"
+ value := "endpoints"
+ mockSdlGetRetVal := make(map[string]interface{})
+ mockSdlGetRetVal[key] = serializedSubsReq
+
+ mockSdlGetRetVal2 := make(map[string]interface{})
+ mockSdlGetRetVal2[value] = serializedSubsReq2
+ mSdl.On("GetAll").Return([]string{key}, mockSdlRetOk).Twice()
+ mSdl.On("Get", []string{key}).Return(mockSdlGetRetVal, mockSdlRetNok).Once()
+ mSdl2.On("Get", []string{value}).Return(mockSdlGetRetVal2, mockSdlRetOk).Once()
+
+ restHook := createResthook(false, mSdl,mSdl2)
+
+ mSdl2.On("Get", []string{value}).Return(mockSdlGetRetVal2, mockSdlRetOk).Once()
+
+ ret := restHook.GetAppsInSDL()
+ if ret == nil {
+ assert.Nil(t, ret)
+ }
+}
+
+func TestGetAppsInSDLFail3(t *testing.T) {
+ var mockSdlRetOk error
+ var params models.RegisterRequest
+
+ mSdl := new(SdlMock)
+ mSdl2 := new(SdlMock)
+ mockSdlRetNok := errors.New("some SDL error")
+
+ serializedSubsReq1, err := json.Marshal(params)
+ if err != nil {
+ t.Logf("error in marshal .. %v", err)
+ }
+
+ subsReq := createSubscription(models.EventTypeCreated, int64(5), int64(10), "http://localhost:8087/xapps_hook")
+ serializedSubsReq, err := json.Marshal(subsReq)
+ assert.Nil(t, err)
+
+ key := "key-1"
+ value := "endpoints"
+ mockSdlGetRetVal := make(map[string]interface{})
+ mockSdlGetRetVal[key] = serializedSubsReq
+
+ mockSdlGetRetVal1 := make(map[string]interface{})
+ mockSdlGetRetVal1[key] = serializedSubsReq1
+
+ mSdl.On("GetAll").Return([]string{key}, mockSdlRetOk).Twice()
+ mSdl.On("Get", []string{key}).Return(mockSdlGetRetVal, mockSdlRetNok).Once()
+ mSdl2.On("Get", []string{value}).Return(mockSdlGetRetVal1, mockSdlRetOk).Once()
+
+ restHook := createResthook(false, mSdl,mSdl2)
+
+ mSdl2.On("Get", []string{value}).Return(mockSdlGetRetVal1, mockSdlRetOk).Once()
+ ret2 := restHook.GetAppsInSDL()
+ if ret2 != nil {
+ t.Logf("SDL Returning: %s \n",*ret2)
+ }else{
+ assert.Nil(t, ret2)
+ }
+}
+
+func TestUpdateAppDataSucc(t *testing.T) {
+ var mockSdlRetOk error
+ var params models.RegisterRequest
+
+ mSdl := new(SdlMock)
+ mSdl2 := new(SdlMock)
+ mockSdlRetNok := errors.New("some SDL error")
+
+ var tEndpoint1 string = "10.104.237.59:8087"
+ params.HTTPEndpoint = &tEndpoint1
+ serializedSubsReq1, err := json.Marshal(params)
+ if err != nil {
+ t.Logf("error in marshal .. %v", err)
+ }
+ subsReq := createSubscription(models.EventTypeCreated, int64(5), int64(10), "http://localhost:8087/xapps_hook")
+ serializedSubsReq, err := json.Marshal(subsReq)
+ assert.Nil(t, err)
+
+ key := "key-1"
+ value := "endpoints"
+ mockSdlGetRetVal := make(map[string]interface{})
+ mockSdlGetRetVal[key] = serializedSubsReq
+
+ mockSdlGetRetVal1 := make(map[string]interface{})
+ mockSdlGetRetVal1[key] = serializedSubsReq1
+
+ mSdl.On("GetAll").Return([]string{key}, mockSdlRetOk).Twice()
+ mSdl.On("Get", []string{key}).Return(mockSdlGetRetVal, mockSdlRetNok).Once()
+ mSdl2.On("Get", []string{value}).Return(mockSdlGetRetVal1, mockSdlRetOk).Once()
+
+ restHook := createResthook(false, mSdl,mSdl2)
+
+ mSdl2.On("Get", []string{value}).Return(mockSdlGetRetVal1, mockSdlRetOk).Once()
+ mSdl2.On("Set", mock.Anything).Return(mockSdlRetOk)
+ restHook.UpdateAppData(params, true)
+}
+
+func TestUpdateAppDataSucc1(t *testing.T) {
+ var mockSdlRetOk error
+ var params models.RegisterRequest
+
+ mSdl := new(SdlMock)
+ mSdl2 := new(SdlMock)
+ mockSdlRetNok := errors.New("some SDL error")
+
+ var tEndpoint1 string = "10.104.237.59:8087"
+ params.HTTPEndpoint = &tEndpoint1
+ appsindb := []string{ "10.104.237.59:8088 " , " ", " "," 10.104.237.59:8087"}
+ serializedSubsReq1, err := json.Marshal(appsindb)
+ if err != nil {
+ t.Logf("error in marshal .. %v", err)
+ }
+ subsReq := createSubscription(models.EventTypeCreated, int64(5), int64(10), "http://localhost:8087/xapps_hook")
+ serializedSubsReq, err := json.Marshal(subsReq)
+ assert.Nil(t, err)
+
+ key := "key-1"
+ value := "endpoints"
+ mockSdlGetRetVal := make(map[string]interface{})
+ mockSdlGetRetVal[key] = serializedSubsReq
+
+ mockSdlGetRetVal1 := make(map[string]interface{})
+ mockSdlGetRetVal1[value] = serializedSubsReq1
+
+ mSdl.On("GetAll").Return([]string{key}, mockSdlRetOk).Twice()
+ mSdl.On("Get", []string{key}).Return(mockSdlGetRetVal, mockSdlRetNok).Once()
+ mSdl2.On("Get", []string{value}).Return(mockSdlGetRetVal1, mockSdlRetOk).Once()
+
+ restHook := createResthook(false, mSdl,mSdl2)
+
+ mSdl2.On("Get", []string{value}).Return(mockSdlGetRetVal1, mockSdlRetOk).Once()
+ mSdl2.On("Set", []string{value}).Return(mockSdlRetOk).Twice()
+
+ mSdl2.On("Remove").Return(mockSdlRetOk)
+ mSdl2.On("Set", mock.Anything).Return(mockSdlRetOk)
+ restHook.UpdateAppData(params, true)
+}
+
+
+func TestUpdateAppDataSucc2(t *testing.T) {
+ var mockSdlRetOk error
+ var params models.RegisterRequest
+
+ mSdl := new(SdlMock)
+ mSdl2 := new(SdlMock)
+ mockSdlRetNok := errors.New("some SDL error")
+
+ var tEndpoint1 string = "10.104.237.59:8087"
+ params.Config = "/temp/config.yaml"
+ params.HTTPEndpoint = &tEndpoint1
+ serializedSubsReq1, err := json.Marshal(tEndpoint1)
+ if err != nil {
+ t.Logf("error in marshal .. %v", err)
+ }
+ subsReq := createSubscription(models.EventTypeCreated, int64(5), int64(10), "http://localhost:8087/xapps_hook")
+ serializedSubsReq, err := json.Marshal(subsReq)
+ assert.Nil(t, err)
+
+ key := "key-1"
+ value := "endpoints"
+ mockSdlGetRetVal := make(map[string]interface{})
+ mockSdlGetRetVal[key] = serializedSubsReq
+
+ mockSdlGetRetVal1 := make(map[string]interface{})
+ mockSdlGetRetVal1[value] = serializedSubsReq1
+
+ mSdl.On("GetAll").Return([]string{key}, mockSdlRetOk).Twice()
+ mSdl.On("Get", []string{key}).Return(mockSdlGetRetVal, mockSdlRetNok).Once()
+ mSdl2.On("Get", []string{value}).Return(mockSdlGetRetVal1, mockSdlRetOk).Once()
+
+ restHook := createResthook(false, mSdl,mSdl2)
+
+ mSdl2.On("Get", []string{value}).Return(mockSdlGetRetVal1, mockSdlRetOk).Once()
+ mSdl2.On("Set", []string{value}).Return(mockSdlRetOk).Twice()
+
+ mSdl2.On("Remove").Return(mockSdlRetOk)
+ mSdl2.On("Set", mock.Anything).Return(mockSdlRetOk)
+ restHook.UpdateAppData(params, true)
+}