}

TwitterPlugin::TwitterPlugin(Config *config, Swift::SimpleEventLoop *loop, StorageBackend *storagebackend, const std::string &host, int port) : NetworkPlugin()

{

	this->config = config;

	this->storagebackend = storagebackend;

	this->m_firstPing = true;

	if (CONFIG_HAS_KEY(config, "twitter.consumer_key") == false) {

		consumerKey = "5mFePMiJi0KpeURONkelg";

	}

	else {

		consumerKey = CONFIG_STRING(config, "twitter.consumer_key");

	}

	if (CONFIG_HAS_KEY(config, "twitter.consumer_secret") == false) {

		consumerSecret = "YFZCDJwRhbkccXEnaYr1waCQejTJcOY8F7l5Wim3FA";

	}

	else {

		consumerSecret = CONFIG_STRING(config, "twitter.consumer_secret");

	}

	if (consumerSecret.empty() || consumerKey.empty()) {

		LOG4CXX_ERROR(logger, "Consumer key and Consumer secret can't be empty.");

		exit(1);

	}

	adminLegacyName = "twitter.com";

	adminChatRoom = "#twitter";

	adminNickName = "twitter";

	adminAlias = "twitter";

	OAUTH_KEY = "twitter_oauth_token";

	OAUTH_SECRET = "twitter_oauth_secret";

	MODE = "mode";

	m_factories = new Swift::BoostNetworkFactories(loop);

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

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

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

	tp = new ThreadPool(loop_, 10);

	LOG4CXX_INFO(logger, "Fetch timeout is set to " << CONFIG_INT_DEFAULTED(config, "twitter.fetch_timeout", 90000));

	tweet_timer = m_factories->getTimerFactory()->createTimer(CONFIG_INT_DEFAULTED(config, "twitter.fetch_timeout", 90000));

	message_timer = m_factories->getTimerFactory()->createTimer(CONFIG_INT_DEFAULTED(config, "twitter.fetch_timeout", 90000));

	tweet_timer->onTick.connect(boost::bind(&TwitterPlugin::pollForTweets, this));

	tweet_timer->start();

	message_timer->start();

#if HAVE_SWIFTEN_3

		cryptoProvider = SWIFTEN_SHRPTR_NAMESPACE::shared_ptr<Swift::CryptoProvider>(Swift::PlatformCryptoProvider::create());

#endif

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

}

TwitterPlugin::~TwitterPlugin()

{

	delete storagebackend;

	std::set<std::string>::iterator it;

	for(it = onlineUsers.begin() ; it != onlineUsers.end() ; it++) delete userdb[*it].sessions;

	delete tp;

}

// Send data to NetworkPlugin server

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

{

	m_conn->write(Swift::createSafeByteArray(string));

}

// Receive date from the NetworkPlugin server and invoke the appropirate payload handler (implement in the NetworkPlugin class)

void TwitterPlugin::_handleDataRead(SWIFTEN_SHRPTR_NAMESPACE::shared_ptr<Swift::SafeByteArray> data)

{

	if (m_firstPing) {

		m_firstPing = false;

		// Users can join the network without registering if we allow

		// one user to connect multiple IRC networks.

		NetworkPlugin::PluginConfig cfg;

		cfg.setNeedPassword(false);

		sendConfig(cfg);

	}

	std::string d(data->begin(), data->end());

	handleDataRead(d);

}

// User trying to login into his twitter account

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

{

	if(userdb.count(user) && (userdb[user].connectionState == NEW ||

										userdb[user].connectionState == CONNECTED ||

										userdb[user].connectionState == WAITING_FOR_PIN)) {