X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Fxapp%2Futils_test.go;h=3bfcff555b852e024bddfd5614c555be93703d52;hb=65456a961258998289dde353f1f6fad9687fee72;hp=358fbe25bfc4fa3b65f9da48bfed3a226a138366;hpb=4623ad98eb5826c5fbb0928c972e9f02bed4a57a;p=ric-plt%2Fxapp-frame.git diff --git a/pkg/xapp/utils_test.go b/pkg/xapp/utils_test.go index 358fbe2..3bfcff5 100644 --- a/pkg/xapp/utils_test.go +++ b/pkg/xapp/utils_test.go @@ -21,6 +21,7 @@ package xapp import ( "net/http" + "os" "testing" "github.com/stretchr/testify/assert" @@ -36,58 +37,68 @@ func TestNewUtils(t *testing.T) { utils.FetchFiles("./", []string{"go.mod"}) utils.FetchFiles("./", []string{"go.mod"}) + tmpFileName, err := utils.ZipFilesToTmpFile("/tmp/abcd", "symptom", []string{"/tmp/abcd/file.txt"}) + assert.Equal(t, err, nil) + defer os.Remove(tmpFileName) + + assert.Equal(t, utils.CreateDir("/tmp/dcba"), nil) + _, err = utils.UnZipFiles(tmpFileName, "/tmp/dcba") + assert.Equal(t, err, nil) + utils.DeleteFile("/tmp/abcd") + utils.DeleteFile("/tmp/dcba") } func TestSymptomdata(t *testing.T) { + os.Setenv("RMR_STASH_RT", "config/uta_rtg.rt.stash.inc") assert.Equal(t, Resource.CollectDefaultSymptomData("abcd.tgz", "data"), "/tmp/xapp/") } func TestSymptomdataCollection(t *testing.T) { - var handler = func(w http.ResponseWriter, r *http.Request) { + var handler1 = func(w http.ResponseWriter, r *http.Request) { Resource.SendSymptomDataJson(w, r, "data", "aaaa") Resource.SendSymptomDataFile(w, r, "./config", "symptomdata.gz") } - Resource.InjectQueryRoute("/ric/v1/user", handler, "GET", "foo", "bar", "id", "mykey") + Resource.InjectQueryRoute("/ric/v1/user1", handler1, "GET", "foo", "bar", "id", "mykey") - req, _ := http.NewRequest("GET", "/ric/v1/user?foo=bar&id=mykey", nil) + req, _ := http.NewRequest("GET", "/ric/v1/user1?foo=bar&id=mykey", nil) resp := executeRequest(req, nil) checkResponseCode(t, http.StatusOK, resp.Code) } func TestSymptomdataCollectionError(t *testing.T) { - var handler = func(w http.ResponseWriter, r *http.Request) { + var handler2 = func(w http.ResponseWriter, r *http.Request) { Resource.SendSymptomDataError(w, r, "Error text") } - Resource.InjectQueryRoute("/ric/v1/user", handler, "GET", "foo", "bar", "id", "mykey") + Resource.InjectQueryRoute("/ric/v1/user2", handler2, "GET", "foo", "bar", "id", "mykey") - req, _ := http.NewRequest("GET", "/ric/v1/user?foo=bar&id=mykey", nil) + req, _ := http.NewRequest("GET", "/ric/v1/user2?foo=bar&id=mykey", nil) resp := executeRequest(req, nil) - checkResponseCode(t, http.StatusOK, resp.Code) + checkResponseCode(t, http.StatusInternalServerError, resp.Code) } func TestGetSymptomDataParams(t *testing.T) { - var handler = func(w http.ResponseWriter, r *http.Request) { + var handler3 = func(w http.ResponseWriter, r *http.Request) { Resource.GetSymptomDataParams(w, r) } - Resource.InjectQueryRoute("/ric/v1/user", handler, "GET", "foo", "bar", "id", "mykey") + Resource.InjectQueryRoute("/ric/v1/user3", handler3, "GET", "timeout", "10", "fromtime", "1", "totime", "2") - req, _ := http.NewRequest("GET", "/ric/v1/user?foo=bar&id=mykey", nil) + req, _ := http.NewRequest("GET", "/ric/v1/user3?timeout=10&fromtime=1&totime=2", nil) resp := executeRequest(req, nil) checkResponseCode(t, http.StatusOK, resp.Code) } func TestAppconfigHandler(t *testing.T) { - var handler = func(w http.ResponseWriter, r *http.Request) { + var handler4 = func(w http.ResponseWriter, r *http.Request) { appconfigHandler(w, r) } - Resource.InjectQueryRoute("/ric/v1/user", handler, "GET", "foo", "bar", "id", "mykey") + Resource.InjectQueryRoute("/ric/v1/user4", handler4, "GET", "foo", "bar", "id", "mykey") - req, _ := http.NewRequest("GET", "/ric/v1/user?foo=bar&id=mykey", nil) + req, _ := http.NewRequest("GET", "/ric/v1/user4?foo=bar&id=mykey", nil) resp := executeRequest(req, nil) - checkResponseCode(t, http.StatusOK, resp.Code) + checkResponseCode(t, http.StatusInternalServerError, resp.Code) }