<?php

/**
 * DeliveryHandler class.
 *
 * Abstract class for different types of delivery handlers
 *
 * LICENSE: This product includes software developed at
 * the Acelle Co., Ltd. (http://acellemail.com/).
 *
 * @category   MVC Model
 *
 * @author     N. Pham <[email protected]>
 * @author     L. Pham <[email protected]>
 * @copyright  Acelle Co., Ltd
 * @license    Acelle Co., Ltd
 *
 * @version    1.0
 *
 * @link       http://acellemail.com
 */

namespace App\Model;

use Illuminate\Database\Eloquent\Model;
use App\Library\StringHelper;
use Carbon\Carbon;
use Monolog\Logger;
use Monolog\Handler\RotatingFileHandler;
use Monolog\Formatter\LineFormatter;

class DeliveryHandler extends Model
{

    protected $logger;

    public function logger()
    {
        if (!is_null($this->logger)) {
            return $this->logger;
        }

        $formatter = new LineFormatter("[%datetime%] %channel%.%level_name%: %message%\n");

        $logfile = $this->getLogFile();
        $stream = new RotatingFileHandler($logfile, 0, 'debug');

        $stream->setFormatter($formatter);

        $pid = getmypid();
        $logger = new Logger($pid);
        $logger->pushHandler($stream);

        $this->logger = $logger;

        return $this->logger;
    }

    public function getLogFile()
    {
        return storage_path('logs/' . php_sapi_name() . '/'.$this->logfile.'-'.$this->uid.'.log');
    }

    /**
     * Test the handler connection.
     *
     * @return mixed
     */
    public function test()
    {
        $this->logger()->info('Start testing');

        // Connect to IMAP server
        $imapPath = "{{$this->host}:{$this->port}/{$this->protocol}/{$this->encryption}}INBOX";

        // try to connect
        $inbox = @imap_open($imapPath, $this->username, $this->password);

        // try again with ssl/novalidate-cert
        if ($inbox == false) {
            if (strcasecmp($this->encryption, 'ssl') == 0) {
                $this->logger()->warning('Try using ssl/novalidate-cert instead');
                $imapPath = "{{$this->host}:{$this->port}/{$this->protocol}/ssl/novalidate-cert}INBOX";
                $inbox = @imap_open($imapPath, $this->username, $this->password);
            }
        }

        // if failed
        if ($inbox == false) {
            $this->logger()->error("Cannot connect to the server: $imapPath");
            throw new \Exception("Cannot connect to the server: $imapPath");
        }

        // search and get unseen emails, function will return email ids
        $emails = imap_search($inbox, 'UNSEEN');

        // close the connection
        imap_expunge($inbox);
        imap_close($inbox);

        $this->logger()->info("Testing OK");

        return true;
    }

    /**
     * Start the handling processes.
     *
     * @return mixed
     */
    public function start($debug = false)
    {
        $this->logger()->info("Starting...");
        try {
            // Connect to IMAP server
            $imapPath = "{{$this->host}:{$this->port}/{$this->protocol}/{$this->encryption}}INBOX";

            // try to connect
            try {
                $inbox = @imap_open($imapPath, $this->username, $this->password);
            } catch (\Exception $ex) {
                $this->logger()->info("Failed imap_open: ".$ex->getMessage().":\n".$ex->getTraceAsString());
                $inbox = false;
            }


            // try again with ssl/novalidate-cert
            if ($inbox == false) {
                if (strcasecmp($this->encryption, 'ssl') == 0) {
                    $this->logger()->warning('Try using ssl/novalidate-cert instead');
                    $imapPath = "{{$this->host}:{$this->port}/{$this->protocol}/ssl/novalidate-cert}INBOX";
                    $inbox = @imap_open($imapPath, $this->username, $this->password);
                }
            }

            // if failed
            if ($inbox == false) {
                $this->logger()->error("Cannot connect to the server: $imapPath");
                throw new \Exception("Cannot connect to the server: $imapPath");
            }

            // search and get unseen emails, function will return email ids
            $emails = imap_search($inbox, 'UNSEEN');

            $count = 1;
            if (!empty($emails)) {
                $this->logger()->info(sprintf('%s unread emails found', sizeof($emails)));

                foreach ($emails as $message) {
                    $this->logger()->info(sprintf('Processing message %s/%s', $count, sizeof($emails)));
                    $this->processMessage($inbox, $message);
                    $count += 1;
                }
            }

            // colse the connection
            imap_expunge($inbox);
            imap_close($inbox);
        } catch (\Exception $e) {
            // suppress the IMAP error
            // see http://stackoverflow.com/questions/5422405/cant-silence-imap-open-error-notices-in-php
            imap_errors();
            imap_alerts();
            $this->logger()->error('Failed. '.$e->getMessage());
        } finally {
            $this->logger()->info("Done!");
        }
    }

    /**
     * Extract message ID from email .
     *
     * @return string
     */
    public function getMessageId($message)
    {
        preg_match('/(?<=X-Acelle-Message-Id:)\s{0,1}<{0,1}(?<id>[a-zA-Z0-9\.]+[a-zA-Z0-9]+@[a-zA-Z0-9\.\-]+[a-zA-Z0-9]+)/', $message, $matched);
        if (array_key_exists('id', $matched)) {
            return StringHelper::cleanupMessageId($matched['id']);
        }

        // more tolerant matching (case-insensitive, no need for Acelle prefix, etc.)
        preg_match('/(?<=Message-Id:)\s{0,1}<{0,1}(?<id>[a-zA-Z0-9\.]+[a-zA-Z0-9]+@[a-zA-Z0-9\.\-]+[a-zA-Z0-9]+)/i', $message, $matched);
        if (array_key_exists('id', $matched)) {
            return StringHelper::cleanupMessageId($matched['id']);
        }

        return;
    }

    public function getAcxMessageId()
    {
        preg_match('/(?<=X-Acelle-Message-Id:)\s{0,1}<{0,1}(?<id>[a-zA-Z0-9-\.]+[a-zA-Z0-9-]+@[a-zA-Z0-9\.\-]+[a-zA-Z0-9]+)/', $message, $matched);

        return $matched['id'] ?? null;
    }

    public function getClientMessageId()
    {
        preg_match('/(?<=X-Client-Message-Id:)\s{0,1}<{0,1}(?<id>[a-zA-Z0-9-\.]+[a-zA-Z0-9-]+@[a-zA-Z0-9\.\-]+[a-zA-Z0-9]+)/', $message, $matched);

        return $matched['id'] ?? null;
    }

    /**
     * Process bounced / feedback loop messages.
     *
     * @return mixed
     */
    public function processMessage($mbox, $message)
    {
        // for overwriting
    }
}