Inspection of "Adds new stream db repositories and use them to re..." - jacobemerick/web - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( c330e2...cf0c7a )

by Jacob

created 2015-12-27 02:18 UTC

Status

Indentation +3 added lines, -3 removed lines patch added patch discarded remove patch

@@ -6,7 +6,7 @@
 block discarded – undo
 
 interface DistanceRepositoryInterface
 {
-    public function getDistanceById($id);
-    public function getDistanceByFields(DateTimeInterface $date, $type, $mileage);
-    public function getUnmappedDistances();
+	public function getDistanceById($id);
+	public function getDistanceByFields(DateTimeInterface $date, $type, $mileage);
+	public function getUnmappedDistances();
 }

Please login to merge, or discard this patch.

src/Domain/Stream/Distance/MysqlDistanceRepository.php 1 patch

Indentation +56 added lines, -56 removed lines patch added patch discarded remove patch

@@ -8,79 +8,79 @@
 block discarded – undo
 class MysqlDistanceRepository implements DistanceRepositoryInterface
 {
 
-    /** @var  ConnectionLocator */
-    protected $connections;
+	/** @var  ConnectionLocator */
+	protected $connections;
 
-    /**
-     * @param ConnectonLocator $connections
-     */
-    public function __construct(ConnectionLocator $connections)
-    {
-        $this->connections = $connections;
-    }
+	/**
+	 * @param ConnectonLocator $connections
+	 */
+	public function __construct(ConnectionLocator $connections)
+	{
+		$this->connections = $connections;
+	}
 
-    /**
-     * @param integer $id
-     *
-     * @return array|false
-     */
-    public function getDistanceById($id)
-    {
-        $query = "
+	/**
+	 * @param integer $id
+	 *
+	 * @return array|false
+	 */
+	public function getDistanceById($id)
+	{
+		$query = "
             SELECT *
             FROM `jpemeric_stream`.`distance`
             WHERE `id` = :id
             LIMIT 1";
-        $bindings = [
-            'id' => $id,
-        ];
+		$bindings = [
+			'id' => $id,
+		];
 
-        return $this
-            ->connections
-            ->getRead()
-            ->fetchOne($query, $bindings);
-    }
+		return $this
+			->connections
+			->getRead()
+			->fetchOne($query, $bindings);
+	}
 
-    /**
-     * @param DateTimeInterface $date
-     * @param string            $type
-     * @param double            $mileage
-     *
-     * @return array|false
-     */
-    public function getDistanceByFields(DateTimeInterface $date, $type, $mileage)
-    {
-        $query = "
+	/**
+	 * @param DateTimeInterface $date
+	 * @param string            $type
+	 * @param double            $mileage
+	 *
+	 * @return array|false
+	 */
+	public function getDistanceByFields(DateTimeInterface $date, $type, $mileage)
+	{
+		$query = "
             SELECT *
             FROM `jpemeric_stream`.`distance`
             WHERE `date` = :date AND `type` = :type AND `mileage` = :mileage
             LIMIT 1";
-        $bindings = [
-            'date' => $date->format('Y-m-d H:i:s'),
-            'type' => $type,
-            'mileage' => $mileage,
-        ];
+		$bindings = [
+			'date' => $date->format('Y-m-d H:i:s'),
+			'type' => $type,
+			'mileage' => $mileage,
+		];
 
-        return $this
-            ->connections
-            ->getRead()
-            ->fetchOne($query, $bindings);
-    }
+		return $this
+			->connections
+			->getRead()
+			->fetchOne($query, $bindings);
+	}
 
-    /**
-     * @return array|false
-     */
-    public function getUnmappedDistances()
-    {
-        $query = "
+	/**
+	 * @return array|false
+	 */
+	public function getUnmappedDistances()
+	{
+		$query = "
             SELECT `id`, `date`
             FROM `jpemeric_stream`.`distance`
             LEFT JOIN `jpemeric_stream`.`post`
             ON `post`.`type_id` = `distance`.`id` AND `post`.`id` IS NULL";
 
-        return $this
-            ->connections
-            ->getRead()
-            ->fetchAll($query);
-    }
+		return $this
+			->connections
+			->getRead()
+			->fetchAll($query);
+	}
 }

Please login to merge, or discard this patch.

src/Domain/Stream/Hulu/HuluRepositoryInterface.php 1 patch

Indentation +1 added lines, -1 removed lines patch added patch discarded remove patch

@@ -4,5 +4,5 @@
 block discarded – undo
 
 interface HuluRepositoryInterface
 {
-    public function getHuluById($id);
+	public function getHuluById($id);
 }

