Send::handle() - Code Metrics - 24Slides/auth-connector - Measure and Improve Code Quality continuously with Scrutinizer

Send::handle() B
last analyzed 2020-10-26 19:06 UTC

↳ Parent: Send
Complexity

Conditions	7
Paths	26
Size

Total Lines	49
Code Lines	27
Duplication

Lines	0
Ratio	0 %
Code Coverage

Tests	0
CRAP Score	56
Importance

Changes	1
Bugs	0	Features	0
Metric	Value
cc	7
eloc	27
c	1
b	0
f	0
nc	26
nop	0
dl	0
loc	49
ccs	0
cts	28
cp	0
crap	56
rs	8.5546
<?php

namespace Slides\Connector\Auth\Clients\Mandrill\Commands;

use Exception;
use Illuminate\Console\Command;
use Illuminate\Support\Fluent;
use Illuminate\Support\Str;
use Slides\Connector\Auth\Clients\Mandrill\Client;
use Slides\Connector\Auth\Clients\Mandrill\Mailer;
use Slides\Connector\Auth\Helpers\ConsoleHelper;

/**
 * Class Send
 *
 * @package Slides\Connector\Auth\Clients\Mandrill\Commands
 */
class Send extends Command
{
    /**
     * The name and signature of the console command.
     *
     * @var string
     */
    protected $signature = 'mandrill:send
                           {--r|recipients=   : The list of recipients or name of the file with recipients }
                           {--t|template=     : Name of the email template }
                           {--p|params=       : The list of parameters for an email }
                           {--c|context=      : The list of context variables }
                           {--f|from=         : The sender email address and name }
                           {--apiToken=       : The Mandrill API token }
                           {--s|subject=      : The message subject }
                           {--tags=           : The list of message tags }';

    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = 'Send a new transactional message through Mandrill using a template.';

    /**
     * @var Client
     */
    protected $client;

    /**
     * @var array
     */
    protected $result = [
        'requests' => 0,
        'emails' => 0,
        'success' => 0,
        'failed' => [],
        'responses' => null
    ];

    /**
     * @var Mailer
     */
    protected $mailer;

    /**
     * Send constructor.
     *
     * @param Mailer $mailer
     */
    public function __construct(Mailer $mailer)
    {
        $this->mailer = $mailer;

        parent::__construct();
    }

    /**
     * Execute the console command.
     *
     * @return void|null
     *
     * @throws Exception
     */
    public function handle()
    {
        $recipients = $this->resolveRecipients();

        if ($secret = $this->option('apiToken')) {
            $this->mailer = $this->mailer->setToken($secret);
        }

        if (!$template = $this->option('template')) {
            throw new Exception('Please, pass the --template option');
        }

        $builder = $this->mailer->template($template)
            ->recipients($recipients)
            ->variables(ConsoleHelper::stringToArray($this->option('params')))
            ->context(ConsoleHelper::stringToArray($this->option('context')))
            ->tags(ConsoleHelper::stringToArray($this->option('tags')));

        if ($from = $this->option('from')) {
            $builder->from(...array_pad(explode(':', $from), 2, null));
            $builder->from(/** @scrutinizer ignore-type */ ...array_pad(explode(':', $from), 2, null));
        }

        if ($subject = $this->option('subject')) {
            $builder->subject($subject);
        }

        if (!$this->confirm('Do you want to send ' . count($recipients) . ' emails?', true)) {
            return;
        }

        $start = time();

        $bar = $this->output->createProgressBar();
        $this->output->newLine('2');
        $bar->start(count($recipients));

        foreach ($builder->sendChunk(1000) as $response) {
            $this->parseResponse($response);
            $this->parseResponse(/** @scrutinizer ignore-type */ $response);

            $bar->advance(count($response));
            $bar->advance(count(/** @scrutinizer ignore-type */ $response));
        }

        $bar->finish();

        $this->output->newLine(2);

        $this->result['spent'] = time() - $start;

        $this->printResult(new Fluent($this->result));
    }

    /**
     * Resolve email recipients.
     *
     * @return array|null
     *
     * @throws Exception
     */
    protected function resolveRecipients(): ?array
    {
        if (!$option = $this->option('recipients')) {
            throw new Exception('Please, pass the --recipients option');
        }

        return Str::contains($option, '@')
            ? ConsoleHelper::stringToArray($option)
            : explode(PHP_EOL, file_get_contents($option));
    }

    /**
     * Parse Mandrill response.
     *
     * @param array $response
     *
     * @return void
     */
    protected function parseResponse(array $response): void
    {
        $result = collect($response);

        $this->result['requests']++;
        $this->result['emails'] += $result->count();
        $this->result['success'] += $result->whereNotIn('status', ['rejected', 'invalid'])->count();

        $this->result['failed'] = $result->whereIn('status', ['rejected', 'invalid'])->pluck('email')->merge($this->result['failed'])->toArray();
        $this->result['responses'] .= json_encode($response) . PHP_EOL;
    }

    /**
     * Print the result of execution.
     *
     * @param Fluent $result
     *
     * @return void
     */
    protected function printResult(Fluent $result): void
    {
        $this->warn('######################################################');

        $this->comment('Number of requests: ' . $result->get('requests'));
        $this->comment('Number of emails: ' . $result->get('emails'));
        $this->comment('Success: ' . $result->get('success'));
        $this->comment('Total time spent: ' . $result->get('spent') . 's');

        if ($failed = $result->get('failed')) {
            $filename = 'mandrill_failed_emails_' . time() . '.log';

            file_put_contents(storage_path('logs/' . $filename), implode(PHP_EOL, $failed));

            $this->output->newLine();
            $this->error('Failed emails saved to ' . $filename);
        }

        $responsesFilename = 'mandrill_responses_' . time() . '.log';

        file_put_contents(storage_path('logs/' . $responsesFilename), $result->get('responses'));

        $this->info('Responses saved to ' . $responsesFilename);
    }
}
24Slides / auth-connector

Send::handle() B last analyzed 2020-10-26 19:06 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

Send::handle() B
last analyzed 2020-10-26 19:06 UTC
