MailgunMessageSummaryRepository::createOrUpdateMessageSummary() - Code Metrics - Inspection of "add Mailgun MessageSummary to group MailgunEvents" - azine/AzineMailgunWebhooksBundle - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — master ( 2f8638...569786 )

by Dominik

created 2020-11-26 10:11 UTC

createOrUpdateMessageSummary() C

↳ Parent: MailgunMessageSummaryRepository

Complexity

Conditions	15
Paths	120

Size

Total Lines	47
Code Lines	32

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	1	Features	0

Metric	Value
cc	15
eloc	32
c	1
b	1
f	0
nc	120
nop	1
dl	0
loc	47
rs	5.75

How to fix Complexity

<?php

namespace Azine\MailgunWebhooksBundle\Entity\Repositories;

use Azine\MailgunWebhooksBundle\Entity\MailgunEvent;
use Azine\MailgunWebhooksBundle\Entity\MailgunMessageSummary;
use Doctrine\ORM\QueryBuilder;

/**
 * MailgunMessageSummaryRepository
 *
 * This class was generated by the Doctrine ORM. Add your own custom
 * repository methods below.
 */
class MailgunMessageSummaryRepository extends \Doctrine\ORM\EntityRepository
{

    public function getFieldsToOrderBy(){
        return array(
            'lastOpened',
            'sendDate',
            'firstOpened',
            'openCount',
            'fromAddress',
            'toAddress',
            'deliveryStatis',
            'subject',
            'senderIp'
        );
    }

    /**
     * Get distinct list of email recipients.
     *
     * @return array of string
     */
    public function getRecipients()
    {
        $q = $this->getEntityManager()->createQueryBuilder()
            ->select('m.toAddress as recipient')
            ->from($this->getEntityName(), 'm')
            ->distinct()
            ->orderBy('m.toAddress ', 'asc')
            ->getQuery();

        $result = array();
        foreach ($q->execute() as $next) {
            $result[] = $next['recipient'];
        }

        return $result;
    }

    /**
     * Get distinct list of email senders.
     *
     * @return array of string
     */
    public function getSenders()
    {
        $q = $this->getEntityManager()->createQueryBuilder()
            ->select('m.fromAddress as sender')
            ->from($this->getEntityName(), 'm')
            ->distinct()
            ->orderBy('m.fromAddress ', 'asc')
            ->getQuery();

        $result = array();
        foreach ($q->execute() as $next) {
            $result[] = $next['sender'];
        }

        return $result;
    }

    public function getMessageSummaries($criteria, $orderBy, $limit, $offset){
        $qb = $this->getMessageSummaryQuery($criteria);

        $orderField = key($orderBy);
        $orderDirection = $orderBy[$orderField];
        $qb->orderBy('m.'.$orderField, $orderDirection);
        if (-1 != $limit) {
            $qb->setMaxResults($limit);
            $qb->setFirstResult($offset);
        }

        $result = $qb->getQuery()->execute();

        return $result;
    }

    public function getMessageSummaryCount($criteria){
        return $this->getMessageSummaryQuery($criteria)->select('count(m.id)')->getQuery()->getSingleScalarResult();
    }

    private function getMessageSummaryQuery($criteria){
        $qb = $this->createQueryBuilder('m');
        if (array_key_exists('fromAddress', $criteria) && '' != $criteria['fromAddress']) {
            $qb->andWhere('m.fromAddress = :fromAddress')
                ->setParameter('fromAddress', $criteria['fromAddress']);
        }

        if (array_key_exists('toAddress', $criteria) && '' != $criteria['toAddress']) {
            $qb->andWhere('m.toAddress like :toAddress')
                ->setParameter('toAddress', '%'.$criteria['toAddress'].'%');
        }

        if (array_key_exists('search', $criteria) && '' != $criteria['search']) {
            $qb->andWhere('(m.toAddress like :search OR m.subject like :search OR m.fromAddress like :search )')
                ->setParameter('search', '%'.$criteria['search'].'%');
        }
        return $qb;
    }

    public function findSummary($fromAddress, $toAddresses, $sendTime, $subject){
    public function findSummary($fromAddress, $toAddresses, /** @scrutinizer ignore-unused */ $sendTime, $subject){
        // extract email-address part
        $from = mailparse_rfc822_parse_addresses($fromAddress)[0];

        $qb = $this->createQueryBuilder('m');
        $qb->where('m.sendDate < :higherBound AND m.sendDate > :lowerBound AND m.fromAddress like :fromAddress')
            ->setParameters('lowerBound', $lowerBound)
            ->/** @scrutinizer ignore-call */ setParameters('lowerBound', $lowerBound)
            ->setParameters('higherBound', $higherBound)

            ->setParameter('fromAddress', $from);

        // extract email-address parts
        $to = "";
        foreach (mailparse_rfc822_parse_addresses($toAddresses) as $nextMatch){
            $to += "'".$nextMatch['address']."',";
        }
        $to = '('.trim($to, ", ").')';

        if(strlen($to) > 0){
            $qb->andWhere('m.toAddress in :to')->setParameters('to', $to);
        }

        if(strlen($to) > 0){
            $qb->andWhere('m.subject like :subject')->setParameters('subject', $subject);
        }
    }

    public function createOrUpdateMessageSummary(MailgunEvent $event){
        $messageSummary = $this->findOneBy(array('id' => $event->getMessageId()));
        if ($messageSummary == null) {
            $ip = $event->getIp() != null ? $event->getIp() : "unknown";
            $messageSummary = new MailgunMessageSummary($event->getMessageId(), $event->getDateTime(), $event->getSender(), $event->getRecipient(), "no subject found yet", $ip);
        }
        $messageSummary->updateDeliveryStatus($event->getEvent());

        if ($event->getEvent() == 'opened') {
            if ($messageSummary->getFirstOpened() == null || $messageSummary->getFirstOpened() > $event->getDateTime()) {
                $messageSummary->setFirstOpened($event->getDateTime());
            }
            if($messageSummary->getLastOpened() == null || $messageSummary->getLastOpened() < $event->getDateTime()) {
                $messageSummary->setLastOpened($event->getDateTime());
            }
            $messageSummary->increaseOpenCount();
        }

        foreach ($event->getMessageHeaders() as $header) {
            if($header[0] == 'X-Mailgun-Sending-Ip') {
                $messageSummary->setSenderIp($header[1]);
            } else

            if($header[0] == 'Subject') {
                $messageSummary->setSubject($header[1]);
            } else

            if($header[0] == 'Sender') {
                $messageSummary->setFromAddress($header[1]);
            } else

            if($header[0] == 'To') {
                $messageSummary->appendToToAddress($header[1]);
            } else

            if($header[0] == 'Cc') {
                $messageSummary->appendToToAddress($header[1]);
            } else

            if($header[0] == 'Bcc') {
                $messageSummary->appendToToAddress($header[1]);
            }
        }

        $manager = $this->getEntityManager();
        $manager->persist($messageSummary);
        $manager->flush($messageSummary);
    }
}


azine / AzineMailgunWebhooksBundle

Push — master ( 2f8638...569786 )

createOrUpdateMessageSummary() C

Complexity

Size

Duplication

Importance

How to fix Complexity

Long Method

Duplication Side-by-Side

Filter issues like