Please login to merge, or discard this patch.

src/Domain/Stream/Hulu/MysqlHuluRepository.php 1 patch

Indentation +25 added lines, -25 removed lines patch added patch discarded remove patch

@@ -7,36 +7,36 @@
 block discarded – undo
 class MysqlHuluRepository implements HuluRepositoryInterface
 {
 
-    /** @var  ConnectionLocator */
-    protected $connections;
+	/** @var  ConnectionLocator */
+	protected $connections;
 
-    /**
-     * @param ConnectonLocator $connections
-     */
-    public function __construct(ConnectionLocator $connections)
-    {
-        $this->connections = $connections;
-    }
+	/**
+	 * @param ConnectonLocator $connections
+	 */
+	public function __construct(ConnectionLocator $connections)
+	{
+		$this->connections = $connections;
+	}
 
-    /**
-     * @param integer $id
-     *
-     * @return array|false
-     */
-    public function getHuluById($id)
-    {
-        $query = "
+	/**
+	 * @param integer $id
+	 *
+	 * @return array|false
+	 */
+	public function getHuluById($id)
+	{
+		$query = "
             SELECT *
             FROM `jpemeric_stream`.`hulu`
             WHERE `id` = :id
             LIMIT 1";
-        $bindings = [
-            'id' => $id,
-        ];
+		$bindings = [
+			'id' => $id,
+		];
 
-        return $this
-            ->connections
-            ->getRead()
-            ->fetchOne($query, $bindings);
-    }
+		return $this
+			->connections
+			->getRead()
+			->fetchOne($query, $bindings);
+	}
 }

Please login to merge, or discard this patch.

src/Domain/Stream/Post/MysqlPostRepository.php 1 patch

Indentation +102 added lines, -102 removed lines patch added patch discarded remove patch

@@ -7,132 +7,132 @@
 block discarded – undo
 class MysqlPostRepository implements PostRepositoryInterface
 {
 
-    /** @var  ConnectionLocator */
-    protected $connections;
-
-    /**
-     * @param ConnectonLocator $connections
-     */
-    public function __construct(ConnectionLocator $connections)
-    {
-        $this->connections = $connections;
-    }
-
-    /**
-     * @param integer $id
-     *
-     * @return array|false
-     */
-    public function getPostById($id)
-    {
-        $query = "
+	/** @var  ConnectionLocator */
+	protected $connections;
+
+	/**
+	 * @param ConnectonLocator $connections
+	 */
+	public function __construct(ConnectionLocator $connections)
+	{
+		$this->connections = $connections;
+	}
+
+	/**
+	 * @param integer $id
+	 *
+	 * @return array|false
+	 */
+	public function getPostById($id)
+	{
+		$query = "
             SELECT *
             FROM `jpemeric_stream`.`post`
             WHERE `id` = :id
             LIMIT 1";
-        $bindings = [
-            'id' => $id,
-        ];
-
-        return $this
-            ->connections
-            ->getRead()
-            ->fetchOne($query, $bindings);
-    }
-
-    /**
-     * @param string  $type
-     * @param integer $type_id
-     *
-     * @return array|false
-     */
-    public function getPostByFields($type, $type_id)
-    {
-        $query = "
+		$bindings = [
+			'id' => $id,
+		];
+
+		return $this
+			->connections
+			->getRead()
+			->fetchOne($query, $bindings);
+	}
+
+	/**
+	 * @param string  $type
+	 * @param integer $type_id
+	 *
+	 * @return array|false
+	 */
+	public function getPostByFields($type, $type_id)
+	{
+		$query = "
             SELECT *
             FROM `jpemeric_stream`.`post`
             WHERE `type` = :type && `type_id` = :type_id
             LIMIT 1";
-        $bindings = [
-            'type'    => $type,
-            'type_id' => $type_id,
-        ];
-
-        return $this
-            ->connections
-            ->getRead()
-            ->fetchOne($query, $bindings);
-    }
-
-    /**
-     * @param integer $limit
-     * @param integer $offset
-     *
-     * @return array|false
-     */
-    public function getPosts($limit = null, $offset = 0)
-    {
-        $query = "
+		$bindings = [
+			'type'    => $type,
+			'type_id' => $type_id,
+		];
+
+		return $this
+			->connections
+			->getRead()
+			->fetchOne($query, $bindings);
+	}
+
+	/**
+	 * @param integer $limit
+	 * @param integer $offset
+	 *
+	 * @return array|false
+	 */
+	public function getPosts($limit = null, $offset = 0)
+	{
+		$query = "
             SELECT *
             FROM `jpemeric_stream`.`post`
             ORDER BY `date` DESC";
-        if (!is_null($limit)) {
-            $query .= "
+		if (!is_null($limit)) {
+			$query .= "
             LIMIT {$offset}, {$limit}";
-        }
+		}
 
-        return $this
-            ->connections
-            ->getRead()
-            ->fetchAll($query);
-    }
+		return $this
+			->connections
+			->getRead()
+			->fetchAll($query);
+	}
 
-    public function getPostsCount()
-    {
-        $query = "
+	public function getPostsCount()
+	{
+		$query = "
             SELECT COUNT(1) AS `count`
             FROM `jpemeric_stream`.`post`";
 
-        return $this
-            ->connections
-            ->getRead()
-            ->fetchValue($query);
-    }
+		return $this
+			->connections
+			->getRead()
+			->fetchValue($query);
+	}
 
-    public function getPostsByType($type, $limit = null, $offset = 0)
-    {
-        $query = "
+	public function getPostsByType($type, $limit = null, $offset = 0)
+	{
+		$query = "
             SELECT *
             FROM `jpemeric_stream`.`post`
             WHERE `type` = :type
             ORDER BY `date` DESC";
-        if (!is_null($limit)) {
-            $query .= "
+		if (!is_null($limit)) {
+			$query .= "
             LIMIT {$offset}, {$limit}";
-        }
-        $bindings = [
-            'type' => $type,
-        ];
-
-        return $this
-            ->connections
-            ->getRead()
-            ->fetchAll($query, $bindings);
-    }
-
-    public function getPostsByTypeCount($type)
-    {
-        $query = "
+		}
+		$bindings = [
+			'type' => $type,
+		];
+
+		return $this
+			->connections
+			->getRead()
+			->fetchAll($query, $bindings);
+	}
+
+	public function getPostsByTypeCount($type)
+	{
+		$query = "
             SELECT COUNT(1) AS `count`
             FROM `jpemeric_stream`.`post`
             WHERE `type` = :type";
-        $bindings = [
-            'type' => $type,
-        ];
-
-        return $this
-            ->connections
-            ->getRead()
-            ->fetchValue($query, $bindings);
-    }
+		$bindings = [
+			'type' => $type,
+		];
+
+		return $this
+			->connections
+			->getRead()
+			->fetchValue($query, $bindings);
+	}
 }

