200 lines
2.9 KiB
Go
200 lines
2.9 KiB
Go
package crawler_manager
|
|
|
|
import (
|
|
//ooo "git.loafle.net/overflow/agent_api/observer"
|
|
//"git.loafle.net/overflow/agent_api/config_manager"
|
|
//"git.loafle.net/overflow/agent_api/messages"
|
|
//
|
|
//"fmt"
|
|
"git.loafle.net/overflow/agent_api/config_manager"
|
|
|
|
)
|
|
|
|
|
|
func Start(res chan bool, conMgr config_manager.ConfigManager) {
|
|
|
|
GetInstance().ConfigMgr = conMgr;
|
|
|
|
SettingPath()
|
|
|
|
err := GetInstance().init();
|
|
if err != nil {
|
|
res <- false
|
|
return;
|
|
}
|
|
|
|
res <- true
|
|
}
|
|
|
|
func Stop(res chan bool) {
|
|
|
|
GetInstance().stopContainerAll()
|
|
|
|
res <- true
|
|
}
|
|
|
|
func AddSensor(id string) error {
|
|
|
|
|
|
err := GetInstance().addSensor(id)
|
|
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
return nil
|
|
|
|
}
|
|
|
|
func RemoveSensor(id string) {
|
|
|
|
GetInstance().removeSensor(id)
|
|
|
|
//FIXME:: error return
|
|
|
|
|
|
}
|
|
|
|
func UpdateSensor(id string) error {
|
|
|
|
|
|
err := GetInstance().updateSensor(id)
|
|
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
func UpdateCRM() {
|
|
|
|
//FIXME:: update crawler
|
|
|
|
}
|
|
|
|
func listenEvent() {
|
|
|
|
//go listenConfigLoaded();
|
|
//go listenAgentStop()
|
|
//
|
|
//go listenAddSensor();
|
|
//go listenRemoveSensor();
|
|
//go listenUpdateSensor();
|
|
//
|
|
//go listenUpdateCrawler()
|
|
}
|
|
//
|
|
//func listenConfigLoaded() {
|
|
//
|
|
// ch := make(chan interface{}, 0)
|
|
// observer.Add(messages.CFG_LOADED, ch)
|
|
//
|
|
// o := <-ch
|
|
//
|
|
// cm := o.(config_manager.ConfigManager)
|
|
//
|
|
// GetInstance().ConfigMgr = cm;
|
|
//
|
|
// SettingPath()
|
|
//
|
|
// err := GetInstance().init();
|
|
// if err != nil {
|
|
// //FIXME:: noti err
|
|
// return;
|
|
// }
|
|
//
|
|
//
|
|
// observer.Notify(messages.CRM_READY, cm)
|
|
//
|
|
//}
|
|
//
|
|
//func listenAgentStop() {
|
|
//
|
|
// ch := make(chan interface{}, 0)
|
|
// observer.Add(messages.CLT_STOPPED, ch)
|
|
//
|
|
// o := <-ch
|
|
//
|
|
// fmt.Println(o)
|
|
//
|
|
// GetInstance().stopContainerAll()
|
|
//
|
|
// observer.Notify(messages.CRM_STOPPED, nil)
|
|
//
|
|
//
|
|
//}
|
|
//
|
|
//func listenAddSensor() {
|
|
// ch := make(chan interface{}, 0)
|
|
// observer.Add(messages.SCF_SENSOR_ADD_DONE, ch);
|
|
//
|
|
// o := <-ch
|
|
//
|
|
// str := o.(string)
|
|
//
|
|
// fmt.Println(str)
|
|
//
|
|
// err := GetInstance().addSensor(str)
|
|
//
|
|
// if err != nil {
|
|
// //FIXME:: noti err
|
|
// return
|
|
// }
|
|
//
|
|
// observer.Notify(messages.CRM_SENSOR_ADD_DONE, nil)
|
|
//
|
|
//}
|
|
//
|
|
//func listenRemoveSensor() {
|
|
//
|
|
// ch := make(chan interface{}, 0)
|
|
// observer.Add(messages.CLT_SENSOR_REMOVE_DONE, ch);
|
|
//
|
|
// o := <-ch
|
|
//
|
|
// str := o.(string)
|
|
//
|
|
// GetInstance().removeSensor(str)
|
|
//
|
|
//
|
|
// observer.Notify(messages.CRM_SENSOR_REMOVE_DONE, nil)
|
|
//
|
|
//}
|
|
//
|
|
//func listenUpdateSensor() {
|
|
//
|
|
// ch := make(chan interface{}, 0)
|
|
// observer.Add(messages.SCF_SENSOR_UPDATE_DONE, ch);
|
|
//
|
|
// o := <-ch
|
|
//
|
|
// container := o.(string)
|
|
//
|
|
// err := GetInstance().runAndInitContainerOne(&container)
|
|
//
|
|
// if err != nil {
|
|
// //FIXME:: noti err
|
|
// return
|
|
// }
|
|
//
|
|
// observer.Notify(messages.CRM_SENSOR_UPDATE_DONE, nil)
|
|
//
|
|
//}
|
|
//
|
|
//func listenUpdateCrawler() {
|
|
//
|
|
// ch := make(chan interface{}, 0)
|
|
// observer.Add(messages.CLT_CRM_UPDATE_DONE, ch);
|
|
//
|
|
// o := <-ch
|
|
//
|
|
// fmt.Println(o)
|
|
// //FIXME::update crawler
|
|
//
|
|
//
|
|
// observer.Notify(messages.CRM_UPDATE_DONE, nil)
|
|
//
|
|
//}
|
|
//
|