X-Git-Url: https://git.quassel-irc.org/?p=quassel.git;a=blobdiff_plain;f=src%2Fclient%2Fclient.cpp;h=ea1738b8f8c73b9030389de94d6c7adef5520b37;hp=64092ddc68a6a5fcb72c53a0f5b3c3e8cba3d24d;hb=52a7b4d0f289f075aa386445a47d876743bcb6d0;hpb=ef12cc4010e853348474b4ea15c383dd596d4858 diff --git a/src/client/client.cpp b/src/client/client.cpp index 64092ddc..ea1738b8 100644 --- a/src/client/client.cpp +++ b/src/client/client.cpp @@ -26,6 +26,7 @@ #include "buffersyncer.h" #include "bufferviewmanager.h" #include "clientbacklogmanager.h" +#include "clientirclisthelper.h" #include "global.h" #include "identity.h" #include "ircchannel.h" @@ -72,10 +73,13 @@ Client::Client(QObject *parent) _backlogManager(new ClientBacklogManager(this)), _bufferViewManager(0), _messageModel(0), + _ircListHelper(new ClientIrcListHelper(this)), _connectedToCore(false), _syncedToCore(false) { _monitorBuffer = new Buffer(BufferInfo(), this); + _signalProxy->synchronize(_ircListHelper); + connect(_backlogManager, SIGNAL(backlog(BufferId, const QVariantList &)), this, SLOT(receiveBacklog(BufferId, const QVariantList &))); } @@ -242,7 +246,8 @@ void Client::coreNetworkCreated(NetworkId id) { } void Client::coreNetworkRemoved(NetworkId id) { - if(!_networks.contains(id)) return; + if(!_networks.contains(id)) + return; Network *net = _networks.take(id); emit networkRemoved(net->networkId()); net->deleteLater(); @@ -497,7 +502,7 @@ void Client::recvMessage(const Message &message) { ? net->networkName() + ":" : QString(); QString sender = networkName + msg.bufferInfo().bufferName() + ":" + msg.sender(); - Message mmsg = Message(msg.timestamp(), msg.bufferInfo(), msg.type(), msg.text(), sender, msg.flags()); + Message mmsg = Message(msg.timestamp(), msg.bufferInfo(), msg.type(), msg.contents(), sender, msg.flags()); monitorBuffer()->appendMsg(mmsg); } emit messageReceived(msg); @@ -505,8 +510,8 @@ void Client::recvMessage(const Message &message) { #else void Client::recvMessage(const Message &msg) { - - + //checkForHighlight(msg); + _messageModel->insertMessage(msg); } #endif /* SPUTDEV */ @@ -515,11 +520,20 @@ void Client::recvStatusMsg(QString /*net*/, QString /*msg*/) { //recvMessage(net, Message::server("", QString("[STATUS] %1").arg(msg))); } +#ifdef SPUTDEV +void Client::receiveBacklog(BufferId bufferId, const QVariantList &msgs) { + //checkForHighlight(msg); + foreach(QVariant v, msgs) { + _messageModel->insertMessage(v.value()); + } +} + +#else + void Client::receiveBacklog(BufferId bufferId, const QVariantList &msgs) { -#ifndef SPUTDEV Buffer *buffer_ = buffer(bufferId); if(!buffer_) { - qWarning() << "Client::recvBacklogData(): received Backlog for unknown Buffer:" << bufferId; + qWarning() << "Client::receiveBacklog(): received Backlog for unknown Buffer:" << bufferId; return; } @@ -542,8 +556,8 @@ void Client::receiveBacklog(BufferId bufferId, const QVariantList &msgs) { if(!layoutTimer->isActive()) { layoutTimer->start(); } -#endif } +#endif /* SPUTDEV */ void Client::layoutMsg() { if(layoutQueue.isEmpty()) { @@ -555,7 +569,7 @@ void Client::layoutMsg() { if(buffer->layoutMsg()) { layoutQueue.append(buffer); // Buffer has more messages in its queue --> Round Robin return; - } + } if(layoutQueue.isEmpty()) layoutTimer->stop(); @@ -579,7 +593,7 @@ void Client::checkForHighlight(Message &msg) { QRegExp nickRegExp("^(.*\\W)?" + QRegExp::escape(nickname) + "(\\W.*)?$"); if((msg.type() & (Message::Plain | Message::Notice | Message::Action)) && !(msg.flags() & Message::Self) - && nickRegExp.exactMatch(msg.text())) { + && nickRegExp.exactMatch(msg.contents())) { msg.setFlags(msg.flags() | Message::Highlight); return; } @@ -599,7 +613,7 @@ void Client::checkForHighlight(Message &msg) { } if((msg.type() & (Message::Plain | Message::Notice | Message::Action)) && !(msg.flags() & Message::Self) - && userRegExp.exactMatch(msg.text())) { + && userRegExp.exactMatch(msg.contents())) { msg.setFlags(msg.flags() | Message::Highlight); return; } @@ -628,7 +642,7 @@ void Client::removeBuffer(BufferId id) { } void Client::bufferRemoved(BufferId bufferId) { - // first remove the buffer from has. this prohibits further lastSeenUpdates + // first remove the buffer from hash. this prohibits further lastSeenUpdates Buffer *buff = 0; if(_buffers.contains(bufferId)) { buff = _buffers.take(bufferId);