+
+func (mc *testingSubmgrControl) GetMetrics(t *testing.T) (string, error) {
+ req, err := http.NewRequest("GET", "http://localhost:8080/ric/v1/metrics", nil)
+ if err != nil {
+ return "", fmt.Errorf("Error reading request. %v", err)
+ }
+ client := &http.Client{Timeout: time.Second * 10}
+ resp, err := client.Do(req)
+ if err != nil {
+ return "", fmt.Errorf("Error reading response. %v", err)
+ }
+ defer resp.Body.Close()
+
+ respBody, err := ioutil.ReadAll(resp.Body)
+ if err != nil {
+ return "", fmt.Errorf("Error reading body. %v", err)
+ }
+ return string(respBody[:]), nil
+}
+
+func (mc *testingSubmgrControl) CounterValuesToBeVeriefied(t *testing.T, countersToBeAdded CountersToBeAdded) {
+
+ if len(toBeAddedCountersMap) == 0 {
+ toBeAddedCountersMap = make(map[string]Counter)
+ }
+ for _, counter := range countersToBeAdded {
+ toBeAddedCountersMap[counter.Name] = counter
+ }
+ mc.GetCounterValuesBefore(t)
+}
+
+func (mc *testingSubmgrControl) GetCounterValuesBefore(t *testing.T) {
+ countersBeforeMap = make(map[string]Counter)
+ countersBeforeMap = mc.GetCurrentCounterValues(t, toBeAddedCountersMap)
+}
+
+func (mc *testingSubmgrControl) VerifyCounterValues(t *testing.T) {
+ currentCountersMap := mc.GetCurrentCounterValues(t, toBeAddedCountersMap)
+ for _, toBeAddedCounter := range toBeAddedCountersMap {
+ if currentCounter, ok := currentCountersMap[toBeAddedCounter.Name]; ok == true {
+ if beforeCounter, ok := countersBeforeMap[toBeAddedCounter.Name]; ok == true {
+ if currentCounter.Value != beforeCounter.Value+toBeAddedCounter.Value {
+ mc.TestError(t, "Error in expected counter value: counterName %v, current value %v, expected value %v",
+ currentCounter.Name, currentCounter.Value, beforeCounter.Value+toBeAddedCounter.Value)
+
+ //fmt.Printf("beforeCounter.Value=%v, toBeAddedCounter.Value=%v, \n",beforeCounter.Value, toBeAddedCounter.Value)
+ }
+ } else {
+ mc.TestError(t, "Counter %v not in countersBeforeMap", toBeAddedCounter.Name)
+ }
+ } else {
+ mc.TestError(t, "Counter %v not in currentCountersMap", toBeAddedCounter.Name)
+ }
+ }
+
+ // Make map empty
+ //fmt.Printf("toBeAddedCountersMap=%v\n",toBeAddedCountersMap)
+ toBeAddedCountersMap = make(map[string]Counter)
+}
+
+func (mc *testingSubmgrControl) GetCurrentCounterValues(t *testing.T, chekedCountersMap map[string]Counter) map[string]Counter {
+ countersString, err := mc.GetMetrics(t)
+ if err != nil {
+ mc.TestError(t, "Error GetMetrics() failed %v", err)
+ return nil
+ }
+
+ retCounterMap := make(map[string]Counter)
+ stringsTable := strings.Split(countersString, "\n")
+ for _, counter := range chekedCountersMap {
+ for _, counterString := range stringsTable {
+ if !strings.Contains(counterString, "#") && strings.Contains(counterString, counter.Name) {
+ counterString := strings.Split(counterString, " ")
+ if strings.Contains(counterString[0], counter.Name) {
+ val, err := strconv.ParseUint(counterString[1], 10, 64)
+ if err != nil {
+ mc.TestError(t, "Error: strconv.ParseUint failed %v", err)
+ }
+ counter.Value = val
+ //fmt.Printf("counter=%v\n", counter)
+ retCounterMap[counter.Name] = counter
+ }
+ }
+ }
+ }
+
+ if len(retCounterMap) != len(chekedCountersMap) {
+ mc.TestError(t, "Error: len(retCounterMap) != len(chekedCountersMap)")
+
+ }
+ return retCounterMap
+}
+
+func (mc *testingSubmgrControl) sendGetRequest(t *testing.T, addr string, path string) {
+
+ 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
+ }
+ req.Header.Set("Cache-Control", "no-cache")
+ client := &http.Client{Timeout: time.Second * 2}
+ resp, err := client.Do(req)
+ if err != nil {
+ mc.TestError(t, "Error reading response. %v", err)
+ return
+ }
+ 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
+ }
+
+ respBody, err := ioutil.ReadAll(resp.Body)
+ if err != nil {
+ mc.TestError(t, "Error reading body. %v", err)
+ return
+ }
+ mc.TestLog(t, "%s", respBody)
+ return
+}
+
+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
+ }
+ client := &http.Client{Timeout: time.Second * 2}
+ resp, err := client.Do(req)
+ if err != nil {
+ mc.TestError(t, "Error reading response. %v", err)
+ return
+ }
+ 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
+ }
+
+ respBody, err := ioutil.ReadAll(resp.Body)
+ if err != nil {
+ mc.TestError(t, "Error reading body. %v", err)
+ return
+ }
+ mc.TestLog(t, "%s", respBody)
+ return
+}