Please login to merge, or discard this patch.

src/Domain/Stream/Post/PostRepositoryInterface.php 1 patch

Indentation +6 added lines, -6 removed lines patch added patch discarded remove patch

@@ -4,10 +4,10 @@
 block discarded – undo
 
 interface PostRepositoryInterface
 {
-    public function getPostById($id);
-    public function getPostByFields($type, $type_id);
-    public function getPosts($limit = null, $offset = 0);
-    public function getPostsCount();
-    public function getPostsByType($type, $limit = null, $offset = 0);
-    public function getPostsByTypeCount($type);
+	public function getPostById($id);
+	public function getPostByFields($type, $type_id);
+	public function getPosts($limit = null, $offset = 0);
+	public function getPostsCount();
+	public function getPostsByType($type, $limit = null, $offset = 0);
+	public function getPostsByTypeCount($type);
 }

Please login to merge, or discard this patch.

src/Domain/Stream/Twitter/MysqlTwitterRepository.php 1 patch

Indentation +54 added lines, -54 removed lines patch added patch discarded remove patch

@@ -8,77 +8,77 @@
 block discarded – undo
 class MysqlTwitterRepository implements TwitterRepositoryInterface
 {
 
-    /** @var  ConnectionLocator */
-    protected $connections;
+	/** @var  ConnectionLocator */
+	protected $connections;
 
-    /**
-     * @param ConnectonLocator $connections
-     */
-    public function __construct(ConnectionLocator $connections)
-    {
-        $this->connections = $connections;
-    }
+	/**
+	 * @param ConnectonLocator $connections
+	 */
+	public function __construct(ConnectionLocator $connections)
+	{
+		$this->connections = $connections;
+	}
 
-    /**
-     * @param integer $id
-     *
-     * @return array|false
-     */
-    public function getTwitterById($id)
-    {
-        $query = "
+	/**
+	 * @param integer $id
+	 *
+	 * @return array|false
+	 */
+	public function getTwitterById($id)
+	{
+		$query = "
             SELECT *
             FROM `jpemeric_stream`.`twitter`
             WHERE `id` = :id
             LIMIT 1";
-        $bindings = [
-            'id' => $id,
-        ];
+		$bindings = [
+			'id' => $id,
+		];
 
-        return $this
-            ->connections
-            ->getRead()
-            ->fetchOne($query, $bindings);
-    }
+		return $this
+			->connections
+			->getRead()
+			->fetchOne($query, $bindings);
+	}
 
-    /**
-     * @param DateTimeInterface $date
-     * @param string            $text
-     *
-     * @return array|false
-     */
-    public function getTwitterByFields(DateTimeInterface $date, $text)
-    {
-        $query = "
+	/**
+	 * @param DateTimeInterface $date
+	 * @param string            $text
+	 *
+	 * @return array|false
+	 */
+	public function getTwitterByFields(DateTimeInterface $date, $text)
+	{
+		$query = "
             SELECT *
             FROM `jpemeric_stream`.`twitter`
             WHERE `date` = :date AND `text` = :text
             LIMIT 1";
-        $bindings = [
-            'date' => $date->format('Y-m-d H:i:s'),
-            'text' => $text,
-        ];
+		$bindings = [
+			'date' => $date->format('Y-m-d H:i:s'),
+			'text' => $text,
+		];
 
-        return $this
-            ->connections
-            ->getRead()
-            ->fetchOne($query, $bindings);
-    }
+		return $this
+			->connections
+			->getRead()
+			->fetchOne($query, $bindings);
+	}
 
-    /**
-     * @return array|false
-     */
-    public function getUnmappedTwitters()
-    {
-        $query = "
+	/**
+	 * @return array|false
+	 */
+	public function getUnmappedTwitters()
+	{
+		$query = "
             SELECT `id`, `date`
             FROM `jpemeric_stream`.`twitter`
             LEFT JOIN `jpemeric_stream`.`post`
             ON `post`.`type_id` = `twitter`.`id` AND `post`.`id` IS NULL";
 
-        return $this
-            ->connections
-            ->getRead()
-            ->fetchAll($query);
-    }
+		return $this
+			->connections
+			->getRead()
+			->fetchAll($query);
+	}
 }

