mirror of https://github.com/Icinga/icinga2.git
157 lines
4.7 KiB
C++
157 lines
4.7 KiB
C++
#include <cstdio>
|
|
#include <iostream>
|
|
#include "i2-icinga.h"
|
|
|
|
#ifndef _WIN32
|
|
# include "icinga-version.h"
|
|
# define ICINGA_VERSION GIT_MESSAGE
|
|
#endif /* _WIN32 */
|
|
|
|
using namespace icinga;
|
|
|
|
IcingaApplication::IcingaApplication(void)
|
|
{
|
|
m_EndpointManager = make_shared<EndpointManager>();
|
|
}
|
|
|
|
int IcingaApplication::Main(const vector<string>& args)
|
|
{
|
|
#ifdef _WIN32
|
|
cout << "Icinga component loader" << endl;
|
|
#else /* _WIN32 */
|
|
cout << "Icinga component loader (version: " << ICINGA_VERSION << ")" << endl;
|
|
#endif /* _WIN32 */
|
|
|
|
if (args.size() < 2) {
|
|
PrintUsage(args[0]);
|
|
return EXIT_FAILURE;
|
|
}
|
|
|
|
string componentDirectory = GetExeDirectory() + "/../lib/icinga";
|
|
AddComponentSearchDir(componentDirectory);
|
|
|
|
ConfigCollection::Ptr componentCollection = GetConfigHive()->GetCollection("component");
|
|
|
|
function<int (ConfigObjectEventArgs::Ptr)> NewComponentHandler = bind_weak(&IcingaApplication::NewComponentHandler, shared_from_this());
|
|
componentCollection->OnObjectCreated += NewComponentHandler;
|
|
componentCollection->ForEachObject(NewComponentHandler);
|
|
|
|
componentCollection->OnObjectRemoved += bind_weak(&IcingaApplication::DeletedComponentHandler, shared_from_this());
|
|
|
|
ConfigCollection::Ptr listenerCollection = GetConfigHive()->GetCollection("rpclistener");
|
|
|
|
function<int (ConfigObjectEventArgs::Ptr)> NewRpcListenerHandler = bind_weak(&IcingaApplication::NewRpcListenerHandler, shared_from_this());
|
|
listenerCollection->OnObjectCreated += NewRpcListenerHandler;
|
|
listenerCollection->ForEachObject(NewRpcListenerHandler);
|
|
|
|
listenerCollection->OnObjectRemoved += bind_weak(&IcingaApplication::DeletedRpcListenerHandler, shared_from_this());
|
|
|
|
ConfigCollection::Ptr connectionCollection = GetConfigHive()->GetCollection("rpcconnection");
|
|
|
|
function<int (ConfigObjectEventArgs::Ptr)> NewRpcConnectionHandler = bind_weak(&IcingaApplication::NewRpcConnectionHandler, shared_from_this());
|
|
connectionCollection->OnObjectCreated += NewRpcConnectionHandler;
|
|
connectionCollection->ForEachObject(NewRpcConnectionHandler);
|
|
|
|
connectionCollection->OnObjectRemoved += bind_weak(&IcingaApplication::DeletedRpcConnectionHandler, shared_from_this());
|
|
|
|
ConfigObject::Ptr fileComponentConfig = make_shared<ConfigObject>("component", "configfilecomponent");
|
|
fileComponentConfig->SetProperty("configFilename", args[1]);
|
|
fileComponentConfig->SetPropertyInteger("replicate", 0);
|
|
GetConfigHive()->AddObject(fileComponentConfig);
|
|
|
|
ConfigCollection::Ptr collection = GetConfigHive()->GetCollection("rpclistener");
|
|
|
|
RunEventLoop();
|
|
|
|
return EXIT_SUCCESS;
|
|
}
|
|
|
|
void IcingaApplication::PrintUsage(const string& programPath)
|
|
{
|
|
cout << "Syntax: " << programPath << " <config-file>" << endl;
|
|
}
|
|
|
|
EndpointManager::Ptr IcingaApplication::GetEndpointManager(void)
|
|
{
|
|
return m_EndpointManager;
|
|
}
|
|
|
|
int IcingaApplication::NewComponentHandler(ConfigObjectEventArgs::Ptr ea)
|
|
{
|
|
string path;
|
|
ConfigObject::Ptr object = static_pointer_cast<ConfigObject>(ea->Source);
|
|
|
|
if (!object->GetProperty("path", &path)) {
|
|
#ifdef _WIN32
|
|
path = object->GetName() + ".dll";
|
|
#else /* _WIN32 */
|
|
path = "lib" + object->GetName() + ".la";
|
|
#endif /* _WIN32 */
|
|
|
|
// TODO: try to figure out where the component is located */
|
|
}
|
|
|
|
LoadComponent(path, object);
|
|
|
|
return 0;
|
|
}
|
|
|
|
int IcingaApplication::DeletedComponentHandler(ConfigObjectEventArgs::Ptr ea)
|
|
{
|
|
ConfigObject::Ptr object = static_pointer_cast<ConfigObject>(ea->Source);
|
|
UnloadComponent(object->GetName());
|
|
|
|
return 0;
|
|
}
|
|
|
|
int IcingaApplication::NewRpcListenerHandler(ConfigObjectEventArgs::Ptr ea)
|
|
{
|
|
ConfigObject::Ptr object = static_pointer_cast<ConfigObject>(ea->Source);
|
|
int port;
|
|
|
|
if (!object->GetPropertyInteger("port", &port))
|
|
throw Exception("Parameter 'port' is required for 'rpclistener' objects.");
|
|
|
|
Log("Creating JSON-RPC listener on port %d", port);
|
|
|
|
GetEndpointManager()->AddListener(port);
|
|
|
|
return 0;
|
|
}
|
|
|
|
int IcingaApplication::DeletedRpcListenerHandler(ConfigObjectEventArgs::Ptr ea)
|
|
{
|
|
throw Exception("Unsupported operation.");
|
|
|
|
return 0;
|
|
}
|
|
|
|
int IcingaApplication::NewRpcConnectionHandler(ConfigObjectEventArgs::Ptr ea)
|
|
{
|
|
ConfigObject::Ptr object = static_pointer_cast<ConfigObject>(ea->Source);
|
|
string hostname;
|
|
int port;
|
|
|
|
if (!object->GetProperty("hostname", &hostname))
|
|
throw Exception("Parameter 'hostname' is required for 'rpcconnection' objects.");
|
|
|
|
if (!object->GetPropertyInteger("port", &port))
|
|
throw Exception("Parameter 'port' is required for 'rpcconnection' objects.");
|
|
|
|
Log("Creating JSON-RPC connection to %s:%d", hostname.c_str(), port);
|
|
|
|
GetEndpointManager()->AddConnection(hostname, port);
|
|
|
|
return 0;
|
|
}
|
|
|
|
int IcingaApplication::DeletedRpcConnectionHandler(ConfigObjectEventArgs::Ptr ea)
|
|
{
|
|
throw Exception("Unsupported operation.");
|
|
|
|
return 0;
|
|
}
|
|
|
|
|
|
SET_START_CLASS(icinga::IcingaApplication);
|