diff --git a/backends/libcommuni/singleircnetworkplugin.cpp b/backends/libcommuni/singleircnetworkplugin.cpp new file mode 100644 index 0000000000000000000000000000000000000000..06bd378ce18c8c0abc19cbae95b0a8226cb900b1 --- /dev/null +++ b/backends/libcommuni/singleircnetworkplugin.cpp @@ -0,0 +1,128 @@ +#include "singleircnetworkplugin.h" +#include "log4cxx/logger.h" +#include +#include + +using namespace log4cxx; + +static LoggerPtr logger = log4cxx::Logger::getLogger("SingleIRCNetworkPlugin"); + +SingleIRCNetworkPlugin::SingleIRCNetworkPlugin(Config *config, Swift::QtEventLoop *loop, const std::string &host, int port) { + this->config = config; + m_server = config->getUnregistered().find("service.irc_server")->second; + m_socket = new QTcpSocket(); + m_socket->connectToHost(QString::fromStdString(host), port); + connect(m_socket, SIGNAL(readyRead()), this, SLOT(readData())); + + if (config->getUnregistered().find("service.irc_identify") != config->getUnregistered().end()) { + m_identify = config->getUnregistered().find("service.irc_identify")->second; + } + else { + m_identify = "NickServ identify $name $password"; + } + + LOG4CXX_INFO(logger, "SingleIRCNetworkPlugin for server " << m_server << " initialized."); +} + +void SingleIRCNetworkPlugin::readData() { + size_t availableBytes = m_socket->bytesAvailable(); + if (availableBytes == 0) + return; + + std::string d = std::string(m_socket->readAll().data(), availableBytes); + handleDataRead(d); +} + +void SingleIRCNetworkPlugin::sendData(const std::string &string) { + m_socket->write(string.c_str(), string.size()); +} + +void SingleIRCNetworkPlugin::handleLoginRequest(const std::string &user, const std::string &legacyName, const std::string &password) { + // legacy name is users nickname + if (m_sessions[user] != NULL) { + LOG4CXX_WARN(logger, user << ": Already logged in."); + return; + } + LOG4CXX_INFO(logger, user << ": Connecting " << m_server << " as " << legacyName); + + MyIrcSession *session = new MyIrcSession(user, this); + session->setUserName(QString::fromStdString(legacyName)); + session->setNickName(QString::fromStdString(legacyName)); + session->setRealName(QString::fromStdString(legacyName)); + session->setHost(QString::fromStdString(m_server)); + session->setPort(6667); + + std::string identify = m_identify; + boost::replace_all(identify, "$password", password); + boost::replace_all(identify, "$name", legacyName); + session->setIdentify(identify); + + session->open(); + + m_sessions[user] = session; +} + +void SingleIRCNetworkPlugin::handleLogoutRequest(const std::string &user, const std::string &legacyName) { + if (m_sessions[user] == NULL) { + LOG4CXX_WARN(logger, user << ": Already disconnected."); + return; + } + LOG4CXX_INFO(logger, user << ": Disconnecting."); + + m_sessions[user]->close(); + m_sessions[user]->deleteLater(); + m_sessions.erase(user); +} + +void SingleIRCNetworkPlugin::handleMessageSendRequest(const std::string &user, const std::string &legacyName, const std::string &message, const std::string &/*xhtml*/) { + if (m_sessions[user] == NULL) { + LOG4CXX_WARN(logger, user << ": Message received for unconnected user"); + return; + } + + // handle PMs + std::string r = legacyName; + if (legacyName.find("/") == std::string::npos) { + r = legacyName.substr(0, r.find("@")); + } + else { + r = legacyName.substr(legacyName.find("/") + 1); + } + + LOG4CXX_INFO(logger, user << ": Forwarding message to " << r); + m_sessions[user]->sendCommand(IrcCommand::createMessage(QString::fromStdString(r), QString::fromStdString(message))); + + if (r.find("#") == 0) { + handleMessage(user, legacyName, message, m_sessions[user]->nickName().toStdString()); + } +} + +void SingleIRCNetworkPlugin::handleJoinRoomRequest(const std::string &user, const std::string &room, const std::string &nickname, const std::string &password) { + if (m_sessions[user] == NULL) { + LOG4CXX_WARN(logger, user << ": Join room requested for unconnected user"); + return; + } + + LOG4CXX_INFO(logger, user << ": Joining " << room); + m_sessions[user]->addAutoJoinChannel(room); + m_sessions[user]->sendCommand(IrcCommand::createJoin(QString::fromStdString(room), QString::fromStdString(password))); + m_sessions[user]->rooms += 1; + + // update nickname, because we have nickname per session, no nickname per room. + handleRoomNicknameChanged(user, room, m_sessions[user]->userName().toStdString()); +} + +void SingleIRCNetworkPlugin::handleLeaveRoomRequest(const std::string &user, const std::string &room) { + std::string r = room; + std::string u = user; + + if (m_sessions[u] == NULL) { + LOG4CXX_WARN(logger, user << ": Leave room requested for unconnected user"); + return; + } + + LOG4CXX_INFO(logger, user << ": Leaving " << room); + m_sessions[u]->sendCommand(IrcCommand::createPart(QString::fromStdString(r))); + m_sessions[u]->removeAutoJoinChannel(r); + m_sessions[u]->rooms -= 1; +}