MikoPBX\Core\Workers\WorkerNotifyByEmail

Complexity

Total Complexity

10

Size/Duplication

Total Lines	87
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	start()	0	8	2
B	workerNotifyByEmail()	0	43	7
A	replaceParams()	0	20	1

<?php
/*
 * MikoPBX - free phone system for small business
 * Copyright (C) 2017-2020 Alexey Portnov and Nikolay Beketov
 *
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 3 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License along with this program.
 * If not, see <https://www.gnu.org/licenses/>.
 */

namespace MikoPBX\Core\Workers;
require_once 'Globals.php';
use MikoPBX\Core\System\{BeanstalkClient, MikoPBXConfig, Notifications, Util};
use Throwable;


class WorkerNotifyByEmail extends WorkerBase
{
    /**
     * Entry point
     *
     * @param $argv
     */
    public function start($argv): void
    {
        $client = new BeanstalkClient(__CLASS__);
        $client->subscribe(__CLASS__, [$this, 'workerNotifyByEmail']);
        $client->subscribe($this->makePingTubeName(self::class), [$this, 'pingCallBack']);

        while ($this->needRestart === false) {
            $client->wait();
        }
    }

    private function replaceParams(string $src, array $params):string
    {
        return str_replace(
            [
                "\n",
                "NOTIFICATION_MISSEDCAUSE",
                "NOTIFICATION_CALLERID",
                "NOTIFICATION_TO",
                "NOTIFICATION_DURATION",
                "NOTIFICATION_DATE"
            ],
            [
                "<br>",
                'NOANSWER',
                $params['from_number'],
                $params['to_number'],
                $params['duration'],
                explode('.', $params['start'])[0]
            ],
            $src);
    }

    /**
     * Main worker
     * @param $message
     */
    public function workerNotifyByEmail($message): void
    {
        $notifier = new Notifications();
        $config   = new MikoPBXConfig();
        $settings = $config->getGeneralSettings();

        /** @var BeanstalkClient $message */
        $data = json_decode($message->getBody(), true);

        $template_body    = $settings['MailTplMissedCallBody'];
        $template_subject = $settings['MailTplMissedCallSubject'];
        if(empty($template_subject)){
            $template_subject = Util::translate("You have missing call") . ' <-- NOTIFICATION_CALLERID';
        }
        $template_Footer  = $settings['MailTplMissedCallFooter'];
        $emails           = [];

        $tmpArray = [];
        foreach ($data as $call) {
            $keyHash = $call['email'].$call['start'].$call['from_number'].$call['to_number'];
            if(in_array($keyHash, $tmpArray, true)){
                continue;
            }
            $tmpArray[] = $keyHash;
            if (!isset($emails[$call['email']])) {
                $emails[$call['email']] = [
                    'subject' => $this->replaceParams($template_subject, $call),
                    'body'    => '',
                    'footer'  => $this->replaceParams($template_Footer, $call),
                ];
            }
            if (!empty($template_body)) {
                $email = $this->replaceParams($template_body, $call);
                $emails[$call['email']]['body'] .= "$email <br><hr><br>";
            }
        }

        foreach ($emails as $to => $email) {
            $subject = $email['subject'];
            $body = "{$email['body']}<br>{$email['footer']}";
            $notifier->sendMail($to, $subject, $body);
        }
        sleep(1);
    }
}

// Start worker process
WorkerNotifyByEmail::startWorker($argv??null);