X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=E2Manager%2Fconfiguration%2Fconfiguration_test.go;h=695ed9ab7998051d987c46fe1737e7097928bb0b;hb=ddf7aedcbeadaa40afb882a49ae20fbb6e2c98ca;hp=ac76d994e1cde392e1f327f9b76f56e60352f37f;hpb=08ae8615200de08fd666ed22bfe06ded2362af9f;p=ric-plt%2Fe2mgr.git diff --git a/E2Manager/configuration/configuration_test.go b/E2Manager/configuration/configuration_test.go index ac76d99..695ed9a 100644 --- a/E2Manager/configuration/configuration_test.go +++ b/E2Manager/configuration/configuration_test.go @@ -42,6 +42,13 @@ func TestParseConfigurationSuccess(t *testing.T) { assert.NotNil(t, config.GlobalRicId) assert.NotEmpty(t, config.GlobalRicId.PlmnId) assert.NotEmpty(t, config.GlobalRicId.RicNearRtId) +/* assert.NotEmpty(t, config.Kubernetes.KubeNamespace) + assert.NotEmpty(t, config.Kubernetes.ConfigPath)*/ +} + +func TestStringer(t *testing.T) { + config := ParseConfiguration().String() + assert.NotEmpty(t, config) } func TestParseConfigurationFileNotFoundFailure(t *testing.T) { @@ -201,6 +208,7 @@ func TestGlobalRicIdConfigNotFoundFailure(t *testing.T) { "logging": map[string]interface{}{"logLevel": "info"}, "http": map[string]interface{}{"port": 3800}, "routingManager": map[string]interface{}{"baseUrl": "http://iltlv740.intl.att.com:8080/ric/v1/handles/"}, + //"kubernetes": map[string]interface{}{"kubeNamespace": "test", "ConfigPath": "test"}, } buf, err := yaml.Marshal(yamlMap) if err != nil { @@ -213,3 +221,35 @@ func TestGlobalRicIdConfigNotFoundFailure(t *testing.T) { assert.PanicsWithValue(t, "#configuration.populateGlobalRicIdConfig - failed to populate Global RicId configuration: The entry 'globalRicId' not found\n", func() { ParseConfiguration() }) } + +/*func TestKubernetesConfigNotFoundFailure(t *testing.T) { + configPath := "../resources/configuration.yaml" + configPathTmp := "../resources/configuration.yaml_tmp" + err := os.Rename(configPath, configPathTmp) + if err != nil { + t.Errorf("#TestKubernetesConfigNotFoundFailure - failed to rename configuration file: %s\n", configPath) + } + defer func() { + err = os.Rename(configPathTmp, configPath) + if err != nil { + t.Errorf("#TestKubernetesConfigNotFoundFailure - failed to rename configuration file: %s\n", configPath) + } + }() + yamlMap := map[string]interface{}{ + "rmr": map[string]interface{}{"port": 3801, "maxMsgSize": 4096}, + "logging": map[string]interface{}{"logLevel": "info"}, + "http": map[string]interface{}{"port": 3800}, + "routingManager": map[string]interface{}{"baseUrl": "http://iltlv740.intl.att.com:8080/ric/v1/handles/"}, + "globalRicId": map[string]interface{}{"plmnId": "131014", "ricNearRtId": "556670"}, + } + buf, err := yaml.Marshal(yamlMap) + if err != nil { + t.Errorf("#TestKubernetesConfigNotFoundFailure - failed to marshal configuration map\n") + } + err = ioutil.WriteFile("../resources/configuration.yaml", buf, 0644) + if err != nil { + t.Errorf("#TestKubernetesConfigNotFoundFailure - failed to write configuration file: %s\n", configPath) + } + assert.PanicsWithValue(t, "#configuration.populateKubernetesConfig - failed to populate Kubernetes configuration: The entry 'kubernetes' not found\n", + func() { ParseConfiguration() }) +}*/