Sinergi\Emails\Emails\EmailsRepository

Complexity

Total Complexity

14

Size/Duplication

Total Lines	72
Duplicated Lines	12.5 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes	1
Bugs	0	Features	1

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	9	18	3
B	save()	0	30	6
A	mapEmails()	0	8	3
A	mapEmail()	0	8	2

<?php

namespace Sinergi\Emails\Emails;

use Omnimail\Attachment;
use Omnimail\EmailInterface;
use PDO;
use Sinergi\Emails\Attachments\AttachmentsRepository;
use Sinergi\Emails\Driver\MySQL;
use DateTime;

class EmailsRepository
{
    private $connection;

    public function __construct(PDO $connection)
    {
        $this->connection = $connection;

        switch ($connection->getAttribute(PDO::ATTR_DRIVER_NAME)) {

This code seems to be duplicated across your project.

            case 'mysql':
                $this->driver = new MySQL($connection);

The property driver does not exist. Did you maybe forget to declare it?

                break;
            default:
                throw new \Exception(
                    'Driver ' . $connection->getAttribute(PDO::ATTR_DRIVER_NAME) . ' not yet implemented'
                );
        }

        if (!$this->driver->checkTable('emails')) {
            $this->driver->createEmailsTable();
        }
    }

    public function save(EmailInterface $email, bool $isSent, string $error = null, bool $storeAttachments = false)
    {
        try {
            $id = $this->driver->insert('emails', [
                'from' => $this->mapEmail($email->getFrom()),
                'subject' => $email->getSubject(),
                'text_body' => $email->getTextBody(),
                'html_body' => $email->getHtmlBody(),
                'to' => $this->mapEmails($email->getTos()),
                'cc' => $this->mapEmails($email->getCcs()),
                'bcc' => $this->mapEmails($email->getBccs()),
                'reply_to' => $this->mapEmails($email->getReplyTos()),
                'is_sent' => $isSent,
                'has_error' => !$isSent,
                'errors' => $error,
                'sent_date_time' => (new DateTime())->format('Y-m-d H:i:s'),
                'creation_date_time' => (new DateTime())->format('Y-m-d H:i:s'),
            ]);
            if ($storeAttachments && $email->getAttachements()) {

The method getAttachements() does not exist on Omnimail\EmailInterface. Did you maybe mean getAttachments()?

                $attachmentsRepository = new AttachmentsRepository($this->connection);
                if (count($email->getAttachements())) {

The method getAttachements() does not exist on Omnimail\EmailInterface. Did you maybe mean getAttachments()?

                    foreach ($email->getAttachements() as $attachement) {

The method getAttachements() does not exist on Omnimail\EmailInterface. Did you maybe mean getAttachments()?

                        $attachmentsRepository->save($attachement, $id);
                    }
                }
            }
        } catch (\Exception $e) {
            throw new \Exception('Could not insert email in database', null, $e);
        }
    }

    private function mapEmails(array $emails)
    {
        $finalEmails = '';
        foreach ($emails as $email) {
            $finalEmails .= $this->mapEmail($email) . ', ';
        }
        return !empty($finalEmails) ? substr($finalEmails, 0, -2) : '';
    }

    private function mapEmail($email)
    {
        if (!empty($email['name'])) {
            return "'{$email['name']}' <{$email['email']}>";
        } else {
            return $email['email'];
        }
    }
}