Slides\Connector\Auth\Clients\Mandrill\Builders\Email

Complexity

Total Complexity

20

Size/Duplication

Total Lines	283
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes	1
Bugs	0	Features	0

16 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	2
A	getRecipients()	0	3	1
A	variables()	0	5	1
A	subject()	0	5	1
A	context()	0	5	1
A	from()	0	5	1
A	recipients()	0	5	1
A	template()	0	5	1
A	sendChunk()	0	4	2
A	send()	0	7	2
A	buildVariables()	0	8	1
A	build()	0	7	1
A	userVariables()	0	9	2
A	buildRecipients()	0	8	1
A	tags()	0	5	1
A	chunk()	0	5	1

<?php

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

use Exception;
use Illuminate\Support\Collection;
use Slides\Connector\Auth\Clients\Mandrill\Mailer;
use Slides\Connector\Auth\Clients\Mandrill\VariableResolver;

/**
 * Class Email
 *
 * @package Slides\Connector\Auth\Clients\Mandrill\Builders
 */
class Email
{
    /**
     * @var Mailer
     */
    protected $mailer;

    /**
     * The variable resolver.
     *
     * @var string
     */
    protected $resolver;

    /**
     * @var VariableResolver
     */
    protected $resolverInstance;

    /**
     * The additional attributes that should be added to email.
     *
     * @var array
     */
    protected $attributes = [];

    /**
     * The list of context variables.
     *
     * @var array
     */
    protected $context = [];

    /**
     * @var string
     */
    protected $template;

    /**
     * @var array
     */
    protected $variables;

    /**
     * @var Collection
     */
    protected $recipients;

    /**
     * Email constructor.
     *
     * @param Mailer $mailer
     * @param string $resolver
     */
    public function __construct(Mailer $mailer, string $resolver = null)
    {
        $this->mailer = $mailer;
        $this->recipients = new Collection();

        $this->resolver = $resolver ?: config('connector.credentials.clients.mandrill.resolver');
    }

    /**
     * Retrieve recipients.
     *
     * @return Collection
     */
    public function getRecipients(): Collection
    {
        return $this->recipients;
    }

    /**
     * Set the email template.
     *
     * @param string $template
     *
     * @return $this
     */
    public function template(string $template)
    {
        $this->template = $template;

        return $this;
    }

    /**
     * Set additional variables.
     *
     * @param array $variables
     *
     * @return $this
     */
    public function variables(array $variables)
    {
        $this->variables = $variables;

        return $this;
    }

    /**
     * Set the message subject.
     *
     * @param string $subject
     *
     * @return static
     */
    public function subject(string $subject)
    {
        $this->attributes['subject'] = $subject;

        return $this;
    }

    /**
     * Set the sender email address and name.
     *
     * @param string $email
     * @param string $name
     *
     * @return static
     */
    public function from(string $email, ?string $name = null)
    {
        $this->attributes['from'] = compact('email', 'name');

        return $this;
    }

    /**
     * Set the email recipients.
     *
     * @param mixed $recipients
     *
     * @return static
     */
    public function recipients($recipients)
    {
        $this->recipients = collect($recipients);

        return $this;
    }

    /**
     * Set email context.
     *
     * @param array $context
     *
     * @return static
     */
    public function context(array $context)
    {
        $this->context = $context;

        return $this;
    }

    /**
     * Set message tags.
     *
     * @param array $tags
     *
     * @return static
     */
    public function tags(array $tags)
    {
        $this->attributes['tags'] = $tags;

        return $this;
    }

    /**
     * Send the email.
     *
     * @param Collection $recipients
     *
     * @return mixed
     */
    public function send(Collection $recipients = null)
    {
        if (is_null($recipients)) {
            $recipients = $this->recipients;
        }

        return $this->mailer->send($this->build($recipients));
    }

    /**
     * Chunk recipients before sending.
     *
     * @param int $size
     *
     * @return \Generator
     */
    public function sendChunk(int $size = 1000)
    {
        foreach ($this->recipients->chunk($size) as $chunk) {
            yield $this->send($chunk);
        }
    }

    /**
     * Chunk the recipients.
     *
     * @param int $size
     *
     * @return array
     */
    protected function chunk(int $size = 1000): array
    {
        $chunks = $this->recipients->chunk($size);

        return $chunks->map([$this, 'build'])->toArray();
    }

    /**
     * Build the email to be sent.
     *
     * @param Collection|null $recipients
     *
     * @return array
     */
    protected function build(Collection $recipients): array
    {
        return array_merge([
            'template' => $this->template,
            'recipients' => $this->buildRecipients($recipients),
            'variables' => $this->buildVariables($recipients),
        ], $this->attributes);
    }

    /**
     * Build the message recipients.
     *
     * @param Collection $recipients
     *
     * @return array
     */
    protected function buildRecipients(Collection $recipients): array
    {
        return $recipients->map(function (string $email) {
            return [
                'email' => $email,
                'type' => 'to'
            ];
        })->toArray();
    }

    /**
     * Build the variables for given collection of recipients.
     *
     * @param Collection $recipients
     *
     * @return array
     */
    protected function buildVariables(Collection $recipients): array
    {
        return $recipients->map(function (string $email) {
            return [
                'rcpt' => $email,
                'vars' => $this->userVariables($email)
            ];
        })->toArray();
    }

    /**
     * Build variable for a user.
     *
     * @param string $email
     *
     * @return array
     *
     * @throws Exception
     */
    protected function userVariables(string $email): array
    {
        if (!$this->resolverInstance) {
            $this->resolverInstance = new $this->resolver($this->recipients, $this->context);
        }

        return array_map(function ($variable) use ($email) {
            return $this->resolverInstance->resolve($variable, $email);
        }, $this->variables);
    }
}