<?php

namespace AcyMailing\Controllers;

use AcyMailing\Classes\QueueClass;
use AcyMailing\Helpers\QueueHelper;
use AcyMailing\Core\AcymController;
use AcyMailing\Controllers\Queue\Campaigns;
use AcyMailing\Controllers\Queue\Scheduled;
use AcyMailing\Controllers\Queue\Detailed;

class QueueController extends AcymController
{
    use Campaigns;
    use Scheduled;
    use Detailed;

    public function __construct()
    {
        parent::__construct();

        $this->breadcrumb[acym_translation('ACYM_QUEUE')] = acym_completeLink('queue');
        $this->setDefaultTask('campaigns');
    }

    public function scheduleReady(): void
    {
        $queueClass = new QueueClass();
        $queueClass->scheduleReady();
    }

    public function continuesend(): void
    {
        wp_verify_nonce(acym_getVar('cmd', '_wpnonce'), 'acymnonce') || die('Invalid Token');

        //Are we configured to use the automatic send process only?
        //If so, we don't allow the user to access this feature!
        if ($this->config->get('queue_type') === 'onlyauto') {
            acym_setNoTemplate();
            acym_display(acym_translation('ACYM_ONLYAUTOPROCESS'), 'warning');

            exit;
        }

        //we move the next cron task so that we won't have problem with double send process
        $newCronTime = time() + 120;
        if ($this->config->get('cron_next') < $newCronTime) {
            $this->config->saveConfig(['cron_next' => $newCronTime]);
        }

        $mailid = acym_getCID('id');

        $totalSend = acym_getVar('int', 'totalsend', 0);
        if (empty($totalSend)) {
            $query = 'SELECT COUNT(queue.user_id) FROM #__acym_queue AS queue LEFT JOIN #__acym_campaign AS campaign ON queue.mail_id = campaign.mail_id WHERE (campaign.id IS NULL OR campaign.active = 1) AND queue.sending_date < '.acym_escapeDB(
                    acym_date('now', 'Y-m-d H:i:s', false)
                );
            if (!empty($mailid)) {
                $query .= ' AND queue.mail_id = '.intval($mailid);
            }
            $totalSend = acym_loadResult($query);
        }

        $alreadySent = acym_getVar('int', 'alreadysent', 0);

        $queueHelper = new QueueHelper();
        $queueHelper->id = $mailid;
        $queueHelper->report = true;
        $queueHelper->total = (int)$totalSend;
        $queueHelper->start = $alreadySent;
        $queueHelper->pause = (int)$this->config->get('queue_pause', 0);
        // ->Process will exit the current page if it needs to be continued
        $queueHelper->fromManual = true;
        $queueHelper->process();

        //We should never be there... but if the user tries to resume the send process and the messages are not ready to be sent then it will land here...
        acym_setNoTemplate();
        exit;
    }
}