Please login to merge, or discard this patch.

src/Domain/Stream/Twitter/TwitterRepositoryInterface.php 1 patch

Indentation +3 added lines, -3 removed lines patch added patch discarded remove patch

@@ -6,7 +6,7 @@
 block discarded – undo
 
 interface TwitterRepositoryInterface
 {
-    public function getTwitterById($id);
-    public function getTwitterByFields(DateTimeInterface $date, $text);
-    public function getUnmappedTwitters();
+	public function getTwitterById($id);
+	public function getTwitterByFields(DateTimeInterface $date, $text);
+	public function getUnmappedTwitters();
 }

Please login to merge, or discard this patch.

src/Domain/Stream/YouTube/YouTubeRepositoryInterface.php 1 patch

Indentation +3 added lines, -3 removed lines patch added patch discarded remove patch

@@ -4,7 +4,7 @@
 block discarded – undo
 
 interface YouTubeRepositoryInterface
 {
-    public function getYouTubeById($id);
-    public function getYouTubeByVideoId($videoId);
-    public function getUnmappedYouTubes();
+	public function getYouTubeById($id);
+	public function getYouTubeByVideoId($videoId);
+	public function getUnmappedYouTubes();
 }

Please login to merge, or discard this patch.

		@@ -6,7 +6,7 @@
		block discarded – undo
6	6
7	7	interface DistanceRepositoryInterface
8	8	{
9		- public function getDistanceById($id);
10		- public function getDistanceByFields(DateTimeInterface $date, $type, $mileage);
11		- public function getUnmappedDistances();
	9	+ public function getDistanceById($id);
	10	+ public function getDistanceByFields(DateTimeInterface $date, $type, $mileage);
	11	+ public function getUnmappedDistances();
12	12	}

		@@ -8,79 +8,79 @@
		block discarded – undo
