Jacobemerick\Web\Domain\Stream\DailyMile\MysqlDailyMileRepository

Complexity

Total Complexity

6

Size/Duplication

Total Lines	106
Duplicated Lines	100 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes	2
Bugs	0	Features	2

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	4	4	1
A	getEntries()	16	16	2
A	getEntryByEntryId()	17	17	1
A	getDailyMilesUpdatedSince()	16	16	1
A	insertEntry()	20	20	1

<?php

namespace Jacobemerick\Web\Domain\Stream\DailyMile;

use Aura\Sql\ConnectionLocator;
use DateTime;

class MysqlDailyMileRepository implements DailyMileRepositoryInterface

This class seems to be duplicated in your project.

{

    /** @var  ConnectionLocator */
    protected $connections;

    /**
     * @param ConnectonLocator $connections
     */
    public function __construct(ConnectionLocator $connections)
    {
        $this->connections = $connections;
    }

    /**
     * @param integer $limit
     * @param integer $offset
     *
     * @return array|false
     */
    public function getEntries($limit = null, $offset = 0)
    {
        $query = "
            SELECT `id`, `entry_id`, `datetime`
            FROM `jpemeric_stream`.`dailymile`
            ORDER BY `datetime` DESC";
        if (!is_null($limit)) {
          $query .= "
          LIMIT {$offset}, {$limit}";
        }

        return $this
            ->connections
            ->getRead()
            ->fetchAll($query);
    }

    /**
     * @param integer $entryId
     *
     * @return array|false
     */
    public function getEntryByEntryId($entryId)
    {
        $query = "
            SELECT *
            FROM `jpemeric_stream`.`dailymile`
            WHERE `entry_id` = :entry_id
            LIMIT 1";

        $bindings = [
            'entry_id' => $entryId,
        ];

        return $this
            ->connections
            ->getRead()
            ->fetchOne($query, $bindings);
    }

    public function getDailyMilesUpdatedSince(DateTime $datetime)
    {
        $query = "
            SELECT *
            FROM `jpemeric_stream`.`dailymile`
            WHERE `updated_at` >= :last_update";

        $bindings = [
            'last_update' => $datetime->format('Y-m-d H:i:s'),
        ];

        return $this
            ->connections
            ->getRead()
            ->fetchAll($query, $bindings);
    }

    /**
     * @param integer  $entryId
     * @param string   $entryType
     * @param DateTime $datetime
     * @param array    $metadata
     *
     * @return
     */
    public function insertEntry($entryId, $entryType, DateTime $datetime, array $metadata)
    {
        $query = "
            INSERT INTO `jpemeric_stream`.`dailymile`
                (`entry_id`, `type`, `datetime`, `metadata`)
            VALUES
                (:entry_id, :entry_type, :datetime, :metadata)";

        $bindings = [
            'entry_id' => $entryId,
            'entry_type' => $entryType,
            'datetime' => $datetime->format('Y-m-d H:i:s'),
            'metadata' => json_encode($metadata),
        ];

        return $this
            ->connections
            ->getWrite()
            ->perform($query, $bindings);
    }
}