mirror of
https://bitbucket.org/jsuto/piler.git
synced 2024-12-25 21:50:12 +01:00
e4f64b41bc
Signed-off-by: Janos SUTO <sj@acts.hu>
118 lines
3.0 KiB
PHP
118 lines
3.0 KiB
PHP
<?php
|
|
|
|
class ModelMailMail extends Model {
|
|
|
|
|
|
public function send_smtp_email($smtphost, $smtpport, $yourdomain, $from, $to = array(), $msg){
|
|
$ok = 0;
|
|
$queue_id = '';
|
|
|
|
if($to == "" || strlen($msg) < 30){ return $ok; }
|
|
|
|
if(REWRITE_MESSAGE_ID == 1) {
|
|
$msg = preg_replace("/Message-ID:([^\n]+)\n/i", "Message-ID: <" . generate_random_string(25) . '@' . SITE_NAME . ">\n", $msg);
|
|
}
|
|
|
|
$msg = preg_replace("/^\..*$/m", ".$0", $msg);
|
|
|
|
$r = fsockopen($smtphost, $smtpport);
|
|
if(!$r){ return -1; }
|
|
|
|
$l = fgets($r, 4096);
|
|
|
|
fputs($r, "HELO $yourdomain\r\n");
|
|
$l = fgets($r, 4096);
|
|
|
|
fputs($r, "MAIL FROM: <$from>\r\n");
|
|
$l = fgets($r, 4096);
|
|
|
|
while(list($k, $v) = each($to)) {
|
|
fputs($r, "RCPT TO: <$v>\r\n");
|
|
$l = fgets($r, 4096);
|
|
}
|
|
|
|
fputs($r, "DATA\r\n");
|
|
$l = fgets($r, 4096);
|
|
if(!preg_match("/^354/", $l)){ $l = fgets($r, 4096); }
|
|
|
|
fputs($r, $msg);
|
|
|
|
fputs($r, "\r\n.\r\n");
|
|
|
|
$l = fgets($r, 4096);
|
|
|
|
if(preg_match("/^250/", $l)){ $queue_id = $l; $ok = 1; }
|
|
|
|
fputs($r, "QUIT\r\n");
|
|
$l = fgets($r, 4096);
|
|
|
|
fclose($r);
|
|
|
|
syslog(LOG_INFO, "sending mail from=$from, rcpt=" . implode(" ", $to) . ", status=$ok, queue_id=$queue_id");
|
|
|
|
return $ok;
|
|
}
|
|
|
|
|
|
public function message_as_rfc822_attachment($piler_id = '', $msg = '', $rcpt = '') {
|
|
if($piler_id == '' || $msg == '' || $rcpt == '') { return ''; }
|
|
|
|
$boundary = generate_random_string(24);
|
|
|
|
$hdr = substr($msg, 0, 8192);
|
|
$subject = "";
|
|
|
|
$s = strstr($hdr, "Subject:");
|
|
if($s) {
|
|
$l1 = strlen($s);
|
|
$l2 = strlen(strstr($s, "\n"));
|
|
if($l1 > $l2 + 10) {
|
|
$subject = substr($s, 0, $l1 - $l2) . EOL;
|
|
}
|
|
}
|
|
|
|
|
|
$s = "";
|
|
$s .= "Received: by piler" . EOL . PILER_HEADER_FIELD . $piler_id . EOL;
|
|
$s .= "Date: " . date("r") . EOL;
|
|
$s .= "Message-ID: <" . generate_random_string(25) . '@' . SITE_NAME . ">" . EOL;
|
|
$s .= "From: " . SMTP_FROMADDR . EOL;
|
|
$s .= "To: " . $rcpt . EOL;
|
|
|
|
if($subject) { $s .= $subject; }
|
|
else { $s .= "Subject: Retrieved message from the email archive" . EOL; }
|
|
|
|
$s .= "MIME-Version: 1.0" . EOL;
|
|
$s .= "Content-Type: multipart/mixed; boundary=\"$boundary\"" . EOL . EOL . EOL;
|
|
$s .= "--$boundary" . EOL;
|
|
$s .= "Content-Type: message/rfc822; name=\"" . $piler_id . "\"" . EOL;
|
|
$s .= "Content-Disposition: attachment; filename=\"" . $piler_id . "\"" . EOL . EOL;
|
|
$s .= $msg . EOL;
|
|
$s .= "--$boundary" . EOL;
|
|
|
|
return $s;
|
|
}
|
|
|
|
|
|
public function connect_imap() {
|
|
$this->imap = new Zend_Mail_Protocol_Imap(IMAP_HOST, IMAP_PORT, IMAP_SSL);
|
|
|
|
$session = Registry::get('session');
|
|
|
|
if($this->imap) {
|
|
if($this->imap->login($session->get("username"), $session->get("password"))) { return 1; }
|
|
}
|
|
|
|
return 0;
|
|
}
|
|
|
|
|
|
public function disconnect_imap() {
|
|
$this->imap->logout;
|
|
}
|
|
|
|
|
|
}
|
|
|
|
?>
|