bot_bucket.php

<?PHP
//set_time_limit(0);
ini_set('max_execution_time', 0); // 0 = Unlimited
ini_set('memory_limit','-1');

require_once ( __DIR__ . '/public_html/quickstatements.php' ) ;

function checkAndRunSingleBatch(){
	if ( isset($_GET['single_batch']) && isset($_GET['id']) ) {
		$qs = new QuickStatements ;
		$db = $qs->getDB();

		$sql = "SELECT * FROM batch WHERE id = " . $_GET['id'];
		$query = $db->query($sql);
		$result = $query->fetch_object();

		if (!$result) {
			echo('Error: Specified id from URL parameter does not exist in the database.<br>');
			die;
		}

		$sql = "SELECT count(*) AS cnt from batch WHERE status='RUN_SEQUENTIAL_BUCKET'" ;
		if(!$result2 = $db->query($sql)){
			echo $db->error;
			return $this->setErrorMessage ( 'There was an error running the query [' . $db->error . ']'."\n$sql" ) ;
		}
		$o = $result2->fetch_object() ;
		if ( $o->cnt > 0 ) {
			echo "There is already a sequential batch running.";
			die;
		}

		if ( $result->status == 'INIT' || $result->status == 'STOP') {
			// sets the batch status to RUN
			if ( !$qs->startBatch($result->id) ) {
				echo 'died';
				print "{$result->id}: " . $qs->last_error_message."\n" ;
				return 0;
			}
		} else if ($result->status == 'DONE') {
			echo('Error: The specified batch id "'. $_GET['id'] .'" has already been processed (has a status of DONE).');
			die;
		}

		$id = $_GET['id'];
		$sql = "SELECT row_num FROM command_$id WHERE status='INIT' ORDER BY id LIMIT 1";
		$query = $db->query($sql);
		$row_num = intval($query->fetch_object()->row_num);
		
		while(1) {
			$qs2 = new QuickStatements;

			if ( !$qs2->runNextCommandInBatchSequentialBucket($result->id, $row_num) )
				return 0;

			$row_num++;

			$status = $qs2->getBatchStatus( [$result->id] );
			if ( $status[$result->id]['batch']->status != 'RUN_SEQUENTIAL' )
				return 1;
		}

		return 1;
	} else {
		echo '<br>';
		if (!isset($_GET['single_batch']))
			echo 'Error: "single_batch" URL parameter is not set.<br>';
		if (!isset($_GET['id']))
			echo 'Error: "id" URL parameter is not set.<br>';
		die;
	}
}

if ( checkAndRunSingleBatch() ) {
	echo('Finished a batch. Stopping the bot.');
}

?>