louiz’
99a4ddedaf
This adds a hard dependency on one of Botan or gcrypt. Botan is already a recommended dependency, and gcrypt is probably packaged almost everywhere, so this should not be a big deal. ref #3241
64 lines
1.8 KiB
C++
64 lines
1.8 KiB
C++
#include <identd/identd_socket.hpp>
|
|
#include <identd/identd_server.hpp>
|
|
#include <xmpp/biboumi_component.hpp>
|
|
#include <sstream>
|
|
#include <iomanip>
|
|
|
|
#include <utils/sha1.hpp>
|
|
|
|
#include <logger/logger.hpp>
|
|
|
|
IdentdSocket::IdentdSocket(std::shared_ptr<Poller> poller, const socket_t socket, TcpSocketServer<IdentdSocket>& server):
|
|
TCPSocketHandler(poller),
|
|
server(dynamic_cast<IdentdServer&>(server))
|
|
{
|
|
this->socket = socket;
|
|
}
|
|
|
|
void IdentdSocket::parse_in_buffer(const std::size_t)
|
|
{
|
|
while (true)
|
|
{
|
|
const auto line_end = this->in_buf.find('\n');
|
|
if (line_end == std::string::npos)
|
|
break;
|
|
std::istringstream line(this->in_buf.substr(0, line_end));
|
|
this->consume_in_buffer(line_end + 1);
|
|
|
|
uint16_t local_port;
|
|
uint16_t remote_port;
|
|
char sep;
|
|
line >> local_port >> sep >> remote_port;
|
|
const auto& xmpp = this->server.get_biboumi_component();
|
|
auto response = this->generate_answer(xmpp, local_port, remote_port);
|
|
|
|
this->send_data(std::move(response));
|
|
}
|
|
}
|
|
|
|
static std::string hash_jid(const std::string& jid)
|
|
{
|
|
return sha1(jid);
|
|
}
|
|
|
|
std::string IdentdSocket::generate_answer(const BiboumiComponent& biboumi, uint16_t local, uint16_t remote)
|
|
{
|
|
for (const Bridge* bridge: biboumi.get_bridges())
|
|
{
|
|
for (const auto& pair: bridge->get_irc_clients())
|
|
{
|
|
if (pair.second->match_port_pairt(local, remote))
|
|
{
|
|
std::ostringstream os;
|
|
os << local << " , " << remote << " : USERID : OTHER : " << hash_jid(bridge->get_bare_jid());
|
|
log_debug("Identd, sending: ", os.str());
|
|
return os.str();
|
|
}
|
|
}
|
|
}
|
|
std::ostringstream os;
|
|
os << local << " , " << remote << " ERROR : NO-USER";
|
|
log_debug("Identd, sending: ", os.str());
|
|
return os.str();
|
|
}
|