8	8	class MysqlDistanceRepository implements DistanceRepositoryInterface
9	9	{
10	10
11		- /** @var ConnectionLocator */
12		- protected $connections;
	11	+ /** @var ConnectionLocator */
	12	+ protected $connections;
13	13
14		- /**
15		- * @param ConnectonLocator $connections
16		- */
17		- public function __construct(ConnectionLocator $connections)
18		- {
19		- $this->connections = $connections;
20		- }
	14	+ /**
	15	+ * @param ConnectonLocator $connections
	16	+ */
	17	+ public function __construct(ConnectionLocator $connections)
	18	+ {
	19	+ $this->connections = $connections;
	20	+ }
21	21
22		- /**
23		- * @param integer $id
24		- *
25		- * @return array\|false
26		- */
27		- public function getDistanceById($id)
28		- {
29		- $query = "
	22	+ /**
	23	+ * @param integer $id
	24	+ *
	25	+ * @return array\|false
	26	+ */
	27	+ public function getDistanceById($id)
	28	+ {
	29	+ $query = "
30	30	SELECT *
31	31	FROM `jpemeric_stream`.`distance`
32	32	WHERE `id` = :id
33	33	LIMIT 1";
34		- $bindings = [
35		- 'id' => $id,
36		- ];
	34	+ $bindings = [
	35	+ 'id' => $id,
	36	+ ];
37	37
38		- return $this
39		- ->connections
40		- ->getRead()
41		- ->fetchOne($query, $bindings);
42		- }
	38	+ return $this
	39	+ ->connections
	40	+ ->getRead()
	41	+ ->fetchOne($query, $bindings);
	42	+ }
43	43
44		- /**
45		- * @param DateTimeInterface $date
46		- * @param string $type
47		- * @param double $mileage
48		- *
49		- * @return array\|false
50		- */
51		- public function getDistanceByFields(DateTimeInterface $date, $type, $mileage)
52		- {
53		- $query = "
	44	+ /**
	45	+ * @param DateTimeInterface $date
	46	+ * @param string $type
	47	+ * @param double $mileage
	48	+ *
	49	+ * @return array\|false
	50	+ */
	51	+ public function getDistanceByFields(DateTimeInterface $date, $type, $mileage)
	52	+ {
	53	+ $query = "
54	54	SELECT *
55	55	FROM `jpemeric_stream`.`distance`
56	56	WHERE `date` = :date AND `type` = :type AND `mileage` = :mileage
57	57	LIMIT 1";
58		- $bindings = [
59		- 'date' => $date->format('Y-m-d H:i:s'),
60		- 'type' => $type,
61		- 'mileage' => $mileage,
62		- ];
	58	+ $bindings = [
	59	+ 'date' => $date->format('Y-m-d H:i:s'),
	60	+ 'type' => $type,
	61	+ 'mileage' => $mileage,
	62	+ ];
63	63
64		- return $this
65		- ->connections
66		- ->getRead()
67		- ->fetchOne($query, $bindings);
68		- }
	64	+ return $this
	65	+ ->connections
	66	+ ->getRead()
	67	+ ->fetchOne($query, $bindings);
	68	+ }
69	69
70		- /**
71		- * @return array\|false
72		- */
73		- public function getUnmappedDistances()
74		- {
75		- $query = "
	70	+ /**
	71	+ * @return array\|false
	72	+ */
	73	+ public function getUnmappedDistances()
	74	+ {
	75	+ $query = "
76	76	SELECT `id`, `date`
77	77	FROM `jpemeric_stream`.`distance`
78	78	LEFT JOIN `jpemeric_stream`.`post`
79	79	ON `post`.`type_id` = `distance`.`id` AND `post`.`id` IS NULL";
80	80
81		- return $this
82		- ->connections
83		- ->getRead()
84		- ->fetchAll($query);
85		- }
	81	+ return $this
	82	+ ->connections
	83	+ ->getRead()
	84	+ ->fetchAll($query);
	85	+ }
86	86	}

		@@ -4,5 +4,5 @@
		block discarded – undo
4	4
5	5	interface HuluRepositoryInterface
6	6	{
7		- public function getHuluById($id);
	7	+ public function getHuluById($id);
8	8	}

		@@ -7,36 +7,36 @@
		block discarded – undo
