#include "utils.h"

#include "glib.h"

#include "purple.h"

#include <algorithm>

#include <iostream>

#include "transport/networkplugin.h"

#include "geventloop.h"

#include "log4cxx/logger.h"

#include "log4cxx/consoleappender.h"

#include "log4cxx/patternlayout.h"

#include "log4cxx/propertyconfigurator.h"

#include "log4cxx/helpers/properties.h"

#include "log4cxx/helpers/fileinputstream.h"

#include "log4cxx/helpers/transcoder.h"

// #include "valgrind/memcheck.h"

#include "malloc.h"

#include <algorithm>

#include "errno.h"

#ifdef WITH_LIBEVENT

#include <event.h>

#endif

using namespace log4cxx;

static LoggerPtr logger_libpurple = log4cxx::Logger::getLogger("libpurple");

static LoggerPtr logger = log4cxx::Logger::getLogger("backend");

int main_socket;

static int writeInput;

using namespace Transport;

template <class T> T fromString(const std::string &str) {

	T i;

	std::istringstream os(str);

	os >> i;

	return i;

}

template <class T> std::string stringOf(T object) {

	std::ostringstream os;

	os << object;

	return (os.str());

}

static void transportDataReceived(gpointer data, gint source, PurpleInputCondition cond);

class SpectrumNetworkPlugin;

GKeyFile *keyfile;

SpectrumNetworkPlugin *np;

static std::string replaceAll(

  std::string result,

  const std::string& replaceWhat,

  const std::string& replaceWithWhat)

{

  while(1)

  {

	const int pos = result.find(replaceWhat);

	if (pos==-1) break;

	result.replace(pos,replaceWhat.size(),replaceWithWhat);

  }

  return result;

}

static std::string KEYFILE_STRING(const std::string &cat, const std::string &key, const std::string &def = "") {

	gchar *str = g_key_file_get_string(keyfile, cat.c_str(), key.c_str(), 0);

	if (!str) {

		return def;

	}

/**

 * libtransport -- C++ library for easy XMPP Transports development

 *

 * Copyright (C) 2011, 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/networkplugin.h"

#include "log4cxx/logger.h"

#include "log4cxx/basicconfigurator.h"

#include "transport/memoryusage.h"

#ifndef WIN32

#include <arpa/inet.h>

#else 

#include <winsock2.h>

#include <stdint.h>

#endif

using namespace log4cxx;

static LoggerPtr logger = Logger::getLogger("NetworkPlugin");

namespace Transport {

#define WRAP(MESSAGE, TYPE) 	pbnetwork::WrapperMessage wrap; \

	wrap.set_type(TYPE); \

	wrap.set_payload(MESSAGE); \

	wrap.SerializeToString(&MESSAGE);

template <class T> std::string stringOf(T object) {

	std::ostringstream os;

	os << object;

	return (os.str());

}

NetworkPlugin::NetworkPlugin() {

	m_pingReceived = false;

	double shared;

#ifndef WIN32

	process_mem_usage(shared, m_init_res);

#endif

}

NetworkPlugin::~NetworkPlugin() {

}

void NetworkPlugin::handleMessage(const std::string &user, const std::string &legacyName, const std::string &msg, const std::string &nickname, const std::string &xhtml) {

	pbnetwork::ConversationMessage m;

	m.set_username(user);

	m.set_buddyname(legacyName);

	m.set_message(msg);

	m.set_nickname(nickname);

	m.set_xhtml(xhtml);

	std::string message;

	m.SerializeToString(&message);

	WRAP(message, pbnetwork::WrapperMessage_Type_TYPE_CONV_MESSAGE);

	send(message);

}

void NetworkPlugin::handleAttention(const std::string &user, const std::string &buddyName, const std::string &msg) {

/**

 * libtransport -- C++ library for easy XMPP Transports development

 *

 * Copyright (C) 2011, 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/logging.h"

#include "transport/config.h"

#include <boost/foreach.hpp>

#include <iostream>

#include <iterator>

#include <algorithm>

#include "log4cxx/logger.h"

#include "log4cxx/consoleappender.h"

#include "log4cxx/patternlayout.h"

#include "log4cxx/propertyconfigurator.h"

#include "log4cxx/helpers/properties.h"

#include "log4cxx/helpers/fileinputstream.h"

#include "log4cxx/helpers/transcoder.h"

#include <boost/filesystem.hpp>

#include <boost/algorithm/string.hpp>

#ifndef WIN32

#include "sys/signal.h"

#include <pwd.h>

#include <grp.h>

#include <sys/resource.h>

#include "libgen.h"

#else

#include <windows.h>

#endif

using namespace boost::filesystem;

using namespace log4cxx;

namespace Transport {

namespace Logging {

static LoggerPtr root;

static void initLogging(Config *config, std::string key) {

	if (CONFIG_STRING(config, key).empty()) {

		root = log4cxx::Logger::getRootLogger();

#ifdef WIN32

		root->addAppender(new ConsoleAppender(new PatternLayout(L"%d %-5p %c: %m%n")));

#else

		root->addAppender(new ConsoleAppender(new PatternLayout("%d %-5p %c: %m%n")));

#endif

	}

	else {

		log4cxx::helpers::Properties p;

		log4cxx::helpers::FileInputStream *istream = new log4cxx::helpers::FileInputStream(CONFIG_STRING(config, key));

		p.load(istream);

		LogString pid, jid;

		log4cxx::helpers::Transcoder::decode(boost::lexical_cast<std::string>(getpid()), pid);

		log4cxx::helpers::Transcoder::decode(CONFIG_STRING(config, "service.jid"), jid);

#ifdef WIN32

		p.setProperty(L"pid", pid);

		p.setProperty(L"jid", jid);

#else

		p.setProperty("pid", pid);

		p.setProperty("jid", jid);

#endif

		std::string dir;

		BOOST_FOREACH(const log4cxx::LogString &prop, p.propertyNames()) {

			if (boost::ends_with(prop, ".File")) {

				log4cxx::helpers::Transcoder::encode(p.get(prop), dir);

				boost::replace_all(dir, "${jid}", jid);

				break;

			}

		}

		if (!dir.empty()) {

			// create directories

			try {