<?php

require_once('include/admin.inc.php');

//	First, the quick hack way. May become neccessary to parallelize later.

$tweets = $dbConnection->fetchAll('SELECT username, password, text, status, tp.id AS id FROM twitter_post tp JOIN twitter_user tu ON tp.user = tu.id ' .
	'WHERE tp.status = \'scheduled\' AND time >= NOW() AND time < TIMESTAMPADD(?, NOW())', array(RUN_INTERVAL));

//	Check if we actually have any tweets. If not, bail.
if(count($tweets) === 0)
{
	exit(0);
}

//	There are tweets to post. Let's get to work.

foreach($tweets as $t)
{
	//	Lock the tweet
	$dbConnection->executeUpdate('UPDATE twitter_post SET status = \'locked\' WHERE id = ? AND status = \'scheduled\'', array($t->id));

	if(twitterpost($t->text, $t->username, $t->password))
	{
		//	It worked!
		adminlog("Scheduled tweet posted for user ".$t->username, MTS_TWITTER, MTA_ADD);
		$t->status = 'success';
	}
	else
	{
		//	Well, shit. Something went wrong. Log it.
		adminlog("Error $ret_code posting scheduled tweet ".$t->id . ' with return value ' . $ret, MTS_TWITTER, MTA_ADD);
		$t->status = 'error';
	}

	//	Unlock tweet, update db.
	$dbConnection->executeUpdate('UPDATE twitter_post SET status = ? WHERE status = \'locked\' AND id = ?', array($t->status, $t->id));
}

?>