7	7	class MysqlHuluRepository implements HuluRepositoryInterface
8	8	{
9	9
10		- /** @var ConnectionLocator */
11		- protected $connections;
	10	+ /** @var ConnectionLocator */
	11	+ protected $connections;
12	12
13		- /**
14		- * @param ConnectonLocator $connections
15		- */
16		- public function __construct(ConnectionLocator $connections)
17		- {
18		- $this->connections = $connections;
19		- }
	13	+ /**
	14	+ * @param ConnectonLocator $connections
	15	+ */
	16	+ public function __construct(ConnectionLocator $connections)
	17	+ {
	18	+ $this->connections = $connections;
	19	+ }
20	20
21		- /**
22		- * @param integer $id
23		- *
24		- * @return array\|false
25		- */
26		- public function getHuluById($id)
27		- {
28		- $query = "
	21	+ /**
	22	+ * @param integer $id
	23	+ *
	24	+ * @return array\|false
	25	+ */
	26	+ public function getHuluById($id)
	27	+ {
	28	+ $query = "
29	29	SELECT *
30	30	FROM `jpemeric_stream`.`hulu`
31	31	WHERE `id` = :id
32	32	LIMIT 1";
33		- $bindings = [
34		- 'id' => $id,
35		- ];
	33	+ $bindings = [
	34	+ 'id' => $id,
	35	+ ];
36	36
37		- return $this
38		- ->connections
39		- ->getRead()
40		- ->fetchOne($query, $bindings);
41		- }
	37	+ return $this
	38	+ ->connections
	39	+ ->getRead()
	40	+ ->fetchOne($query, $bindings);
	41	+ }
42	42	}

		@@ -7,132 +7,132 @@
		block discarded – undo
7	7	class MysqlPostRepository implements PostRepositoryInterface
8	8	{
9	9
10		- /** @var ConnectionLocator */
11		- protected $connections;
12		-
13		- /**
14		- * @param ConnectonLocator $connections
15		- */
16		- public function __construct(ConnectionLocator $connections)
17		- {
18		- $this->connections = $connections;
19		- }
20		-
21		- /**
22		- * @param integer $id
23		- *
24		- * @return array\|false
25		- */
26		- public function getPostById($id)
27		- {
28		- $query = "
	10	+ /** @var ConnectionLocator */
	11	+ protected $connections;
	12	+
	13	+ /**
	14	+ * @param ConnectonLocator $connections
	15	+ */
	16	+ public function __construct(ConnectionLocator $connections)
	17	+ {
	18	+ $this->connections = $connections;
	19	+ }
	20	+
	21	+ /**
	22	+ * @param integer $id
	23	+ *
	24	+ * @return array\|false
	25	+ */
	26	+ public function getPostById($id)
	27	+ {
	28	+ $query = "
29	29	SELECT *
30	30	FROM `jpemeric_stream`.`post`
31	31	WHERE `id` = :id
32	32	LIMIT 1";
33		- $bindings = [
34		- 'id' => $id,
35		- ];
36		-
37		- return $this
38		- ->connections
39		- ->getRead()
40		- ->fetchOne($query, $bindings);
41		- }
42		-
43		- /**
44		- * @param string $type
45		- * @param integer $type_id
46		- *
47		- * @return array\|false
48		- */
49		- public function getPostByFields($type, $type_id)
50		- {
51		- $query = "
	33	+ $bindings = [
	34	+ 'id' => $id,
	35	+ ];
	36	+
	37	+ return $this
	38	+ ->connections
	39	+ ->getRead()
	40	+ ->fetchOne($query, $bindings);
	41	+ }
	42	+
	43	+ /**
	44	+ * @param string $type
	45	+ * @param integer $type_id
	46	+ *
	47	+ * @return array\|false
	48	+ */
	49	+ public function getPostByFields($type, $type_id)
	50	+ {
	51	+ $query = "
52	52	SELECT *
53	53	FROM `jpemeric_stream`.`post`
54	54	WHERE `type` = :type && `type_id` = :type_id
55	55	LIMIT 1";
56		- $bindings = [
57		- 'type' => $type,
58		- 'type_id' => $type_id,
59		- ];
60		-
61		- return $this
62		- ->connections
63		- ->getRead()
64		- ->fetchOne($query, $bindings);
65		- }
66		-
67		- /**
68		- * @param integer $limit
69		- * @param integer $offset
70		- *
71		- * @return array\|false
72		- */
73		- public function getPosts($limit = null, $offset = 0)
74		- {
75		- $query = "
	56	+ $bindings = [
	57	+ 'type' => $type,
	58	+ 'type_id' => $type_id,
	59	+ ];
	60	+
	61	+ return $this
	62	+ ->connections
	63	+ ->getRead()
	64	+ ->fetchOne($query, $bindings);
	65	+ }
	66	+
	67	+ /**
	68	+ * @param integer $limit
	69	+ * @param integer $offset
	70	+ *
	71	+ * @return array\|false
	72	+ */
	73	+ public function getPosts($limit = null, $offset = 0)
	74	+ {
	75	+ $query = "
76	76	SELECT *
77	77	FROM `jpemeric_stream`.`post`
78	78	ORDER BY `date` DESC";
79		- if (!is_null($limit)) {
80		- $query .= "
	79	+ if (!is_null($limit)) {
	80	+ $query .= "
81	81	LIMIT {$offset}, {$limit}";
82		- }
	82	+ }
83	83
84		- return $this
85		- ->connections
86		- ->getRead()
87		- ->fetchAll($query);
88		- }
	84	+ return $this
	85	+ ->connections
	86	+ ->getRead()
	87	+ ->fetchAll($query);
	88	+ }
89	89
90		- public function getPostsCount()
91		- {
92		- $query = "
	90	+ public function getPostsCount()
	91	+ {
	92	+ $query = "
93	93	SELECT COUNT(1) AS `count`
94	94	FROM `jpemeric_stream`.`post`";
95	95
96		- return $this
97		- ->connections
98		- ->getRead()
99		- ->fetchValue($query);
100		- }
	96	+ return $this
	97	+ ->connections
	98	+ ->getRead()
	99	+ ->fetchValue($query);
	100	+ }
101	101
102		- public function getPostsByType($type, $limit = null, $offset = 0)
103		- {
104		- $query = "
	102	+ public function getPostsByType($type, $limit = null, $offset = 0)
	103	+ {
	104	+ $query = "
105	105	SELECT *
106	106	FROM `jpemeric_stream`.`post`
107	107	WHERE `type` = :type
108	108	ORDER BY `date` DESC";
109		- if (!is_null($limit)) {
110		- $query .= "
	109	+ if (!is_null($limit)) {
	110	+ $query .= "
111	111	LIMIT {$offset}, {$limit}";
112		- }
113		- $bindings = [
114		- 'type' => $type,
115		- ];
116		-
117		- return $this
118		- ->connections
119		- ->getRead()
120		- ->fetchAll($query, $bindings);
121		- }
122		-
123		- public function getPostsByTypeCount($type)
124		- {
125		- $query = "
	112	+ }
	113	+ $bindings = [
	114	+ 'type' => $type,
	115	+ ];
	116	+
	117	+ return $this
	118	+ ->connections
	119	+ ->getRead()
	120	+ ->fetchAll($query, $bindings);
	121	+ }
	122	+
	123	+ public function getPostsByTypeCount($type)
	124	+ {
	125	+ $query = "
126	126	SELECT COUNT(1) AS `count`
127	127	FROM `jpemeric_stream`.`post`
128	128	WHERE `type` = :type";
129		- $bindings = [
130		- 'type' => $type,
131		- ];
132		-
133		- return $this
134		- ->connections
135		- ->getRead()
136		- ->fetchValue($query, $bindings);
137		- }
	129	+ $bindings = [
	130	+ 'type' => $type,
	131	+ ];
	132	+
	133	+ return $this
	134	+ ->connections
	135	+ ->getRead()
	136	+ ->fetchValue($query, $bindings);
	137	+ }
138	138	}

		@@ -4,10 +4,10 @@
		block discarded – undo
