add delete method to /mts_sessions (d105adf3) · Commits · MEC - Multi-access Edge Computing / ETSI MEC Sandbox

go-apps/meep-tm/server/traffic-mgmt_test.go

+70 −26

Original line number	Diff line number	Diff line
		@@ -491,26 +491,7 @@ const testScenarioName = "testScenario"

		var m *mod.Model

		func TestMtsSessionPost(t *testing.T) {
		fmt.Println("--- ", t.Name())
		log.MeepTextLogInit(t.Name())

		initializeVars()

		err := Init()
		if err != nil {
		t.Fatalf("Error initializing test basic procedure")
		}
		err = Run()
		if err != nil {
		t.Fatalf("Error running test basic procedure")
		}

		fmt.Println("Set a scenario")
		initialiseScenario(testScenario)

		time.Sleep(1000 * time.Millisecond)
		updateScenario("mobility1")
		func testMtsSessionPost(t *testing.T) (string, string) {

		/******************************
		* expected response section
		@@ -528,6 +509,10 @@ func TestMtsSessionPost(t *testing.T) {
		MtsMode: &expectedMtsMode,
		TrafficDirection: expectedTrafficDirection,
		}
		expectedResponseStr, err := json.Marshal(expectedMtsSessionInfo)
		if err != nil {
		t.Fatalf(err.Error())
		}

		/******************************
		* request body section
		@@ -585,10 +570,7 @@ func TestMtsSessionPost(t *testing.T) {
		t.Fatalf("Failed to get expected response")
		}

		/******************************
		* back to initial state section
		******************************/
		terminateScenario()
		return respBody.SessionId, string(expectedResponseStr)
		}

		func TestMtsSessionsListGet(t *testing.T) {
		@@ -612,8 +594,8 @@ func TestMtsSessionsListGet(t *testing.T) {
		/******************************
		* POST request section
		******************************/
		TestMtsSessionPost(t)
		TestMtsSessionPost(t)
		_, _ = testMtsSessionPost(t)
		_, _ = testMtsSessionPost(t)

		/******************************
		* expected response section
		@@ -646,6 +628,68 @@ func TestMtsSessionsListGet(t *testing.T) {
		terminateScenario()
		}

		func testMtsSessionDelete(t *testing.T, sessionId string, expectSuccess bool) {

		/******************************
		* request vars section
		******************************/
		vars := make(map[string]string)
		vars["sessionId"] = sessionId

		/******************************
		* request execution section
		******************************/

		if expectSuccess {
		_, err := sendRequest(http.MethodDelete, "/mts/v1/mts_sessions", nil, vars, nil, http.StatusNoContent, mts.MtsSessionDELETE)
		if err != nil {
		t.Fatalf("Failed to get expected response")
		}
		} else {
		_, err := sendRequest(http.MethodDelete, "/mts/v1/mts_sessions", nil, vars, nil, http.StatusNotFound, mts.MtsSessionDELETE)
		if err != nil {
		t.Fatalf("Failed to get expected response")
		}
		}
		}

		func TestMtsSessionComplete(t *testing.T) {
		fmt.Println("--- ", t.Name())
		log.MeepTextLogInit(t.Name())

		initializeVars()

		err := Init()
		if err != nil {
		t.Fatalf("Error initializing test basic procedure")
		}
		err = Run()
		if err != nil {
		t.Fatalf("Error running test basic procedure")
		}

		fmt.Println("Set a scenario")
		initialiseScenario(testScenario)

		time.Sleep(1000 * time.Millisecond)
		updateScenario("mobility1")

		// POST
		sessionId, _ := testMtsSessionPost(t)
		// GET
		// TODO
		// PUT
		// TODO
		// DELETE
		testMtsSessionDelete(t, sessionId, true)

		/******************************
		* back to initial state section
		******************************/

		terminateScenario()
		}

		func terminateScenario() {
		if mqLocal != nil {
		_ = Stop()