/**

 * XMPP - libpurple transport

 *

 * Copyright (C) 2013, Jan Kaluza <hanzz.k@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 2 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, write to the Free Software

 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02111-1301  USA

 */

#include <IrcCommand>

#include <IrcMessage>

#include "transport/Logging.h"

DEFINE_LOGGER(logger, "IRCNetworkPlugin");

#define FROM_UTF8(WHAT) QString::fromUtf8((WHAT).c_str(), (WHAT).size())

#define TO_UTF8(WHAT) std::string((WHAT).toUtf8().data(), (WHAT).toUtf8().size())

IRCNetworkPlugin::IRCNetworkPlugin(Config *config, Swift::QtEventLoop *loop, const std::string &host, int port) {

	m_config = config;

	m_currentServer = 0;

	m_firstPing = true;

	m_socket = new QTcpSocket();

	m_socket->connectToHost(FROM_UTF8(host), port);

	connect(m_socket, SIGNAL(readyRead()), this, SLOT(readData()));

	std::string server = CONFIG_STRING_DEFAULTED(m_config, "service.irc_server", "");

	if (!server.empty()) {

		m_servers.push_back(server);

	}

	else {

		std::list<std::string> list;

		list = CONFIG_LIST_DEFAULTED(m_config, "service.irc_server", list);

		m_servers.insert(m_servers.begin(), list.begin(), list.end());

	}

	if (CONFIG_HAS_KEY(m_config, "service.irc_identify")) {

		m_identify = CONFIG_STRING(m_config, "service.irc_identify");

	}

	else {

		m_identify = "NickServ identify $name $password";

	}

}

void IRCNetworkPlugin::tryNextServer() {

	if (!m_servers.empty()) {

		int nextServer = (m_currentServer + 1) % m_servers.size();

		LOG4CXX_INFO(logger, "Server " << m_servers[m_currentServer] << " disconnected user. Next server to try will be " << m_servers[nextServer]);

		m_currentServer = nextServer;

	}

}

void IRCNetworkPlugin::readData() {

	size_t availableBytes = m_socket->bytesAvailable();

	if (availableBytes == 0)

		return;

	if (m_firstPing) {

/**

 * XMPP - libpurple transport

 *

 * Copyright (C) 2013, Jan Kaluza <hanzz.k@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 2 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, write to the Free Software

 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02111-1301  USA

 */

#pragma once

#ifndef Q_MOC_RUN

#include "session.h"

#include <QtCore>

#include <QtNetwork>

#include "Swiften/EventLoop/Qt/QtEventLoop.h"

#endif

class IRCNetworkPlugin : public QObject, public NetworkPlugin {

	Q_OBJECT

	public:

		IRCNetworkPlugin(Config *config, Swift::QtEventLoop *loop, const std::string &host, int port);

		void handleLoginRequest(const std::string &user, const std::string &legacyName, const std::string &password);

		void handleLogoutRequest(const std::string &user, const std::string &legacyName);

		void handleMessageSendRequest(const std::string &user, const std::string &legacyName, const std::string &message, const std::string &/*xhtml*/, const std::string &/*id*/);

		void handleJoinRoomRequest(const std::string &user, const std::string &room, const std::string &nickname, const std::string &password);

		void handleLeaveRoomRequest(const std::string &user, const std::string &room);

		void handleRoomSubjectChangedRequest(const std::string &user, const std::string &room, const std::string &message);

		void handleVCardRequest(const std::string &user, const std::string &legacyName, unsigned int id);

		void handleStatusChangeRequest(const std::string &user, int status, const std::string &statusMessage);

		void tryNextServer();

		Config *getConfig() {

			return m_config;

		}

	public slots:

		void readData();

		void sendData(const std::string &string);

	private:

		MyIrcSession *createSession(const std::string &user, const std::string &hostname, const std::string &nickname, const std::string &password, const std::string &suffix = "");

		std::string getSessionName(const std::string &user, const std::string &legacyName);

		std::string getTargetName(const std::string &legacyName);

	private:

		Config *m_config;

		QTcpSocket *m_socket;

		std::map<std::string, MyIrcSession *> m_sessions;

		std::vector<std::string> m_servers;

		int m_currentServer;

		std::string m_identify;

		bool m_firstPing;

/**

 * XMPP - libpurple transport

 *

 * Copyright (C) 2013, Jan Kaluza <hanzz.k@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 2 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, write to the Free Software

 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02111-1301  USA

 */

#include "transport/Config.h"

#include "transport/NetworkPlugin.h"

#include "transport/Logging.h"

#include "Swiften/EventLoop/Qt/QtEventLoop.h"

#include "ircnetworkplugin.h"

using namespace boost::program_options;

using namespace Transport;

NetworkPlugin * np = NULL;

int main (int argc, char* argv[]) {

	std::string host;

	int port;

	std::string error;

	Config *cfg = Config::createFromArgs(argc, argv, error, host, port);

	if (cfg == NULL) {

		std::cerr << error;

		return 1;

	}

	Logging::initBackendLogging(cfg);

	QCoreApplication app(argc, argv);

	Swift::QtEventLoop eventLoop;

	np = new IRCNetworkPlugin(cfg, &eventLoop, host, port);

	return app.exec();

}