<?php

// $Platon: mylist/backend/sender/sender.php,v 1.7 2005/04/16 13:14:30 majo Exp $

require_once dirname(__FILE__).'/../../mylist.config.php';
require_once "Mail.php";

class CSender
{

	function send() 
	{
		global $dbh;
		
		// setting up Mail factory
		$params["sendmail_path"] = '/usr/lib/sendmail';
		$mf = Mail::factory("sendmail", $params);
		
		$sql  = "SELECT queue_message_id, recipient FROM mylist_queue ";
		$sql .= "WHERE dt_sent IS NULL ";
		$sql .= "ORDER BY queue_message_id";

		$res =& $dbh->query($sql);
		if (PEAR::isError($res))
			die($res->getMessage());

		$last_queue_message_id = "";

		while ($res->fetchInto($row))
		{

			if ($row["queue_message_id"] != $last_queue_message_id )			{
				
				$sql  = "SELECT message_header, message_body FROM mylist_queue_messages WHERE id = ".$row["queue_message_id"];
				$res2 =& $dbh->query($sql);
				if (PEAR::isError($res2))
					die($res2->getMessage());

				$res2->fetchInto($row2);
				$headers = Array();
				$lines = explode("\n", $row2["message_header"]);
				foreach ($lines as $line)
				{
				    $pos = StrPos($line, ":");
				    $key = Trim(SubStr($line, 0,$pos));
				    if (StrLen($key))
						if ($key == "Received")
						{
							if (StrLen($headers["Received"]))
								$headers["Received"] .= "\nReceived: ".Trim(SubStr($line, $pos+1));
							else
				     		   $headers[$key] = Trim(SubStr($line, $pos+1));
						}
						else
				    	   $headers[$key] = Trim(SubStr($line, $pos+1));
								
				}
			}
			
			$last_queue_message_id = $row["queue_message_id"];
			
			if (@$ret =	$mf->send($row["recipient"], $headers, $row2["message_body"]))
			{
				$sql  = "UPDATE mylist_queue ";
				$sql .= "SET dt_sent = '".Date("Y-m-d H:i:s")."'  WHERE ";
				$sql .= "queue_message_id = '";
				$sql .= $row["queue_message_id"];
				$sql .= "' AND ";
				$sql .= "recipient LIKE ";
				$sql .= "'".$row["recipient"]."'";
				$res3 =& $dbh->query($sql);
				if (PEAR::isError($res3))
					die($res3->getMessage());

				echo "posielam spravu s queue id '".$row["queue_message_id"]."' na adresu '".$row["recipient"]."'\n";
			}
		}
	} 

}

/* Modeline for ViM {{{
 * vim: set ts=4:
 * vim600: fdm=marker fdl=0 fdc=0:
 * }}} */

?>