4	4
5	5	interface PostRepositoryInterface
6	6	{
7		- public function getPostById($id);
8		- public function getPostByFields($type, $type_id);
9		- public function getPosts($limit = null, $offset = 0);
10		- public function getPostsCount();
11		- public function getPostsByType($type, $limit = null, $offset = 0);
12		- public function getPostsByTypeCount($type);
	7	+ public function getPostById($id);
	8	+ public function getPostByFields($type, $type_id);
	9	+ public function getPosts($limit = null, $offset = 0);
	10	+ public function getPostsCount();
	11	+ public function getPostsByType($type, $limit = null, $offset = 0);
	12	+ public function getPostsByTypeCount($type);
13	13	}

		@@ -8,77 +8,77 @@
		block discarded – undo
8	8	class MysqlTwitterRepository implements TwitterRepositoryInterface
9	9	{
10	10
11		- /** @var ConnectionLocator */
12		- protected $connections;
	11	+ /** @var ConnectionLocator */
	12	+ protected $connections;
13	13
14		- /**
15		- * @param ConnectonLocator $connections
16		- */
17		- public function __construct(ConnectionLocator $connections)
18		- {
19		- $this->connections = $connections;
20		- }
	14	+ /**
	15	+ * @param ConnectonLocator $connections
	16	+ */
	17	+ public function __construct(ConnectionLocator $connections)
	18	+ {
	19	+ $this->connections = $connections;
	20	+ }
21	21
22		- /**
23		- * @param integer $id
24		- *
25		- * @return array\|false
26		- */
27		- public function getTwitterById($id)
28		- {
29		- $query = "
	22	+ /**
	23	+ * @param integer $id
	24	+ *
	25	+ * @return array\|false
	26	+ */
	27	+ public function getTwitterById($id)
	28	+ {
	29	+ $query = "
30	30	SELECT *
31	31	FROM `jpemeric_stream`.`twitter`
32	32	WHERE `id` = :id
33	33	LIMIT 1";
34		- $bindings = [
35		- 'id' => $id,
36		- ];
	34	+ $bindings = [
	35	+ 'id' => $id,
	36	+ ];
37	37
38		- return $this
39		- ->connections
40		- ->getRead()
41		- ->fetchOne($query, $bindings);
42		- }
	38	+ return $this
	39	+ ->connections
	40	+ ->getRead()
	41	+ ->fetchOne($query, $bindings);
	42	+ }
43	43
44		- /**
45		- * @param DateTimeInterface $date
46		- * @param string $text
47		- *
48		- * @return array\|false
49		- */
50		- public function getTwitterByFields(DateTimeInterface $date, $text)
51		- {
52		- $query = "
	44	+ /**
	45	+ * @param DateTimeInterface $date
	46	+ * @param string $text
	47	+ *
	48	+ * @return array\|false
	49	+ */
	50	+ public function getTwitterByFields(DateTimeInterface $date, $text)
	51	+ {
	52	+ $query = "
53	53	SELECT *
54	54	FROM `jpemeric_stream`.`twitter`
55	55	WHERE `date` = :date AND `text` = :text
56	56	LIMIT 1";
57		- $bindings = [
58		- 'date' => $date->format('Y-m-d H:i:s'),
59		- 'text' => $text,
60		- ];
	57	+ $bindings = [
	58	+ 'date' => $date->format('Y-m-d H:i:s'),
	59	+ 'text' => $text,
	60	+ ];
61	61
62		- return $this
63		- ->connections
64		- ->getRead()
65		- ->fetchOne($query, $bindings);
66		- }
	62	+ return $this
	63	+ ->connections
	64	+ ->getRead()
	65	+ ->fetchOne($query, $bindings);
	66	+ }
67	67
68		- /**
69		- * @return array\|false
70		- */
71		- public function getUnmappedTwitters()
72		- {
73		- $query = "
	68	+ /**
	69	+ * @return array\|false
	70	+ */
	71	+ public function getUnmappedTwitters()
	72	+ {
	73	+ $query = "
74	74	SELECT `id`, `date`
75	75	FROM `jpemeric_stream`.`twitter`
76	76	LEFT JOIN `jpemeric_stream`.`post`
77	77	ON `post`.`type_id` = `twitter`.`id` AND `post`.`id` IS NULL";
78	78
79		- return $this
80		- ->connections
81		- ->getRead()
82		- ->fetchAll($query);
83		- }
	79	+ return $this
	80	+ ->connections
	81	+ ->getRead()
	82	+ ->fetchAll($query);
	83	+ }
84	84	}

		@@ -6,7 +6,7 @@
		block discarded – undo
