smtp : add SMTP support to send emails

git-svn-id: https://svn.fournier38.fr/svn/ProgSVN/trunk@2713 bf3deb0d-5f1a-0410-827f-c0cc1f45334c
2016-05-03 09:59:49 +00:00
parent 58fe500730
commit f40b919648
1 changed files with 140 additions and 0 deletions
--- a/smtp.php
+++ b/smtp.php
@@ -0,0 +1,140 @@
+<?php
+/** DomFramework
+    @package domframework
+    @author Dominique Fournier <dominique@fournier38.fr> */
+
+/** Allow to send mails by smtp */
+class smtp
+{
+  /** Debug mode */
+  public $debug = 0;
+  /** The authentication user allow to send SMTP mails */
+  public $user = null;
+  /** The authentication password allow to send SMTP mails */
+  public $password = null;
+  /** The SMTP server name or IP */
+  public $server = "127.0.0.1";
+  /** The SMTP port */
+  public $port = 25;
+  /** The SMTPS support by tunnelling the session in SSL transport */
+  public $ssl = false;
+  /** The Timeout between the answer of the SMTP server. If the server don't
+    * answer in this time, an exception is raised */
+  public $timeout = 10;
+  /** The socket of the connection */
+  private $smtpStream = null;
+
+  /** Connect to the SMTP server */
+  public function connect ()
+  {
+    if ($this->ssl)
+      $this->server = "tls://$this->server";
+    $this->debug ("####SMTP Connection to $this->server:$this->port\n");
+    $this->smtpStream = @fsockopen ($this->server, $this->port,
+                                    $errno, $errstr,
+                                    $this->timeout);
+    if ($this->smtpStream === false)
+      throw new \Exception (sprintf (_("Can't connect to SMTP server : %s"),
+                                     $errstr), 500);
+    stream_set_timeout ($this->smtpStream, $this->timeout);
+    // Wait for banner
+    $banner = $this->getLine ("SMTP Banner");
+    // Send EHLO
+    $this->putLine ("EHLO ".gethostname ()."\r\n");
+    if ($this->user !== null && $this->password !== null)
+    {
+      // Send User and password AUTH PLAIN
+      $this->putLine ("AUTH PLAIN ".
+                      base64_encode ($this->user.chr(0).$this->user.chr(0).
+                                     $this->password)."\r\n");
+    }
+  }
+
+  /** Send the mail to the users 
+    * @param string $from The email address used for the from enveloppe
+    * @param string|array $to the recipient of the email. Not displayed in the
+    *        email content
+    * @param $completeMail The content of the email
+    */
+  public function send ($from, $to, $completeMail)
+  {
+    if ($this->smtpStream === null)
+      throw new \Exception (
+                           _("Can't send email : not connected to SMTP server"),
+                           500);
+    if (is_string ($to))
+      $to = array ($to);
+    $this->putLine ("MAIL FROM: $from\r\n");
+    foreach ($to as $t)
+      $this->putLine ("RCPT TO: $t\r\n");
+    $this->putLine ("DATA\r\n");
+    if (substr ($completeMail, -2) !== "\r\n")
+      $completeMail .= "\r\n";
+    $this->putLine ("$completeMail.\r\n");
+  }
+
+  /** Disconnect from the SMTP server */
+  public function disconnect ()
+  {
+    if ($this->smtpStream === null)
+      throw new \Exception (
+                           _("Can't send email : not connected to SMTP server"),
+                           500);
+    $this->putLine ("QUIT\r\n");
+    fclose ($this->smtpStream);
+  }
+  
+  /** Reset the session to start a new mail in the same SMTP connection */
+  public function reset ()
+  {
+    if ($this->smtpStream === null)
+      throw new \Exception (
+                           _("Can't send email : not connected to SMTP server"),
+                           500);
+    $this->putLine ("RSET\r\n");
+  }
+
+  /** Send something to the SMTP server. Wait the acknoledgement line */
+  private function putLine ($data)
+  {
+    $this->debug ("> $data");
+    fwrite ($this->smtpStream, $data);
+    return $this->getLine ($data);
+  }
+
+  /** Wait something from the server */
+  private function getLine ($message = "")
+  {
+    $this->debug ("Waiting for ".rtrim ($message)." answer\n", 2);
+    $content = "";
+    while (1)
+    {
+      $line = stream_get_line ($this->smtpStream, 1024, "\r\n");
+      $meta = stream_get_meta_data ($this->smtpStream);
+      if ($meta["timed_out"] !== FALSE)
+      {
+        $this->debug ("Timeout when waiting $message\n");
+        throw new  \Exception ("Timeout when waiting $message", 500);
+      }
+      $content .= $line;
+      if (substr ($line, 3, 1) === " ")
+        break;
+    }
+    $this->debug ("< $content\n");
+    if (substr ($line, 0, 1) !== "2" && substr ($line, 0, 1) !== "3")
+    {
+      $this->debug ("Can't send mail : server answer : $line\n");
+      throw new \Exception ("Can't send mail : server answer : $line", 500);
+    }
+    return $content;
+  }
+
+  private function debug ($message, $priority = 1)
+  {
+    if ($this->debug == false)
+      return;
+    if ($priority > $this->debug)
+      return;
+    file_put_contents ("/tmp/debugsmtp", $message, FILE_APPEND);
+  }
+}