Commit c6c32447 authored by Yann Garcia's avatar Yann Garcia
Browse files

Minor issue fixed in convertProblemDetailstoJson(); Add skeleton of...

Minor issue fixed in convertProblemDetailstoJson(); Add skeleton of meep-vis-traffic-mgr test script
parent 2fad9c7a
Loading
Loading
Loading
Loading
+1 −1
Original line number Diff line number Diff line
@@ -34,7 +34,7 @@ func convertPredictedQostoJson(predictedQos *PredictedQos) string {
func convertProblemDetailstoJson(probdetails *ProblemDetails) string {
	jsonInfo, err := json.Marshal(*probdetails)
	if err != nil {
		log.Println(err.Error())
		log.Error(err.Error())
		return ""
	}
	return string(jsonInfo)
+120 −0
Original line number Diff line number Diff line
package vistrafficmgr

import (
	"fmt"
	"testing"

	log "github.com/InterDigitalInc/AdvantEDGE/go-packages/meep-logger"
)

const ( // FIXME To be update with correct values at the end
	amName      = "pc"
	amNamespace = "postgis-ns"
	amDBUser    = "postgres"
	amDBPwd     = "pwd"
	amDBHost    = "localhost"
	amDBPort    = "30432"
)

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

	// Invalid Connector
	fmt.Println("Invalid VIS Asset Manager")
	tm, err := NewTrafficMgr("", amNamespace, amDBUser, amDBPwd, amDBHost, amDBPort)
	if err == nil || tm != nil {
		t.Fatalf("DB connection should have failed")
	}
	tm, err = NewTrafficMgr(amName, amNamespace, amDBUser, amDBPwd, "invalid-host", amDBPort)
	if err == nil || tm != nil {
		t.Fatalf("DB connection should have failed")
	}
	tm, err = NewTrafficMgr(amName, amNamespace, amDBUser, amDBPwd, amDBHost, "invalid-port")
	if err == nil || tm != nil {
		t.Fatalf("DB connection should have failed")
	}
	tm, err = NewTrafficMgr(amName, amNamespace, amDBUser, "invalid-pwd", amDBHost, amDBPort)
	if err == nil || tm != nil {
		t.Fatalf("DB connection should have failed")
	}

	// Valid Connector
	fmt.Println("Create valid VIS Asset Manager")
	tm, err = NewTrafficMgr(amName, amNamespace, amDBUser, amDBPwd, amDBHost, amDBPort)
	if err != nil || tm == nil {
		t.Fatalf("Failed to create VIS Asset Manager")
	}

	// Cleanup
	_ = tm.DeleteTable(TrafficTable)

	// Create tables
	fmt.Println("Create Table")
	err = tm.CreateTable()
	if err != nil {
		t.Fatalf("Failed to create table")
	}

	// Cleanup
	err = tm.DeleteTables()
	if err != nil {
		t.Fatalf("Failed to create table")
	}

	// t.Fatalf("DONE")
}

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

	// Create Connector
	fmt.Println("Create valid VIS Asset Manager")
	tm, err := NewTrafficMgr(amName, amNamespace, amDBUser, amDBPwd, amDBHost, amDBPort)
	if err != nil || tm == nil {
		t.Fatalf("Failed to create VIS Asset Manager")
	}

	// Cleanup
	_ = tm.DeleteTables()

	// Create tables
	fmt.Println("Create Table")
	err = tm.CreateTable()
	if err != nil {
		t.Fatalf("Failed to create tables")
	}

	// Make sure POA load don't exist
	fmt.Println("Verify no POA load present")
	// TODO
	/*poaMap, err := tm.GetAllPoaLoad()
	if err != nil {
		t.Fatalf("Failed to get all POA load")
	}
	if len(poaMap) != 0 {
		t.Fatalf("No POA load should be present")
	}*/

	// Add Invalid POA load
	fmt.Println("Create Invalid POA load")
	// TODO
	/*poaData := map[string]interface{}{
	}
	err = tm.CreatePoaLoad("")*/

	// Delete all & validate updates
	fmt.Println("Delete all & validate updates")
	// TODO
	/*err = tm.DeleteAllPoaLoad()
	if err != nil {
		t.Fatalf("Failed to delete all POA load")
	}
	poaMap, err = tm.GetAllPoaLoad()
	if err != nil || len(poaMap) != 0 {
		t.Fatalf("POA load should no longer exist")
	}*/

	// t.Fatalf("DONE")
}
+1 −0
Original line number Diff line number Diff line
@@ -15,6 +15,7 @@ GOAPPS=(
GOPKGS=(
    meep-couch
    meep-gis-asset-mgr
    meep-vis-traffic-mgr
    meep-metrics
    meep-model
    meep-mq