import (
"bytes"
+ "io/ioutil"
"net/http"
"net/http/httptest"
"os"
"github.com/stretchr/testify/assert"
)
-//var _ = func() bool {
-// testing.Init()
-// return true
-//}()
+var _ = func() bool {
+ testing.Init()
+ return true
+}()
type Consumer struct{}
}
func TestConfigAccess(t *testing.T) {
- Logger.Info("CASE: AddConfigChangeListener")
+ Logger.Info("CASE: TestConfigAccess")
assert.Equal(t, Config.GetString("name"), "xapp")
assert.Equal(t, Config.GetInt("controls.logger.level"), 3)
}
func TestPublishConfigChange(t *testing.T) {
- Logger.Info("CASE: AddConfigChangeListener")
+ Logger.Info("CASE: TestPublishConfigChange")
PublishConfigChange("testApp", "values")
+ ReadConfig("testApp")
}
func TestNewSubscriber(t *testing.T) {
Sdl.Store("myKey", "Values")
Sdl.MStore("myKey", "Values")
Sdl.RegisterMetrics()
+ Sdl.UpdateStatCounter("Stored")
// Misc.
var NotificationCb = func(ch string, events ...string) {}
Sdl.Subscribe(NotificationCb, "channel1")
Sdl.MSubscribe(NotificationCb, "channel1", "channel2")
+ Sdl.StoreAndPublish("channel1", "event", "key1", "data1")
Sdl.MStoreAndPublish([]string{"channel1"}, "event", "key1", "data1")
}
executeRequest(req, handleFunc)
}
+func TestConfigChange(t *testing.T) {
+ Logger.Error("CASE: TestConfigChange: %s", os.Getenv("CFG_FILE"))
+
+ input, err := ioutil.ReadFile(os.Getenv("CFG_FILE"))
+ assert.Equal(t, err, nil)
+
+ err = ioutil.WriteFile(os.Getenv("CFG_FILE"), input, 0644)
+ assert.Equal(t, err, nil)
+}
+
func TestRegisterXapp(t *testing.T) {
Logger.Error("CASE: TestRegisterXapp")
doRegister()