pEp.foundation
/
pEpJSONServerAdapter
10
2
Fork 4
Code Issues 1 Pull Requests Releases 1 Wiki Activity

implement eventListener map

JSON-2
Roker 2016-08-15 17:08:41 +02:00
parent ebba3a177a
commit b636088139
2 changed files with 30 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
server/json-adapter.cc
View File

@ -410,6 +410,7 @@ auto ThreadDeleter = [](std::thread *t)
typedef std::unique_ptr<std::thread, decltype(ThreadDeleter)> ThreadPtr;
typedef std::vector<ThreadPtr> ThreadPool;
typedef std::pair<std::string, unsigned> EventListenerKey;
struct JsonAdapter::Internal
{
@ -417,6 +418,7 @@ struct JsonAdapter::Internal
std::unique_ptr<evhttp, decltype(&evhttp_free)> evHttp = {nullptr, &evhttp_free};
std::string address;
std::string token;
std::map<EventListenerKey, std::string> eventListener;
unsigned start_port = 0;
unsigned end_port = 0;
@ -579,3 +581,30 @@ bool JsonAdapter::verify_security_token(const std::string& s) const
}
return s == i->token;
}
void JsonAdapter::registerEventListener(const std::string& address, unsigned port, const std::string& securityContext)
{
const auto key = std::make_pair(address, port);
const auto q = i->eventListener.find(key);
if( q != i->eventListener.end() && q->second != securityContext)
{
throw std::runtime_error("EventListener at host \"" + address + "\":" + std::to_string(port) + " is already registered with different securityContext." );
}
i->eventListener[key] = securityContext;
}
void JsonAdapter::unregisterEventListener(const std::string& address, unsigned port, const std::string& securityContext)
{
const auto key = std::make_pair(address, port);
const auto q = i->eventListener.find(key);
if( q == i->eventListener.end() || q->second != securityContext)
{
throw std::runtime_error("Cannot unregister EventListener at host \"" + address + "\":" + std::to_string(port) + ". Not registered or wrong securityContext." );
}
i->eventListener.erase(q);
}

2
server/json-adapter.hh
View File

@ -19,7 +19,7 @@ public:
JsonAdapter(const JsonAdapter&) = delete;
void operator=(const JsonAdapter&) = delete;
void registerEventListener(const std::string& address, unsigned port, const std::string& securityContext);
void registerEventListener(const std::string& address, unsigned port, const std::string& securityContext);
void unregisterEventListener(const std::string& address, unsigned port, const std::string& securityContext);
// run the server in another thread and returns immediately.