Skip to content
Normal view Permalink
model_test.go 68.1 KiB
Newer Older
Michel Roy's avatar
meep-model package
Michel Roy committed
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 
/*
 * Copyright (c) 2019  InterDigital Communications, Inc
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

package model

import (
	"fmt"
	"testing"
Michel Roy's avatar
Added Listen()  
Michel Roy committed
22 
	"time"
Michel Roy's avatar
meep-model package
Michel Roy committed
23
Kevin Di Lallo's avatar
split ctrl-engine into platfrom-ctrl & sandbox-ctrl  
Kevin Di Lallo committed
24 
	dataModel "github.com/InterDigitalInc/AdvantEDGE/go-packages/meep-data-model"
Michel Roy's avatar
meep-model package
Michel Roy committed
25 
	log "github.com/InterDigitalInc/AdvantEDGE/go-packages/meep-logger"
Kevin Di Lallo's avatar
added meep-model scenario validator  
Kevin Di Lallo committed
26 
	"github.com/blang/semver"
Michel Roy's avatar
meep-model package
Michel Roy committed
27 28 
)
Kevin Di Lallo's avatar
update mg-manager to use meep-model package + added dijkstra network graph to model  
Kevin Di Lallo committed
29 30 
const modelRedisAddr string = "localhost:30380"
const modelRedisTestTable = 0
Michel Roy's avatar
Added Listen()  
Michel Roy committed
31 32 
const modelName string = "test-model"
const moduleName string = "test-module"
Kevin Di Lallo's avatar
meep-data-key-manager to standardize redis data keys + virt engine & webhook multi-scenario support  
Kevin Di Lallo committed
33 
const moduleNamespace string = "test-ns"
Kevin Di Lallo's avatar
added meep-model scenario validator  
Kevin Di Lallo committed
34 
const testScenario string = `{"_id":"demo1","_rev":"5-905df5009b54170401d47031711afff7","name":"demo1","deployment":{"interDomainLatency":50,"interDomainLatencyVariation":5,"interDomainThroughput":1000,"domains":[{"id":"PUBLIC","name":"PUBLIC","type":"PUBLIC","interZoneLatency":6,"interZoneLatencyVariation":2,"interZoneThroughput":1000000,"zones":[{"id":"PUBLIC-COMMON","name":"PUBLIC-COMMON","type":"COMMON","interFogLatency":2,"interFogLatencyVariation":1,"interFogThroughput":1000000,"interEdgeLatency":3,"interEdgeLatencyVariation":1,"interEdgeThroughput":1000000,"edgeFogLatency":5,"edgeFogLatencyVariation":1,"edgeFogThroughput":1000000,"networkLocations":[{"id":"PUBLIC-COMMON-DEFAULT","name":"PUBLIC-COMMON-DEFAULT","type":"DEFAULT","terminalLinkLatency":1,"terminalLinkLatencyVariation":1,"terminalLinkThroughput":50000,"terminalLinkPacketLoss":1,"physicalLocations":[{"id":"cloud1","name":"cloud1","type":"DC","processes":[{"id":"cloud1-iperf","name":"cloud1-iperf","type":"CLOUD-APP","image":"gophernet/iperf-server","commandArguments":"-c, export; iperf -s -p $IPERF_SERVICE_PORT","commandExe":"/bin/bash","serviceConfig":{"name":"cloud1-iperf","ports":[{"protocol":"UDP","port":80}]}},{"id":"cloud1-svc","name":"cloud1-svc","type":"CLOUD-APP","image":"meep-docker-registry:30001/demo-server","environment":"MGM_GROUP_NAME=cloud1-svc, MGM_APP_ID=cloud1-svc, MGM_APP_PORT=80","serviceConfig":{"name":"cloud1-svc","ports":[{"protocol":"TCP","port":80}]}}]}]}]}]},{"id":"operator1","name":"operator1","type":"OPERATOR","interZoneLatency":15,"interZoneLatencyVariation":3,"interZoneThroughput":1000,"zones":[{"id":"operator1-COMMON","name":"operator1-COMMON","type":"COMMON","interFogLatency":2,"interFogLatencyVariation":1,"interFogThroughput":1000000,"interEdgeLatency":3,"interEdgeLatencyVariation":1,"interEdgeThroughput":1000000,"edgeFogLatency":5,"edgeFogLatencyVariation":1,"edgeFogThroughput":1000000,"networkLocations":[{"id":"operator1-COMMON-DEFAULT","name":"operator1-COMMON-DEFAULT","type":"DEFAULT","terminalLinkLatency":1,"terminalLinkLatencyVariation":1,"terminalLinkThroughput":50000,"terminalLinkPacketLoss":1}]},{"id":"zone1","name":"zone1","type":"ZONE","interFogLatency":10,"interFogLatencyVariation":2,"interFogThroughput":1000,"interEdgeLatency":12,"interEdgeLatencyVariation":2,"interEdgeThroughput":1000,"edgeFogLatency":5,"edgeFogLatencyVariation":1,"edgeFogThroughput":1000,"networkLocations":[{"id":"zone1-DEFAULT","name":"zone1-DEFAULT","type":"DEFAULT","terminalLinkLatency":1,"terminalLinkLatencyVariation":1,"terminalLinkThroughput":50000,"terminalLinkPacketLoss":1,"physicalLocations":[{"id":"zone1-edge1","name":"zone1-edge1","type":"EDGE","processes":[{"id":"zone1-edge1-iperf","name":"zone1-edge1-iperf","type":"EDGE-APP","image":"gophernet/iperf-server","commandArguments":"-c, export; iperf -s -p $IPERF_SERVICE_PORT","commandExe":"/bin/bash","serviceConfig":{"name":"zone1-edge1-iperf","meSvcName":"iperf","ports":[{"protocol":"UDP","port":80}]}},{"id":"zone1-edge1-svc","name":"zone1-edge1-svc","type":"EDGE-APP","image":"meep-docker-registry:30001/demo-server","environment":"MGM_GROUP_NAME=svc, MGM_APP_ID=zone1-edge1-svc, MGM_APP_PORT=80","serviceConfig":{"name":"zone1-edge1-svc","meSvcName":"svc","ports":[{"protocol":"TCP","port":80}]}}]}]},{"id":"zone1-poa1","name":"zone1-poa1","type":"POA","terminalLinkLatency":1,"terminalLinkLatencyVariation":1,"terminalLinkThroughput":1000,"physicalLocations":[{"id":"zone1-fog1","name":"zone1-fog1","type":"FOG","processes":[{"id":"zone1-fog1-iperf","name":"zone1-fog1-iperf","type":"EDGE-APP","image":"gophernet/iperf-server","commandArguments":"-c, export; iperf -s -p $IPERF_SERVICE_PORT;","commandExe":"/bin/bash","serviceConfig":{"name":"zone1-fog1-iperf","meSvcName":"iperf","ports":[{"protocol":"UDP","port":80}]}},{"id":"zone1-fog1-svc","name":"zone1-fog1-svc","type":"EDGE-APP","image":"meep-docker-registry:30001/demo-server","environment":"MGM_GROUP_NAME=svc, MGM_APP_ID=zone1-fog1-svc, MGM_APP_PORT=80","serviceConfig":{"name":"zone1-fog1-svc","meSvcName":"svc","ports":[{"protocol":"TCP","port":80}]}}]},{"id":"ue1","name":"ue1","type":"UE","processes":[{"id":"ue1-iperf","name":"ue1-iperf","type":"UE-APP","image":"gophernet/iperf-client","commandArguments":"-c, export; iperf -u -c $IPERF_SERVICE_HOST -p $IPERF_SERVICE_PORT -t 3600 -b 50M;","commandExe":"/bin/bash"}]},{"id":"ue2-ext","name":"ue2-ext","type":"UE","isExternal":true,"processes":[{"id":"ue2-svc","name":"ue2-svc","type":"UE-APP","isExternal":true,"externalConfig":{"ingressServiceMap":[{"name":"svc","port":80,"externalPort":31111,"protocol":"TCP"},{"name":"iperf","port":80,"externalPort":31222,"protocol":"UDP"},{"name":"cloud1-svc","port":80,"externalPort":31112,"protocol":"TCP"},{"name":"cloud1-iperf","port":80,"externalPort":31223,"protocol":"UDP"}]}}]}]},{"id":"zone1-poa2","name":"zone1-poa2","type":"POA","terminalLinkLatency":10,"terminalLinkLatencyVariation":2,"terminalLinkThroughput":50}]},{"id":"zone2","name":"zone2","type":"ZONE","interFogLatency":10,"interFogLatencyVariation":2,"interFogThroughput":1000,"interEdgeLatency":12,"interEdgeLatencyVariation":2,"interEdgeThroughput":1000,"edgeFogLatency":5,"edgeFogLatencyVariation":1,"edgeFogThroughput":1000,"networkLocations":[{"id":"zone2-DEFAULT","name":"zone2-DEFAULT","type":"DEFAULT","terminalLinkLatency":1,"terminalLinkLatencyVariation":1,"terminalLinkThroughput":50000,"terminalLinkPacketLoss":1,"physicalLocations":[{"id":"zone2-edge1","name":"zone2-edge1","type":"EDGE","processes":[{"id":"zone2-edge1-iperf","name":"zone2-edge1-iperf","type":"EDGE-APP","image":"gophernet/iperf-server","commandArguments":"-c, export; iperf -s -p $IPERF_SERVICE_PORT;","commandExe":"/bin/bash","serviceConfig":{"name":"zone2-edge1-iperf","meSvcName":"iperf","ports":[{"protocol":"UDP","port":80}]}},{"id":"zone2-edge1-svc","name":"zone2-edge1-svc","type":"EDGE-APP","image":"meep-docker-registry:30001/demo-server","environment":"MGM_GROUP_NAME=svc, MGM_APP_ID=zone2-edge1-svc, MGM_APP_PORT=80","serviceConfig":{"name":"zone2-edge1-svc","meSvcName":"svc","ports":[{"protocol":"TCP","port":80}]}}]}]},{"id":"zone2-poa1","name":"zone2-poa1","type":"POA","terminalLinkLatency":1,"terminalLinkLatencyVariation":1,"terminalLinkThroughput":20}]}]}]}}`
Simon Pastor's avatar
merge ul and dl changes and distribution  
Simon Pastor committed
35
Kevin Di Lallo's avatar
added meep-model scenario validator  
Kevin Di Lallo committed
36 
const testScenario_v1_0_0 string = `{"version":"1.0.0","name":"demo1","deployment":{"interDomainLatency":50,"interDomainLatencyVariation":5,"interDomainThroughput":1000,"domains":[{"id":"PUBLIC","name":"PUBLIC","type":"PUBLIC","interZoneLatency":6,"interZoneLatencyVariation":2,"interZoneThroughput":1000000,"zones":[{"id":"PUBLIC-COMMON","name":"PUBLIC-COMMON","type":"COMMON","interFogLatency":2,"interFogLatencyVariation":1,"interFogThroughput":1000000,"interEdgeLatency":3,"interEdgeLatencyVariation":1,"interEdgeThroughput":1000000,"edgeFogLatency":5,"edgeFogLatencyVariation":1,"edgeFogThroughput":1000000,"networkLocations":[{"id":"PUBLIC-COMMON-DEFAULT","name":"PUBLIC-COMMON-DEFAULT","type":"DEFAULT","terminalLinkLatency":1,"terminalLinkLatencyVariation":1,"terminalLinkThroughput":50000,"terminalLinkPacketLoss":1,"physicalLocations":[{"id":"cloud1","name":"cloud1","type":"DC","processes":[{"id":"cloud1-iperf","name":"cloud1-iperf","type":"CLOUD-APP","image":"gophernet/iperf-server","commandArguments":"-c, export; iperf -s -p $IPERF_SERVICE_PORT","commandExe":"/bin/bash","serviceConfig":{"name":"cloud1-iperf","ports":[{"protocol":"UDP","port":80}]}},{"id":"cloud1-svc","name":"cloud1-svc","type":"CLOUD-APP","image":"meep-docker-registry:30001/demo-server","environment":"MGM_GROUP_NAME=cloud1-svc, MGM_APP_ID=cloud1-svc, MGM_APP_PORT=80","serviceConfig":{"name":"cloud1-svc","ports":[{"protocol":"TCP","port":80}]}}]}]}]}]},{"id":"operator1","name":"operator1","type":"OPERATOR","interZoneLatency":15,"interZoneLatencyVariation":3,"interZoneThroughput":1000,"zones":[{"id":"operator1-COMMON","name":"operator1-COMMON","type":"COMMON","interFogLatency":2,"interFogLatencyVariation":1,"interFogThroughput":1000000,"interEdgeLatency":3,"interEdgeLatencyVariation":1,"interEdgeThroughput":1000000,"edgeFogLatency":5,"edgeFogLatencyVariation":1,"edgeFogThroughput":1000000,"networkLocations":[{"id":"operator1-COMMON-DEFAULT","name":"operator1-COMMON-DEFAULT","type":"DEFAULT","terminalLinkLatency":1,"terminalLinkLatencyVariation":1,"terminalLinkThroughput":50000,"terminalLinkPacketLoss":1}]},{"id":"zone1","name":"zone1","type":"ZONE","interFogLatency":10,"interFogLatencyVariation":2,"interFogThroughput":1000,"interEdgeLatency":12,"interEdgeLatencyVariation":2,"interEdgeThroughput":1000,"edgeFogLatency":5,"edgeFogLatencyVariation":1,"edgeFogThroughput":1000,"networkLocations":[{"id":"zone1-DEFAULT","name":"zone1-DEFAULT","type":"DEFAULT","terminalLinkLatency":1,"terminalLinkLatencyVariation":1,"terminalLinkThroughput":50000,"terminalLinkPacketLoss":1,"physicalLocations":[{"id":"zone1-edge1","name":"zone1-edge1","type":"EDGE","processes":[{"id":"zone1-edge1-iperf","name":"zone1-edge1-iperf","type":"EDGE-APP","image":"gophernet/iperf-server","commandArguments":"-c, export; iperf -s -p $IPERF_SERVICE_PORT","commandExe":"/bin/bash","serviceConfig":{"name":"zone1-edge1-iperf","meSvcName":"iperf","ports":[{"protocol":"UDP","port":80}]}},{"id":"zone1-edge1-svc","name":"zone1-edge1-svc","type":"EDGE-APP","image":"meep-docker-registry:30001/demo-server","environment":"MGM_GROUP_NAME=svc, MGM_APP_ID=zone1-edge1-svc, MGM_APP_PORT=80","serviceConfig":{"name":"zone1-edge1-svc","meSvcName":"svc","ports":[{"protocol":"TCP","port":80}]}}]}]},{"id":"zone1-poa1","name":"zone1-poa1","type":"POA","terminalLinkLatency":1,"terminalLinkLatencyVariation":1,"terminalLinkThroughput":1000,"physicalLocations":[{"id":"zone1-fog1","name":"zone1-fog1","type":"FOG","processes":[{"id":"zone1-fog1-iperf","name":"zone1-fog1-iperf","type":"EDGE-APP","image":"gophernet/iperf-server","commandArguments":"-c, export; iperf -s -p $IPERF_SERVICE_PORT;","commandExe":"/bin/bash","serviceConfig":{"name":"zone1-fog1-iperf","meSvcName":"iperf","ports":[{"protocol":"UDP","port":80}]}},{"id":"zone1-fog1-svc","name":"zone1-fog1-svc","type":"EDGE-APP","image":"meep-docker-registry:30001/demo-server","environment":"MGM_GROUP_NAME=svc, MGM_APP_ID=zone1-fog1-svc, MGM_APP_PORT=80","serviceConfig":{"name":"zone1-fog1-svc","meSvcName":"svc","ports":[{"protocol":"TCP","port":80}]}}]},{"id":"ue1","name":"ue1","type":"UE","processes":[{"id":"ue1-iperf","name":"ue1-iperf","type":"UE-APP","image":"gophernet/iperf-client","commandArguments":"-c, export; iperf -u -c $IPERF_SERVICE_HOST -p $IPERF_SERVICE_PORT -t 3600 -b 50M;","commandExe":"/bin/bash"}]},{"id":"ue2-ext","name":"ue2-ext","type":"UE","isExternal":true,"processes":[{"id":"ue2-svc","name":"ue2-svc","type":"UE-APP","isExternal":true,"externalConfig":{"ingressServiceMap":[{"name":"svc","port":80,"externalPort":31111,"protocol":"TCP"},{"name":"iperf","port":80,"externalPort":31222,"protocol":"UDP"},{"name":"cloud1-svc","port":80,"externalPort":31112,"protocol":"TCP"},{"name":"cloud1-iperf","port":80,"externalPort":31223,"protocol":"UDP"}]}}]}]},{"id":"zone1-poa2","name":"zone1-poa2","type":"POA","terminalLinkLatency":10,"terminalLinkLatencyVariation":2,"terminalLinkThroughput":50}]},{"id":"zone2","name":"zone2","type":"ZONE","interFogLatency":10,"interFogLatencyVariation":2,"interFogThroughput":1000,"interEdgeLatency":12,"interEdgeLatencyVariation":2,"interEdgeThroughput":1000,"edgeFogLatency":5,"edgeFogLatencyVariation":1,"edgeFogThroughput":1000,"networkLocations":[{"id":"zone2-DEFAULT","name":"zone2-DEFAULT","type":"DEFAULT","terminalLinkLatency":1,"terminalLinkLatencyVariation":1,"terminalLinkThroughput":50000,"terminalLinkPacketLoss":1,"physicalLocations":[{"id":"zone2-edge1","name":"zone2-edge1","type":"EDGE","processes":[{"id":"zone2-edge1-iperf","name":"zone2-edge1-iperf","type":"EDGE-APP","image":"gophernet/iperf-server","commandArguments":"-c, export; iperf -s -p $IPERF_SERVICE_PORT;","commandExe":"/bin/bash","serviceConfig":{"name":"zone2-edge1-iperf","meSvcName":"iperf","ports":[{"protocol":"UDP","port":80}]}},{"id":"zone2-edge1-svc","name":"zone2-edge1-svc","type":"EDGE-APP","image":"meep-docker-registry:30001/demo-server","environment":"MGM_GROUP_NAME=svc, MGM_APP_ID=zone2-edge1-svc, MGM_APP_PORT=80","serviceConfig":{"name":"zone2-edge1-svc","meSvcName":"svc","ports":[{"protocol":"TCP","port":80}]}}]}]},{"id":"zone2-poa1","name":"zone2-poa1","type":"POA","terminalLinkLatency":1,"terminalLinkLatencyVariation":1,"terminalLinkThroughput":20}]}]}]}}`
Simon Pastor's avatar
merge ul and dl changes and distribution  
Simon Pastor committed
37
Kevin Di Lallo's avatar
added meep-model scenario validator  
Kevin Di Lallo committed
38 
const testScenario_v1_3_0 string = `{"version":"1.3.0","name":"demo1","deployment":{"interDomainLatency":50,"interDomainLatencyVariation":5,"interDomainThroughput":1000,"domains":[{"id":"PUBLIC","name":"PUBLIC","type":"PUBLIC","interZoneLatency":6,"interZoneLatencyVariation":2,"interZoneThroughput":1000000,"zones":[{"id":"PUBLIC-COMMON","name":"PUBLIC-COMMON","type":"COMMON","netChar":{"latency":5,"latencyVariation":1,"throughput":1000000},"networkLocations":[{"id":"PUBLIC-COMMON-DEFAULT","name":"PUBLIC-COMMON-DEFAULT","type":"DEFAULT","terminalLinkLatency":1,"terminalLinkLatencyVariation":1,"terminalLinkThroughput":50000,"terminalLinkPacketLoss":1,"physicalLocations":[{"id":"cloud1","name":"cloud1","type":"DC","processes":[{"id":"cloud1-iperf","name":"cloud1-iperf","type":"CLOUD-APP","image":"gophernet/iperf-server","commandArguments":"-c, export; iperf -s -p $IPERF_SERVICE_PORT","commandExe":"/bin/bash","serviceConfig":{"name":"cloud1-iperf","ports":[{"protocol":"UDP","port":80}]}},{"id":"cloud1-svc","name":"cloud1-svc","type":"CLOUD-APP","image":"meep-docker-registry:30001/demo-server","environment":"MGM_GROUP_NAME=cloud1-svc, MGM_APP_ID=cloud1-svc, MGM_APP_PORT=80","serviceConfig":{"name":"cloud1-svc","ports":[{"protocol":"TCP","port":80}]}}]}]}]}]},{"id":"operator1","name":"operator1","type":"OPERATOR","interZoneLatency":15,"interZoneLatencyVariation":3,"interZoneThroughput":1000,"zones":[{"id":"operator1-COMMON","name":"operator1-COMMON","type":"COMMON","netChar":{"latency":5,"latencyVariation":1,"throughput":1000000},"networkLocations":[{"id":"operator1-COMMON-DEFAULT","name":"operator1-COMMON-DEFAULT","type":"DEFAULT","terminalLinkLatency":1,"terminalLinkLatencyVariation":1,"terminalLinkThroughput":50000,"terminalLinkPacketLoss":1}]},{"id":"zone1","name":"zone1","type":"ZONE","netChar":{"latency":5,"latencyVariation":1,"throughput":1000},"networkLocations":[{"id":"zone1-DEFAULT","name":"zone1-DEFAULT","type":"DEFAULT","terminalLinkLatency":1,"terminalLinkLatencyVariation":1,"terminalLinkThroughput":50000,"terminalLinkPacketLoss":1,"physicalLocations":[{"id":"zone1-edge1","name":"zone1-edge1","type":"EDGE","processes":[{"id":"zone1-edge1-iperf","name":"zone1-edge1-iperf","type":"EDGE-APP","image":"gophernet/iperf-server","commandArguments":"-c, export; iperf -s -p $IPERF_SERVICE_PORT","commandExe":"/bin/bash","serviceConfig":{"name":"zone1-edge1-iperf","meSvcName":"iperf","ports":[{"protocol":"UDP","port":80}]}},{"id":"zone1-edge1-svc","name":"zone1-edge1-svc","type":"EDGE-APP","image":"meep-docker-registry:30001/demo-server","environment":"MGM_GROUP_NAME=svc, MGM_APP_ID=zone1-edge1-svc, MGM_APP_PORT=80","serviceConfig":{"name":"zone1-edge1-svc","meSvcName":"svc","ports":[{"protocol":"TCP","port":80}]}}]}]},{"id":"zone1-poa1","name":"zone1-poa1","type":"POA","terminalLinkLatency":1,"terminalLinkLatencyVariation":1,"terminalLinkThroughput":1000,"physicalLocations":[{"id":"zone1-fog1","name":"zone1-fog1","type":"FOG","processes":[{"id":"zone1-fog1-iperf","name":"zone1-fog1-iperf","type":"EDGE-APP","image":"gophernet/iperf-server","commandArguments":"-c, export; iperf -s -p $IPERF_SERVICE_PORT;","commandExe":"/bin/bash","serviceConfig":{"name":"zone1-fog1-iperf","meSvcName":"iperf","ports":[{"protocol":"UDP","port":80}]}},{"id":"zone1-fog1-svc","name":"zone1-fog1-svc","type":"EDGE-APP","image":"meep-docker-registry:30001/demo-server","environment":"MGM_GROUP_NAME=svc, MGM_APP_ID=zone1-fog1-svc, MGM_APP_PORT=80","serviceConfig":{"name":"zone1-fog1-svc","meSvcName":"svc","ports":[{"protocol":"TCP","port":80}]}}]},{"id":"ue1","name":"ue1","type":"UE","processes":[{"id":"ue1-iperf","name":"ue1-iperf","type":"UE-APP","image":"gophernet/iperf-client","commandArguments":"-c, export; iperf -u -c $IPERF_SERVICE_HOST -p $IPERF_SERVICE_PORT -t 3600 -b 50M;","commandExe":"/bin/bash"}]},{"id":"ue2-ext","name":"ue2-ext","type":"UE","isExternal":true,"processes":[{"id":"ue2-svc","name":"ue2-svc","type":"UE-APP","isExternal":true,"externalConfig":{"ingressServiceMap":[{"name":"svc","port":80,"externalPort":31111,"protocol":"TCP"},{"name":"iperf","port":80,"externalPort":31222,"protocol":"UDP"},{"name":"cloud1-svc","port":80,"externalPort":31112,"protocol":"TCP"},{"name":"cloud1-iperf","port":80,"externalPort":31223,"protocol":"UDP"}]}}]}]},{"id":"zone1-poa2","name":"zone1-poa2","type":"POA","terminalLinkLatency":10,"terminalLinkLatencyVariation":2,"terminalLinkThroughput":50}]},{"id":"zone2","name":"zone2","type":"ZONE","netChar":{"latency":5,"latencyVariation":1,"throughput":1000},"networkLocations":[{"id":"zone2-DEFAULT","name":"zone2-DEFAULT","type":"DEFAULT","terminalLinkLatency":1,"terminalLinkLatencyVariation":1,"terminalLinkThroughput":50000,"terminalLinkPacketLoss":1,"physicalLocations":[{"id":"zone2-edge1","name":"zone2-edge1","type":"EDGE","processes":[{"id":"zone2-edge1-iperf","name":"zone2-edge1-iperf","type":"EDGE-APP","image":"gophernet/iperf-server","commandArguments":"-c, export; iperf -s -p $IPERF_SERVICE_PORT;","commandExe":"/bin/bash","serviceConfig":{"name":"zone2-edge1-iperf","meSvcName":"iperf","ports":[{"protocol":"UDP","port":80}]}},{"id":"zone2-edge1-svc","name":"zone2-edge1-svc","type":"EDGE-APP","image":"meep-docker-registry:30001/demo-server","environment":"MGM_GROUP_NAME=svc, MGM_APP_ID=zone2-edge1-svc, MGM_APP_PORT=80","serviceConfig":{"name":"zone2-edge1-svc","meSvcName":"svc","ports":[{"protocol":"TCP","port":80}]}}]}]},{"id":"zone2-poa1","name":"zone2-poa1","type":"POA","terminalLinkLatency":1,"terminalLinkLatencyVariation":1,"terminalLinkThroughput":20}]}]}]}}`
Michel Roy's avatar
meep-model package
Michel Roy committed
39
Simon Pastor's avatar
merge ul and dl changes and distribution  
Simon Pastor committed
40 
const testScenario_v1_5_0 string = `{"version":"1.5.0","name":"demo1","deployment":{"netChar":{"latency":50,"latencyVariation":5,"latencyDistribution":"Normal","throughputDl":1000,"throughputUl":1000,"throughput":null,"packetLoss":null},"domains":[{"id":"PUBLIC","name":"PUBLIC","type":"PUBLIC","netChar":{"latency":6,"latencyVariation":2,"throughputDl":1000000,"throughputUl":1000000,"latencyDistribution":null,"throughput":null,"packetLoss":null},"zones":[{"id":"PUBLIC-COMMON","name":"PUBLIC-COMMON","type":"COMMON","netChar":{"latency":5,"latencyVariation":1,"latencyDistribution":null,"throughput":null,"throughputDl":null,"throughputUl":null,"packetLoss":null},"networkLocations":[{"id":"PUBLIC-COMMON-DEFAULT","name":"PUBLIC-COMMON-DEFAULT","type":"DEFAULT","netChar":{"latency":1,"latencyVariation":1,"throughputDl":50000,"throughputUl":50000,"packetLoss":1,"latencyDistribution":null,"throughput":null},"physicalLocations":[{"id":"cloud1","name":"cloud1","type":"DC","processes":[{"id":"cloud1-iperf","name":"cloud1-iperf","type":"CLOUD-APP","image":"meep-docker-registry:30001/iperf-server","commandArguments":"-c, export; iperf -s -p $IPERF_SERVICE_PORT","commandExe":"/bin/bash","serviceConfig":{"name":"cloud1-iperf","ports":[{"protocol":"UDP","port":80,"externalPort":null}],"meSvcName":null},"netChar":{"latency":null,"latencyVariation":null,"latencyDistribution":null,"throughput":null,"throughputDl":null,"throughputUl":null,"packetLoss":null},"isExternal":null,"environment":null,"gpuConfig":null,"externalConfig":null,"status":null,"userChartLocation":null,"userChartAlternateValues":null,"userChartGroup":null,"meta":null,"userMeta":null,"appLatency":null,"appLatencyVariation":null,"appThroughput":null,"appPacketLoss":null,"placementId":null},{"id":"cloud1-svc","name":"cloud1-svc","type":"CLOUD-APP","image":"meep-docker-registry:30001/demo-server","environment":"MGM_GROUP_NAME=cloud1-svc, MGM_APP_ID=cloud1-svc, MGM_APP_PORT=80","serviceConfig":{"name":"cloud1-svc","ports":[{"protocol":"TCP","port":80,"externalPort":null}],"meSvcName":null},"netChar":{"latency":null,"latencyVariation":null,"latencyDistribution":null,"throughput":null,"throughputDl":null,"throughputUl":null,"packetLoss":null},"isExternal":null,"commandArguments":null,"commandExe":null,"gpuConfig":null,"externalConfig":null,"status":null,"userChartLocation":null,"userChartAlternateValues":null,"userChartGroup":null,"meta":null,"userMeta":null,"appLatency":null,"appLatencyVariation":null,"appThroughput":null,"appPacketLoss":null,"placementId":null}],"netChar":{"latency":null,"latencyVariation":null,"latencyDistribution":null,"throughput":null,"throughputDl":null,"throughputUl":null,"packetLoss":null},"isExternal":null,"geoData":null,"networkLocationsInRange":null,"meta":null,"userMeta":null,"linkLatency":null,"linkLatencyVariation":null,"linkThroughput":null,"linkPacketLoss":null}],"terminalLinkLatency":null,"terminalLinkLatencyVariation":null,"terminalLinkThroughput":null,"terminalLinkPacketLoss":null,"meta":null,"userMeta":null,"cellularPoaConfig":null,"geoData":null}],"interFogLatency":null,"interFogLatencyVariation":null,"interFogThroughput":null,"interFogPacketLoss":null,"interEdgeLatency":null,"interEdgeLatencyVariation":null,"interEdgeThroughput":null,"interEdgePacketLoss":null,"edgeFogLatency":null,"edgeFogLatencyVariation":null,"edgeFogThroughput":null,"edgeFogPacketLoss":null,"meta":null,"userMeta":null}],"interZoneLatency":null,"interZoneLatencyVariation":null,"interZoneThroughput":null,"interZonePacketLoss":null,"meta":null,"userMeta":null,"cellularDomainConfig":null},{"id":"operator1","name":"operator1","type":"OPERATOR","netChar":{"latency":15,"latencyVariation":3,"throughputDl":1000,"throughputUl":1000,"latencyDistribution":null,"throughput":null,"packetLoss":null},"zones":[{"id":"operator1-COMMON","name":"operator1-COMMON","type":"COMMON","netChar":{"latency":5,"latencyVariation":1,"latencyDistribution":null,"throughput":null,"throughputDl":null,"throughputUl":null,"packetLoss":null},"networkLocations":[{"id":"operator1-COMMON-DEFAULT","name":"operator1-COMMON-DEFAULT","type":"DEFAULT","netChar":{"latency":1,"latencyVariation":1,"throughputDl":50000,"throughputUl":50000,"packetLoss":1,"latencyDistribution":null,"throughput":null},"terminalLinkLatency":null,"terminalLinkLatencyVariation":null,"terminalLinkThroughput":null,"terminalLinkPacketLoss":null,"meta":null,"userMeta":null,"cellularPoaConfig":null,"geoData":null,"physicalLocations":null}],"interFogLatency":null,"interFogLatencyVariation":null,"interFogThroughput":null,"interFogPacketLoss":null,"interEdgeLatency":null,"interEdgeLatencyVariation":null,"interEdgeThroughput":null,"interEdgePacketLoss":null,"edgeFogLatency":null,"edgeFogLatencyVariation":null,"edgeFogThroughput":null,"edgeFogPacketLoss":null,"meta":null,"userMeta":null},{"id":"zone1","name":"zone1","type":"ZONE","netChar":{"latency":5,"latencyVariation":1,"latencyDistribution":null,"throughput":null,"throughputDl":null,"throughputUl":null,"packetLoss":null},"networkLocations":[{"id":"zone1-DEFAULT","name":"zone1-DEFAULT","type":"DEFAULT","netChar":{"latency":1,"latencyVariation":1,"throughputDl":50000,"throughputUl":50000,"packetLoss":1,"latencyDistribution":null,"throughput":null},"physicalLocations":[{"id":"zone1-edge1","name":"zone1-edge1","type":"EDGE","processes":[{"id":"zone1-edge1-iperf","name":"zone1-edge1-iperf","type":"EDGE-APP","image":"meep-docker-registry:30001/iperf-server","commandArguments":"-c, export; iperf -s -p $IPERF_SERVICE_PORT","commandExe":"/bin/bash","serviceConfig":{"name":"zone1-edge1-iperf","meSvcName":"iperf","ports":[{"protocol":"UDP","port":80,"externalPort":null}]},"netChar":{"latency":null,"latencyVariation":null,"latencyDistribution":null,"throughput":null,"throughputDl":null,"throughputUl":null,"packetLoss":null},"isExternal":null,"environment":null,"gpuConfig":null,"externalConfig":null,"status":null,"userChartLocation":null,"userChartAlternateValues":null,"userChartGroup":null,"meta":null,"userMeta":null,"appLatency":null,"appLatencyVariation":null,"appThroughput":null,"appPacketLoss":null,"placementId":null},{"id":"zone1-edge1-svc","name":"zone1-edge1-svc","type":"EDGE-APP","image":"meep-docker-registry:30001/demo-server","environment":"MGM_GROUP_NAME=svc, MGM_APP_ID=zone1-edge1-svc, MGM_APP_PORT=80","serviceConfig":{"name":"zone1-edge1-svc","meSvcName":"svc","ports":[{"protocol":"TCP","port":80,"externalPort":null}]},"netChar":{"latency":null,"latencyVariation":null,"latencyDistribution":null,"throughput":null,"throughputDl":null,"throughputUl":null,"packetLoss":null},"isExternal":null,"commandArguments":null,"commandExe":null,"gpuConfig":null,"externalConfig":null,"status":null,"userChartLocation":null,"userChartAlternateValues":null,"userChartGroup":null,"meta":null,"userMeta":null,"appLatency":null,"appLatencyVariation":null,"appThroughput":null,"appPacketLoss":null,"placementId":null}],"netChar":{"latency":null,"latencyVariation":null,"latencyDistribution":null,"throughput":null,"throughputDl":null,"throughputUl":null,"packetLoss":null},"isExternal":null,"geoData":null,"networkLocationsInRange":null,"meta":null,"userMeta":null,"linkLatency":null,"linkLatencyVariation":null,"linkThroughput":null,"linkPacketLoss":null}],"terminalLinkLatency":null,"terminalLinkLatencyVariation":null,"terminalLinkThroughput":null,"terminalLinkPacketLoss":null,"meta":null,"userMeta":null,"cellularPoaConfig":null,"geoData":null},{"id":"zone1-poa1","name":"zone1-poa1","type":"POA","netChar":{"latency":1,"latencyVariation":1,"throughputDl":1000,"throughputUl":1000,"latencyDistribution":null,"throughput":null,"packetLoss":null},"physicalLocations":[{"id":"zone1-fog1","name":"zone1-fog1","type":"FOG","processes":[{"id":"zone1-fog1-iperf","name":"zone1-fog1-iperf","type":"EDGE-APP","image":"meep-docker-registry:30001/iperf-server","commandArguments":"-c, export; iperf -s -p $IPERF_SERVICE_PORT;","commandExe":"/bin/bash","serviceConfig":{"name":"zone1-fog1-iperf","meSvcName":"iperf","ports":[{"protocol":"UDP","port":80,"externalPort":null}]},"netChar":{"latency":null,"latencyVariation":null,"latencyDistribution":null,"throughput":null,"throughputDl":null,"throughputUl":null,"packetLoss":null},"isExternal":null,"environment":null,"gpuConfig":null,"externalConfig":null,"status":null,"userChartLocation":null,"userChartAlternateValues":null,"userChartGroup":null,"meta":null,"userMeta":null,"appLatency":null,"appLatencyVariation":null,"appThroughput":null,"appPacketLoss":null,"placementId":null},{"id":"zone1-fog1-svc","name":"zone1-fog1-svc","type":"EDGE-APP","image":"meep-docker-registry:30001/demo-server","environment":"MGM_GROUP_NAME=svc, MGM_APP_ID=zone1-fog1-svc, MGM_APP_PORT=80","serviceConfig":{"name":"zone1-fog1-svc","meSvcName":"svc","ports":[{"protocol":"TCP","port":80,"externalPort":null}]},"netChar":{"latency":null,"latencyVariation":null,"latencyDistribution":null,"throughput":null,"throughputDl":null,"throughputUl":null,"packetLoss":null},"isExternal":null,"commandArguments":null,"commandExe":null,"gpuConfig":null,"externalConfig":null,"status":null,"userChartLocation":null,"userChartAlternateValues":null,"userChartGroup":null,"meta":null,"userMeta":null,"appLatency":null,"appLatencyVariation":null,"appThroughput":null,"appPacketLoss":null,"placementId":null}],"netChar":{"latency":null,"latencyVariation":null,"latencyDistribution":null,"throughput":null,"throughputDl":null,"throughputUl":null,"packetLoss":null},"isExternal":null,"geoData":null,"networkLocationsInRange":null,"meta":null,"userMeta":null,"linkLatency":null,"linkLatencyVariation":null,"linkThroughput":null,"linkPacketLoss":null},{"id":"ue1","name":"ue1","type":"UE","processes":[{"id":"ue1-iperf","name":"ue1-iperf","type":"UE-APP","image":"meep-docker-registry:30001/iperf-client","commandArguments":"-c, export; iperf -u -c $IPERF_SERVICE_HOST -p $IPERF_SERVICE_PORT -t 3600 -b 50M;","commandExe":"/bin/bash","netChar":{"latency":null,"latencyVariation":null,"latencyDistribution":null,"throughput":null,"throughputDl":null,"throughputUl":null,"packetLoss":null},"isExternal":null,"environment":null,"serviceConfig":null,"gpuConfig":null,"externalConfig":null,"status":null,"userChartLocation":null,"userChartAlternateValues":null,"userChartGroup":null,"meta":null,"userMeta":null,"appLatency":null,"appLatencyVariation":null,"appThroughput":null,"appPacketLoss":null,"placementId":null}],"netChar":{"latency":null,"latencyVariation":null,"latencyDistribution":null,"throughput":null,"throughputDl":null,"throughputUl":null,"packetLoss":null},"isExternal":null,"geoData":null,"networkLocationsInRange":null,"meta":null,"userMeta":null,"linkLatency":null,"linkLatencyVariation":null,"linkThroughput":null,"linkPacketLoss":null},{"id":"ue2-ext","name":"ue2-ext","type":"UE","isExternal":true,"processes":[{"id":"ue2-svc","name":"ue2-svc","type":"UE-APP","isExternal":true,"externalConfig":{"ingressServiceMap":[{"name":"svc","port":80,"externalPort":31111,"protocol":"TCP"},{"name":"iperf","port":80,"externalPort":31222,"protocol":"UDP"},{"name":"cloud1-svc","port":80,"externalPort":31112,"protocol":"TCP"},{"name":"cloud1-iperf","port":80,"externalPort":31223,"protocol":"UDP"}],"egressServiceMap":null},"netChar":{"latency":null,"latencyVariation":null,"latencyDistribution":null,"throughput":null,"throughputDl":null,"throughputUl":null,"packetLoss":null},"image":null,"environment":null,"commandArguments":null,"commandExe":null,"serviceConfig":null,"gpuConfig":null,"status":null,"userChartLocation":null,"userChartAlternateValues":null,"userChartGroup":null,"meta":null,"userMeta":null,"appLatency":null,"appLatencyVariation":null,"appThroughput":null,"appPacketLoss":null,"placementId":null}],"netChar":{"latency":null,"latencyVariation":null,"latencyDistribution":null,"throughput":null,"throughputDl":null,"throughputUl":null,"packetLoss":null},"geoData":null,"networkLocationsInRange":null,"meta":null,"userMeta":null,"linkLatency":null,"linkLatencyVariation":null,"linkThroughput":null,"linkPacketLoss":null}],"terminalLinkLatency":null,"terminalLinkLatencyVariation":null,"terminalLinkThroughput":null,"terminalLinkPacketLoss":null,"meta":null,"userMeta":null,"cellularPoaConfig":null,"geoData":null},{"id":"zone1-poa2","name":"zone1-poa2","type":"POA","netChar":{"latency":10,"latencyVariation":2,"throughputDl":50,"throughputUl":50,"latencyDistribution":null,"throughput":null,"packetLoss":null},"terminalLinkLatency":null,"terminalLinkLatencyVariation":null,"terminalLinkThroughput":null,"terminalLinkPacketLoss":null,"meta":null,"userMeta":null,"cellularPoaConfig":null,"geoData":null,"physicalLocations":null}],"interFogLatency":null,"interFogLatencyVariation":null,"interFogThroughput":null,"interFogPacketLoss":null,"interEdgeLatency":null,"interEdgeLatencyVariation":null,"interEdgeThroughput":null,"interEdgePacketLoss":null,"edgeFogLatency":null,"edgeFogLatencyVariation":null,"edgeFogThroughput":null,"edgeFogPacketLoss":null,"meta":null,"userMeta":null},{"id":"zone2","name":"zone2","type":"ZONE","netChar":{"latency":5,"latencyVariation":1,"latencyDistribution":null,"throughput":null,"throughputDl":null,"throughputUl":null,"packetLoss":null},"networkLocations":[{"id":"zone2-DEFAULT","name":"zone2-DEFAULT","type":"DEFAULT","netChar":{"latency":1,"latencyVariation":1,"throughputDl":50000,"throughputUl":50000,"packetLoss":1,"latencyDistribution":null,"throughput":null},"physicalLocations":[{"id":"zone2-edge1","name":"zone2-edge1","type":"EDGE","processes":[{"id":"zone2-edge1-iperf","name":"zone2-edge1-iperf","type":"EDGE-APP","image":"meep-docker-registry:30001/iperf-server","commandArguments":"-c, export; iperf -s -p $IPERF_SERVICE_PORT;","commandExe":"/bin/bash","serviceConfig":{"name":"zone2-edge1-iperf","meSvcName":"iperf","ports":[{"protocol":"UDP","port":80,"externalPort":null}]},"netChar":{"latency":null,"latencyVariation":null,"latencyDistribution":null,"throughput":null,"throughputDl":null,"throughputUl":null,"packetLoss":null},"isExternal":null,"environment":null,"gpuConfig":null,"externalConfig":null,"status":null,"userChartLocation":null,"userChartAlternateValues":null,"userChartGroup":null,"meta":null,"userMeta":null,"appLatency":null,"appLatencyVariation":null,"appThroughput":null,"appPacketLoss":null,"placementId":null},{"id":"zone2-edge1-svc","name":"zone2-edge1-svc","type":"EDGE-APP","image":"meep-docker-registry:30001/demo-server","environment":"MGM_GROUP_NAME=svc, MGM_APP_ID=zone2-edge1-svc, MGM_APP_PORT=80","serviceConfig":{"name":"zone2-edge1-svc","meSvcName":"svc","ports":[{"protocol":"TCP","port":80,"externalPort":null}]},"netChar":{"latency":null,"latencyVariation":null,"latencyDistribution":null,"throughput":null,"throughputDl":null,"throughputUl":null,"packetLoss":null},"isExternal":null,"commandArguments":null,"commandExe":null,"gpuConfig":null,"externalConfig":null,"status":null,"userChartLocation":null,"userChartAlternateValues":null,"userChartGroup":null,"meta":null,"userMeta":null,"appLatency":null,"appLatencyVariation":null,"appThroughput":null,"appPacketLoss":null,"placementId":null}],"netChar":{"latency":null,"latencyVariation":null,"latencyDistribution":null,"throughput":null,"throughputDl":null,"throughputUl":null,"packetLoss":null},"isExternal":null,"geoData":null,"networkLocationsInRange":null,"meta":null,"userMeta":null,"linkLatency":null,"linkLatencyVariation":null,"linkThroughput":null,"linkPacketLoss":null}],"terminalLinkLatency":null,"terminalLinkLatencyVariation":null,"terminalLinkThroughput":null,"terminalLinkPacketLoss":null,"meta":null,"userMeta":null,"cellularPoaConfig":null,"geoData":null},{"id":"zone2-poa1","name":"zone2-poa1","type":"POA","netChar":{"latency":1,"latencyVariation":1,"throughputDl":20,"throughputUl":20,"latencyDistribution":null,"throughput":null,"packetLoss":null},"terminalLinkLatency":null,"terminalLinkLatencyVariation":null,"terminalLinkThroughput":null,"terminalLinkPacketLoss":null,"meta":null,"userMeta":null,"cellularPoaConfig":null,"geoData":null,"physicalLocations":null}],"interFogLatency":null,"interFogLatencyVariation":null,"interFogThroughput":null,"interFogPacketLoss":null,"interEdgeLatency":null,"interEdgeLatencyVariation":null,"interEdgeThroughput":null,"interEdgePacketLoss":null,"edgeFogLatency":null,"edgeFogLatencyVariation":null,"edgeFogThroughput":null,"edgeFogPacketLoss":null,"meta":null,"userMeta":null}],"interZoneLatency":null,"interZoneLatencyVariation":null,"interZoneThroughput":null,"interZonePacketLoss":null,"meta":null,"userMeta":null,"cellularDomainConfig":null}],"interDomainLatency":null,"interDomainLatencyVariation":null,"interDomainThroughput":null,"interDomainPacketLoss":null,"meta":null,"userMeta":null},"id":null,"description":null,"config":null}`
Michel Roy's avatar
meep-model package
Michel Roy committed
41 42 43 44 
func TestNewModel(t *testing.T) {
	fmt.Println("--- ", t.Name())
	log.MeepTextLogInit(t.Name())
Michel Roy's avatar
Added Listen()  
Michel Roy committed
45 46 47 
	// Switch to a different table for testing
	redisTable = modelRedisTestTable
Michel Roy's avatar
meep-model package
Michel Roy committed
48 49 
	// Keep this one first...
	fmt.Println("Invalid Redis DB address")
Kevin Di Lallo's avatar
meep-data-key-manager to standardize redis data keys + virt engine & webhook multi-scenario support  
Kevin Di Lallo committed
50 
	cfg := ModelCfg{Name: modelName, Namespace: moduleNamespace, Module: "test-mod", DbAddr: "ExpectedFailure-InvalidDbLocation"}
Kevin Di Lallo's avatar
integrated message queue in all microservices  
Kevin Di Lallo committed
51 
	_, err := NewModel(cfg)
Michel Roy's avatar
meep-model package
Michel Roy committed
52 
	if err == nil {
Kevin Di Lallo's avatar
integrated message queue in all microservices  
Kevin Di Lallo committed
53 
		t.Fatalf("Should report error on invalid Redis db")
Michel Roy's avatar
meep-model package
Michel Roy committed
54 55 
	}
	fmt.Println("Invalid module")
Kevin Di Lallo's avatar
meep-data-key-manager to standardize redis data keys + virt engine & webhook multi-scenario support  
Kevin Di Lallo committed
56 
	cfg = ModelCfg{Name: modelName, Namespace: moduleNamespace, Module: "", DbAddr: modelRedisAddr}
Kevin Di Lallo's avatar
integrated message queue in all microservices  
Kevin Di Lallo committed
57 
	_, err = NewModel(cfg)
Michel Roy's avatar
meep-model package
Michel Roy committed
58 
	if err == nil {
Kevin Di Lallo's avatar
integrated message queue in all microservices  
Kevin Di Lallo committed
59 
		t.Fatalf("Should report error on invalid module")
Michel Roy's avatar
meep-model package
Michel Roy committed
60 61 62 
	}

	fmt.Println("Create normal")
Kevin Di Lallo's avatar
meep-data-key-manager to standardize redis data keys + virt engine & webhook multi-scenario support  
Kevin Di Lallo committed
63 
	cfg = ModelCfg{Name: modelName, Namespace: moduleNamespace, Module: "test-mod", DbAddr: modelRedisAddr}
Kevin Di Lallo's avatar
integrated message queue in all microservices  
Kevin Di Lallo committed
64 
	_, err = NewModel(cfg)
Michel Roy's avatar
meep-model package
Michel Roy committed
65 
	if err != nil {
Kevin Di Lallo's avatar
integrated message queue in all microservices  
Kevin Di Lallo committed
66 
		t.Fatalf("Unable to create model")
Michel Roy's avatar
meep-model package
Michel Roy committed
67 68 69 
	}

	fmt.Println("Create no name")
Kevin Di Lallo's avatar
integrated message queue in all microservices  
Kevin Di Lallo committed
70 71 
	cfg = ModelCfg{Name: "", Module: "test-mod", DbAddr: modelRedisAddr}
	_, err = NewModel(cfg)
Michel Roy's avatar
meep-model package
Michel Roy committed
72 
	if err == nil {
Kevin Di Lallo's avatar
integrated message queue in all microservices  
Kevin Di Lallo committed
73 
		t.Fatalf("Should not allow creating model without a name")
Michel Roy's avatar
meep-model package
Michel Roy committed
74 75 76 
	}
}
Michel Roy's avatar
added node/edge getters  
Michel Roy committed
77 
func TestGetSetScenario(t *testing.T) {
Michel Roy's avatar
meep-model package
Michel Roy committed
78 79 80 
	fmt.Println("--- ", t.Name())
	log.MeepTextLogInit(t.Name())
Michel Roy's avatar
Added Listen()  
Michel Roy committed
81 82 83 
	// Switch to a different table for testing
	redisTable = modelRedisTestTable
Kevin Di Lallo's avatar
meep-data-key-manager to standardize redis data keys + virt engine & webhook multi-scenario support  
Kevin Di Lallo committed
84 
	cfg := ModelCfg{Name: modelName, Namespace: moduleNamespace, Module: "test-mod", DbAddr: modelRedisAddr}
Kevin Di Lallo's avatar
integrated message queue in all microservices  
Kevin Di Lallo committed
85 
	m, err := NewModel(cfg)
Michel Roy's avatar
meep-model package
Michel Roy committed
86 
	if err != nil {
Kevin Di Lallo's avatar
integrated message queue in all microservices  
Kevin Di Lallo committed
87 
		t.Fatalf("Unable to create model")
Michel Roy's avatar
meep-model package
Michel Roy committed
88 89 
	}
Michel Roy's avatar
meep-model integ - compile  
Michel Roy committed
90 
	fmt.Println("GetSvcMap - error case")
Michel Roy's avatar
meep-model package
Michel Roy committed
91 
	svcMap := m.GetServiceMaps()
Michel Roy's avatar
meep-model integ - compile  
Michel Roy committed
92 
	if len(*svcMap) != 0 {
Kevin Di Lallo's avatar
integrated message queue in all microservices  
Kevin Di Lallo committed
93 
		t.Fatalf("Service map unexpected")
Michel Roy's avatar
meep-model package
Michel Roy committed
94 95 96 
	}

	fmt.Println("Set Model")
Michel Roy's avatar
added node/edge getters  
Michel Roy committed
97 
	err = m.SetScenario([]byte(testScenario))
Michel Roy's avatar
meep-model package
Michel Roy committed
98 
	if err != nil {
Kevin Di Lallo's avatar
integrated message queue in all microservices  
Kevin Di Lallo committed
99 
		t.Fatalf("Error setting model")
Michel Roy's avatar
meep-model package
Michel Roy committed
100 101 
	}
	if m.scenario.Name != "demo1" {
Kevin Di Lallo's avatar
integrated message queue in all microservices  
Kevin Di Lallo committed
102 
		t.Fatalf("SetScenario failed")
Michel Roy's avatar
meep-model package
Michel Roy committed
103 104 105 
	}

	fmt.Println("Get Model")
Michel Roy's avatar
added node/edge getters  
Michel Roy committed
106 107 
	s, err := m.GetScenario()
	if err != nil {
Kevin Di Lallo's avatar
integrated message queue in all microservices  
Kevin Di Lallo committed
108 
		t.Fatalf("Error getting scenario")
Michel Roy's avatar
meep-model package
Michel Roy committed
109 
	}
Michel Roy's avatar
added node/edge getters  
Michel Roy committed
110 
	if s == nil {
Kevin Di Lallo's avatar
integrated message queue in all microservices  
Kevin Di Lallo committed
111 
		t.Fatalf("Error getting scenario")
Michel Roy's avatar
meep-model package
Michel Roy committed
112 
	}
Michel Roy's avatar
added node/edge getters  
Michel Roy committed
113 
	// if s.Name != "demo1" {
Kevin Di Lallo's avatar
integrated message queue in all microservices  
Kevin Di Lallo committed
114 
	// 	t.Fatalf("GetModel failed")
Michel Roy's avatar
added node/edge getters  
Michel Roy committed
115 
	// }
Michel Roy's avatar
meep-model package
Michel Roy committed
116 117 118 119 

	fmt.Println("GetSvcMap - existing")
	svcMap = m.GetServiceMaps()
	if svcMap == nil {
Kevin Di Lallo's avatar
integrated message queue in all microservices  
Kevin Di Lallo committed
120 
		t.Fatalf("Service map expected")
Michel Roy's avatar
meep-model package
Michel Roy committed
121 122 123 124 125 126 127 
	}
}

func TestActivateDeactivate(t *testing.T) {
	fmt.Println("--- ", t.Name())
	log.MeepTextLogInit(t.Name())
Michel Roy's avatar
Added Listen()  
Michel Roy committed
128 129 130 
	// Switch to a different table for testing
	redisTable = modelRedisTestTable
Kevin Di Lallo's avatar
meep-data-key-manager to standardize redis data keys + virt engine & webhook multi-scenario support  
Kevin Di Lallo committed
131 
	cfg := ModelCfg{Name: modelName, Namespace: moduleNamespace, Module: "test-mod", DbAddr: modelRedisAddr}
Kevin Di Lallo's avatar
integrated message queue in all microservices  
Kevin Di Lallo committed
132 
	m, err := NewModel(cfg)
Michel Roy's avatar
meep-model package
Michel Roy committed
133 
	if err != nil {
Kevin Di Lallo's avatar
integrated message queue in all microservices  
Kevin Di Lallo committed
134 
		t.Fatalf("Unable to create model")
Michel Roy's avatar
meep-model package
Michel Roy committed
135 
	}
Michel Roy's avatar
Added Listen()  
Michel Roy committed
136 
	fmt.Println("Set model")
Michel Roy's avatar
added node/edge getters  
Michel Roy committed
137 
	err = m.SetScenario([]byte(testScenario))
Michel Roy's avatar
meep-model package
Michel Roy committed
138 
	if err != nil {
Kevin Di Lallo's avatar
integrated message queue in all microservices  
Kevin Di Lallo committed
139 
		t.Fatalf("Error setting model")
Michel Roy's avatar
meep-model package
Michel Roy committed
140 141 
	}
	if m.scenario.Name != "demo1" {
Kevin Di Lallo's avatar
integrated message queue in all microservices  
Kevin Di Lallo committed
142 
		t.Fatalf("SetScenario failed")
Michel Roy's avatar
meep-model package
Michel Roy committed
143 144 145 146 
	}
	fmt.Println("Activate model")
	err = m.Activate()
	if err != nil {
Kevin Di Lallo's avatar
integrated message queue in all microservices  
Kevin Di Lallo committed
147 
		t.Fatalf("Error activating model")
Michel Roy's avatar
meep-model package
Michel Roy committed
148 
	}
Michel Roy's avatar
Added Listen()  
Michel Roy committed
149 
	fmt.Println("Set model")
Michel Roy's avatar
added node/edge getters  
Michel Roy committed
150 
	err = m.SetScenario([]byte(testScenario))
Michel Roy's avatar
meep-model package
Michel Roy committed
151 
	if err != nil {
Kevin Di Lallo's avatar
integrated message queue in all microservices  
Kevin Di Lallo committed
152 
		t.Fatalf("Error updating model")
Michel Roy's avatar
meep-model package
Michel Roy committed
153 154 155 156 
	}
	fmt.Println("Deactivate model")
	err = m.Deactivate()
	if err != nil {
Kevin Di Lallo's avatar
integrated message queue in all microservices  
Kevin Di Lallo committed
157 
		t.Fatalf("Error deactivating model")
Michel Roy's avatar
meep-model package
Michel Roy committed
158 159 160 161 162 163 164 
	}
}

func TestMoveNode(t *testing.T) {
	fmt.Println("--- ", t.Name())
	log.MeepTextLogInit(t.Name())
Michel Roy's avatar
Added Listen()  
Michel Roy committed
165 166 167 
	// Switch to a different table for testing
	redisTable = modelRedisTestTable
Kevin Di Lallo's avatar
meep-data-key-manager to standardize redis data keys + virt engine & webhook multi-scenario support  
Kevin Di Lallo committed
168 
	cfg := ModelCfg{Name: modelName, Namespace: moduleNamespace, Module: "test-mod", DbAddr: modelRedisAddr}
Kevin Di Lallo's avatar
integrated message queue in all microservices  
Kevin Di Lallo committed
169 
	m, err := NewModel(cfg)
Michel Roy's avatar
meep-model package
Michel Roy committed
170 
	if err != nil {
Kevin Di Lallo's avatar
integrated message queue in all microservices  
Kevin Di Lallo committed
171 
		t.Fatalf("Unable to create model")
Michel Roy's avatar
meep-model package
Michel Roy committed
172 173 
	}
	fmt.Println("Set Model")
Michel Roy's avatar
added node/edge getters  
Michel Roy committed
174 
	err = m.SetScenario([]byte(testScenario))
Michel Roy's avatar
meep-model package
Michel Roy committed
175 
	if err != nil {
Kevin Di Lallo's avatar
integrated message queue in all microservices  
Kevin Di Lallo committed
176 
		t.Fatalf("Error setting model")
Michel Roy's avatar
meep-model package
Michel Roy committed
177 178 
	}
	if m.scenario.Name != "demo1" {
Kevin Di Lallo's avatar
integrated message queue in all microservices  
Kevin Di Lallo committed
179 
		t.Fatalf("SetScenario failed")
Michel Roy's avatar
meep-model package
Michel Roy committed
180 181 182 183 
	}
	fmt.Println("Move ue1")
	old, new, err := m.MoveNode("ue1", "zone2-poa1")
	if err != nil {
Kevin Di Lallo's avatar
integrated message queue in all microservices  
Kevin Di Lallo committed
184 
		t.Fatalf("Error moving UE")
Michel Roy's avatar
meep-model package
Michel Roy committed
185 186 
	}
	if old != "zone1-poa1" {
Kevin Di Lallo's avatar
integrated message queue in all microservices  
Kevin Di Lallo committed
187 
		t.Fatalf("Move Node - wrong origin Location " + old)
Michel Roy's avatar
meep-model package
Michel Roy committed
188 189 
	}
	if new != "zone2-poa1" {
Kevin Di Lallo's avatar
integrated message queue in all microservices  
Kevin Di Lallo committed
190 
		t.Fatalf("Move Node - wrong destination Location " + new)
Michel Roy's avatar
meep-model package
Michel Roy committed
191 192 193 194 
	}
	fmt.Println("Move ue2-ext")
	old, new, err = m.MoveNode("ue2-ext", "zone2-poa1")
	if err != nil {
Kevin Di Lallo's avatar
integrated message queue in all microservices  
Kevin Di Lallo committed
195 
		t.Fatalf("Error moving UE")
Michel Roy's avatar
meep-model package
Michel Roy committed
196 197 
	}
	if old != "zone1-poa1" {
Kevin Di Lallo's avatar
integrated message queue in all microservices  
Kevin Di Lallo committed
198 
		t.Fatalf("Move Node - wrong origin Location " + old)
Michel Roy's avatar
meep-model package
Michel Roy committed
199 200 
	}
	if new != "zone2-poa1" {
Loading full blame…