mirror of
https://github.com/EGroupware/egroupware.git
synced 2024-10-06 10:02:21 +02:00
formatting, globals
This commit is contained in:
Miles Lott
parent
2f0bed436e
commit
81833f8843
@ -27,363 +27,362 @@
|
||||
|
||||
/* $Id$ */
|
||||
|
||||
class send
|
||||
{
|
||||
var $err = array("code","msg","desc");
|
||||
var $to_res = array();
|
||||
class send
|
||||
{
|
||||
var $err = array('code','msg','desc');
|
||||
var $to_res = array();
|
||||
|
||||
function send()
|
||||
{
|
||||
$this->err["code"] = " ";
|
||||
$this->err["msg"] = " ";
|
||||
$this->err["desc"] = " ";
|
||||
}
|
||||
|
||||
function msg($service, $to, $subject, $body, $msgtype='', $cc='', $bcc='', $from='', $sender='')
|
||||
{
|
||||
global $phpgw_info, $phpgw, $attach_sig;
|
||||
if ($from == '')
|
||||
function send()
|
||||
{
|
||||
$from = $phpgw_info['user']['fullname'].' <'.$phpgw_info['user']['preferences']['email']['address'].'>';
|
||||
}
|
||||
if ($sender == '')
|
||||
{
|
||||
$sender = $phpgw_info['user']['fullname'].' <'.$phpgw_info['user']['preferences']['email']['address'].'>';
|
||||
$this->err['code'] = ' ';
|
||||
$this->err['msg'] = ' ';
|
||||
$this->err['desc'] = ' ';
|
||||
}
|
||||
|
||||
if ($service == "email")
|
||||
function msg($service, $to, $subject, $body, $msgtype='', $cc='', $bcc='', $from='', $sender='')
|
||||
{
|
||||
$now = getdate();
|
||||
$header = 'Date: '.gmdate('D, d M Y H:i:s').' +0000'."\n";
|
||||
$header .= 'From: '.$from."\n";
|
||||
if($from != $sender)
|
||||
if ($from == '')
|
||||
{
|
||||
$header .= 'Sender: '.$sender."\n";
|
||||
$from = $GLOBALS['phpgw_info']['user']['fullname'].' <'.$GLOBALS['phpgw_info']['user']['preferences']['email']['address'].'>';
|
||||
}
|
||||
$header .= 'Reply-To: '.$phpgw_info['user']['preferences']['email']['address']."\n";
|
||||
$header .= 'To: '.$to."\n";
|
||||
if (!empty($cc))
|
||||
if ($sender == '')
|
||||
{
|
||||
$header .= 'Cc: '.$cc."\n";
|
||||
$sender = $GLOBALS['phpgw_info']['user']['fullname'].' <'.$GLOBALS['phpgw_info']['user']['preferences']['email']['address'].'>';
|
||||
}
|
||||
if (!empty($bcc))
|
||||
{
|
||||
$header .= 'Bcc: '.$bcc."\n";
|
||||
}
|
||||
if (!empty($msgtype))
|
||||
{
|
||||
$header .= 'X-phpGW-Type: '.$msgtype."\n";
|
||||
}
|
||||
$header .= 'X-Mailer: phpGroupWare (http://www.phpgroupware.org)'."\n";
|
||||
|
||||
/* // moved to email/send_message.php
|
||||
if ($phpgw_info['user']['preferences']['email']['email_sig'] && $attach_sig)
|
||||
if ($service == "email")
|
||||
{
|
||||
//$body .= "\n-----\n".$phpgw_info['user']['preferences']['email']['email_sig'];
|
||||
$get_sig = $this->sig_html_to_text($phpgw_info['user']['preferences']['email']['email_sig']);
|
||||
$body .= "\n-----\n" .$get_sig;
|
||||
$now = getdate();
|
||||
$header = 'Date: '.gmdate('D, d M Y H:i:s').' +0000'."\n";
|
||||
$header .= 'From: '.$from."\n";
|
||||
if($from != $sender)
|
||||
{
|
||||
$header .= 'Sender: '.$sender."\n";
|
||||
}
|
||||
$header .= 'Reply-To: '.$GLOBALS['phpgw_info']['user']['preferences']['email']['address']."\n";
|
||||
$header .= 'To: '.$to."\n";
|
||||
if (!empty($cc))
|
||||
{
|
||||
$header .= 'Cc: '.$cc."\n";
|
||||
}
|
||||
if (!empty($bcc))
|
||||
{
|
||||
$header .= 'Bcc: '.$bcc."\n";
|
||||
}
|
||||
if (!empty($msgtype))
|
||||
{
|
||||
$header .= 'X-phpGW-Type: '.$msgtype."\n";
|
||||
}
|
||||
$header .= 'X-Mailer: phpGroupWare (http://www.phpgroupware.org)'."\n";
|
||||
|
||||
/* // moved to email/send_message.php
|
||||
if ($GLOBALS['phpgw_info']['user']['preferences']['email']['email_sig'] && $attach_sig)
|
||||
{
|
||||
//$body .= "\n-----\n".$GLOBALS['phpgw_info']['user']['preferences']['email']['email_sig'];
|
||||
$get_sig = $this->sig_html_to_text($GLOBALS['phpgw_info']['user']['preferences']['email']['email_sig']);
|
||||
$body .= "\n-----\n" .$get_sig;
|
||||
}
|
||||
*/
|
||||
|
||||
if (ereg('Message-Boundary', $body))
|
||||
{
|
||||
$header .= 'Subject: ' . stripslashes($subject) . "\n"
|
||||
. 'MIME-Version: 1.0'."\n"
|
||||
. 'Content-Type: multipart/mixed;'."\n"
|
||||
. ' boundary="Message-Boundary"'."\n\n"
|
||||
. '--Message-Boundary'."\n"
|
||||
. 'Content-type: text/plain; charset=US-ASCII'."\n";
|
||||
// if (!empty($msgtype))
|
||||
// {
|
||||
// $header .= "Content-type: text/plain; phpgw-type=".$msgtype."\n";
|
||||
// }
|
||||
|
||||
$header .= 'Content-Disposition: inline'."\n"
|
||||
. 'Content-transfer-encoding: 7BIT'."\n\n"
|
||||
. $body;
|
||||
$body = "";
|
||||
}
|
||||
else
|
||||
{
|
||||
$header .= 'Subject: '.stripslashes($subject)."\n"
|
||||
. 'MIME-version: 1.0'."\n"
|
||||
. 'Content-type: text/plain; charset="'.lang('charset').'"'."\n";
|
||||
if (!empty($msgtype))
|
||||
{
|
||||
$header .= 'Content-type: text/plain; phpgw-type='.$msgtype."\n";
|
||||
}
|
||||
$header .= 'Content-Disposition: inline'."\n"
|
||||
. 'Content-description: Mail message body'."\n";
|
||||
}
|
||||
if ($GLOBALS['phpgw_info']['user']['preferences']['email']['mail_server_type'] == 'imap' && $GLOBALS['phpgw_info']['user']['apps']['email'] && is_object($GLOBALS['phpgw']->msg))
|
||||
{
|
||||
$stream = $GLOBALS['phpgw']->msg->login('Sent');
|
||||
$GLOBALS['phpgw']->msg->append($stream, 'Sent', $header, $body, "\\Seen");
|
||||
$GLOBALS['phpgw']->msg->close($stream);
|
||||
}
|
||||
if (strlen($cc)>1)
|
||||
{
|
||||
$to .= ','.$cc;
|
||||
}
|
||||
|
||||
if (strlen($bcc)>1)
|
||||
{
|
||||
$to .= ','.$bcc;
|
||||
}
|
||||
|
||||
$returnccode = $this->smail($to, '', $body, $header);
|
||||
|
||||
return $returnccode;
|
||||
}
|
||||
*/
|
||||
|
||||
if (ereg('Message-Boundary', $body))
|
||||
elseif ($type == 'nntp')
|
||||
{
|
||||
$header .= 'Subject: ' . stripslashes($subject) . "\n"
|
||||
. 'MIME-Version: 1.0'."\n"
|
||||
. 'Content-Type: multipart/mixed;'."\n"
|
||||
. ' boundary="Message-Boundary"'."\n\n"
|
||||
. '--Message-Boundary'."\n"
|
||||
. 'Content-type: text/plain; charset=US-ASCII'."\n";
|
||||
// if (!empty($msgtype)) {
|
||||
// $header .= "Content-type: text/plain; phpgw-type=".$msgtype."\n";
|
||||
// }
|
||||
// nothing is here?
|
||||
}
|
||||
}
|
||||
|
||||
$header .= 'Content-Disposition: inline'."\n"
|
||||
. 'Content-transfer-encoding: 7BIT'."\n\n"
|
||||
. $body;
|
||||
$body = "";
|
||||
// ==================================================[ some sub-functions ]===
|
||||
|
||||
function socket2msg($socket)
|
||||
{
|
||||
$followme = '-';
|
||||
$this->err['msg'] = '';
|
||||
do
|
||||
{
|
||||
$rmsg = fgets($socket,255);
|
||||
// echo "< $rmsg<BR>\n";
|
||||
$this->err['code'] = substr($rmsg,0,3);
|
||||
$followme = substr($rmsg,3,1);
|
||||
$this->err['msg'] = substr($rmsg,4);
|
||||
if (substr($this->err["code"],0,1) != 2 && substr($this->err["code"],0,1) != 3)
|
||||
{
|
||||
$rc = fclose($socket);
|
||||
return False;
|
||||
}
|
||||
if ($followme = ' ')
|
||||
{
|
||||
break;
|
||||
}
|
||||
}
|
||||
while ($followme = '-');
|
||||
return True;
|
||||
}
|
||||
|
||||
function msg2socket($socket,$message)
|
||||
{
|
||||
// send single line\n
|
||||
// echo "raw> $message<BR>\n";
|
||||
// echo "hex> ".bin2hex($message)."<BR>\n";
|
||||
$rc = fputs($socket,"$message");
|
||||
if (!$rc)
|
||||
{
|
||||
$this->err['code'] = '420';
|
||||
$this->err['msg'] = 'lost connection';
|
||||
$this->err['desc'] = 'Lost connection to smtp server.';
|
||||
$rc = fclose($socket);
|
||||
return False;
|
||||
}
|
||||
return True;
|
||||
}
|
||||
|
||||
function put2socket($socket,$message)
|
||||
{
|
||||
// check for multiple lines 1st
|
||||
$pos = strpos($message,"\n");
|
||||
if (!is_int($pos))
|
||||
{
|
||||
// no new line found
|
||||
$message .= "\r\n";
|
||||
$this->msg2socket($socket,$message);
|
||||
}
|
||||
else
|
||||
{
|
||||
$header .= 'Subject: '.stripslashes($subject)."\n"
|
||||
. 'MIME-version: 1.0'."\n"
|
||||
. 'Content-type: text/plain; charset="'.lang('charset').'"'."\n";
|
||||
if (!empty($msgtype))
|
||||
// multiple lines, we have to split it
|
||||
do
|
||||
{
|
||||
$header .= 'Content-type: text/plain; phpgw-type='.$msgtype."\n";
|
||||
$msglen = $pos + 1;
|
||||
$msg = substr($message,0,$msglen);
|
||||
$message = substr($message,$msglen);
|
||||
$pos = strpos($msg,"\r\n");
|
||||
if (!is_int($pos))
|
||||
{
|
||||
// line not terminated
|
||||
$msg = chop($msg)."\r\n";
|
||||
}
|
||||
$pos = strpos($msg,'.'); // escape leading periods
|
||||
if (is_int($pos) && !$pos)
|
||||
{
|
||||
$msg = '.' . $msg;
|
||||
}
|
||||
if (!$this->msg2socket($socket,$msg))
|
||||
{
|
||||
return False;
|
||||
}
|
||||
$pos = strpos($message,"\n");
|
||||
}
|
||||
$header .= 'Content-Disposition: inline'."\n"
|
||||
. 'Content-description: Mail message body'."\n";
|
||||
while (strlen($message)>0);
|
||||
}
|
||||
if ($phpgw_info['user']['preferences']['email']['mail_server_type'] == 'imap' && $phpgw_info['user']['apps']['email'] && is_object($phpgw->msg))
|
||||
{
|
||||
$stream = $phpgw->msg->login('Sent');
|
||||
$phpgw->msg->append($stream, 'Sent', $header, $body, "\\Seen");
|
||||
$phpgw->msg->close($stream);
|
||||
}
|
||||
if (strlen($cc)>1)
|
||||
{
|
||||
$to .= ','.$cc;
|
||||
}
|
||||
|
||||
if (strlen($bcc)>1)
|
||||
{
|
||||
$to .= ','.$bcc;
|
||||
}
|
||||
|
||||
$returnccode = $this->smail($to, '', $body, $header);
|
||||
|
||||
return $returnccode;
|
||||
return True;
|
||||
}
|
||||
elseif ($type == 'nntp')
|
||||
{
|
||||
// nothing is here?
|
||||
}
|
||||
}
|
||||
|
||||
// ==================================================[ some sub-functions ]===
|
||||
|
||||
function socket2msg($socket)
|
||||
{
|
||||
$followme = "-";
|
||||
$this->err["msg"] = "";
|
||||
do
|
||||
{
|
||||
$rmsg = fgets($socket,255);
|
||||
// echo "< $rmsg<BR>\n";
|
||||
$this->err["code"] = substr($rmsg,0,3);
|
||||
$followme = substr($rmsg,3,1);
|
||||
$this->err["msg"] = substr($rmsg,4);
|
||||
if (substr($this->err["code"],0,1) != 2 && substr($this->err["code"],0,1) != 3)
|
||||
function check_header($subject,$header)
|
||||
{
|
||||
$rc = fclose($socket);
|
||||
return false;
|
||||
}
|
||||
if ($followme = " ")
|
||||
{
|
||||
break;
|
||||
}
|
||||
}
|
||||
while ($followme = "-");
|
||||
return true;
|
||||
}
|
||||
|
||||
function msg2socket($socket,$message)
|
||||
{
|
||||
// send single line\n
|
||||
// echo "raw> $message<BR>\n";
|
||||
// echo "hex> ".bin2hex($message)."<BR>\n";
|
||||
$rc = fputs($socket,"$message");
|
||||
if (!$rc)
|
||||
{
|
||||
$this->err["code"] = "420";
|
||||
$this->err["msg"] = "lost connection";
|
||||
$this->err["desc"] = "Lost connection to smtp server.";
|
||||
$rc = fclose($socket);
|
||||
return false;
|
||||
}
|
||||
return true;
|
||||
}
|
||||
|
||||
function put2socket($socket,$message)
|
||||
{
|
||||
// check for multiple lines 1st
|
||||
$pos = strpos($message,"\n");
|
||||
if (!is_int($pos))
|
||||
{
|
||||
// no new line found
|
||||
$message .= "\r\n";
|
||||
$this->msg2socket($socket,$message);
|
||||
}
|
||||
else
|
||||
{
|
||||
// multiple lines, we have to split it
|
||||
do
|
||||
{
|
||||
$msglen = $pos + 1;
|
||||
$msg = substr($message,0,$msglen);
|
||||
$message = substr($message,$msglen);
|
||||
$pos = strpos($msg,"\r\n");
|
||||
if (!is_int($pos))
|
||||
// check if header contains subject and is correctly terminated
|
||||
$header = chop($header);
|
||||
$header .= "\n";
|
||||
if (is_string($subject) && !$subject)
|
||||
{
|
||||
// line not terminated
|
||||
$msg = chop($msg)."\r\n";
|
||||
// no subject specified
|
||||
return $header;
|
||||
}
|
||||
$pos = strpos($msg,"."); // escape leading periods
|
||||
$theader = strtolower($header);
|
||||
$pos = strpos($theader,"\nsubject:");
|
||||
if (is_int($pos))
|
||||
{
|
||||
// found after a new line
|
||||
return $header;
|
||||
}
|
||||
$pos = strpos($theader,'subject:');
|
||||
if (is_int($pos) && !$pos)
|
||||
{
|
||||
$msg = "." . $msg;
|
||||
// found at start
|
||||
return $header;
|
||||
}
|
||||
if (!$this->msg2socket($socket,$msg))
|
||||
$pos = substr($subject,"\n");
|
||||
if (!is_int($pos))
|
||||
{
|
||||
return false;
|
||||
$subject .= "\n";
|
||||
}
|
||||
$pos = strpos($message,"\n");
|
||||
$subject = 'Subject: ' .$subject;
|
||||
$header .= $subject;
|
||||
return $header;
|
||||
}
|
||||
while (strlen($message)>0);
|
||||
}
|
||||
return true;
|
||||
}
|
||||
|
||||
function check_header($subject,$header)
|
||||
{
|
||||
// check if header contains subject and is correctly terminated
|
||||
$header = chop($header);
|
||||
$header .= "\n";
|
||||
if (is_string($subject) && !$subject)
|
||||
{
|
||||
// no subject specified
|
||||
return $header;
|
||||
}
|
||||
$theader = strtolower($header);
|
||||
$pos = strpos($theader,"\nsubject:");
|
||||
if (is_int($pos))
|
||||
{
|
||||
// found after a new line
|
||||
return $header;
|
||||
}
|
||||
$pos = strpos($theader,"subject:");
|
||||
if (is_int($pos) && !$pos)
|
||||
{
|
||||
// found at start
|
||||
return $header;
|
||||
}
|
||||
$pos = substr($subject,"\n");
|
||||
if (!is_int($pos)) $subject .= "\n";
|
||||
$subject = "Subject: " .$subject;
|
||||
$header .= $subject;
|
||||
return $header;
|
||||
}
|
||||
|
||||
function sig_html_to_text($sig)
|
||||
{
|
||||
// convert HTML chars for ' and " in the email sig to normal text
|
||||
$sig_clean = $sig;
|
||||
$sig_clean = ereg_replace('"', '"', $sig_clean);
|
||||
$sig_clean = ereg_replace(''', '\'', $sig_clean);
|
||||
return $sig_clean;
|
||||
}
|
||||
function sig_html_to_text($sig)
|
||||
{
|
||||
// convert HTML chars for ' and " in the email sig to normal text
|
||||
$sig_clean = $sig;
|
||||
$sig_clean = ereg_replace('"', '"', $sig_clean);
|
||||
$sig_clean = ereg_replace(''', '\'', $sig_clean);
|
||||
return $sig_clean;
|
||||
}
|
||||
|
||||
// ==============================================[ main function: smail() ]===
|
||||
|
||||
function smail($to,$subject,$message,$header)
|
||||
{
|
||||
global $phpgw_info;
|
||||
|
||||
$fromuser = $phpgw_info["user"]["preferences"]["email"]["address"];
|
||||
$mymachine = $phpgw_info["server"]["hostname"];
|
||||
// error code and message of failed connection
|
||||
$errcode = "";
|
||||
$errmsg = "";
|
||||
// timeout in secs
|
||||
$timeout = 5;
|
||||
|
||||
// now we try to open the socket and check, if any smtp server responds
|
||||
$socket = fsockopen($phpgw_info["server"]["smtp_server"],$phpgw_info["server"]["smtp_port"],$errcode,$errmsg,$timeout);
|
||||
if (!$socket)
|
||||
{
|
||||
$this->err["code"] = "420";
|
||||
$this->err["msg"] = "$errcode:$errmsg";
|
||||
$this->err["desc"] = "Connection to ".$phpgw_info["server"]["smtp_server"].":".$phpgw_info["server"]["smtp_port"]." failed - could not open socket.";
|
||||
return false;
|
||||
}
|
||||
else
|
||||
{
|
||||
$rrc = $this->socket2msg($socket);
|
||||
}
|
||||
|
||||
// now we can send our message. 1st we identify ourselves and the sender
|
||||
$cmds = array (
|
||||
"\$src = \$this->msg2socket(\$socket,\"HELO \$mymachine\r\n\");",
|
||||
"\$rrc = \$this->socket2msg(\$socket);",
|
||||
"\$src = \$this->msg2socket(\$socket,\"MAIL FROM:<\$fromuser>\r\n\");",
|
||||
"\$rrc = \$this->socket2msg(\$socket);"
|
||||
);
|
||||
for ($src=true,$rrc=true,$i=0; $i<count($cmds);$i++)
|
||||
{
|
||||
eval ($cmds[$i]);
|
||||
if (!$src || !$rrc)
|
||||
function smail($to,$subject,$message,$header)
|
||||
{
|
||||
return false;
|
||||
}
|
||||
}
|
||||
$fromuser = $GLOBALS['phpgw_info']['user']['preferences']['email']['address'];
|
||||
$mymachine = $GLOBALS['phpgw_info']['server']['hostname'];
|
||||
// error code and message of failed connection
|
||||
$errcode = '';
|
||||
$errmsg = '';
|
||||
// timeout in secs
|
||||
$timeout = 5;
|
||||
|
||||
// now we've got to evaluate the $to's
|
||||
$toaddr = explode(",",$to);
|
||||
$numaddr = count($toaddr);
|
||||
for ($i=0; $i<$numaddr; $i++)
|
||||
{
|
||||
$src = $this->msg2socket($socket,'RCPT TO:<'.$toaddr[$i].">\r\n");
|
||||
$rrc = $this->socket2msg($socket);
|
||||
// for lateron validation
|
||||
$this->to_res[$i][addr] = $toaddr[$i];
|
||||
$this->to_res[$i][code] = $this->err["code"];
|
||||
$this->to_res[$i][msg] = $this->err["msg"];
|
||||
$this->to_res[$i][desc] = $this->err["desc"];
|
||||
}
|
||||
// now we try to open the socket and check, if any smtp server responds
|
||||
$socket = fsockopen($GLOBALS['phpgw_info']['server']['smtp_server'],$GLOBALS['phpgw_info']['server']['smtp_port'],$errcode,$errmsg,$timeout);
|
||||
if (!$socket)
|
||||
{
|
||||
$this->err['code'] = '420';
|
||||
$this->err['msg'] = $errcode . ':' . $errmsg;
|
||||
$this->err['desc'] = 'Connection to '.$GLOBALS['phpgw_info']['server']['smtp_server'].':'.$GLOBALS['phpgw_info']['server']['smtp_port'].' failed - could not open socket.';
|
||||
return False;
|
||||
}
|
||||
else
|
||||
{
|
||||
$rrc = $this->socket2msg($socket);
|
||||
}
|
||||
|
||||
//now we have to make sure that at least one $to-address was accepted
|
||||
$stop = 1;
|
||||
for ($i=0;$i<count($this->to_res);$i++)
|
||||
{
|
||||
$rc = substr($this->to_res[$i][code],0,1);
|
||||
if ($rc == 2)
|
||||
{
|
||||
// at least to this address we can deliver
|
||||
$stop = 0;
|
||||
}
|
||||
}
|
||||
if ($stop)
|
||||
{
|
||||
// no address found we can deliver to
|
||||
return false;
|
||||
}
|
||||
// now we can send our message. 1st we identify ourselves and the sender
|
||||
$cmds = array (
|
||||
"\$src = \$this->msg2socket(\$socket,\"HELO \$mymachine\r\n\");",
|
||||
"\$rrc = \$this->socket2msg(\$socket);",
|
||||
"\$src = \$this->msg2socket(\$socket,\"MAIL FROM:<\$fromuser>\r\n\");",
|
||||
"\$rrc = \$this->socket2msg(\$socket);"
|
||||
);
|
||||
for ($src=True,$rrc=True,$i=0; $i<count($cmds);$i++)
|
||||
{
|
||||
eval ($cmds[$i]);
|
||||
if (!$src || !$rrc)
|
||||
{
|
||||
return False;
|
||||
}
|
||||
}
|
||||
|
||||
// now we can go to deliver the message!
|
||||
if (!$this->msg2socket($socket,"DATA\r\n"))
|
||||
{
|
||||
return false;
|
||||
}
|
||||
if (!$this->socket2msg($socket))
|
||||
{
|
||||
return false;
|
||||
}
|
||||
if ($header != "")
|
||||
{
|
||||
$header = $this->check_header($subject,$header);
|
||||
if (!$this->put2socket($socket,$header))
|
||||
{
|
||||
return false;
|
||||
}
|
||||
if (!$this->put2socket($socket,"\r\n"))
|
||||
{
|
||||
return false;
|
||||
}
|
||||
}
|
||||
$message = chop($message);
|
||||
$message .= "\n";
|
||||
if (!$this->put2socket($socket,$message))
|
||||
{
|
||||
return false;
|
||||
}
|
||||
if (!$this->msg2socket($socket,".\r\n"))
|
||||
{
|
||||
return false;
|
||||
}
|
||||
if (!$this->socket2msg($socket))
|
||||
{
|
||||
return false;
|
||||
}
|
||||
if (!$this->msg2socket($socket,"QUIT\r\n"))
|
||||
{
|
||||
return false;
|
||||
}
|
||||
do
|
||||
{
|
||||
$closing = $this->socket2msg($socket);
|
||||
}
|
||||
while ($closing);
|
||||
return true;
|
||||
}
|
||||
// now we've got to evaluate the $to's
|
||||
$toaddr = explode(",",$to);
|
||||
$numaddr = count($toaddr);
|
||||
for ($i=0; $i<$numaddr; $i++)
|
||||
{
|
||||
$src = $this->msg2socket($socket,'RCPT TO:<'.$toaddr[$i].">\r\n");
|
||||
$rrc = $this->socket2msg($socket);
|
||||
// for lateron validation
|
||||
$this->to_res[$i]['addr'] = $toaddr[$i];
|
||||
$this->to_res[$i]['code'] = $this->err['code'];
|
||||
$this->to_res[$i]['msg'] = $this->err['msg'];
|
||||
$this->to_res[$i]['desc'] = $this->err['desc'];
|
||||
}
|
||||
|
||||
// end of class
|
||||
}
|
||||
//now we have to make sure that at least one $to-address was accepted
|
||||
$stop = 1;
|
||||
for ($i=0;$i<count($this->to_res);$i++)
|
||||
{
|
||||
$rc = substr($this->to_res[$i]['code'],0,1);
|
||||
if ($rc == 2)
|
||||
{
|
||||
// at least to this address we can deliver
|
||||
$stop = 0;
|
||||
}
|
||||
}
|
||||
if ($stop)
|
||||
{
|
||||
// no address found we can deliver to
|
||||
return False;
|
||||
}
|
||||
|
||||
// now we can go to deliver the message!
|
||||
if (!$this->msg2socket($socket,"DATA\r\n"))
|
||||
{
|
||||
return False;
|
||||
}
|
||||
if (!$this->socket2msg($socket))
|
||||
{
|
||||
return False;
|
||||
}
|
||||
if ($header != "")
|
||||
{
|
||||
$header = $this->check_header($subject,$header);
|
||||
if (!$this->put2socket($socket,$header))
|
||||
{
|
||||
return False;
|
||||
}
|
||||
if (!$this->put2socket($socket,"\r\n"))
|
||||
{
|
||||
return False;
|
||||
}
|
||||
}
|
||||
$message = chop($message);
|
||||
$message .= "\n";
|
||||
if (!$this->put2socket($socket,$message))
|
||||
{
|
||||
return False;
|
||||
}
|
||||
if (!$this->msg2socket($socket,".\r\n"))
|
||||
{
|
||||
return False;
|
||||
}
|
||||
if (!$this->socket2msg($socket))
|
||||
{
|
||||
return False;
|
||||
}
|
||||
if (!$this->msg2socket($socket,"QUIT\r\n"))
|
||||
{
|
||||
return False;
|
||||
}
|
||||
do
|
||||
{
|
||||
$closing = $this->socket2msg($socket);
|
||||
}
|
||||
while ($closing);
|
||||
return True;
|
||||
}
|
||||
} /* end of class */
|
||||
|
||||
Loading…
Reference in New Issue
Block a user