60 lines
1.6 KiB
Go
60 lines
1.6 KiB
Go
package config_manager_go
|
|
|
|
import (
|
|
"testing"
|
|
"github.com/stretchr/testify/assert"
|
|
"io/ioutil"
|
|
"log"
|
|
"loafle.com/overflow/agent_api/config_manager"
|
|
"encoding/json"
|
|
"github.com/google/uuid"
|
|
"loafle.com/overflow/agent_api/observer"
|
|
"loafle.com/overflow/agent_api/observer/messages"
|
|
"time"
|
|
)
|
|
|
|
func TestLoadConfig(t *testing.T) {
|
|
|
|
c := NewConfigManager()
|
|
c.loadGlobalConfig("/root/gowork/src/loafle.com/overflow/config_manager_go/test_agent/global.yaml")
|
|
c.loadCrawlerConfigAll()
|
|
|
|
assert.NotEqual(t, len(c.configs),0)
|
|
}
|
|
|
|
|
|
func TestAddConfig(t *testing.T) {
|
|
|
|
_configManager.loadGlobalConfig("/root/gowork/src/loafle.com/overflow/config_manager_go/test_agent/global.yaml")
|
|
|
|
// 원본 테스트 설정 파일 로드
|
|
b, err := ioutil.ReadFile("/root/gowork/src/loafle.com/overflow/config_manager_go/test_agent/test.json")
|
|
if err != nil {
|
|
log.Panic(err)
|
|
}
|
|
var m = config_manager.Config{}
|
|
json.Unmarshal(b, &m)
|
|
|
|
// uuid로 원본 파일 복제
|
|
rid,_ := uuid.NewRandom()
|
|
m.Id = rid.String()
|
|
b,err = json.Marshal(&m)
|
|
ioutil.WriteFile("/root/gowork/src/loafle.com/overflow/config_manager_go/test_agent/" + m.Id,b,0644)
|
|
|
|
|
|
// add test
|
|
observer.Notify(messages.ADD_SENSOR_0,"/root/gowork/src/loafle.com/overflow/config_manager_go/test_agent/" + m.Id)
|
|
time.Sleep(1 * time.Second)
|
|
}
|
|
|
|
|
|
func TestRemoveConfig(t *testing.T) {
|
|
|
|
_configManager.loadGlobalConfig("/root/gowork/src/loafle.com/overflow/config_manager_go/test_agent/global.yaml")
|
|
_configManager.loadCrawlerConfigAll()
|
|
|
|
// remove test
|
|
observer.Notify(messages.REMOVE_SENSOR_0,"289575d2-4a34-4475-b91d-7fb0992cc3de")
|
|
time.Sleep(1 * time.Second)
|
|
}
|