| version 1.7, 2005/04/16 13:14:30 |
version 1.8, 2005/04/16 18:20:50 |
|
|
| <?php |
<?php |
| |
|
| // $Platon: mylist/backend/sender/sender.php,v 1.6 2005/04/12 20:34:01 nepto Exp $ |
// $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 dirname(__FILE__).'/../../mylist.config.php'; |
| require_once "Mail.php"; |
require_once "Mail.php"; |
| Line 8 require_once "Mail.php"; |
|
| Line 8 require_once "Mail.php"; |
|
| class CSender |
class CSender |
| { |
{ |
| |
|
| function send() /* {{{ */ |
function send() |
| { |
{ |
| global $dbh; |
global $dbh; |
| |
|
|
|
| die($res2->getMessage()); |
die($res2->getMessage()); |
| |
|
| $res2->fetchInto($row2); |
$res2->fetchInto($row2); |
| // my parser: problem with Received headers |
|
| $headers = Array(); |
$headers = Array(); |
| $lines = explode("\n", $row2["message_header"]); |
$lines = explode("\n", $row2["message_header"]); |
| foreach ($lines as $line) |
foreach ($lines as $line) |
| { |
{ |
| $pos = StrPos($line, ":"); |
$pos = StrPos($line, ":"); |
| $key = Trim(SubStr($line, 0,$pos)); |
$key = Trim(SubStr($line, 0,$pos)); |
| if (StrLen($key)) |
if (StrLen($key)) |
| $headers[$key] = Trim(SubStr($line, $pos+1)); |
if ($key == "Received") |
| //$headers[StrToLower($key)] = Trim(SubStr($line, $pos+1)); |
{ |
| |
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)); |
| |
|
| } |
} |
| |
|
| |
|
| // or use mimedecode parser, the same as in processing message (validator.php) |
|
| $emailParser = new Mail_mimeDecode($row2["message_header"]."\n\n", "\n"); |
|
| $params['include_bodies'] = false; |
|
| $params['decode_bodies'] = false; |
|
| $params['decode_headers'] = true; |
|
| $structure = $emailParser->decode($params); |
|
| // print_r($structure->headers); |
|
| } |
} |
| |
|
| |
|
| |
|
| $last_queue_message_id = $row["queue_message_id"]; |
$last_queue_message_id = $row["queue_message_id"]; |
| // $structure->headers["received"] = ""; |
|
| // print_r($structure->headers); |
|
| if (@$ret = $mf->send($row["recipient"], $headers, $row2["message_body"])) |
if (@$ret = $mf->send($row["recipient"], $headers, $row2["message_body"])) |
| // if (@$ret = $mf->send($row["recipient"], $structure->headers, $row2["message_body"])) |
|
| { |
{ |
| $sql = "UPDATE mylist_queue "; |
$sql = "UPDATE mylist_queue "; |
| $sql .= "SET dt_sent = '".Date("Y-m-d H:i:s")."' WHERE "; |
$sql .= "SET dt_sent = '".Date("Y-m-d H:i:s")."' WHERE "; |
|
|
| echo "posielam spravu s queue id '".$row["queue_message_id"]."' na adresu '".$row["recipient"]."'\n"; |
echo "posielam spravu s queue id '".$row["queue_message_id"]."' na adresu '".$row["recipient"]."'\n"; |
| } |
} |
| } |
} |
| } /* }}} */ |
} |
| |
|
| } |
} |
| |
|