Dolibarr / dolibarr

htdocs/includes/swiftmailer/lib/classes/Swift/MimePart.php

Indentation +26 added lines, -26 removed lines

@@ -15,31 +15,31 @@
  */
 class Swift_MimePart extends Swift_Mime_MimePart
 {
-    /**
-     * Create a new MimePart.
-     *
-     * Details may be optionally passed into the constructor.
-     *
-     * @param string $body
-     * @param string $contentType
-     * @param string $charset
-     */
-    public function __construct($body = null, $contentType = null, $charset = null)
-    {
-        \call_user_func_array(
-            [$this, 'Swift_Mime_MimePart::__construct'],
-            Swift_DependencyContainer::getInstance()
-                ->createDependenciesFor('mime.part')
-            );
+	/**
+	 * Create a new MimePart.
+	 *
+	 * Details may be optionally passed into the constructor.
+	 *
+	 * @param string $body
+	 * @param string $contentType
+	 * @param string $charset
+	 */
+	public function __construct($body = null, $contentType = null, $charset = null)
+	{
+		\call_user_func_array(
+			[$this, 'Swift_Mime_MimePart::__construct'],
+			Swift_DependencyContainer::getInstance()
+				->createDependenciesFor('mime.part')
+			);
 
-        if (!isset($charset)) {
-            $charset = Swift_DependencyContainer::getInstance()
-                ->lookup('properties.charset');
-        }
-        $this->setBody($body);
-        $this->setCharset($charset);
-        if ($contentType) {
-            $this->setContentType($contentType);
-        }
-    }
+		if (!isset($charset)) {
+			$charset = Swift_DependencyContainer::getInstance()
+				->lookup('properties.charset');
+		}
+		$this->setBody($body);
+		$this->setCharset($charset);
+		if ($contentType) {
+			$this->setContentType($contentType);
+		}
+	}
 }

htdocs/includes/swiftmailer/lib/classes/Swift/SwiftException.php

Indentation +10 added lines, -10 removed lines

@@ -15,14 +15,14 @@
  */
 class Swift_SwiftException extends Exception
 {
-    /**
-     * Create a new SwiftException with $message.
-     *
-     * @param string $message
-     * @param int    $code
-     */
-    public function __construct($message, $code = 0, Exception $previous = null)
-    {
-        parent::__construct($message, $code, $previous);
-    }
+	/**
+	 * Create a new SwiftException with $message.
+	 *
+	 * @param string $message
+	 * @param int    $code
+	 */
+	public function __construct($message, $code = 0, Exception $previous = null)
+	{
+		parent::__construct($message, $code, $previous);
+	}
 }

htdocs/includes/swiftmailer/lib/classes/Swift/Attachment.php

Indentation +34 added lines, -34 removed lines

@@ -15,40 +15,40 @@
  */
 class Swift_Attachment extends Swift_Mime_Attachment
 {
-    /**
-     * Create a new Attachment.
-     *
-     * Details may be optionally provided to the constructor.
-     *
-     * @param string|Swift_OutputByteStream $data
-     * @param string                        $filename
-     * @param string                        $contentType
-     */
-    public function __construct($data = null, $filename = null, $contentType = null)
-    {
-        \call_user_func_array(
-            [$this, 'Swift_Mime_Attachment::__construct'],
-            Swift_DependencyContainer::getInstance()
-                ->createDependenciesFor('mime.attachment')
-            );
+	/**
+	 * Create a new Attachment.
+	 *
+	 * Details may be optionally provided to the constructor.
+	 *
+	 * @param string|Swift_OutputByteStream $data
+	 * @param string                        $filename
+	 * @param string                        $contentType
+	 */
+	public function __construct($data = null, $filename = null, $contentType = null)
+	{
+		\call_user_func_array(
+			[$this, 'Swift_Mime_Attachment::__construct'],
+			Swift_DependencyContainer::getInstance()
+				->createDependenciesFor('mime.attachment')
+			);
 
-        $this->setBody($data, $contentType);
-        $this->setFilename($filename);
-    }
+		$this->setBody($data, $contentType);
+		$this->setFilename($filename);
+	}
 
-    /**
-     * Create a new Attachment from a filesystem path.
-     *
-     * @param string $path
-     * @param string $contentType optional
-     *
-     * @return self
-     */
-    public static function fromPath($path, $contentType = null)
-    {
-        return (new self())->setFile(
-            new Swift_ByteStream_FileByteStream($path),
-            $contentType
-        );
-    }
+	/**
+	 * Create a new Attachment from a filesystem path.
+	 *
+	 * @param string $path
+	 * @param string $contentType optional
+	 *
+	 * @return self
+	 */
+	public static function fromPath($path, $contentType = null)
+	{
+		return (new self())->setFile(
+			new Swift_ByteStream_FileByteStream($path),
+			$contentType
+		);
+	}
 }

htdocs/includes/swiftmailer/lib/classes/Swift/Transport/SmtpAgent.php

Indentation +17 added lines, -17 removed lines

@@ -15,22 +15,22 @@
  */
 interface Swift_Transport_SmtpAgent
 {
-    /**
-     * Get the IoBuffer where read/writes are occurring.
-     *
-     * @return Swift_Transport_IoBuffer
-     */
-    public function getBuffer();
+	/**
+	 * Get the IoBuffer where read/writes are occurring.
+	 *
+	 * @return Swift_Transport_IoBuffer
+	 */
+	public function getBuffer();
 
-    /**
-     * Run a command against the buffer, expecting the given response codes.
-     *
-     * If no response codes are given, the response will not be validated.
-     * If codes are given, an exception will be thrown on an invalid response.
-     *
-     * @param string   $command
-     * @param int[]    $codes
-     * @param string[] $failures An array of failures by-reference
-     */
-    public function executeCommand($command, $codes = [], &$failures = null);
+	/**
+	 * Run a command against the buffer, expecting the given response codes.
+	 *
+	 * If no response codes are given, the response will not be validated.
+	 * If codes are given, an exception will be thrown on an invalid response.
+	 *
+	 * @param string   $command
+	 * @param int[]    $codes
+	 * @param string[] $failures An array of failures by-reference
+	 */
+	public function executeCommand($command, $codes = [], &$failures = null);
 }

htdocs/includes/swiftmailer/lib/classes/Swift/Transport/SendmailTransport.php

Indentation +136 added lines, -136 removed lines

