#include "ircnetworkplugin.h"

#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) {

	this->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(config, "service.irc_server", "");

	if (!server.empty()) {

		m_servers.push_back(server);

	}

	else {

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

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

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

	}

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

		m_identify = CONFIG_STRING(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();

#pragma once

#include "transport/config.h"

#include "transport/networkplugin.h"

#include "session.h"

#include <QtCore>

#include <QtNetwork>

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

#include "ircnetworkplugin.h"

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 tryNextServer();

	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 *config;

		QTcpSocket *m_socket;

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

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

		int m_currentServer;

		std::string m_identify;

 *

 */

#include "transport/config.h"

#include "transport/networkplugin.h"

#include "transport/logging.h"

#include "session.h"

#include <QtCore>

#include <QtNetwork>

#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();

}

 *

 */

#include "session.h"

#include <QtCore>

#include <iostream>

#include <IrcCommand>

#include <IrcMessage>

#include "ircnetworkplugin.h"

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

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

#include "transport/logging.h"

DEFINE_LOGGER(logger, "IRCSession");

static bool sentList;

MyIrcSession::MyIrcSession(const std::string &user, IRCNetworkPlugin *np, const std::string &suffix, QObject* parent) : IrcSession(parent)

{

	this->np = np;

	this->user = user;

	this->suffix = suffix;

	m_connected = false;

	rooms = 0;

	connect(this, SIGNAL(disconnected()), SLOT(on_disconnected()));

	connect(this, SIGNAL(socketError(QAbstractSocket::SocketError)), SLOT(on_socketError(QAbstractSocket::SocketError)));

	connect(this, SIGNAL(connected()), SLOT(on_connected()));

	connect(this, SIGNAL(messageReceived(IrcMessage*)), this, SLOT(onMessageReceived(IrcMessage*)));

	m_awayTimer = new QTimer(this);

	connect(m_awayTimer, SIGNAL(timeout()), this, SLOT(awayTimeout()));

	m_awayTimer->start(5*1000);

}

MyIrcSession::~MyIrcSession() {

	delete m_awayTimer;

}

void MyIrcSession::on_connected() {

	m_connected = true;

	if (suffix.empty()) {

		np->handleConnected(user);

// 		if (!sentList) {

// 			sendCommand(IrcCommand::createList("", ""));

// 			sentList = true;

// 		}

 *

 */

#ifndef SESSION_H

#define SESSION_H

#include <IrcSession>

#include <transport/networkplugin.h>

#include "Swiften/Swiften.h"

#include <boost/smart_ptr/make_shared.hpp>

#include <QTimer>

using namespace Transport;

class IRCNetworkPlugin;

class MyIrcSession : public IrcSession

{

    Q_OBJECT

public:

	class AutoJoinChannel {

		public:

			AutoJoinChannel(const std::string &channel = "", const std::string &password = "", int awayCycle = 12) : m_channel(channel), m_password(password),

				m_awayCycle(awayCycle), m_currentAwayTick(0) {}

			virtual ~AutoJoinChannel() {}

			const std::string &getChannel() { return m_channel; }

			const std::string &getPassword() { return m_password; }

			bool shouldAskWho() {

				if (m_currentAwayTick == m_awayCycle) {

					m_currentAwayTick = 0;

					return true;

				}

				m_currentAwayTick++;

				return false;

			}

		private:

			std::string m_channel;

			std::string m_password;

			int m_awayCycle;

			int m_currentAwayTick;

	};

	class IRCBuddy {

		public:

			IRCBuddy(bool op = false, bool away = false) : m_op(op), m_away(away) {};