2017-01-27 16:45:01 -05:00
|
|
|
#include "STDInclude.hpp"
|
|
|
|
|
|
|
|
namespace Components
|
|
|
|
{
|
|
|
|
std::unordered_map<std::string, IPCHandler::Callback> IPCHandler::ClientCallbacks;
|
|
|
|
std::unique_ptr<Utils::IPC::BidirectionalChannel> IPCHandler::ClientChannel;
|
|
|
|
|
|
|
|
void IPCHandler::SendClient(std::string message, std::string data)
|
|
|
|
{
|
2017-01-30 14:47:01 -05:00
|
|
|
IPCHandler::InitChannel();
|
2017-01-27 17:09:32 -05:00
|
|
|
|
|
|
|
Proto::IPC::Command command;
|
2017-01-28 09:51:50 -05:00
|
|
|
command.set_name(message);
|
2017-01-27 17:09:32 -05:00
|
|
|
command.set_data(data);
|
|
|
|
|
|
|
|
IPCHandler::ClientChannel->send(command.SerializeAsString());
|
2017-01-27 16:45:01 -05:00
|
|
|
}
|
|
|
|
|
|
|
|
void IPCHandler::OnClient(std::string message, IPCHandler::Callback callback)
|
|
|
|
{
|
|
|
|
IPCHandler::ClientCallbacks[message] = callback;
|
|
|
|
}
|
|
|
|
|
2017-01-30 14:47:01 -05:00
|
|
|
void IPCHandler::InitChannel()
|
2017-01-27 16:45:01 -05:00
|
|
|
{
|
|
|
|
if (!IPCHandler::ClientChannel)
|
|
|
|
{
|
|
|
|
IPCHandler::ClientChannel.reset(new Utils::IPC::BidirectionalChannel("IW4x-Client-Channel", Singleton::IsFirstInstance()));
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2017-01-27 17:09:32 -05:00
|
|
|
void IPCHandler::HandleClient()
|
|
|
|
{
|
2017-01-30 14:47:01 -05:00
|
|
|
IPCHandler::InitChannel();
|
2017-01-27 17:09:32 -05:00
|
|
|
|
|
|
|
std::string packet;
|
|
|
|
if(IPCHandler::ClientChannel->receive(&packet))
|
|
|
|
{
|
|
|
|
Proto::IPC::Command command;
|
|
|
|
if(command.ParseFromString(packet))
|
|
|
|
{
|
2017-01-28 09:51:50 -05:00
|
|
|
auto callback = IPCHandler::ClientCallbacks.find(command.name());
|
2017-01-27 17:09:32 -05:00
|
|
|
if (callback != IPCHandler::ClientCallbacks.end())
|
|
|
|
{
|
|
|
|
callback->second(command.data());
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2017-01-27 16:45:01 -05:00
|
|
|
IPCHandler::IPCHandler()
|
|
|
|
{
|
2017-01-29 16:56:22 -05:00
|
|
|
if (Dedicated::IsEnabled() || ZoneBuilder::IsEnabled() || Loader::PerformingUnitTests()) return;
|
2017-01-27 16:45:01 -05:00
|
|
|
|
2017-01-30 14:47:01 -05:00
|
|
|
IPCHandler::InitChannel();
|
2017-01-27 16:45:01 -05:00
|
|
|
|
2017-01-30 14:47:01 -05:00
|
|
|
QuickPatch::OnFrame(IPCHandler::HandleClient);
|
2017-01-27 16:45:01 -05:00
|
|
|
}
|
|
|
|
|
|
|
|
IPCHandler::~IPCHandler()
|
|
|
|
{
|
|
|
|
IPCHandler::ClientCallbacks.clear();
|
2017-01-28 13:03:44 -05:00
|
|
|
IPCHandler::ClientChannel.release();
|
2017-01-27 16:45:01 -05:00
|
|
|
}
|
|
|
|
}
|