#include <boost/filesystem.hpp>

#include "unistd.h"

#include "signal.h"

#include "sys/wait.h"

#include "sys/signal.h"

#include <fstream>

#include <streambuf>

Swift::SimpleEventLoop *loop_;

#include <boost/filesystem.hpp>

#include <boost/algorithm/string.hpp>

using namespace boost::filesystem;

using namespace boost::program_options;

using namespace Transport;

DEFINE_LOGGER(logger, "SMSNetworkPlugin");

#define INTERNAL_USER "/sms@backend@internal@user"

class SMSNetworkPlugin;

SMSNetworkPlugin * np = NULL;

class SMSNetworkPlugin : public NetworkPlugin {

	public:

		Swift::BoostNetworkFactories *m_factories;

		Swift::BoostIOServiceThread m_boostIOServiceThread;

		boost::shared_ptr<Swift::Connection> m_conn;

		Swift::Timer::ref m_timer;

		int m_internalUser;

			this->config = config;

			m_factories = new Swift::BoostNetworkFactories(loop);

			m_conn = m_factories->getConnectionFactory()->createConnection();

			m_conn->onDataRead.connect(boost::bind(&SMSNetworkPlugin::_handleDataRead, this, _1));

			m_conn->connect(Swift::HostAddressPort(Swift::HostAddress(host), port));

// 			m_conn->onConnectFinished.connect(boost::bind(&FrotzNetworkPlugin::_handleConnected, this, _1));

// 			m_conn->onDisconnected.connect(boost::bind(&FrotzNetworkPlugin::handleDisconnected, this));

			LOG4CXX_INFO(logger, "Starting the plugin.");

			m_timer = m_factories->getTimerFactory()->createTimer(5000);

			m_timer->onTick.connect(boost::bind(&SMSNetworkPlugin::handleSMSDir, this));

			m_timer->start();

			// We're reusing our database model here. Buddies of user with JID INTERNAL_USER are there

			// to match received GSM messages from number N with the XMPP users who sent message to number N.

			// BuddyName = GSM number

			// Alias = XMPP user JID to which the messages from this number is sent to.

			// TODO: This should be per Modem!!!

			UserInfo info;

			info.jid = INTERNAL_USER;

			info.password = "";

			storageBackend->setUser(info);

			storageBackend->getUser(INTERNAL_USER, info);

			m_internalUser = info.id;

	std::string error;

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

	if (cfg == NULL) {

		std::cerr << error;

		return 1;

	}

	Logging::initBackendLogging(cfg);

	StorageBackend *storageBackend = StorageBackend::createBackend(cfg, error);

	if (storageBackend == NULL) {

		if (!error.empty()) {

			std::cerr << error << "\n";

			return -2;

		}

	}

	else if (!storageBackend->connect()) {

		std::cerr << "Can't connect to database. Check the log to find out the reason.\n";

		return -1;

	}

	Swift::SimpleEventLoop eventLoop;

	loop_ = &eventLoop;

	loop_->run();

	return 0;

}