messagedispatcher.cpp

/*
    This file is part of the Kapotah project.
    Copyright (C) 2010 Shantanu Tushar <shaan7in@gmail.com>
    Copyright (C) 2010 Sudhendu Kumar <sudhendu.kumar.roy@gmail.com>

    This program is free software: you can redistribute it and/or modify
    it under the terms of the GNU General Public License as published by
    the Free Software Foundation, either version 3 of the License, or
    (at your option) any later version.

    This program is distributed in the hope that it will be useful,
    but WITHOUT ANY WARRANTY; without even the implied warranty of
    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
    GNU General Public License for more details.

    You should have received a copy of the GNU General Public License
    along with this program.  If not, see <http://www.gnu.org/licenses/>.
*/


#include "messagedispatcher.h"
#include <xml/messagexmlparser.h>
#include <xml/transferxmlparser.h>
#include "messagesenderthread.h"

using namespace Kapotah;

template<> MessageDispatcher *Kapotah::Singleton<MessageDispatcher>::m_instance = 0;

MessageDispatcher::MessageDispatcher()
{
    m_messageDispatcherServer = new MessageDispatcherServer (this);
    connect (m_messageDispatcherServer, SIGNAL (gotMessage (QString, QHostAddress)),
             SLOT (newMessage (QString, QHostAddress)));
}

MessageDispatcherServer* MessageDispatcher::messageDispatcherServer()
{
    return m_messageDispatcherServer;
}

void MessageDispatcher::newMessage (QString message, QHostAddress peerAddress)
{
    //Try parsing as Message
    MessageXmlParser parser;
    MessageXmlData *data = static_cast<MessageXmlData*>(parser.parseXml(message));

    if (data->type == AbstractXmlData::Message) {
        emit gotNewMessage (data->message, peerAddress);
    } else {    //FIXME: Don't straightaway assume its Transfer, do sanity checks
        gotNewTransfer(message, peerAddress);
    }
}

void MessageDispatcher::sendNewMessage (QString message, QHostAddress peerAddress)
{
    MessageXmlData data;
    MessageXmlParser parser;
    data.type = AbstractXmlData::Message;
    data.message = message;
    MessageSenderThread *thread = new MessageSenderThread (parser.composeXml(&data), peerAddress);
    thread->start();
}

#include "messagedispatcher.moc"