@@ -19,140 +19,140 @@
  */
 class Swift_Transport_SendmailTransport extends Swift_Transport_AbstractSmtpTransport
 {
-    /**
-     * Connection buffer parameters.
-     *
-     * @var array
-     */
-    private $params = [
-        'timeout' => 30,
-        'blocking' => 1,
-        'command' => '/usr/sbin/sendmail -bs',
-        'type' => Swift_Transport_IoBuffer::TYPE_PROCESS,
-        ];
-
-    /**
-     * Create a new SendmailTransport with $buf for I/O.
-     *
-     * @param string $localDomain
-     */
-    public function __construct(Swift_Transport_IoBuffer $buf, Swift_Events_EventDispatcher $dispatcher, $localDomain = '127.0.0.1', Swift_AddressEncoder $addressEncoder = null)
-    {
-        parent::__construct($buf, $dispatcher, $localDomain, $addressEncoder);
-    }
-
-    /**
-     * Start the standalone SMTP session if running in -bs mode.
-     */
-    public function start()
-    {
-        if (false !== strpos($this->getCommand(), ' -bs')) {
-            parent::start();
-        }
-    }
-
-    /**
-     * Set the command to invoke.
-     *
-     * If using -t mode you are strongly advised to include -oi or -i in the flags.
-     * For example: /usr/sbin/sendmail -oi -t
-     * Swift will append a -f<sender> flag if one is not present.
-     *
-     * The recommended mode is "-bs" since it is interactive and failure notifications
-     * are hence possible.
-     *
-     * @param string $command
-     *
-     * @return $this
-     */
-    public function setCommand($command)
-    {
-        $this->params['command'] = $command;
-
-        return $this;
-    }
-
-    /**
-     * Get the sendmail command which will be invoked.
-     *
-     * @return string
-     */
-    public function getCommand()
-    {
-        return $this->params['command'];
-    }
-
-    /**
-     * Send the given Message.
-     *
-     * Recipient/sender data will be retrieved from the Message API.
-     *
-     * The return value is the number of recipients who were accepted for delivery.
-     * NOTE: If using 'sendmail -t' you will not be aware of any failures until
-     * they bounce (i.e. send() will always return 100% success).
-     *
-     * @param string[] $failedRecipients An array of failures by-reference
-     *
-     * @return int
-     */
-    public function send(Swift_Mime_SimpleMessage $message, &$failedRecipients = null)
-    {
-        $failedRecipients = (array) $failedRecipients;
-        $command = $this->getCommand();
-        $buffer = $this->getBuffer();
-        $count = 0;
-
-        if (false !== strpos($command, ' -t')) {
-            if ($evt = $this->eventDispatcher->createSendEvent($this, $message)) {
-                $this->eventDispatcher->dispatchEvent($evt, 'beforeSendPerformed');
-                if ($evt->bubbleCancelled()) {
-                    return 0;
-                }
-            }
-
-            if (false === strpos($command, ' -f')) {
-                $command .= ' -f'.escapeshellarg($this->getReversePath($message) ?? '');
-            }
-
-            $buffer->initialize(array_merge($this->params, ['command' => $command]));
-
-            if (false === strpos($command, ' -i') && false === strpos($command, ' -oi')) {
-                $buffer->setWriteTranslations(["\r\n" => "\n", "\n." => "\n.."]);
-            } else {
-                $buffer->setWriteTranslations(["\r\n" => "\n"]);
-            }
-
-            $count = \count((array) $message->getTo())
-                + \count((array) $message->getCc())
-                + \count((array) $message->getBcc())
-                ;
-            $message->toByteStream($buffer);
-            $buffer->flushBuffers();
-            $buffer->setWriteTranslations([]);
-            $buffer->terminate();
-
-            if ($evt) {
-                $evt->setResult(Swift_Events_SendEvent::RESULT_SUCCESS);
-                $evt->setFailedRecipients($failedRecipients);
-                $this->eventDispatcher->dispatchEvent($evt, 'sendPerformed');
-            }
-
-            $message->generateId();
-        } elseif (false !== strpos($command, ' -bs')) {
-            $count = parent::send($message, $failedRecipients);
-        } else {
-            $this->throwException(new Swift_TransportException(
-                'Unsupported sendmail command flags ['.$command.']. '.
-                'Must be one of "-bs" or "-t" but can include additional flags.'
-                ));
-        }
-
-        return $count;
-    }
-
-    /** Get the params to initialize the buffer */
-    protected function getBufferParams()
-    {
-        return $this->params;
-    }
+	/**
+	 * Connection buffer parameters.
+	 *
+	 * @var array
+	 */
+	private $params = [
+		'timeout' => 30,
+		'blocking' => 1,
+		'command' => '/usr/sbin/sendmail -bs',
+		'type' => Swift_Transport_IoBuffer::TYPE_PROCESS,
+		];
+
+	/**
+	 * Create a new SendmailTransport with $buf for I/O.
+	 *
+	 * @param string $localDomain
+	 */
+	public function __construct(Swift_Transport_IoBuffer $buf, Swift_Events_EventDispatcher $dispatcher, $localDomain = '127.0.0.1', Swift_AddressEncoder $addressEncoder = null)
+	{
+		parent::__construct($buf, $dispatcher, $localDomain, $addressEncoder);
+	}
+
+	/**
+	 * Start the standalone SMTP session if running in -bs mode.
+	 */
+	public function start()
+	{
+		if (false !== strpos($this->getCommand(), ' -bs')) {
+			parent::start();
+		}
+	}
+
+	/**
+	 * Set the command to invoke.
+	 *
+	 * If using -t mode you are strongly advised to include -oi or -i in the flags.
+	 * For example: /usr/sbin/sendmail -oi -t
+	 * Swift will append a -f<sender> flag if one is not present.
+	 *
+	 * The recommended mode is "-bs" since it is interactive and failure notifications
+	 * are hence possible.
+	 *
+	 * @param string $command
+	 *
+	 * @return $this
+	 */
+	public function setCommand($command)
+	{
+		$this->params['command'] = $command;
+
+		return $this;
+	}
+
+	/**
+	 * Get the sendmail command which will be invoked.
+	 *
+	 * @return string
+	 */
+	public function getCommand()
+	{
+		return $this->params['command'];
+	}
+
+	/**
+	 * Send the given Message.
+	 *
+	 * Recipient/sender data will be retrieved from the Message API.
+	 *
+	 * The return value is the number of recipients who were accepted for delivery.
+	 * NOTE: If using 'sendmail -t' you will not be aware of any failures until
+	 * they bounce (i.e. send() will always return 100% success).
+	 *
+	 * @param string[] $failedRecipients An array of failures by-reference
+	 *
+	 * @return int
+	 */
+	public function send(Swift_Mime_SimpleMessage $message, &$failedRecipients = null)
+	{
+		$failedRecipients = (array) $failedRecipients;
+		$command = $this->getCommand();
+		$buffer = $this->getBuffer();
+		$count = 0;
+
+		if (false !== strpos($command, ' -t')) {
+			if ($evt = $this->eventDispatcher->createSendEvent($this, $message)) {
+				$this->eventDispatcher->dispatchEvent($evt, 'beforeSendPerformed');
+				if ($evt->bubbleCancelled()) {
+					return 0;
+				}
+			}
+
+			if (false === strpos($command, ' -f')) {
+				$command .= ' -f'.escapeshellarg($this->getReversePath($message) ?? '');
+			}
+
+			$buffer->initialize(array_merge($this->params, ['command' => $command]));
+
+			if (false === strpos($command, ' -i') && false === strpos($command, ' -oi')) {
+				$buffer->setWriteTranslations(["\r\n" => "\n", "\n." => "\n.."]);
+			} else {
+				$buffer->setWriteTranslations(["\r\n" => "\n"]);
+			}
+
+			$count = \count((array) $message->getTo())
+				+ \count((array) $message->getCc())
+				+ \count((array) $message->getBcc())
+				;
+			$message->toByteStream($buffer);
+			$buffer->flushBuffers();
+			$buffer->setWriteTranslations([]);
+			$buffer->terminate();
+
+			if ($evt) {
+				$evt->setResult(Swift_Events_SendEvent::RESULT_SUCCESS);
+				$evt->setFailedRecipients($failedRecipients);
+				$this->eventDispatcher->dispatchEvent($evt, 'sendPerformed');
+			}
+
+			$message->generateId();
+		} elseif (false !== strpos($command, ' -bs')) {
+			$count = parent::send($message, $failedRecipients);
+		} else {
+			$this->throwException(new Swift_TransportException(
+				'Unsupported sendmail command flags ['.$command.']. '.
+				'Must be one of "-bs" or "-t" but can include additional flags.'
+				));
+		}
+
+		return $count;
+	}
+
+	/** Get the params to initialize the buffer */
+	protected function getBufferParams()
+	{
+		return $this->params;
+	}
 }

htdocs/includes/swiftmailer/lib/classes/Swift/Transport/EsmtpHandler.php

Indentation +60 added lines, -60 removed lines

@@ -15,72 +15,72 @@
  */
 interface Swift_Transport_EsmtpHandler
 {
-    /**
-     * Get the name of the ESMTP extension this handles.
-     *
-     * @return string
-     */
-    public function getHandledKeyword();
+	/**
+	 * Get the name of the ESMTP extension this handles.
+	 *
+	 * @return string
+	 */
+	public function getHandledKeyword();
 
-    /**
-     * Set the parameters which the EHLO greeting indicated.
-     *
-     * @param string[] $parameters
-     */
-    public function setKeywordParams(array $parameters);
+	/**
+	 * Set the parameters which the EHLO greeting indicated.
+	 *
+	 * @param string[] $parameters
+	 */
+	public function setKeywordParams(array $parameters);
 
-    /**
-     * Runs immediately after a EHLO has been issued.
-     *
-     * @param Swift_Transport_SmtpAgent $agent to read/write
-     */
-    public function afterEhlo(Swift_Transport_SmtpAgent $agent);
+	/**
+	 * Runs immediately after a EHLO has been issued.
+	 *
+	 * @param Swift_Transport_SmtpAgent $agent to read/write
+	 */
+	public function afterEhlo(Swift_Transport_SmtpAgent $agent);
 
-    /**
-     * Get params which are appended to MAIL FROM:<>.
-     *
-     * @return string[]
-     */
-    public function getMailParams();
+	/**
+	 * Get params which are appended to MAIL FROM:<>.
+	 *
+	 * @return string[]
+	 */
+	public function getMailParams();
 
-    /**
-     * Get params which are appended to RCPT TO:<>.
-     *
-     * @return string[]
-     */
-    public function getRcptParams();
+	/**
+	 * Get params which are appended to RCPT TO:<>.
+	 *
+	 * @return string[]
+	 */
+	public function getRcptParams();
 
-    /**
-     * Runs when a command is due to be sent.
-     *
-     * @param Swift_Transport_SmtpAgent $agent            to read/write
-     * @param string                    $command          to send
-     * @param int[]                     $codes            expected in response
-     * @param string[]                  $failedRecipients to collect failures
-     * @param bool                      $stop             to be set true  by-reference if the command is now sent
-     */
-    public function onCommand(Swift_Transport_SmtpAgent $agent, $command, $codes = [], &$failedRecipients = null, &$stop = false);
+	/**
+	 * Runs when a command is due to be sent.
+	 *
+	 * @param Swift_Transport_SmtpAgent $agent            to read/write
+	 * @param string                    $command          to send
+	 * @param int[]                     $codes            expected in response
+	 * @param string[]                  $failedRecipients to collect failures
+	 * @param bool                      $stop             to be set true  by-reference if the command is now sent
+	 */
+	public function onCommand(Swift_Transport_SmtpAgent $agent, $command, $codes = [], &$failedRecipients = null, &$stop = false);
 
-    /**
-     * Returns +1, -1 or 0 according to the rules for usort().
-     *
-     * This method is called to ensure extensions can be execute in an appropriate order.
-     *
-     * @param string $esmtpKeyword to compare with
-     *
-     * @return int
-     */
-    public function getPriorityOver($esmtpKeyword);
+	/**
+	 * Returns +1, -1 or 0 according to the rules for usort().
+	 *
+	 * This method is called to ensure extensions can be execute in an appropriate order.
+	 *
+	 * @param string $esmtpKeyword to compare with
+	 *
+	 * @return int
+	 */
+	public function getPriorityOver($esmtpKeyword);
 
-    /**
-     * Returns an array of method names which are exposed to the Esmtp class.
-     *
-     * @return string[]
-     */
-    public function exposeMixinMethods();
+	/**
+	 * Returns an array of method names which are exposed to the Esmtp class.
+	 *
+	 * @return string[]
+	 */
+	public function exposeMixinMethods();
 
-    /**
-     * Tells this handler to clear any buffers and reset its state.
-     */
-    public function resetState();
+	/**
+	 * Tells this handler to clear any buffers and reset its state.
+	 */
+	public function resetState();
 }

htdocs/includes/swiftmailer/lib/classes/Swift/Transport/EsmtpTransport.php

Indentation +428 added lines, -428 removed lines

