X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Fcontrol%2Fut_ctrl_submgr_test.go;h=78d99904c1898aa192ea1d229bf4b54f28ae4e9c;hb=92c3855b5c2d86a54f1342498a2772a605073e06;hp=1563a00dd4190c5c24f12a8019a90d143476f45c;hpb=2738517925ce36e7a107bd0779ca998018e78991;p=ric-plt%2Fsubmgr.git diff --git a/pkg/control/ut_ctrl_submgr_test.go b/pkg/control/ut_ctrl_submgr_test.go index 1563a00..78d9990 100644 --- a/pkg/control/ut_ctrl_submgr_test.go +++ b/pkg/control/ut_ctrl_submgr_test.go @@ -449,15 +449,49 @@ func (mc *testingSubmgrControl) GetCurrentCounterValues(t *testing.T, chekedCoun return retCounterMap } -func (mc *testingSubmgrControl) sendGetRequest(t *testing.T, addr string, path string) { +func (mc *testingSubmgrControl) SendGetRequest(t *testing.T, addr string, path string) []byte { mc.TestLog(t, "GET http://"+addr+"%v", path) req, err := http.NewRequest("GET", "http://"+addr+path, nil) + if err != nil { + mc.TestError(t, "Error reading request. %v", err) + return nil + } + + req.Header.Set("accept", "application/json") + client := &http.Client{Timeout: time.Second * 2} + resp, err := client.Do(req) + if err != nil { + mc.TestError(t, "Error reading response. %v", err) + return nil + } + defer resp.Body.Close() + + mc.TestLog(t, "Response status: %v", resp.Status) + mc.TestLog(t, "Response Headers: %v", resp.Header) + if !strings.Contains(resp.Status, "200 OK") { + mc.TestError(t, "Wrong response status") + return nil + } + + respBody, err := ioutil.ReadAll(resp.Body) + if err != nil { + mc.TestError(t, "Error reading body. %v", err) + return nil + } + mc.TestLog(t, "%s", respBody) + return respBody +} + +func (mc *testingSubmgrControl) SendPostRequest(t *testing.T, addr string, path string) { + + mc.TestLog(t, "POST http://"+addr+"%v", path) + req, err := http.NewRequest("POST", "http://"+addr+path, nil) if err != nil { mc.TestError(t, "Error reading request. %v", err) return } - req.Header.Set("Cache-Control", "no-cache") + req.Header.Set("accept", "application/json") client := &http.Client{Timeout: time.Second * 2} resp, err := client.Do(req) if err != nil { @@ -482,14 +516,15 @@ func (mc *testingSubmgrControl) sendGetRequest(t *testing.T, addr string, path s return } -func (mc *testingSubmgrControl) sendPostRequest(t *testing.T, addr string, path string) { +func (mc *testingSubmgrControl) SendDeleteRequest(t *testing.T, addr string, path string) { - mc.TestLog(t, "POST http://"+addr+"%v", path) - req, err := http.NewRequest("POST", "http://"+addr+path, nil) + mc.TestLog(t, "DELETE http://"+addr+"%v", path) + req, err := http.NewRequest("DELETE", "http://"+addr+path, nil) if err != nil { mc.TestError(t, "Error reading request. %v", err) return } + req.Header.Set("accept", "application/json") client := &http.Client{Timeout: time.Second * 2} resp, err := client.Do(req) if err != nil { @@ -500,7 +535,7 @@ func (mc *testingSubmgrControl) sendPostRequest(t *testing.T, addr string, path mc.TestLog(t, "Response status: %v", resp.Status) mc.TestLog(t, "Response Headers: %v", resp.Header) - if !strings.Contains(resp.Status, "200 OK") { + if !strings.Contains(resp.Status, "204 No Content") { mc.TestError(t, "Wrong response status") return } @@ -514,12 +549,19 @@ func (mc *testingSubmgrControl) sendPostRequest(t *testing.T, addr string, path return } -//----------------------------------------------------------------------------- -// -//----------------------------------------------------------------------------- func (mc *testingSubmgrControl) SetE2State(t *testing.T, ranNameState string) { if err := mc.c.e2IfStateDb.XappRnibStoreAndPublish("RAN_CONNECTION_STATUS_CHANGE", ranNameState, "key1", "data1"); err != nil { t.Errorf("XappRnibStoreAndPublish failed: %v", err) } } + +func (mc *testingSubmgrControl) VerifyStringExistInSlice(verifiedString string, list []string) bool { + + for _, listItem := range list { + if listItem == verifiedString { + return true + } + } + return false +}