alexdodonov / mezon-pop3-client

Client.php

<?php
namespace Mezon\Pop3;

/**
 * Class Client
 *
 * @package Mezon
 * @subpackage Pop3Client
 * @author Dodonov A.A.
 * @version v.1.0 (2019/08/13)
 * @copyright Copyright (c) 2019, aeon.org
 */

/**
 * POP3 protocol client.
 */
class Client
{

    /**
     * Connection
     * 
     * @var resource
     */
    private $connection = null;

    /**
     * Method connects to server
     *
     * @param string $server
     *            Server domain
     * @param string $login
     *            Login
     * @param string $password
     *            Password
     * @param int $timeOut
     *            Timeout
     * @param int $port
     *            Port number
     */
    public function connect(string $server, string $login, string $password, int $timeOut = 5, int $port = 110)
    {
        try {
            $errorMessage = '';
            $errorCode = 0;

            $context = stream_context_create([
                'ssl' => [
                    'verify_peer' => false
                ]
            ]);

            $this->connection = stream_socket_client(

It seems like stream_socket_client($server . ':'.$port, $errorCode, $errorMessage, $timeOut, Mezon\Pop3\STREAM_CLIENT_CONNECT, $context) can also be of type false. However, the property $connection is declared as type resource. Maybe add an additional type check?

                $server . ":$port",
                $errorCode,
                $errorMessage,
                $timeOut,
                STREAM_CLIENT_CONNECT,
                $context);

            if ($this->connection === false) {
                throw (new \Exception('Connection was not established', - 1));
            }

            $result = fgets($this->connection, 1024);

            if (substr($result, 0, 3) !== '+OK') {
                throw (new \Exception('Connection. ' . $result, 0));
            }

            fputs($this->connection, "USER $login\r\n");

            $result = fgets($this->connection, 1024);

            if (substr($result, 0, 3) !== '+OK') {
                throw (new \Exception("USER $login " . $result, 0));
            }

            fputs($this->connection, "PASS $password\r\n");

            $result = fgets($this->connection, 1024);

            if (substr($result, 0, 3) !== '+OK') {
                throw (new \Exception("PASS " . $result . $login, 0));
            }
        } catch (\Exception $e) {
            throw ($e);
        }
    }

    /**
     * Constructor
     *
     * @param string $server
     *            Server domain
     * @param string $login
     *            Login
     * @param string $password
     *            Password
     * @param int $timeOut
     *            Timeout
     * @param int $port
     *            Port number
     */
    public function __construct(string $server, string $login, string $password, int $timeOut = 5, int $port = 110)
    {
        $this->connect($server, $login, $password, $timeOut, $port);
    }

    /**
     * Method returns emails count.
     */
    public function getCount(): int
    {
        fputs($this->connection, "STAT\r\n");

        $result = fgets($this->connection, 1024);

        if (substr($result, 0, 3) !== '+OK') {
            throw (new \Exception("STAT " . $result, 0));
        }

        $result = explode(' ', $result);

        return intval($result[1]);
    }

    /**
     * Method returns data from connection
     *
     * @return string Fetched data
     */
    protected function getData(): string
    {
        $data = '';

        while (! feof($this->connection)) {
            $buffer = chop(fgets($this->connection, 1024));

            if (strpos($buffer, '-ERR') === 0) {
                throw (new \Exception(str_replace('-ERR ', '', $buffer), 0));
            }

            $data .= "$buffer\r\n";

            if (trim($buffer) == '.') {
                break;
            }
        }

        return $data;
    }

    /**
     * Method returns email's headers
     *
     * @param int $i
     *            Number of the message
     * @return string Headers
     */
    public function getMessageHeaders(int $i): string
    {
        fputs($this->connection, "TOP $i 3\r\n");

        return $this->getData();
    }

    /**
     * Method deletes email
     *
     * @param int $i
     *            Number of the message
     * @return string Result of the deletion
     */
    public function deleteMessage($i): string
    {
        fputs($this->connection, "DELE $i\r\n");

        return fgets($this->connection);
    }

    /**
     * Method terminates session
     */
    public function quit()
    {
        fputs($this->connection, "QUIT\r\n");
    }

    /**
     * Method parses subject with any prefix
     *
     * @param string $line
     *            Line of the email
     * @param int $i
     *            Line cursor
     * @param array $headers
     *            Email headers
     * @param string $type
     *            Mime type
     * @return string Decoded data
     */
    protected function parseAnyType(string $line, int $i, array $headers, string $type): string
    {
        $subject = substr($line, 0, strlen($line) - 2);

        $count = count($headers);
        for ($j = $i + 1; $j < $count; $j ++) {
            if (substr($headers[$j], 0, 1) == ' ') {
                $subject .= str_replace([
                    ' ' . $type,
                    '?='
                ], [
                    '',
                    ''
                ], $headers[$j]);
            } else {
                return str_replace('Subject: ', '', iconv_mime_decode($subject . "?=\r\n", 0, "UTF-8"));
            }
        }

        return '';
    }

    /**
     * Method returns message's subject
     *
     * @param int $i
     *            Line number
     * @return string Decoded data
     */
    public function getMessageSubject(int $i): string
    {
        $headers = $this->getMessageHeaders($i);

        $headers = explode("\r\n", $headers);

        foreach ($headers as $i => $line) {
            if (strpos($line, 'Subject: ') === 0) {
                if (strpos($line, '=?UTF-8?Q?') !== false) {
                    return $this->parseAnyType($line, $i, $headers, '=?UTF-8?Q?');
                } elseif (strpos($line, '=?UTF-8?B?') !== false) {
                    return $this->parseAnyType($line, $i, $headers, '=?UTF-8?B?');
                }
            }
        }

        return '';
    }

    /**
     * Method returns true if the mail with the specified subject exists
     *
     * @param string $subject
     *            Searching subject
     * @return bool Email exists
     */
    public function messageWithSubjectExists(string $subject): bool
    {
        $count = $this->getCount();

        for ($i = 1; $i <= $count; $i ++) {
            $mailSubject = $this->getMessageSubject($i);

            if ($subject == $mailSubject) {
                return true;
            }
        }

        return false;
    }

    /**
     * Method removes all the mails with the specified subject
     *
     * @param string $subject
     *            subject of emails to be deleted
     */
    public function deleteMessagesWithSubject(string $subject)
    {
        $count = $this->getCount();

        for ($i = 1; $i <= $count; $i ++) {
            $mailSubject = $this->getMessageSubject($i);

            if ($subject == $mailSubject) {
                $this->deleteMessage($i);
            }
        }
    }

    /**
     * Method returns Message-ID
     *
     * @param string $headers
     *            email headers
     * @return string Message-ID
     */
    public static function getMessageId(string $headers): string
    {
        $matches = [];

        preg_match('/Message-ID: <([0-9a-zA-Z\.@\-]*)>/mi', $headers, $matches);

        return $matches[1];
    }
}