@@ -15,432 +15,432 @@
  */
 class Swift_Transport_EsmtpTransport extends Swift_Transport_AbstractSmtpTransport implements Swift_Transport_SmtpAgent
 {
-    /**
-     * ESMTP extension handlers.
-     *
-     * @var Swift_Transport_EsmtpHandler[]
-     */
-    private $handlers = [];
-
-    /**
-     * ESMTP capabilities.
-     *
-     * @var string[]
-     */
-    private $capabilities = [];
-
-    /**
-     * Connection buffer parameters.
-     *
-     * @var array
-     */
-    private $params = [
-        'protocol' => 'tcp',
-        'host' => 'localhost',
-        'port' => 25,
-        'timeout' => 30,
-        'blocking' => 1,
-        'tls' => false,
-        'type' => Swift_Transport_IoBuffer::TYPE_SOCKET,
-        'stream_context_options' => [],
-        ];
-
-    /**
-     * Creates a new EsmtpTransport using the given I/O buffer.
-     *
-     * @param Swift_Transport_EsmtpHandler[] $extensionHandlers
-     * @param string                         $localDomain
-     */
-    public function __construct(Swift_Transport_IoBuffer $buf, array $extensionHandlers, Swift_Events_EventDispatcher $dispatcher, $localDomain = '127.0.0.1', Swift_AddressEncoder $addressEncoder = null)
-    {
-        parent::__construct($buf, $dispatcher, $localDomain, $addressEncoder);
-        $this->setExtensionHandlers($extensionHandlers);
-    }
-
-    /**
-     * Set the host to connect to.
-     *
-     * Literal IPv6 addresses should be wrapped in square brackets.
-     *
-     * @param string $host
-     *
-     * @return $this
-     */
-    public function setHost($host)
-    {
-        $this->params['host'] = $host;
-
-        return $this;
-    }
-
-    /**
-     * Get the host to connect to.
-     *
-     * @return string
-     */
-    public function getHost()
-    {
-        return $this->params['host'];
-    }
-
-    /**
-     * Set the port to connect to.
-     *
-     * @param int $port
-     *
-     * @return $this
-     */
-    public function setPort($port)
-    {
-        $this->params['port'] = (int) $port;
-
-        return $this;
-    }
-
-    /**
-     * Get the port to connect to.
-     *
-     * @return int
-     */
-    public function getPort()
-    {
-        return $this->params['port'];
-    }
-
-    /**
-     * Set the connection timeout.
-     *
-     * @param int $timeout seconds
-     *
-     * @return $this
-     */
-    public function setTimeout($timeout)
-    {
-        $this->params['timeout'] = (int) $timeout;
-        $this->buffer->setParam('timeout', (int) $timeout);
-
-        return $this;
-    }
-
-    /**
-     * Get the connection timeout.
-     *
-     * @return int
-     */
-    public function getTimeout()
-    {
-        return $this->params['timeout'];
-    }
-
-    /**
-     * Set the encryption type (tls or ssl).
-     *
-     * @param string $encryption
-     *
-     * @return $this
-     */
-    public function setEncryption($encryption)
-    {
-        $encryption = strtolower($encryption ?? '');
-        if ('tls' == $encryption) {
-            $this->params['protocol'] = 'tcp';
-            $this->params['tls'] = true;
-        } else {
-            $this->params['protocol'] = $encryption;
-            $this->params['tls'] = false;
-        }
-
-        return $this;
-    }
-
-    /**
-     * Get the encryption type.
-     *
-     * @return string
-     */
-    public function getEncryption()
-    {
-        return $this->params['tls'] ? 'tls' : $this->params['protocol'];
-    }
-
-    /**
-     * Sets the stream context options.
-     *
-     * @param array $options
-     *
-     * @return $this
-     */
-    public function setStreamOptions($options)
-    {
-        $this->params['stream_context_options'] = $options;
-
-        return $this;
-    }
-
-    /**
-     * Returns the stream context options.
-     *
-     * @return array
-     */
-    public function getStreamOptions()
-    {
-        return $this->params['stream_context_options'];
-    }
-
-    /**
-     * Sets the source IP.
-     *
-     * IPv6 addresses should be wrapped in square brackets.
-     *
-     * @param string $source
-     *
-     * @return $this
-     */
-    public function setSourceIp($source)
-    {
-        $this->params['sourceIp'] = $source;
-
-        return $this;
-    }
-
-    /**
-     * Returns the IP used to connect to the destination.
-     *
-     * @return string
-     */
-    public function getSourceIp()
-    {
-        return $this->params['sourceIp'] ?? null;
-    }
-
-    /**
-     * Sets whether SMTP pipelining is enabled.
-     *
-     * By default, support is auto-detected using the PIPELINING SMTP extension.
-     * Use this function to override that in the unlikely event of compatibility
-     * issues.
-     *
-     * @param bool $enabled
-     *
-     * @return $this
-     */
-    public function setPipelining($enabled)
-    {
-        $this->pipelining = $enabled;
-
-        return $this;
-    }
-
-    /**
-     * Returns whether SMTP pipelining is enabled.
-     *
-     * @return bool|null a boolean if pipelining is explicitly enabled or disabled,
-     *                   or null if support is auto-detected
-     */
-    public function getPipelining()
-    {
-        return $this->pipelining;
-    }
-
-    /**
-     * Set ESMTP extension handlers.
-     *
-     * @param Swift_Transport_EsmtpHandler[] $handlers
-     *
-     * @return $this
-     */
-    public function setExtensionHandlers(array $handlers)
-    {
-        $assoc = [];
-        foreach ($handlers as $handler) {
-            $assoc[$handler->getHandledKeyword()] = $handler;
-        }
-        uasort($assoc, function ($a, $b) {
-            return $a->getPriorityOver($b->getHandledKeyword());
-        });
-        $this->handlers = $assoc;
-        $this->setHandlerParams();
-
-        return $this;
-    }
-
-    /**
-     * Get ESMTP extension handlers.
-     *
-     * @return Swift_Transport_EsmtpHandler[]
-     */
-    public function getExtensionHandlers()
-    {
-        return array_values($this->handlers);
-    }
-
-    /**
-     * Run a command against the buffer, expecting the given response codes.
-     *
-     * If no response codes are given, the response will not be validated.
-     * If codes are given, an exception will be thrown on an invalid response.
-     *
-     * @param string   $command
-     * @param int[]    $codes
-     * @param string[] $failures An array of failures by-reference
-     * @param bool     $pipeline Do not wait for response
-     * @param string   $address  the address, if command is RCPT TO
-     *
-     * @return string|null The server response, or null if pipelining is enabled
-     */
-    public function executeCommand($command, $codes = [], &$failures = null, $pipeline = false, $address = null)
-    {
-        $failures = (array) $failures;
-        $stopSignal = false;
-        $response = null;
-        foreach ($this->getActiveHandlers() as $handler) {
-            $response = $handler->onCommand(
-                $this, $command, $codes, $failures, $stopSignal
-                );
-            if ($stopSignal) {
-                return $response;
-            }
-        }
-
-        return parent::executeCommand($command, $codes, $failures, $pipeline, $address);
-    }
-
-    /** Mixin handling method for ESMTP handlers */
-    public function __call($method, $args)
-    {
-        foreach ($this->handlers as $handler) {
-            if (\in_array(strtolower($method),
-                array_map('strtolower', (array) $handler->exposeMixinMethods())
-                )) {
-                $return = \call_user_func_array([$handler, $method], $args);
-                // Allow fluid method calls
-                if (null === $return && 'set' == substr($method, 0, 3)) {
-                    return $this;
-                } else {
-                    return $return;
-                }
-            }
-        }
-        trigger_error('Call to undefined method '.$method, E_USER_ERROR);
-    }
-
-    /** Get the params to initialize the buffer */
-    protected function getBufferParams()
-    {
-        return $this->params;
-    }
-
-    /** Overridden to perform EHLO instead */
-    protected function doHeloCommand()
-    {
-        try {
-            $response = $this->executeCommand(
-                sprintf("EHLO %s\r\n", $this->domain), [250]
-                );
-        } catch (Swift_TransportException $e) {
-            return parent::doHeloCommand();
-        }
-
-        if ($this->params['tls']) {
-            try {
-                $this->executeCommand("STARTTLS\r\n", [220]);
-
-                if (!$this->buffer->startTLS()) {
-                    throw new Swift_TransportException('Unable to connect with TLS encryption');
-                }
-
-                try {
-                    $response = $this->executeCommand(
-                        sprintf("EHLO %s\r\n", $this->domain), [250]
-                        );
-                } catch (Swift_TransportException $e) {
-                    return parent::doHeloCommand();
-                }
-            } catch (Swift_TransportException $e) {
-                $this->throwException($e);
-            }
-        }
-
-        $this->capabilities = $this->getCapabilities($response);
-        if (!isset($this->pipelining)) {
-            $this->pipelining = isset($this->capabilities['PIPELINING']);
-        }
-
-        $this->setHandlerParams();
-        foreach ($this->getActiveHandlers() as $handler) {
-            $handler->afterEhlo($this);
-        }
-    }
-
-    /** Overridden to add Extension support */
-    protected function doMailFromCommand($address)
-    {
-        $address = $this->addressEncoder->encodeString($address);
-        $handlers = $this->getActiveHandlers();
-        $params = [];
-        foreach ($handlers as $handler) {
-            $params = array_merge($params, (array) $handler->getMailParams());
-        }
-        $paramStr = !empty($params) ? ' '.implode(' ', $params) : '';
-        $this->executeCommand(
-            sprintf("MAIL FROM:<%s>%s\r\n", $address, $paramStr), [250], $failures, true
-            );
-    }
-
-    /** Overridden to add Extension support */
-    protected function doRcptToCommand($address)
-    {
-        $address = $this->addressEncoder->encodeString($address);
-        $handlers = $this->getActiveHandlers();
-        $params = [];
-        foreach ($handlers as $handler) {
-            $params = array_merge($params, (array) $handler->getRcptParams());
-        }
-        $paramStr = !empty($params) ? ' '.implode(' ', $params) : '';
-        $this->executeCommand(
-            sprintf("RCPT TO:<%s>%s\r\n", $address, $paramStr), [250, 251, 252], $failures, true, $address
-            );
-    }
-
-    /** Determine ESMTP capabilities by function group */
-    private function getCapabilities($ehloResponse)
-    {
-        $capabilities = [];
-        $ehloResponse = trim($ehloResponse ?? '');
-        $lines = explode("\r\n", $ehloResponse);
-        array_shift($lines);
-        foreach ($lines as $line) {
-            if (preg_match('/^[0-9]{3}[ -]([A-Z0-9-]+)((?:[ =].*)?)$/Di', $line, $matches)) {
-                $keyword = strtoupper($matches[1]);
-                $paramStr = strtoupper(ltrim($matches[2], ' ='));
-                $params = !empty($paramStr) ? explode(' ', $paramStr) : [];
-                $capabilities[$keyword] = $params;
-            }
-        }
-
-        return $capabilities;
-    }
-
-    /** Set parameters which are used by each extension handler */
-    private function setHandlerParams()
-    {
-        foreach ($this->handlers as $keyword => $handler) {
-            if (\array_key_exists($keyword, $this->capabilities)) {
-                $handler->setKeywordParams($this->capabilities[$keyword]);
-            }
-        }
-    }
-
-    /** Get ESMTP handlers which are currently ok to use */
-    private function getActiveHandlers()
-    {
-        $handlers = [];
-        foreach ($this->handlers as $keyword => $handler) {
-            if (\array_key_exists($keyword, $this->capabilities)) {
-                $handlers[] = $handler;
-            }
-        }
-
-        return $handlers;
-    }
+	/**
+	 * ESMTP extension handlers.
+	 *
+	 * @var Swift_Transport_EsmtpHandler[]
+	 */
+	private $handlers = [];
+
+	/**
+	 * ESMTP capabilities.
+	 *
+	 * @var string[]
+	 */
+	private $capabilities = [];
+
+	/**
+	 * Connection buffer parameters.
+	 *
+	 * @var array
+	 */
+	private $params = [
+		'protocol' => 'tcp',
+		'host' => 'localhost',
+		'port' => 25,
+		'timeout' => 30,
+		'blocking' => 1,
+		'tls' => false,
+		'type' => Swift_Transport_IoBuffer::TYPE_SOCKET,
+		'stream_context_options' => [],
+		];
+
+	/**
+	 * Creates a new EsmtpTransport using the given I/O buffer.
+	 *
+	 * @param Swift_Transport_EsmtpHandler[] $extensionHandlers
+	 * @param string                         $localDomain
+	 */
+	public function __construct(Swift_Transport_IoBuffer $buf, array $extensionHandlers, Swift_Events_EventDispatcher $dispatcher, $localDomain = '127.0.0.1', Swift_AddressEncoder $addressEncoder = null)
+	{
+		parent::__construct($buf, $dispatcher, $localDomain, $addressEncoder);
+		$this->setExtensionHandlers($extensionHandlers);
+	}
+
+	/**
+	 * Set the host to connect to.
+	 *
+	 * Literal IPv6 addresses should be wrapped in square brackets.
+	 *
+	 * @param string $host
+	 *
+	 * @return $this
+	 */
+	public function setHost($host)
+	{
+		$this->params['host'] = $host;
+
+		return $this;
+	}
+
+	/**
+	 * Get the host to connect to.
+	 *
+	 * @return string
+	 */
+	public function getHost()
+	{
+		return $this->params['host'];
+	}
+
+	/**
+	 * Set the port to connect to.
+	 *
+	 * @param int $port
+	 *
+	 * @return $this
+	 */
+	public function setPort($port)
+	{
+		$this->params['port'] = (int) $port;
+
+		return $this;
+	}
+
+	/**
+	 * Get the port to connect to.
+	 *
+	 * @return int
+	 */
+	public function getPort()
+	{
+		return $this->params['port'];
+	}
+
+	/**
+	 * Set the connection timeout.
+	 *
+	 * @param int $timeout seconds
+	 *
+	 * @return $this
+	 */
+	public function setTimeout($timeout)
+	{
+		$this->params['timeout'] = (int) $timeout;
+		$this->buffer->setParam('timeout', (int) $timeout);
+
+		return $this;
+	}
+
+	/**
+	 * Get the connection timeout.
+	 *
+	 * @return int
+	 */
+	public function getTimeout()
+	{
+		return $this->params['timeout'];
+	}
+
+	/**
+	 * Set the encryption type (tls or ssl).
+	 *
+	 * @param string $encryption
+	 *
+	 * @return $this
+	 */
+	public function setEncryption($encryption)
+	{
+		$encryption = strtolower($encryption ?? '');
+		if ('tls' == $encryption) {
+			$this->params['protocol'] = 'tcp';
+			$this->params['tls'] = true;
+		} else {
+			$this->params['protocol'] = $encryption;
+			$this->params['tls'] = false;
+		}
+
+		return $this;
+	}
+
+	/**
+	 * Get the encryption type.
+	 *
+	 * @return string
+	 */
+	public function getEncryption()
+	{
+		return $this->params['tls'] ? 'tls' : $this->params['protocol'];
+	}
+
+	/**
+	 * Sets the stream context options.
+	 *
+	 * @param array $options
+	 *
+	 * @return $this
+	 */
+	public function setStreamOptions($options)
+	{
+		$this->params['stream_context_options'] = $options;
+
+		return $this;
+	}
+
+	/**
+	 * Returns the stream context options.
+	 *
+	 * @return array
+	 */
+	public function getStreamOptions()
+	{
+		return $this->params['stream_context_options'];
+	}
+
+	/**
+	 * Sets the source IP.
+	 *
+	 * IPv6 addresses should be wrapped in square brackets.
+	 *
+	 * @param string $source
+	 *
+	 * @return $this
+	 */
+	public function setSourceIp($source)
+	{
+		$this->params['sourceIp'] = $source;
+
+		return $this;
+	}
+
+	/**
+	 * Returns the IP used to connect to the destination.
+	 *
+	 * @return string
+	 */
+	public function getSourceIp()
+	{
+		return $this->params['sourceIp'] ?? null;
+	}
+
+	/**
+	 * Sets whether SMTP pipelining is enabled.
+	 *
+	 * By default, support is auto-detected using the PIPELINING SMTP extension.
+	 * Use this function to override that in the unlikely event of compatibility
+	 * issues.
+	 *
+	 * @param bool $enabled
+	 *
+	 * @return $this
+	 */
+	public function setPipelining($enabled)
+	{
+		$this->pipelining = $enabled;
+
+		return $this;
+	}
+
+	/**
+	 * Returns whether SMTP pipelining is enabled.
+	 *
+	 * @return bool|null a boolean if pipelining is explicitly enabled or disabled,
+	 *                   or null if support is auto-detected
+	 */
+	public function getPipelining()
+	{
+		return $this->pipelining;
+	}
+
+	/**
+	 * Set ESMTP extension handlers.
+	 *
+	 * @param Swift_Transport_EsmtpHandler[] $handlers
+	 *
+	 * @return $this
+	 */
+	public function setExtensionHandlers(array $handlers)
+	{
+		$assoc = [];
+		foreach ($handlers as $handler) {
+			$assoc[$handler->getHandledKeyword()] = $handler;
+		}
+		uasort($assoc, function ($a, $b) {
+			return $a->getPriorityOver($b->getHandledKeyword());
+		});
+		$this->handlers = $assoc;
+		$this->setHandlerParams();
+
+		return $this;
+	}
+
+	/**
+	 * Get ESMTP extension handlers.
+	 *
+	 * @return Swift_Transport_EsmtpHandler[]
+	 */
+	public function getExtensionHandlers()
+	{
+		return array_values($this->handlers);
+	}
+
+	/**
+	 * Run a command against the buffer, expecting the given response codes.
+	 *
+	 * If no response codes are given, the response will not be validated.
+	 * If codes are given, an exception will be thrown on an invalid response.
+	 *
+	 * @param string   $command
+	 * @param int[]    $codes
+	 * @param string[] $failures An array of failures by-reference
+	 * @param bool     $pipeline Do not wait for response
+	 * @param string   $address  the address, if command is RCPT TO
+	 *
+	 * @return string|null The server response, or null if pipelining is enabled
+	 */
+	public function executeCommand($command, $codes = [], &$failures = null, $pipeline = false, $address = null)
+	{
+		$failures = (array) $failures;
+		$stopSignal = false;
+		$response = null;
+		foreach ($this->getActiveHandlers() as $handler) {
+			$response = $handler->onCommand(
+				$this, $command, $codes, $failures, $stopSignal
+				);
+			if ($stopSignal) {
+				return $response;
+			}
+		}
+
+		return parent::executeCommand($command, $codes, $failures, $pipeline, $address);
+	}
+
+	/** Mixin handling method for ESMTP handlers */
+	public function __call($method, $args)
+	{
+		foreach ($this->handlers as $handler) {
+			if (\in_array(strtolower($method),
+				array_map('strtolower', (array) $handler->exposeMixinMethods())
+				)) {
+				$return = \call_user_func_array([$handler, $method], $args);
+				// Allow fluid method calls
+				if (null === $return && 'set' == substr($method, 0, 3)) {
+					return $this;
+				} else {
+					return $return;
+				}
+			}
+		}
+		trigger_error('Call to undefined method '.$method, E_USER_ERROR);
+	}
+
+	/** Get the params to initialize the buffer */
+	protected function getBufferParams()
+	{
+		return $this->params;
+	}
+
+	/** Overridden to perform EHLO instead */
+	protected function doHeloCommand()
+	{
+		try {
+			$response = $this->executeCommand(
+				sprintf("EHLO %s\r\n", $this->domain), [250]
+				);
+		} catch (Swift_TransportException $e) {
+			return parent::doHeloCommand();
+		}
+
+		if ($this->params['tls']) {
+			try {
+				$this->executeCommand("STARTTLS\r\n", [220]);
+
+				if (!$this->buffer->startTLS()) {
+					throw new Swift_TransportException('Unable to connect with TLS encryption');
+				}
+
+				try {
+					$response = $this->executeCommand(
+						sprintf("EHLO %s\r\n", $this->domain), [250]
+						);
+				} catch (Swift_TransportException $e) {
+					return parent::doHeloCommand();
+				}
+			} catch (Swift_TransportException $e) {
+				$this->throwException($e);
+			}
+		}
+
+		$this->capabilities = $this->getCapabilities($response);
+		if (!isset($this->pipelining)) {
+			$this->pipelining = isset($this->capabilities['PIPELINING']);
+		}
+
+		$this->setHandlerParams();
+		foreach ($this->getActiveHandlers() as $handler) {
+			$handler->afterEhlo($this);
+		}
+	}
+
+	/** Overridden to add Extension support */
+	protected function doMailFromCommand($address)
+	{
+		$address = $this->addressEncoder->encodeString($address);
+		$handlers = $this->getActiveHandlers();
+		$params = [];
+		foreach ($handlers as $handler) {
+			$params = array_merge($params, (array) $handler->getMailParams());
+		}
+		$paramStr = !empty($params) ? ' '.implode(' ', $params) : '';
+		$this->executeCommand(
+			sprintf("MAIL FROM:<%s>%s\r\n", $address, $paramStr), [250], $failures, true
+			);
+	}
+
+	/** Overridden to add Extension support */
+	protected function doRcptToCommand($address)
+	{
+		$address = $this->addressEncoder->encodeString($address);
+		$handlers = $this->getActiveHandlers();
+		$params = [];
+		foreach ($handlers as $handler) {
+			$params = array_merge($params, (array) $handler->getRcptParams());
+		}
+		$paramStr = !empty($params) ? ' '.implode(' ', $params) : '';
+		$this->executeCommand(
+			sprintf("RCPT TO:<%s>%s\r\n", $address, $paramStr), [250, 251, 252], $failures, true, $address
+			);
+	}
+
+	/** Determine ESMTP capabilities by function group */
+	private function getCapabilities($ehloResponse)
+	{
+		$capabilities = [];
+		$ehloResponse = trim($ehloResponse ?? '');
+		$lines = explode("\r\n", $ehloResponse);
+		array_shift($lines);
+		foreach ($lines as $line) {
+			if (preg_match('/^[0-9]{3}[ -]([A-Z0-9-]+)((?:[ =].*)?)$/Di', $line, $matches)) {
+				$keyword = strtoupper($matches[1]);
+				$paramStr = strtoupper(ltrim($matches[2], ' ='));
+				$params = !empty($paramStr) ? explode(' ', $paramStr) : [];
+				$capabilities[$keyword] = $params;
+			}
+		}
+
+		return $capabilities;
+	}
+
+	/** Set parameters which are used by each extension handler */
+	private function setHandlerParams()
+	{
+		foreach ($this->handlers as $keyword => $handler) {
+			if (\array_key_exists($keyword, $this->capabilities)) {
+				$handler->setKeywordParams($this->capabilities[$keyword]);
+			}
+		}
+	}
+
+	/** Get ESMTP handlers which are currently ok to use */
+	private function getActiveHandlers()
+	{
+		$handlers = [];
+		foreach ($this->handlers as $keyword => $handler) {
+			if (\array_key_exists($keyword, $this->capabilities)) {
+				$handlers[] = $handler;
+			}
+		}
+
+		return $handlers;
+	}
 }

