<?php

class RemindSchedule extends Schedule {
	public function process($time) {
		$timestamp = $this->getTimestamp($time);
		$query = "select * from emailbot_reminders where
			reminderdate < '".addslashes($timestamp)."'
			and sent='0'
			";
		mysql_connect(DB_HOST,DB_USER,DB_PASS);
		mysql_select_DB(DB_NAME);
		$resource = mysql_query($query);
		$ids = array();
		while (($row = mysql_fetch_assoc($resource)) !== false) {
			$ids[] = $row['id'];
			$this->sendReminder($row);
		}
		$query = "update emailbot_reminders set
			sent='1'
			where id in ('".addslashes(implode("','",$ids))."')
			";
		mysql_query($query);
		mysql_close();
	}

	private function sendReminder($reminder) {
		$from = $reminder['fromaddress'];
		$message = $reminder['message'];

		$this->sendMessage($from,$message);
	}
}

?>