6	6
7	7	interface TwitterRepositoryInterface
8	8	{
9		- public function getTwitterById($id);
10		- public function getTwitterByFields(DateTimeInterface $date, $text);
11		- public function getUnmappedTwitters();
	9	+ public function getTwitterById($id);
	10	+ public function getTwitterByFields(DateTimeInterface $date, $text);
	11	+ public function getUnmappedTwitters();
12	12	}

		@@ -4,7 +4,7 @@
		block discarded – undo
4	4
5	5	interface YouTubeRepositoryInterface
6	6	{
7		- public function getYouTubeById($id);
8		- public function getYouTubeByVideoId($videoId);
9		- public function getUnmappedYouTubes();
	7	+ public function getYouTubeById($id);
	8	+ public function getYouTubeByVideoId($videoId);
	9	+ public function getUnmappedYouTubes();
10	10	}

jacobemerick / web

Push — master ( c330e2...cf0c7a )

Status

Category

Indentation +3 added lines, -3 removed lines patch added patch discarded remove patch

Indentation +56 added lines, -56 removed lines patch added patch discarded remove patch

Indentation +1 added lines, -1 removed lines patch added patch discarded remove patch

Indentation +25 added lines, -25 removed lines patch added patch discarded remove patch

Indentation +102 added lines, -102 removed lines patch added patch discarded remove patch

Indentation +6 added lines, -6 removed lines patch added patch discarded remove patch

Indentation +54 added lines, -54 removed lines patch added patch discarded remove patch

Indentation +3 added lines, -3 removed lines patch added patch discarded remove patch

Indentation +3 added lines, -3 removed lines patch added patch discarded remove patch