Spacing +1 added lines, -1 removed lines

@@ -255,7 +255,7 @@
         foreach ($handlers as $handler) {
             $assoc[$handler->getHandledKeyword()] = $handler;
         }
-        uasort($assoc, function ($a, $b) {
+        uasort($assoc, function($a, $b) {
             return $a->getPriorityOver($b->getHandledKeyword());
         });
         $this->handlers = $assoc;

htdocs/includes/swiftmailer/lib/classes/Swift/Transport/AbstractSmtpTransport.php

Indentation +523 added lines, -523 removed lines

@@ -15,527 +15,527 @@
  */
 abstract class Swift_Transport_AbstractSmtpTransport implements Swift_Transport
 {
-    /** Input-Output buffer for sending/receiving SMTP commands and responses */
-    protected $buffer;
-
-    /** Connection status */
-    protected $started = false;
-
-    /** The domain name to use in HELO command */
-    protected $domain = '[127.0.0.1]';
-
-    /** The event dispatching layer */
-    protected $eventDispatcher;
-
-    protected $addressEncoder;
-
-    /** Whether the PIPELINING SMTP extension is enabled (RFC 2920) */
-    protected $pipelining = null;
-
-    /** The pipelined commands waiting for response */
-    protected $pipeline = [];
-
-    /** Source Ip */
-    protected $sourceIp;
-
-    /** Return an array of params for the Buffer */
-    abstract protected function getBufferParams();
-
-    /**
-     * Creates a new EsmtpTransport using the given I/O buffer.
-     *
-     * @param string $localDomain
-     */
-    public function __construct(Swift_Transport_IoBuffer $buf, Swift_Events_EventDispatcher $dispatcher, $localDomain = '127.0.0.1', Swift_AddressEncoder $addressEncoder = null)
-    {
-        $this->buffer = $buf;
-        $this->eventDispatcher = $dispatcher;
-        $this->addressEncoder = $addressEncoder ?? new Swift_AddressEncoder_IdnAddressEncoder();
-        $this->setLocalDomain($localDomain);
-    }
-
-    /**
-     * Set the name of the local domain which Swift will identify itself as.
-     *
-     * This should be a fully-qualified domain name and should be truly the domain
-     * you're using.
-     *
-     * If your server does not have a domain name, use the IP address. This will
-     * automatically be wrapped in square brackets as described in RFC 5321,
-     * section 4.1.3.
-     *
-     * @param string $domain
-     *
-     * @return $this
-     */
-    public function setLocalDomain($domain)
-    {
-        if ('[' !== substr($domain, 0, 1)) {
-            if (filter_var($domain, FILTER_VALIDATE_IP, FILTER_FLAG_IPV4)) {
-                $domain = '['.$domain.']';
-            } elseif (filter_var($domain, FILTER_VALIDATE_IP, FILTER_FLAG_IPV6)) {
-                $domain = '[IPv6:'.$domain.']';
-            }
-        }
-
-        $this->domain = $domain;
-
-        return $this;
-    }
-
-    /**
-     * Get the name of the domain Swift will identify as.
-     *
-     * If an IP address was specified, this will be returned wrapped in square
-     * brackets as described in RFC 5321, section 4.1.3.
-     *
-     * @return string
-     */
-    public function getLocalDomain()
-    {
-        return $this->domain;
-    }
-
-    /**
-     * Sets the source IP.
-     *
-     * @param string $source
-     */
-    public function setSourceIp($source)
-    {
-        $this->sourceIp = $source;
-    }
-
-    /**
-     * Returns the IP used to connect to the destination.
-     *
-     * @return string
-     */
-    public function getSourceIp()
-    {
-        return $this->sourceIp;
-    }
-
-    public function setAddressEncoder(Swift_AddressEncoder $addressEncoder)
-    {
-        $this->addressEncoder = $addressEncoder;
-    }
-
-    public function getAddressEncoder()
-    {
-        return $this->addressEncoder;
-    }
-
-    /**
-     * Start the SMTP connection.
-     */
-    public function start()
-    {
-        if (!$this->started) {
-            if ($evt = $this->eventDispatcher->createTransportChangeEvent($this)) {
-                $this->eventDispatcher->dispatchEvent($evt, 'beforeTransportStarted');
-                if ($evt->bubbleCancelled()) {
-                    return;
-                }
-            }
-
-            try {
-                $this->buffer->initialize($this->getBufferParams());
-            } catch (Swift_TransportException $e) {
-                $this->throwException($e);
-            }
-            $this->readGreeting();
-            $this->doHeloCommand();
-
-            if ($evt) {
-                $this->eventDispatcher->dispatchEvent($evt, 'transportStarted');
-            }
-
-            $this->started = true;
-        }
-    }
-
-    /**
-     * Test if an SMTP connection has been established.
-     *
-     * @return bool
-     */
-    public function isStarted()
-    {
-        return $this->started;
-    }
-
-    /**
-     * Send the given Message.
-     *
-     * Recipient/sender data will be retrieved from the Message API.
-     * The return value is the number of recipients who were accepted for delivery.
-     *
-     * @param string[] $failedRecipients An array of failures by-reference
-     *
-     * @return int
-     */
-    public function send(Swift_Mime_SimpleMessage $message, &$failedRecipients = null)
-    {
-        if (!$this->isStarted()) {
-            $this->start();
-        }
-
-        $sent = 0;
-        $failedRecipients = (array) $failedRecipients;
-
-        if ($evt = $this->eventDispatcher->createSendEvent($this, $message)) {
-            $this->eventDispatcher->dispatchEvent($evt, 'beforeSendPerformed');
-            if ($evt->bubbleCancelled()) {
-                return 0;
-            }
-        }
-
-        if (!$reversePath = $this->getReversePath($message)) {
-            $this->throwException(new Swift_TransportException('Cannot send message without a sender address'));
-        }
-
-        $to = (array) $message->getTo();
-        $cc = (array) $message->getCc();
-        $bcc = (array) $message->getBcc();
-        $tos = array_merge($to, $cc, $bcc);
-
-        $message->setBcc([]);
-
-        try {
-            $sent += $this->sendTo($message, $reversePath, $tos, $failedRecipients);
-        } finally {
-            $message->setBcc($bcc);
-        }
-
-        if ($evt) {
-            if ($sent == \count($to) + \count($cc) + \count($bcc)) {
-                $evt->setResult(Swift_Events_SendEvent::RESULT_SUCCESS);
-            } elseif ($sent > 0) {
-                $evt->setResult(Swift_Events_SendEvent::RESULT_TENTATIVE);
-            } else {
-                $evt->setResult(Swift_Events_SendEvent::RESULT_FAILED);
-            }
-            $evt->setFailedRecipients($failedRecipients);
-            $this->eventDispatcher->dispatchEvent($evt, 'sendPerformed');
-        }
-
-        $message->generateId(); //Make sure a new Message ID is used
-
-        return $sent;
-    }
-
-    /**
-     * Stop the SMTP connection.
-     */
-    public function stop()
-    {
-        if ($this->started) {
-            if ($evt = $this->eventDispatcher->createTransportChangeEvent($this)) {
-                $this->eventDispatcher->dispatchEvent($evt, 'beforeTransportStopped');
-                if ($evt->bubbleCancelled()) {
-                    return;
-                }
-            }
-
-            try {
-                $this->executeCommand("QUIT\r\n", [221]);
-            } catch (Swift_TransportException $e) {
-            }
-
-            try {
-                $this->buffer->terminate();
-
-                if ($evt) {
-                    $this->eventDispatcher->dispatchEvent($evt, 'transportStopped');
-                }
-            } catch (Swift_TransportException $e) {
-                $this->throwException($e);
-            }
-        }
-        $this->started = false;
-    }
-
-    /**
-     * {@inheritdoc}
-     */
-    public function ping()
-    {
-        try {
-            if (!$this->isStarted()) {
-                $this->start();
-            }
-
-            $this->executeCommand("NOOP\r\n", [250]);
-        } catch (Swift_TransportException $e) {
-            try {
-                $this->stop();
-            } catch (Swift_TransportException $e) {
-            }
-
-            return false;
-        }
-
-        return true;
-    }
-
-    /**
-     * Register a plugin.
-     */
-    public function registerPlugin(Swift_Events_EventListener $plugin)
-    {
-        $this->eventDispatcher->bindEventListener($plugin);
-    }
-
-    /**
-     * Reset the current mail transaction.
-     */
-    public function reset()
-    {
-        $this->executeCommand("RSET\r\n", [250], $failures, true);
-    }
-
-    /**
-     * Get the IoBuffer where read/writes are occurring.
-     *
-     * @return Swift_Transport_IoBuffer
-     */
-    public function getBuffer()
-    {
-        return $this->buffer;
-    }
-
-    /**
-     * Run a command against the buffer, expecting the given response codes.
-     *
-     * If no response codes are given, the response will not be validated.
-     * If codes are given, an exception will be thrown on an invalid response.
-     * If the command is RCPT TO, and the pipeline is non-empty, no exception
-     * will be thrown; instead the failing address is added to $failures.
-     *
-     * @param string   $command
-     * @param int[]    $codes
-     * @param string[] $failures An array of failures by-reference
-     * @param bool     $pipeline Do not wait for response
-     * @param string   $address  the address, if command is RCPT TO
-     *
-     * @return string|null The server response, or null if pipelining is enabled
-     */
-    public function executeCommand($command, $codes = [], &$failures = null, $pipeline = false, $address = null)
-    {
-        $failures = (array) $failures;
-        $seq = $this->buffer->write($command);
-        if ($evt = $this->eventDispatcher->createCommandEvent($this, $command, $codes)) {
-            $this->eventDispatcher->dispatchEvent($evt, 'commandSent');
-        }
-
-        $this->pipeline[] = [$command, $seq, $codes, $address];
-
-        if ($pipeline && $this->pipelining) {
-            return null;
-        }
-
-        $response = null;
-
-        while ($this->pipeline) {
-            list($command, $seq, $codes, $address) = array_shift($this->pipeline);
-            $response = $this->getFullResponse($seq);
-            try {
-                $this->assertResponseCode($response, $codes);
-            } catch (Swift_TransportException $e) {
-                if ($this->pipeline && $address) {
-                    $failures[] = $address;
-                } else {
-                    $this->throwException($e);
-                }
-            }
-        }
-
-        return $response;
-    }
-
-    /** Read the opening SMTP greeting */
-    protected function readGreeting()
-    {
-        $this->assertResponseCode($this->getFullResponse(0), [220]);
-    }
-
-    /** Send the HELO welcome */
-    protected function doHeloCommand()
-    {
-        $this->executeCommand(
-            sprintf("HELO %s\r\n", $this->domain), [250]
-            );
-    }
-
-    /** Send the MAIL FROM command */
-    protected function doMailFromCommand($address)
-    {
-        $address = $this->addressEncoder->encodeString($address);
-        $this->executeCommand(
-            sprintf("MAIL FROM:<%s>\r\n", $address), [250], $failures, true
-            );
-    }
-
-    /** Send the RCPT TO command */
-    protected function doRcptToCommand($address)
-    {
-        $address = $this->addressEncoder->encodeString($address);
-        $this->executeCommand(
-            sprintf("RCPT TO:<%s>\r\n", $address), [250, 251, 252], $failures, true, $address
-            );
-    }
-
-    /** Send the DATA command */
-    protected function doDataCommand(&$failedRecipients)
-    {
-        $this->executeCommand("DATA\r\n", [354], $failedRecipients);
-    }
-
-    /** Stream the contents of the message over the buffer */
-    protected function streamMessage(Swift_Mime_SimpleMessage $message)
-    {
-        $this->buffer->setWriteTranslations(["\r\n." => "\r\n.."]);
-        try {
-            $message->toByteStream($this->buffer);
-            $this->buffer->flushBuffers();
-        } catch (Swift_TransportException $e) {
-            $this->throwException($e);
-        }
-        $this->buffer->setWriteTranslations([]);
-        $this->executeCommand("\r\n.\r\n", [250]);
-    }
-
-    /** Determine the best-use reverse path for this message */
-    protected function getReversePath(Swift_Mime_SimpleMessage $message)
-    {
-        $return = $message->getReturnPath();
-        $sender = $message->getSender();
-        $from = $message->getFrom();
-        $path = null;
-        if (!empty($return)) {
-            $path = $return;
-        } elseif (!empty($sender)) {
-            // Don't use array_keys
-            reset($sender); // Reset Pointer to first pos
-            $path = key($sender); // Get key
-        } elseif (!empty($from)) {
-            reset($from); // Reset Pointer to first pos
-            $path = key($from); // Get key
-        }
-
-        return $path;
-    }
-
-    /** Throw a TransportException, first sending it to any listeners */
-    protected function throwException(Swift_TransportException $e)
-    {
-        if ($evt = $this->eventDispatcher->createTransportExceptionEvent($this, $e)) {
-            $this->eventDispatcher->dispatchEvent($evt, 'exceptionThrown');
-            if (!$evt->bubbleCancelled()) {
-                throw $e;
-            }
-        } else {
-            throw $e;
-        }
-    }
-
-    /** Throws an Exception if a response code is incorrect */
-    protected function assertResponseCode($response, $wanted)
-    {
-        if (!$response) {
-            $this->throwException(new Swift_TransportException('Expected response code '.implode('/', $wanted).' but got an empty response'));
-        }
-
-        list($code) = sscanf($response, '%3d');
-        $valid = (empty($wanted) || \in_array($code, $wanted));
-
-        if ($evt = $this->eventDispatcher->createResponseEvent($this, $response,
-            $valid)) {
-            $this->eventDispatcher->dispatchEvent($evt, 'responseReceived');
-        }
-
-        if (!$valid) {
-            $this->throwException(new Swift_TransportException('Expected response code '.implode('/', $wanted).' but got code "'.$code.'", with message "'.$response.'"', $code));
-        }
-    }
-
-    /** Get an entire multi-line response using its sequence number */
-    protected function getFullResponse($seq)
-    {
-        $response = '';
-        try {
-            do {
-                $line = $this->buffer->readLine($seq);
-                $response .= $line;
-            } while (null !== $line && false !== $line && ' ' != $line[3]);
-        } catch (Swift_TransportException $e) {
-            $this->throwException($e);
-        } catch (Swift_IoException $e) {
-            $this->throwException(new Swift_TransportException($e->getMessage(), 0, $e));
-        }
-
-        return $response;
-    }
-
-    /** Send an email to the given recipients from the given reverse path */
-    private function doMailTransaction($message, $reversePath, array $recipients, array &$failedRecipients)
-    {
-        $sent = 0;
-        $this->doMailFromCommand($reversePath);
-        foreach ($recipients as $forwardPath) {
-            try {
-                $this->doRcptToCommand($forwardPath);
-                ++$sent;
-            } catch (Swift_TransportException $e) {
-                $failedRecipients[] = $forwardPath;
-            } catch (Swift_AddressEncoderException $e) {
-                $failedRecipients[] = $forwardPath;
-            }
-        }
-
-        if (0 != $sent) {
-            $sent += \count($failedRecipients);
-            $this->doDataCommand($failedRecipients);
-            $sent -= \count($failedRecipients);
-
-            $this->streamMessage($message);
-        } else {
-            $this->reset();
-        }
-
-        return $sent;
-    }
-
-    /** Send a message to the given To: recipients */
-    private function sendTo(Swift_Mime_SimpleMessage $message, $reversePath, array $to, array &$failedRecipients)
-    {
-        if (empty($to)) {
-            return 0;
-        }
-
-        return $this->doMailTransaction($message, $reversePath, array_keys($to),
-            $failedRecipients);
-    }
-
-    /**
-     * Destructor.
-     */
-    public function __destruct()
-    {
-        try {
-            $this->stop();
-        } catch (Exception $e) {
-        }
-    }
-
-    public function __sleep()
-    {
-        throw new \BadMethodCallException('Cannot serialize '.__CLASS__);
-    }
-
-    public function __wakeup()
-    {
-        throw new \BadMethodCallException('Cannot unserialize '.__CLASS__);
-    }
+	/** Input-Output buffer for sending/receiving SMTP commands and responses */
+	protected $buffer;
+
+	/** Connection status */
+	protected $started = false;
+
+	/** The domain name to use in HELO command */
+	protected $domain = '[127.0.0.1]';
+
+	/** The event dispatching layer */
+	protected $eventDispatcher;
+
+	protected $addressEncoder;
+
+	/** Whether the PIPELINING SMTP extension is enabled (RFC 2920) */
+	protected $pipelining = null;
+
+	/** The pipelined commands waiting for response */
+	protected $pipeline = [];
+
+	/** Source Ip */
+	protected $sourceIp;
+
+	/** Return an array of params for the Buffer */
+	abstract protected function getBufferParams();
+
+	/**
+	 * Creates a new EsmtpTransport using the given I/O buffer.
+	 *
+	 * @param string $localDomain
+	 */
+	public function __construct(Swift_Transport_IoBuffer $buf, Swift_Events_EventDispatcher $dispatcher, $localDomain = '127.0.0.1', Swift_AddressEncoder $addressEncoder = null)
+	{
+		$this->buffer = $buf;
+		$this->eventDispatcher = $dispatcher;
+		$this->addressEncoder = $addressEncoder ?? new Swift_AddressEncoder_IdnAddressEncoder();
+		$this->setLocalDomain($localDomain);
+	}
+
+	/**
+	 * Set the name of the local domain which Swift will identify itself as.
+	 *
+	 * This should be a fully-qualified domain name and should be truly the domain
+	 * you're using.
+	 *
+	 * If your server does not have a domain name, use the IP address. This will
+	 * automatically be wrapped in square brackets as described in RFC 5321,
+	 * section 4.1.3.
+	 *
+	 * @param string $domain
+	 *
+	 * @return $this
+	 */
+	public function setLocalDomain($domain)
+	{
+		if ('[' !== substr($domain, 0, 1)) {
+			if (filter_var($domain, FILTER_VALIDATE_IP, FILTER_FLAG_IPV4)) {
+				$domain = '['.$domain.']';
+			} elseif (filter_var($domain, FILTER_VALIDATE_IP, FILTER_FLAG_IPV6)) {
+				$domain = '[IPv6:'.$domain.']';
+			}
+		}
+
+		$this->domain = $domain;
+
+		return $this;
+	}
+
+	/**
+	 * Get the name of the domain Swift will identify as.
+	 *
+	 * If an IP address was specified, this will be returned wrapped in square
+	 * brackets as described in RFC 5321, section 4.1.3.
+	 *
+	 * @return string
+	 */
+	public function getLocalDomain()
+	{
+		return $this->domain;
+	}
+
+	/**
+	 * Sets the source IP.
+	 *
+	 * @param string $source
+	 */
+	public function setSourceIp($source)
+	{
+		$this->sourceIp = $source;
+	}
+
+	/**
+	 * Returns the IP used to connect to the destination.
+	 *
+	 * @return string
+	 */
+	public function getSourceIp()
+	{
+		return $this->sourceIp;
+	}
+
+	public function setAddressEncoder(Swift_AddressEncoder $addressEncoder)
+	{
+		$this->addressEncoder = $addressEncoder;
+	}
+
+	public function getAddressEncoder()
+	{
+		return $this->addressEncoder;
+	}
+
+	/**
+	 * Start the SMTP connection.
+	 */
+	public function start()
+	{
+		if (!$this->started) {
+			if ($evt = $this->eventDispatcher->createTransportChangeEvent($this)) {
+				$this->eventDispatcher->dispatchEvent($evt, 'beforeTransportStarted');
+				if ($evt->bubbleCancelled()) {
+					return;
+				}
+			}
+
+			try {
+				$this->buffer->initialize($this->getBufferParams());
+			} catch (Swift_TransportException $e) {
+				$this->throwException($e);
+			}
+			$this->readGreeting();
+			$this->doHeloCommand();
+
+			if ($evt) {
+				$this->eventDispatcher->dispatchEvent($evt, 'transportStarted');
+			}
+
+			$this->started = true;
+		}
+	}
+
+	/**
+	 * Test if an SMTP connection has been established.
+	 *
+	 * @return bool
+	 */
+	public function isStarted()
+	{
+		return $this->started;
+	}
+
+	/**
+	 * Send the given Message.
+	 *
+	 * Recipient/sender data will be retrieved from the Message API.
+	 * The return value is the number of recipients who were accepted for delivery.
+	 *
+	 * @param string[] $failedRecipients An array of failures by-reference
+	 *
+	 * @return int
+	 */
+	public function send(Swift_Mime_SimpleMessage $message, &$failedRecipients = null)
+	{
+		if (!$this->isStarted()) {
+			$this->start();
+		}
+
+		$sent = 0;
+		$failedRecipients = (array) $failedRecipients;
+
+		if ($evt = $this->eventDispatcher->createSendEvent($this, $message)) {
+			$this->eventDispatcher->dispatchEvent($evt, 'beforeSendPerformed');
+			if ($evt->bubbleCancelled()) {
+				return 0;
+			}
+		}
+
+		if (!$reversePath = $this->getReversePath($message)) {
+			$this->throwException(new Swift_TransportException('Cannot send message without a sender address'));
+		}
+
+		$to = (array) $message->getTo();
+		$cc = (array) $message->getCc();
+		$bcc = (array) $message->getBcc();
+		$tos = array_merge($to, $cc, $bcc);
+
+		$message->setBcc([]);
+
+		try {
+			$sent += $this->sendTo($message, $reversePath, $tos, $failedRecipients);
+		} finally {
+			$message->setBcc($bcc);
+		}
+
+		if ($evt) {
+			if ($sent == \count($to) + \count($cc) + \count($bcc)) {
+				$evt->setResult(Swift_Events_SendEvent::RESULT_SUCCESS);
+			} elseif ($sent > 0) {
+				$evt->setResult(Swift_Events_SendEvent::RESULT_TENTATIVE);
+			} else {
+				$evt->setResult(Swift_Events_SendEvent::RESULT_FAILED);
+			}
+			$evt->setFailedRecipients($failedRecipients);
+			$this->eventDispatcher->dispatchEvent($evt, 'sendPerformed');
+		}
+
+		$message->generateId(); //Make sure a new Message ID is used
+
+		return $sent;
+	}
+
+	/**
+	 * Stop the SMTP connection.
+	 */
+	public function stop()
+	{
+		if ($this->started) {
+			if ($evt = $this->eventDispatcher->createTransportChangeEvent($this)) {
+				$this->eventDispatcher->dispatchEvent($evt, 'beforeTransportStopped');
+				if ($evt->bubbleCancelled()) {
+					return;
+				}
+			}
+
+			try {
+				$this->executeCommand("QUIT\r\n", [221]);
+			} catch (Swift_TransportException $e) {
+			}
+
+			try {
+				$this->buffer->terminate();
+
+				if ($evt) {
+					$this->eventDispatcher->dispatchEvent($evt, 'transportStopped');
+				}
+			} catch (Swift_TransportException $e) {
+				$this->throwException($e);
+			}
+		}
+		$this->started = false;
+	}
+
+	/**
+	 * {@inheritdoc}
+	 */
+	public function ping()
+	{
+		try {
+			if (!$this->isStarted()) {
+				$this->start();
+			}
+
+			$this->executeCommand("NOOP\r\n", [250]);
+		} catch (Swift_TransportException $e) {
+			try {
+				$this->stop();
+			} catch (Swift_TransportException $e) {
+			}
+
+			return false;
+		}
+
+		return true;
+	}
+
+	/**
+	 * Register a plugin.
+	 */
+	public function registerPlugin(Swift_Events_EventListener $plugin)
+	{
+		$this->eventDispatcher->bindEventListener($plugin);
+	}
+
+	/**
+	 * Reset the current mail transaction.
+	 */
+	public function reset()
+	{
+		$this->executeCommand("RSET\r\n", [250], $failures, true);
+	}
+
+	/**
+	 * Get the IoBuffer where read/writes are occurring.
+	 *
+	 * @return Swift_Transport_IoBuffer
+	 */
+	public function getBuffer()
+	{
+		return $this->buffer;
+	}
+
+	/**
+	 * Run a command against the buffer, expecting the given response codes.
+	 *
+	 * If no response codes are given, the response will not be validated.
+	 * If codes are given, an exception will be thrown on an invalid response.
+	 * If the command is RCPT TO, and the pipeline is non-empty, no exception
+	 * will be thrown; instead the failing address is added to $failures.
+	 *
+	 * @param string   $command
+	 * @param int[]    $codes
+	 * @param string[] $failures An array of failures by-reference
+	 * @param bool     $pipeline Do not wait for response
+	 * @param string   $address  the address, if command is RCPT TO
+	 *
+	 * @return string|null The server response, or null if pipelining is enabled
+	 */
+	public function executeCommand($command, $codes = [], &$failures = null, $pipeline = false, $address = null)
+	{
+		$failures = (array) $failures;
+		$seq = $this->buffer->write($command);
+		if ($evt = $this->eventDispatcher->createCommandEvent($this, $command, $codes)) {
+			$this->eventDispatcher->dispatchEvent($evt, 'commandSent');
+		}
+
+		$this->pipeline[] = [$command, $seq, $codes, $address];
+
+		if ($pipeline && $this->pipelining) {
+			return null;
+		}
+
+		$response = null;
+
+		while ($this->pipeline) {
+			list($command, $seq, $codes, $address) = array_shift($this->pipeline);
+			$response = $this->getFullResponse($seq);
+			try {
+				$this->assertResponseCode($response, $codes);
+			} catch (Swift_TransportException $e) {
+				if ($this->pipeline && $address) {
+					$failures[] = $address;
+				} else {
+					$this->throwException($e);
+				}
+			}
+		}
+
+		return $response;
+	}
+
+	/** Read the opening SMTP greeting */
+	protected function readGreeting()
+	{
+		$this->assertResponseCode($this->getFullResponse(0), [220]);
+	}
+
+	/** Send the HELO welcome */
+	protected function doHeloCommand()
+	{
+		$this->executeCommand(
+			sprintf("HELO %s\r\n", $this->domain), [250]
+			);
+	}
+
+	/** Send the MAIL FROM command */
+	protected function doMailFromCommand($address)
+	{
+		$address = $this->addressEncoder->encodeString($address);
+		$this->executeCommand(
+			sprintf("MAIL FROM:<%s>\r\n", $address), [250], $failures, true
+			);
+	}
+
+	/** Send the RCPT TO command */
+	protected function doRcptToCommand($address)
+	{
+		$address = $this->addressEncoder->encodeString($address);
+		$this->executeCommand(
+			sprintf("RCPT TO:<%s>\r\n", $address), [250, 251, 252], $failures, true, $address
+			);
+	}
+
+	/** Send the DATA command */
+	protected function doDataCommand(&$failedRecipients)
+	{
+		$this->executeCommand("DATA\r\n", [354], $failedRecipients);
+	}
+
+	/** Stream the contents of the message over the buffer */
+	protected function streamMessage(Swift_Mime_SimpleMessage $message)
+	{
+		$this->buffer->setWriteTranslations(["\r\n." => "\r\n.."]);
+		try {
+			$message->toByteStream($this->buffer);
+			$this->buffer->flushBuffers();
+		} catch (Swift_TransportException $e) {
+			$this->throwException($e);
+		}
+		$this->buffer->setWriteTranslations([]);
+		$this->executeCommand("\r\n.\r\n", [250]);
+	}
+
+	/** Determine the best-use reverse path for this message */
+	protected function getReversePath(Swift_Mime_SimpleMessage $message)
+	{
+		$return = $message->getReturnPath();
+		$sender = $message->getSender();
+		$from = $message->getFrom();
+		$path = null;
+		if (!empty($return)) {
+			$path = $return;
+		} elseif (!empty($sender)) {
+			// Don't use array_keys
+			reset($sender); // Reset Pointer to first pos
+			$path = key($sender); // Get key
+		} elseif (!empty($from)) {
+			reset($from); // Reset Pointer to first pos
+			$path = key($from); // Get key
+		}
+
+		return $path;
+	}
+
+	/** Throw a TransportException, first sending it to any listeners */
+	protected function throwException(Swift_TransportException $e)
+	{
+		if ($evt = $this->eventDispatcher->createTransportExceptionEvent($this, $e)) {
+			$this->eventDispatcher->dispatchEvent($evt, 'exceptionThrown');
+			if (!$evt->bubbleCancelled()) {
+				throw $e;
+			}
+		} else {
+			throw $e;
+		}
+	}
+
+	/** Throws an Exception if a response code is incorrect */
+	protected function assertResponseCode($response, $wanted)
+	{
+		if (!$response) {
+			$this->throwException(new Swift_TransportException('Expected response code '.implode('/', $wanted).' but got an empty response'));
+		}
+
+		list($code) = sscanf($response, '%3d');
+		$valid = (empty($wanted) || \in_array($code, $wanted));
+
+		if ($evt = $this->eventDispatcher->createResponseEvent($this, $response,
+			$valid)) {
+			$this->eventDispatcher->dispatchEvent($evt, 'responseReceived');
+		}
+
+		if (!$valid) {
+			$this->throwException(new Swift_TransportException('Expected response code '.implode('/', $wanted).' but got code "'.$code.'", with message "'.$response.'"', $code));
+		}
+	}
+
+	/** Get an entire multi-line response using its sequence number */
+	protected function getFullResponse($seq)
+	{
+		$response = '';
+		try {
+			do {
+				$line = $this->buffer->readLine($seq);
+				$response .= $line;
+			} while (null !== $line && false !== $line && ' ' != $line[3]);
+		} catch (Swift_TransportException $e) {
+			$this->throwException($e);
+		} catch (Swift_IoException $e) {
+			$this->throwException(new Swift_TransportException($e->getMessage(), 0, $e));
+		}
+
+		return $response;
+	}
+
+	/** Send an email to the given recipients from the given reverse path */
+	private function doMailTransaction($message, $reversePath, array $recipients, array &$failedRecipients)
+	{
+		$sent = 0;
+		$this->doMailFromCommand($reversePath);
+		foreach ($recipients as $forwardPath) {
+			try {
+				$this->doRcptToCommand($forwardPath);
+				++$sent;
+			} catch (Swift_TransportException $e) {
+				$failedRecipients[] = $forwardPath;
+			} catch (Swift_AddressEncoderException $e) {
+				$failedRecipients[] = $forwardPath;
+			}
+		}
+
+		if (0 != $sent) {
+			$sent += \count($failedRecipients);
+			$this->doDataCommand($failedRecipients);
+			$sent -= \count($failedRecipients);
+
+			$this->streamMessage($message);
+		} else {
+			$this->reset();
+		}
+
+		return $sent;
+	}
+
+	/** Send a message to the given To: recipients */
+	private function sendTo(Swift_Mime_SimpleMessage $message, $reversePath, array $to, array &$failedRecipients)
+	{
+		if (empty($to)) {
+			return 0;
+		}
+
+		return $this->doMailTransaction($message, $reversePath, array_keys($to),
+			$failedRecipients);
+	}
+
+	/**
+	 * Destructor.
+	 */
+	public function __destruct()
+	{
+		try {
+			$this->stop();
+		} catch (Exception $e) {
+		}
+	}
+
+	public function __sleep()
+	{
+		throw new \BadMethodCallException('Cannot serialize '.__CLASS__);
+	}
+
+	public function __wakeup()
+	{
+		throw new \BadMethodCallException('Cannot unserialize '.__CLASS__);
+	}
 }

htdocs/includes/swiftmailer/lib/classes/Swift/Transport/LoadBalancedTransport.php

Indentation +174 added lines, -174 removed lines

@@ -15,178 +15,178 @@
  */
 class Swift_Transport_LoadBalancedTransport implements Swift_Transport
 {
-    /**
-     * Transports which are deemed useless.
-     *
-     * @var Swift_Transport[]
-     */
-    private $deadTransports = [];
-
-    /**
-     * The Transports which are used in rotation.
-     *
-     * @var Swift_Transport[]
-     */
-    protected $transports = [];
-
-    /**
-     * The Transport used in the last successful send operation.
-     *
-     * @var Swift_Transport
-     */
-    protected $lastUsedTransport = null;
-
-    // needed as __construct is called from elsewhere explicitly
-    public function __construct()
-    {
-    }
-
-    /**
-     * Set $transports to delegate to.
-     *
-     * @param Swift_Transport[] $transports
-     */
-    public function setTransports(array $transports)
-    {
-        $this->transports = $transports;
-        $this->deadTransports = [];
-    }
-
-    /**
-     * Get $transports to delegate to.
-     *
-     * @return Swift_Transport[]
-     */
-    public function getTransports()
-    {
-        return array_merge($this->transports, $this->deadTransports);
-    }
-
-    /**
-     * Get the Transport used in the last successful send operation.
-     *
-     * @return Swift_Transport
-     */
-    public function getLastUsedTransport()
-    {
-        return $this->lastUsedTransport;
-    }
-
-    /**
-     * Test if this Transport mechanism has started.
-     *
-     * @return bool
-     */
-    public function isStarted()
-    {
-        return \count($this->transports) > 0;
-    }
-
-    /**
-     * Start this Transport mechanism.
-     */
-    public function start()
-    {
-        $this->transports = array_merge($this->transports, $this->deadTransports);
-    }
-
-    /**
-     * Stop this Transport mechanism.
-     */
-    public function stop()
-    {
-        foreach ($this->transports as $transport) {
-            $transport->stop();
-        }
-    }
-
-    /**
-     * {@inheritdoc}
-     */
-    public function ping()
-    {
-        foreach ($this->transports as $transport) {
-            if (!$transport->ping()) {
-                $this->killCurrentTransport();
-            }
-        }
-
-        return \count($this->transports) > 0;
-    }
-
-    /**
-     * Send the given Message.
-     *
-     * Recipient/sender data will be retrieved from the Message API.
-     * The return value is the number of recipients who were accepted for delivery.
-     *
-     * @param string[] $failedRecipients An array of failures by-reference
-     *
-     * @return int
-     */
-    public function send(Swift_Mime_SimpleMessage $message, &$failedRecipients = null)
-    {
-        $maxTransports = \count($this->transports);
-        $sent = 0;
-        $this->lastUsedTransport = null;
-
-        for ($i = 0; $i < $maxTransports
-            && $transport = $this->getNextTransport(); ++$i) {
-            try {
-                if (!$transport->isStarted()) {
-                    $transport->start();
-                }
-                if ($sent = $transport->send($message, $failedRecipients)) {
-                    $this->lastUsedTransport = $transport;
-                    break;
-                }
-            } catch (Swift_TransportException $e) {
-                $this->killCurrentTransport();
-            }
-        }
-
-        if (0 == \count($this->transports)) {
-            throw new Swift_TransportException('All Transports in LoadBalancedTransport failed, or no Transports available');
-        }
-
-        return $sent;
-    }
-
-    /**
-     * Register a plugin.
-     */
-    public function registerPlugin(Swift_Events_EventListener $plugin)
-    {
-        foreach ($this->transports as $transport) {
-            $transport->registerPlugin($plugin);
-        }
-    }
-
-    /**
-     * Rotates the transport list around and returns the first instance.
-     *
-     * @return Swift_Transport
-     */
-    protected function getNextTransport()
-    {
-        if ($next = array_shift($this->transports)) {
-            $this->transports[] = $next;
-        }
-
-        return $next;
-    }
-
-    /**
-     * Tag the currently used (top of stack) transport as dead/useless.
-     */
-    protected function killCurrentTransport()
-    {
-        if ($transport = array_pop($this->transports)) {
-            try {
-                $transport->stop();
-            } catch (Exception $e) {
-            }
-            $this->deadTransports[] = $transport;
-        }
-    }
+	/**
+	 * Transports which are deemed useless.
+	 *
+	 * @var Swift_Transport[]
+	 */
+	private $deadTransports = [];
+
+	/**
+	 * The Transports which are used in rotation.
+	 *
+	 * @var Swift_Transport[]
+	 */
+	protected $transports = [];
+
+	/**
+	 * The Transport used in the last successful send operation.
+	 *
+	 * @var Swift_Transport
+	 */
+	protected $lastUsedTransport = null;
+
+	// needed as __construct is called from elsewhere explicitly
+	public function __construct()
+	{
+	}
+
+	/**
+	 * Set $transports to delegate to.
+	 *
+	 * @param Swift_Transport[] $transports
+	 */
+	public function setTransports(array $transports)
+	{
+		$this->transports = $transports;
+		$this->deadTransports = [];
+	}
+
+	/**
+	 * Get $transports to delegate to.
+	 *
+	 * @return Swift_Transport[]
+	 */
+	public function getTransports()
+	{
+		return array_merge($this->transports, $this->deadTransports);
+	}
+
+	/**
+	 * Get the Transport used in the last successful send operation.
+	 *
+	 * @return Swift_Transport
+	 */
+	public function getLastUsedTransport()
+	{
+		return $this->lastUsedTransport;
+	}
+
+	/**
+	 * Test if this Transport mechanism has started.
+	 *
+	 * @return bool
+	 */
+	public function isStarted()
+	{
+		return \count($this->transports) > 0;
+	}
+
+	/**
+	 * Start this Transport mechanism.
+	 */
+	public function start()
+	{
+		$this->transports = array_merge($this->transports, $this->deadTransports);
+	}
+
+	/**
+	 * Stop this Transport mechanism.
+	 */
+	public function stop()
+	{
+		foreach ($this->transports as $transport) {
+			$transport->stop();
+		}
+	}
+
+	/**
+	 * {@inheritdoc}
+	 */
+	public function ping()
+	{
+		foreach ($this->transports as $transport) {
+			if (!$transport->ping()) {
+				$this->killCurrentTransport();
+			}
+		}
+
+		return \count($this->transports) > 0;
+	}
+
+	/**
+	 * Send the given Message.
+	 *
+	 * Recipient/sender data will be retrieved from the Message API.
+	 * The return value is the number of recipients who were accepted for delivery.
+	 *
+	 * @param string[] $failedRecipients An array of failures by-reference
+	 *
+	 * @return int
+	 */
+	public function send(Swift_Mime_SimpleMessage $message, &$failedRecipients = null)
+	{
+		$maxTransports = \count($this->transports);
+		$sent = 0;
+		$this->lastUsedTransport = null;
+
+		for ($i = 0; $i < $maxTransports
+			&& $transport = $this->getNextTransport(); ++$i) {
+			try {
+				if (!$transport->isStarted()) {
+					$transport->start();
+				}
+				if ($sent = $transport->send($message, $failedRecipients)) {
+					$this->lastUsedTransport = $transport;
+					break;
+				}
+			} catch (Swift_TransportException $e) {
+				$this->killCurrentTransport();
+			}
+		}
+
+		if (0 == \count($this->transports)) {
+			throw new Swift_TransportException('All Transports in LoadBalancedTransport failed, or no Transports available');
+		}
+
+		return $sent;
+	}
+
+	/**
+	 * Register a plugin.
+	 */
+	public function registerPlugin(Swift_Events_EventListener $plugin)
+	{
+		foreach ($this->transports as $transport) {
+			$transport->registerPlugin($plugin);
+		}
+	}
+
+	/**
+	 * Rotates the transport list around and returns the first instance.
+	 *
+	 * @return Swift_Transport
+	 */
+	protected function getNextTransport()
+	{
+		if ($next = array_shift($this->transports)) {
+			$this->transports[] = $next;
+		}
+
+		return $next;
+	}
+
+	/**
+	 * Tag the currently used (top of stack) transport as dead/useless.
+	 */
+	protected function killCurrentTransport()
+	{
+		if ($transport = array_pop($this->transports)) {
+			try {
+				$transport->stop();
+			} catch (Exception $e) {
+			}
+			$this->deadTransports[] = $transport;
+		}
+	}
 }