X-Git-Url: https://git.quassel-irc.org/?p=quassel.git;a=blobdiff_plain;f=src%2Fcore%2Foidentdconfiggenerator.cpp;h=91a7f5bde0c6d76be0ff8f755a816b34f737f78f;hp=fac6dcd91197771f25c11c4810175e6d7b70187d;hb=ca06a6758ab9463becafc453d5f6a32cb3b729a0;hpb=9c15e81b15a20e861c707e240c2cfee56bdf4bc9 diff --git a/src/core/oidentdconfiggenerator.cpp b/src/core/oidentdconfiggenerator.cpp index fac6dcd9..91a7f5bd 100644 --- a/src/core/oidentdconfiggenerator.cpp +++ b/src/core/oidentdconfiggenerator.cpp @@ -1,5 +1,5 @@ /*************************************************************************** - * Copyright (C) 2012 by the Quassel Project * + * Copyright (C) 2005-2019 by the Quassel Project * * devel@quassel-irc.org * * * * This program is free software; you can redistribute it and/or modify * @@ -15,113 +15,158 @@ * You should have received a copy of the GNU General Public License * * along with this program; if not, write to the * * Free Software Foundation, Inc., * - * 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. * + * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA. * ***************************************************************************/ +#ifdef HAVE_UMASK +# include +# include +#endif /* HAVE_UMASK */ + +#include + +#include "corenetwork.h" #include "oidentdconfiggenerator.h" -OidentdConfigGenerator::OidentdConfigGenerator(QObject *parent) : - QObject(parent), - _initialized(false) +OidentdConfigGenerator::OidentdConfigGenerator(QObject* parent) + : QObject(parent) { - if (!_initialized) - init(); + if (!_initialized) + init(); } -OidentdConfigGenerator::~OidentdConfigGenerator() { - _quasselConfig.clear(); - writeConfig(); - _configFile->deleteLater(); +OidentdConfigGenerator::~OidentdConfigGenerator() +{ + _quasselConfig.clear(); + writeConfig(); + _configFile->deleteLater(); } -bool OidentdConfigGenerator::init() { - _configDir = QDir::homePath(); - _configFileName = ".oidentd.conf"; - - if(Quassel::isOptionSet("oidentd-conffile")) - _configPath = Quassel::optionValue("oidentd-conffile"); - else - _configPath = _configDir.absoluteFilePath(_configFileName); - - _configTag = " stanza created by Quassel"; - - _configFile = new QFile(_configPath); - - // Rx has to match Template in order for cleanup to work. - // Template should be enhanced with the "from" parameter as soon as Quassel gains - // the ability to bind to an IP on client sockets. +bool OidentdConfigGenerator::init() +{ + _configDir.setPath(QDir::homePath()); + _configFileName = ".oidentd.conf"; - _quasselStanzaTemplate = QString("lport %1 { reply \"%2\" } #%3\n"); - _quasselStanzaRx = QRegExp(QString("^lport .* \\{ .* \\} #%1\\r?\\n").arg(_configTag)); + if (Quassel::isOptionSet("oidentd-conffile")) + _configPath = Quassel::optionValue("oidentd-conffile"); + else + _configPath = _configDir.absoluteFilePath(_configFileName); - // initially remove all Quassel stanzas that might be present - if (parseConfig(false) && writeConfig()) - _initialized = true; + _configTag = " stanza created by Quassel"; - return _initialized; -} + _configFile = new QFile(_configPath); -bool OidentdConfigGenerator::addSocket(const CoreIdentity *identity, const QHostAddress &localAddress, quint16 localPort, const QHostAddress &peerAddress, quint16 peerPort) { - Q_UNUSED(localAddress) Q_UNUSED(peerAddress) Q_UNUSED(peerPort) - QString ident = identity->ident(); + // Rx has to match Template in order for cleanup to work. + // Template should be enhanced with the "from" parameter as soon as Quassel gains + // the ability to bind to an IP on client sockets. - _quasselConfig.append(_quasselStanzaTemplate.arg(localPort).arg(ident).arg(_configTag).toAscii()); + _quasselStanzaTemplate = QString("lport %1 { reply \"%2\" } #%3\n"); + _quasselStanzaRx = QRegExp(QString(R"(^lport .* \{ .* \} #%1\r?\n)").arg(_configTag)); - bool ret = writeConfig(); + // initially remove all Quassel stanzas that might be present + if (parseConfig(false) && writeConfig()) + _initialized = true; - return ret; + return _initialized; } -//! not yet implemented -bool OidentdConfigGenerator::removeSocket(const CoreIdentity *identity, const QHostAddress &localAddress, quint16 localPort, const QHostAddress &peerAddress, quint16 peerPort) { - Q_UNUSED(identity) Q_UNUSED(localAddress) Q_UNUSED(localPort) Q_UNUSED(peerAddress) Q_UNUSED(peerPort) - return true; +QString OidentdConfigGenerator::sysIdentForIdentity(const CoreIdentity* identity) const +{ + // Make sure the identity's ident complies with strict mode if enabled + const CoreNetwork* network = qobject_cast(sender()); + return network->coreSession()->strictCompliantIdent(identity); } -bool OidentdConfigGenerator::parseConfig(bool readQuasselStanzas) { - if (!_configFile->exists()) - return true; +bool OidentdConfigGenerator::addSocket(const CoreIdentity* identity, + const QHostAddress& localAddress, + quint16 localPort, + const QHostAddress& peerAddress, + quint16 peerPort, + qint64 socketId) +{ + Q_UNUSED(localAddress) + Q_UNUSED(peerAddress) + Q_UNUSED(peerPort) + Q_UNUSED(socketId) - if (!_configFile->isOpen() && !_configFile->open(QIODevice::ReadOnly)) - return false; - _mutex.lock(); + const QString ident = sysIdentForIdentity(identity); - _parsedConfig.clear(); - _configFile->seek(0); - while (!_configFile->atEnd()) { - QByteArray line = _configFile->readLine(); + _quasselConfig.append(_quasselStanzaTemplate.arg(localPort).arg(ident).arg(_configTag).toLatin1()); - if (!lineByUs(line)) - _parsedConfig.append(line); - else if (readQuasselStanzas) - _quasselConfig.append(line); - } + bool ret = writeConfig(); - _configFile->close(); - _mutex.unlock(); - return true; + return ret; } -bool OidentdConfigGenerator::writeConfig() { - mode_t prev_umask = umask(S_IXUSR | S_IWGRP | S_IXGRP | S_IWOTH | S_IXOTH); // == 0133, rw-r--r-- - bool not_open = (!_configFile->isOpen() && !_configFile->open(QIODevice::ReadWrite | QIODevice::Text)); - umask(prev_umask); - - if (not_open) - return false; +//! not yet implemented +bool OidentdConfigGenerator::removeSocket(const CoreIdentity* identity, + const QHostAddress& localAddress, + quint16 localPort, + const QHostAddress& peerAddress, + quint16 peerPort, + qint64 socketId) +{ + Q_UNUSED(identity) + Q_UNUSED(localAddress) + Q_UNUSED(localPort) + Q_UNUSED(peerAddress) + Q_UNUSED(peerPort) + Q_UNUSED(socketId) - _mutex.lock(); + return true; +} - _configFile->seek(0); - _configFile->resize(0); - _configFile->write(_parsedConfig); - _configFile->write(_quasselConfig); +bool OidentdConfigGenerator::parseConfig(bool readQuasselStanzas) +{ + if (!_configFile->exists()) + return true; + + if (!_configFile->isOpen() && !_configFile->open(QIODevice::ReadOnly)) + return false; + _mutex.lock(); + + _parsedConfig.clear(); + _configFile->seek(0); + while (!_configFile->atEnd()) { + QByteArray line = _configFile->readLine(); + + if (!lineByUs(line)) + _parsedConfig.append(line); + else if (readQuasselStanzas) + _quasselConfig.append(line); + } + + _configFile->close(); + _mutex.unlock(); + return true; +} - _configFile->close(); - _mutex.unlock(); - return true; +bool OidentdConfigGenerator::writeConfig() +{ +#ifdef HAVE_UMASK + mode_t prev_umask = umask(S_IXUSR | S_IWGRP | S_IXGRP | S_IWOTH | S_IXOTH); // == 0133, rw-r--r-- +#endif + bool not_open = (!_configFile->isOpen() && !_configFile->open(QIODevice::ReadWrite | QIODevice::Text)); +#ifdef HAVE_UMASK + umask(prev_umask); +#endif + + if (not_open) + return false; + + _mutex.lock(); + + _configFile->seek(0); + _configFile->resize(0); + _configFile->write(_parsedConfig); + _configFile->write(_quasselConfig); + + _configFile->close(); + _mutex.unlock(); + return true; } -bool OidentdConfigGenerator::lineByUs(const QByteArray &line) { - return _quasselStanzaRx.exactMatch(line); +bool OidentdConfigGenerator::lineByUs(const QByteArray& line) +{ + return _quasselStanzaRx.exactMatch(line); }