LÁZÁR Imre AI Agent
c2cf6dab13
common_cadline_libraries (CRM hardlock/db/users classes; upstream cadline_web/cadcommonlib), maintenance/ (ARCHLine.XP license backend; upstream cadline_web/maintenance), maintenance2/. Vetted live files (byte-truth); upstream repos in PROVENANCE.md. NOTE: could be git submodules — kept as live files for byte-fidelity. Signed-off-by: LÁZÁR Imre <imre@illusion.hu> Assisted-by: claude-code@claude-opus-4-8
359 lines
11 KiB
PHP
359 lines
11 KiB
PHP
<?php
|
|
|
|
/**
|
|
* o------------------------------------------------------------------------------o
|
|
* | This package is licensed under the Phpguru license 2008. A quick summary is |
|
|
* | that the code is free to use for non-commercial purposes. For commercial |
|
|
* | purposes of any kind there is a small license fee to pay. You can read more |
|
|
* | at: |
|
|
* | http://www.phpguru.org/static/license.html |
|
|
* o------------------------------------------------------------------------------o
|
|
*
|
|
* ? Copyright 2008 Richard Heyes
|
|
*/
|
|
|
|
define('SMTP_STATUS_NOT_CONNECTED', 1, true);
|
|
define('SMTP_STATUS_CONNECTED', 2, true);
|
|
|
|
class smtp
|
|
{
|
|
private $authenticated;
|
|
private $connection;
|
|
private $recipients;
|
|
private $headers;
|
|
private $timeout;
|
|
private $errors;
|
|
private $status;
|
|
private $body;
|
|
private $from;
|
|
private $host;
|
|
private $port;
|
|
private $helo;
|
|
private $auth;
|
|
private $user;
|
|
private $pass;
|
|
|
|
/**
|
|
* Constructor function. Arguments:
|
|
* $params - An assoc array of parameters:
|
|
*
|
|
* host - The hostname of the smtp server Default: localhost
|
|
* port - The port the smtp server runs on Default: 25
|
|
* helo - What to send as the HELO command Default: localhost
|
|
* (typically the hostname of the
|
|
* machine this script runs on)
|
|
* auth - Whether to use basic authentication Default: FALSE
|
|
* user - Username for authentication Default: <blank>
|
|
* pass - Password for authentication Default: <blank>
|
|
* timeout - The timeout in seconds for the call Default: 5
|
|
* to fsockopen()
|
|
*/
|
|
public function __construct($params = array())
|
|
{
|
|
|
|
if (!defined('CRLF'))
|
|
define('CRLF', "\r\n", TRUE);
|
|
|
|
$this->authenticated = FALSE;
|
|
$this->timeout = 5;
|
|
$this->status = SMTP_STATUS_NOT_CONNECTED;
|
|
$this->host = 'localhost';
|
|
$this->port = 25;
|
|
$this->helo = 'localhost';
|
|
$this->auth = FALSE;
|
|
$this->user = '';
|
|
$this->pass = '';
|
|
$this->errors = array();
|
|
|
|
foreach ($params as $key => $value) {
|
|
$this->$key = $value;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Connect function. This will, when called
|
|
* statically, create a new smtp object,
|
|
* call the connect function (ie this function)
|
|
* and return it. When not called statically,
|
|
* it will connect to the server and send
|
|
* the HELO command.
|
|
*/
|
|
public function connect($params = array())
|
|
{
|
|
if (!isset($this->status)) {
|
|
$obj = new smtp($params);
|
|
if ($obj->connect()) {
|
|
$obj->status = SMTP_STATUS_CONNECTED;
|
|
}
|
|
return $obj;
|
|
} else {
|
|
$this->connection = fsockopen($this->host, $this->port, $errno, $errstr, $this->timeout);
|
|
if (function_exists('socket_set_timeout')) {
|
|
@socket_set_timeout($this->connection, 5, 0);
|
|
}
|
|
|
|
$greeting = $this->get_data();
|
|
if (is_resource($this->connection)) {
|
|
return $this->auth ? $this->ehlo() : $this->helo();
|
|
} else {
|
|
$this->errors[] = 'Failed to connect to server: ' . $errstr;
|
|
return FALSE;
|
|
}
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Function which handles sending the mail.
|
|
* Arguments:
|
|
* $params - Optional assoc array of parameters.
|
|
* Can contain:
|
|
* recipients - Indexed array of recipients
|
|
* from - The from address. (used in MAIL FROM:),
|
|
* this will be the return path
|
|
* headers - Indexed array of headers, one header per array entry
|
|
* body - The body of the email
|
|
* It can also contain any of the parameters from the connect()
|
|
* function
|
|
*/
|
|
public function send($params = array())
|
|
{
|
|
foreach ($params as $key => $value) {
|
|
$this->set($key, $value);
|
|
}
|
|
if ($this->is_connected()) {
|
|
// Do we auth or not? Note the distinction between the auth variable and auth() function
|
|
if ($this->auth and !$this->authenticated) {
|
|
if (!$this->auth())
|
|
return false;
|
|
}
|
|
$this->mail($this->from);
|
|
|
|
if (is_array($this->recipients)) {
|
|
foreach ($this->recipients as $value) {
|
|
$this->rcpt($value);
|
|
}
|
|
} else {
|
|
$this->rcpt($this->recipients);
|
|
}
|
|
if (!$this->data()) {
|
|
return false;
|
|
}
|
|
// Transparency
|
|
$headers = str_replace(CRLF . '.', CRLF . '..', trim(implode(CRLF, $this->headers)));
|
|
$body = str_replace(CRLF . '.', CRLF . '..', $this->body);
|
|
$body = substr($body, 0, 1) == '.' ? '.' . $body : $body;
|
|
$this->send_data($headers);
|
|
$this->send_data('');
|
|
$this->send_data($body);
|
|
$this->send_data('.');
|
|
|
|
$result = (substr(trim($this->get_data()), 0, 3) === '250');
|
|
//$this->rset();
|
|
return $result;
|
|
} else {
|
|
$this->errors[] = 'Not connected!';
|
|
return FALSE;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Function to implement HELO cmd
|
|
*/
|
|
private function helo()
|
|
{
|
|
if (
|
|
is_resource($this->connection)
|
|
and $this->send_data('HELO ' . $this->helo)
|
|
and substr(trim($error = $this->get_data()), 0, 3) === '250'
|
|
) {
|
|
return true;
|
|
} else {
|
|
$this->errors[] = 'HELO command failed, output: ' . trim(substr(trim($error), 3));
|
|
return false;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Function to implement EHLO cmd
|
|
*/
|
|
private function ehlo()
|
|
{
|
|
if (
|
|
is_resource($this->connection)
|
|
and $this->send_data('EHLO ' . $this->helo)
|
|
and substr(trim($error = $this->get_data()), 0, 3) === '250'
|
|
) {
|
|
return true;
|
|
} else {
|
|
$this->errors[] = 'EHLO command failed, output: ' . trim(substr(trim($error), 3));
|
|
return false;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Function to implement RSET cmd
|
|
*/
|
|
private function rset()
|
|
{
|
|
if (
|
|
is_resource($this->connection)
|
|
and $this->send_data('RSET')
|
|
and substr(trim($error = $this->get_data()), 0, 3) === '250'
|
|
) {
|
|
|
|
return true;
|
|
} else {
|
|
$this->errors[] = 'RSET command failed, output: ' . trim(substr(trim($error), 3));
|
|
return false;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Function to implement QUIT cmd
|
|
*/
|
|
private function quit()
|
|
{
|
|
if (
|
|
is_resource($this->connection)
|
|
and $this->send_data('QUIT')
|
|
and substr(trim($error = $this->get_data()), 0, 3) === '221'
|
|
) {
|
|
|
|
fclose($this->connection);
|
|
$this->status = SMTP_STATUS_NOT_CONNECTED;
|
|
return true;
|
|
} else {
|
|
$this->errors[] = 'QUIT command failed, output: ' . trim(substr(trim($error), 3));
|
|
return false;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Function to implement AUTH cmd
|
|
*/
|
|
private function auth()
|
|
{
|
|
if (
|
|
is_resource($this->connection)
|
|
and $this->send_data('AUTH LOGIN')
|
|
and substr(trim($error = $this->get_data()), 0, 3) === '334'
|
|
and $this->send_data(base64_encode($this->user)) // Send username
|
|
and substr(trim($error = $this->get_data()), 0, 3) === '334'
|
|
and $this->send_data(base64_encode($this->pass)) // Send password
|
|
and substr(trim($error = $this->get_data()), 0, 3) === '235'
|
|
) {
|
|
$this->authenticated = true;
|
|
return true;
|
|
} else {
|
|
$this->errors[] = 'AUTH command failed: ' . trim(substr(trim($error), 3));
|
|
return false;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Function that handles the MAIL FROM: cmd
|
|
*/
|
|
private function mail($from)
|
|
{
|
|
if ($this->is_connected()) {
|
|
if ($this->send_data('MAIL FROM:<' . $from . '>')) {
|
|
if (substr(trim($this->get_data()), 0, 3) === '250') {
|
|
return true;
|
|
}
|
|
}
|
|
} else {
|
|
return false;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Function that handles the RCPT TO: cmd
|
|
*/
|
|
private function rcpt($to)
|
|
{
|
|
if ($this->is_connected()) {
|
|
if ($this->send_data('RCPT TO:<' . $to . '>')) {
|
|
if (substr(trim($error = $this->get_data()), 0, 2) === '25')
|
|
return true;
|
|
}
|
|
} else {
|
|
$this->errors[] = trim(substr(trim($error), 3));
|
|
return false;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Function that sends the DATA cmd
|
|
*/
|
|
private function data()
|
|
{
|
|
if ($this->is_connected()) {
|
|
if ($this->send_data('DATA')) {
|
|
if (substr(trim($error = $this->get_data()), 0, 3) === '354')
|
|
return true;
|
|
}
|
|
} else {
|
|
$this->errors[] = trim(substr(trim($error), 3));
|
|
return false;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Function to determine if this object
|
|
* is connected to the server or not.
|
|
*/
|
|
private function is_connected()
|
|
{
|
|
return (is_resource($this->connection) and ($this->status === SMTP_STATUS_CONNECTED));
|
|
}
|
|
|
|
/**
|
|
* Function to send a bit of data
|
|
*/
|
|
private function send_data($data)
|
|
{
|
|
if (is_resource($this->connection)) {
|
|
return fwrite($this->connection, $data . CRLF, strlen($data) + 2);
|
|
} else {
|
|
return false;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Function to get data.
|
|
*/
|
|
private function get_data()
|
|
{
|
|
$return = '';
|
|
$line = '';
|
|
$loops = 0;
|
|
|
|
if (is_resource($this->connection)) {
|
|
while ((strpos($return, CRLF) === FALSE or substr($line, 3, 1) !== ' ') and $loops < 100) {
|
|
$line = fgets($this->connection, 512);
|
|
$return .= $line;
|
|
$loops++;
|
|
}
|
|
return $return;
|
|
} else
|
|
return false;
|
|
}
|
|
|
|
/**
|
|
* Sets a variable
|
|
*/
|
|
public function set($var, $value)
|
|
{
|
|
$this->$var = $value;
|
|
return true;
|
|
}
|
|
|
|
/**
|
|
* Function to return the errors array
|
|
*/
|
|
public function getErrors()
|
|
{
|
|
return $this->errors;
|
|
}
|
|
}
|