jacobemerick / web

script/cron/generate-rss-feeds.php

Indentation +83 added lines, -83 removed lines

@@ -21,14 +21,14 @@ 
  * @return boolean
  */
 $buildFeed = function (Feed $feed, $folder, $name = 'rss') {
-    $tempFeed = __DIR__ . "/../../public/{$folder}/{$name}-new.xml";
-    $finalFeed = __DIR__ . "/../../public/{$folder}/{$name}.xml";
+	$tempFeed = __DIR__ . "/../../public/{$folder}/{$name}-new.xml";
+	$finalFeed = __DIR__ . "/../../public/{$folder}/{$name}.xml";
 
-    $feedHandle = fopen($tempFeed, 'w');
-    fwrite($feedHandle, $feed->render());
-    fclose($feedHandle);
+	$feedHandle = fopen($tempFeed, 'w');
+	fwrite($feedHandle, $feed->render());
+	fclose($feedHandle);
 
-    rename($tempFeed, $finalFeed);
+	rename($tempFeed, $finalFeed);
 };
 
 
@@ -47,56 +47,56 @@ 
 $activeBlogPosts = $blogPostRepository->getActivePosts();
 
 foreach ($activeBlogPosts as $blogPost) {
-    $blogPostItem = new Item();
-
-    $blogPostItem->title($blogPost['title']);
-
-    $url = "https://blog.jacobemerick.com/{$blogPost['category']}/{$blogPost['path']}/";
-    $blogPostItem->url($url);
-    $blogPostItem->guid($url, true);
-
-    $description = $blogPost['body'];
-    $description = strip_tags($description);
-    $description = strtok($description, "\n");
-    if (strlen($description) > 250) {
-        $description = wordwrap($description, 250);
-        $description = strtok($description, "\n");
-        if (substr($description, -1) != '.') {
-            $description .= '…';
-        }
-    }
-    $description = html_entity_decode($description);
-    $blogPostItem->description($description);
-
-    $categoryUrl = "https://blog.jacobemerick.com/{$blogPost['category']}/";
-    $blogPostItem->category($blogPost['category'], $categoryUrl);
-
-    $pubDate = new DateTime($blogPost['date']);
-    $blogPostItem->pubDate($pubDate->getTimestamp());
-
-    $firstPhoto = Content::instance('FetchFirstPhoto', $blogPost['body'])->activate(true, 'large');
-    if (!empty($firstPhoto)) {
-        $firstPhotoPieces = sscanf($firstPhoto, '<img src="%s" height="%d" width="%d" alt="%s" />');
-        $firstPhotoPath = current($firstPhotoPieces);
-        $firstPhotoPath = trim($firstPhotoPath, '"');
-
-        $firstPhotoInternalPath = __DIR__ . '/../../public' . $firstPhotoPath;
-
-        $firstPhotoSize = filesize($firstPhotoInternalPath);
-
-        /**
-         * ugh, remote host does not have pecl fileinfo
-         *
-         * $fInfo = new finfo(FILEINFO_MIME_TYPE);
-         * $firstPhotoType = $fInfo->file($firstPhotoInternalPath);
-         * unset($fInfo);
-         **/
-        $firstPhotoType = 'image/jpeg';
-
-        $blogPostItem->enclosure("https://blog.jacobemerick.com{$firstPhotoPath}", $firstPhotoSize, $firstPhotoType);
-    }
-
-    $blogPostItem->appendTo($blogPostChannel);
+	$blogPostItem = new Item();
+
+	$blogPostItem->title($blogPost['title']);
+
+	$url = "https://blog.jacobemerick.com/{$blogPost['category']}/{$blogPost['path']}/";
+	$blogPostItem->url($url);
+	$blogPostItem->guid($url, true);
+
+	$description = $blogPost['body'];
+	$description = strip_tags($description);
+	$description = strtok($description, "\n");
+	if (strlen($description) > 250) {
+		$description = wordwrap($description, 250);
+		$description = strtok($description, "\n");
+		if (substr($description, -1) != '.') {
+			$description .= '&hellip;';
+		}
+	}
+	$description = html_entity_decode($description);
+	$blogPostItem->description($description);
+
+	$categoryUrl = "https://blog.jacobemerick.com/{$blogPost['category']}/";
+	$blogPostItem->category($blogPost['category'], $categoryUrl);
+
+	$pubDate = new DateTime($blogPost['date']);
+	$blogPostItem->pubDate($pubDate->getTimestamp());
+
+	$firstPhoto = Content::instance('FetchFirstPhoto', $blogPost['body'])->activate(true, 'large');
+	if (!empty($firstPhoto)) {
+		$firstPhotoPieces = sscanf($firstPhoto, '<img src="%s" height="%d" width="%d" alt="%s" />');
+		$firstPhotoPath = current($firstPhotoPieces);
+		$firstPhotoPath = trim($firstPhotoPath, '"');
+
+		$firstPhotoInternalPath = __DIR__ . '/../../public' . $firstPhotoPath;
+
+		$firstPhotoSize = filesize($firstPhotoInternalPath);
+
+		/**
+		 * ugh, remote host does not have pecl fileinfo
+		 *
+		 * $fInfo = new finfo(FILEINFO_MIME_TYPE);
+		 * $firstPhotoType = $fInfo->file($firstPhotoInternalPath);
+		 * unset($fInfo);
+		 **/
+		$firstPhotoType = 'image/jpeg';
+
+		$blogPostItem->enclosure("https://blog.jacobemerick.com{$firstPhotoPath}", $firstPhotoSize, $firstPhotoType);
+	}
+
+	$blogPostItem->appendTo($blogPostChannel);
 }
 
 $buildFeed($blogPostFeed, 'blog');
@@ -114,33 +114,33 @@ 
 $activeBlogComments = $commentRepository->getActiveCommentsBySite('blog');
 
 foreach ($activeBlogComments as $blogComment) {
-    $blogCommentItem = new Item();
-
-    $blogCommentItem->title("Comment on '{$blogComment['title']}' from {$blogComment['name']}");
-
-    $url = "https://blog.jacobemerick.com/{$blogComment['category']}/{$blogComment['path']}/";
-    $url .= "#comment-{$blogComment['id']}";
-    $blogCommentItem->url($url);
-    $blogCommentItem->guid($url, true);
-
-    $description = $blogComment['body'];
-    $description = strip_tags($description);
-    $description = strtok($description, "\n");
-    if (strlen($description) > 250) {
-        $description = wordwrap($description, 250);
-        $description = strtok($description, "\n");
-        if (substr($description, -1) != '.') {
-            $description .= '&hellip;';
-        }
-    }
-    $description = html_entity_decode($description);
-    $description = trim($description);
-    $blogCommentItem->description($description);
-
-    $pubDate = new DateTime($blogComment['date']);
-    $blogCommentItem->pubDate($pubDate->getTimestamp());
-
-    $blogCommentItem->appendTo($blogCommentChannel);
+	$blogCommentItem = new Item();
+
+	$blogCommentItem->title("Comment on '{$blogComment['title']}' from {$blogComment['name']}");
+
+	$url = "https://blog.jacobemerick.com/{$blogComment['category']}/{$blogComment['path']}/";
+	$url .= "#comment-{$blogComment['id']}";
+	$blogCommentItem->url($url);
+	$blogCommentItem->guid($url, true);
+
+	$description = $blogComment['body'];
+	$description = strip_tags($description);
+	$description = strtok($description, "\n");
+	if (strlen($description) > 250) {
+		$description = wordwrap($description, 250);
+		$description = strtok($description, "\n");
+		if (substr($description, -1) != '.') {
+			$description .= '&hellip;';
+		}
+	}
+	$description = html_entity_decode($description);
+	$description = trim($description);
+	$blogCommentItem->description($description);
+
+	$pubDate = new DateTime($blogComment['date']);
+	$blogCommentItem->pubDate($pubDate->getTimestamp());
+
+	$blogCommentItem->appendTo($blogCommentChannel);
 }
 
 $buildFeed($blogCommentFeed, 'blog', 'rss-comments');

utility/Loader.class.inc.php

Indentation +12 added lines, -12 removed lines

@@ -173,17 +173,17 @@
 		return self::instance()->is_live;
 	}
 
-    public static function getRootURL($site = '')
-    {
-        if (strlen($site) > 0) {
-            $protocol = (!empty($_SERVER['HTTPS']) && $_SERVER['HTTPS'] !== 'off') ? 'https' : 'http';
-            if ($site == 'waterfalls' && self::instance()->is_live) {
-                return "{$protocol}://www.waterfallsofthekeweenaw.com/";
-            } else {
-                return $protocol . '://' . (self::instance()->is_live ? '' : 'dev.') . $site . '.jacobemerick.com/';
-            }
-        }
-        return '/';
-    }
+	public static function getRootURL($site = '')
+	{
+		if (strlen($site) > 0) {
+			$protocol = (!empty($_SERVER['HTTPS']) && $_SERVER['HTTPS'] !== 'off') ? 'https' : 'http';
+			if ($site == 'waterfalls' && self::instance()->is_live) {
+				return "{$protocol}://www.waterfallsofthekeweenaw.com/";
+			} else {
+				return $protocol . '://' . (self::instance()->is_live ? '' : 'dev.') . $site . '.jacobemerick.com/';
+			}
+		}
+		return '/';
+	}
 
 }

utility/URLDecode.class.inc.php

Indentation +10 added lines, -10 removed lines

@@ -24,21 +24,21 @@
 		
 		self::$array['host'] = $host;
 		
-    if (
-      $host == 'www.waterfallsofthekeweenaw.com' ||
-      $host == 'waterfallsofthekeweenaw.com'
-    ) {
+	if (
+	  $host == 'www.waterfallsofthekeweenaw.com' ||
+	  $host == 'waterfallsofthekeweenaw.com'
+	) {
 			self::$array['site'] = 'waterfalls';
 		} else {
 			self::$array['site'] = substr($host, 0, strpos($host, '.'));
 		}
 
-    $base = '';
-    $base .= (!empty($_SERVER['HTTPS']) && $_SERVER['HTTPS'] !== 'off') ? 'https' : 'http';
-    $base .= '://';
-    $base .= (!Loader::isLive()) ? 'dev' : '';
-    $base .= $host;
-    $base .= '/';
+	$base = '';
+	$base .= (!empty($_SERVER['HTTPS']) && $_SERVER['HTTPS'] !== 'off') ? 'https' : 'http';
+	$base .= '://';
+	$base .= (!Loader::isLive()) ? 'dev' : '';
+	$base .= $host;
+	$base .= '/';
 
 		self::$array['base'] = $base;
 		self::$array['uri'] = '/' . implode('/', $uri_array);

router/Router.class.inc.php

Indentation +7 added lines, -7 removed lines

@@ -75,19 +75,19 @@ 
 		if($this->requires_trailing_slash() && substr($redirect_uri, -1) != '/')
 			$redirect_uri .= '/';
 		
-        if (URLDecode::getHost() == 'waterfalls.jacobemerick.com') {
-            $protocol = (!empty($_SERVER['HTTPS']) && $_SERVER['HTTPS'] !== 'off') ? 'https' : 'http';
-            $redirect_uri = $protocol . '://' . (!Loader::isLive() ? 'dev' : 'www') . '.waterfallsofthekeweenaw.com' . $redirect_uri;
-        }
+		if (URLDecode::getHost() == 'waterfalls.jacobemerick.com') {
+			$protocol = (!empty($_SERVER['HTTPS']) && $_SERVER['HTTPS'] !== 'off') ? 'https' : 'http';
+			$redirect_uri = $protocol . '://' . (!Loader::isLive() ? 'dev' : 'www') . '.waterfallsofthekeweenaw.com' . $redirect_uri;
+		}
         
 		if($redirect_uri == URLDecode::getURI())
 			return;
 		
 		$controller_check = $redirect_uri;
 		if(substr($redirect_uri, 0, 4) == 'http') {
-      $protocol = (!empty($_SERVER['HTTPS']) && $_SERVER['HTTPS'] !== 'off') ? 'https' : 'http';
+	  $protocol = (!empty($_SERVER['HTTPS']) && $_SERVER['HTTPS'] !== 'off') ? 'https' : 'http';
 			$controller_check = preg_replace('@^' . $protocol . '://([a-z\.]+)@', '', $redirect_uri);
-    }
+	}
 		
 		$controller = $this->get_controller($controller_check);
 		if($controller == '/Error404Controller')
@@ -138,7 +138,7 @@ 
 	{
 		return (
 			URLDecode::getExtension() != 'json' &&
-            strstr(URLDecode::getURI(), '#') === false);
+			strstr(URLDecode::getURI(), '#') === false);
 	}
 
 }

src/Domain/Stream/Activity/MysqlActivityRepository.php

Indentation +75 added lines, -75 removed lines

@@ -7,108 +7,108 @@
 class MysqlActivityRepository implements ActivityRepositoryInterface
 {
 
-    /** @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 getActivityById($id)
-    {
-        $query = "
+	/**
+	 * @param integer $id
+	 *
+	 * @return array|false
+	 */
+	public function getActivityById($id)
+	{
+		$query = "
             SELECT *
             FROM `jpemeric_stream`.`activity`
             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 integer $limit
-     * @param integer $offset
-     *
-     * @return array|false
-     */
-    public function getActivities($limit = null, $offset = 0)
-    {
-        $query = "
+	/**
+	 * @param integer $limit
+	 * @param integer $offset
+	 *
+	 * @return array|false
+	 */
+	public function getActivities($limit = null, $offset = 0)
+	{
+		$query = "
             SELECT *
             FROM `jpemeric_stream`.`activity`
             ORDER BY `datetime` 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 getActivitiesCount()
-    {
-        $query = "
+	public function getActivitiesCount()
+	{
+		$query = "
             SELECT COUNT(1) AS `count`
             FROM `jpemeric_stream`.`activity`";
 
-        return $this
-            ->connections
-            ->getRead()
-            ->fetchValue($query);
-    }
+		return $this
+			->connections
+			->getRead()
+			->fetchValue($query);
+	}
 
-    public function getActivitiesByType($type, $limit = null, $offset = 0)
-    {
-        $query = "
+	public function getActivitiesByType($type, $limit = null, $offset = 0)
+	{
+		$query = "
             SELECT *
             FROM `jpemeric_stream`.`activity`
             WHERE `type` = :type
             ORDER BY `datetime` DESC";
-        if (!is_null($limit)) {
-            $query .= "
+		if (!is_null($limit)) {
+			$query .= "
             LIMIT {$offset}, {$limit}";
-        }
-        $bindings = [
-            'type' => $type,
-        ];
+		}
+		$bindings = [
+			'type' => $type,
+		];
 
-        return $this
-            ->connections
-            ->getRead()
-            ->fetchAll($query, $bindings);
-    }
+		return $this
+			->connections
+			->getRead()
+			->fetchAll($query, $bindings);
+	}
 
-    public function getActivitiesByTypeCount($type)
-    {
-        $query = "
+	public function getActivitiesByTypeCount($type)
+	{
+		$query = "
             SELECT COUNT(1) AS `count`
             FROM `jpemeric_stream`.`activity`
             WHERE `type` = :type";
-        $bindings = [
-            'type' => $type,
-        ];
+		$bindings = [
+			'type' => $type,
+		];
 
-        return $this
-            ->connections
-            ->getRead()
-            ->fetchValue($query, $bindings);
-    }
+		return $this
+			->connections
+			->getRead()
+			->fetchValue($query, $bindings);
+	}
 }

src/Domain/Stream/Changelog/MysqlChangelogRepository.php

Indentation +26 added lines, -26 removed lines

@@ -7,37 +7,37 @@
 class MysqlChangelogRepository implements ChangelogRepositoryInterface
 {
 
-    /** @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 $limit
-     * @param integer $offset
-     *
-     * @return array|false
-     */
-    public function getChanges($limit = null, $offset = 0)
-    {
-        $query = "
+	/**
+	 * @param integer $limit
+	 * @param integer $offset
+	 *
+	 * @return array|false
+	 */
+	public function getChanges($limit = null, $offset = 0)
+	{
+		$query = "
             SELECT `message`, `message_short`, `datetime`, `commit_link`
             FROM `jpemeric_stream`.`changelog`
             ORDER BY `datetime` 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);
+	}
 }

tests/unit/Domain/Blog/Series/MysqlSeriesRepositoryTest.php

Indentation +352 added lines, -352 removed lines

@@ -9,14 +9,14 @@ 
 class MysqlSeriesRepositoryTest extends PHPUnit_Framework_TestCase
 {
 
-    protected static $connection;
+	protected static $connection;
 
-    public static function setUpBeforeClass()
-    {
-        $extendedPdo = new ExtendedPdo('sqlite::memory:');
-        $extendedPdo->exec("ATTACH DATABASE `jpemeric_blog.db` AS `jpemeric_blog`");
+	public static function setUpBeforeClass()
+	{
+		$extendedPdo = new ExtendedPdo('sqlite::memory:');
+		$extendedPdo->exec("ATTACH DATABASE `jpemeric_blog.db` AS `jpemeric_blog`");
 
-        $extendedPdo->exec("
+		$extendedPdo->exec("
             CREATE TABLE IF NOT EXISTS `jpemeric_blog`.`post` (
                 `id` integer PRIMARY KEY AUTOINCREMENT,
                 `title` varchar(60) NOT NULL,
@@ -26,380 +26,380 @@ 
                 `body` text,
                 `display` integer(1) NOT NULL
             )"
-        );
-        $extendedPdo->exec("
+		);
+		$extendedPdo->exec("
             CREATE TABLE IF NOT EXISTS `jpemeric_blog`.`series` (
                 `id` integer PRIMARY KEY AUTOINCREMENT,
                 `title` text NOT NULL,
                 `description` text NOT NULL
             )"
-        );
-        $extendedPdo->exec("
+		);
+		$extendedPdo->exec("
             CREATE TABLE IF NOT EXISTS `jpemeric_blog`.`series_post` (
                 `series` integer NOT NULL,
                 `post` integer NOT NULL,
                 `order` integer(1) NOT NULL
             )"
-        );
-
-        self::$connection = new ConnectionLocator(function () use ($extendedPdo) {
-            return $extendedPdo;
-        });
-    }
-
-    public function testIsInstanceOfSeriesRepository()
-    {
-        $repository = new MysqlSeriesRepository(self::$connection);
-
-        $this->assertInstanceOf(
-            'Jacobemerick\Web\Domain\Blog\Series\MysqlSeriesRepository',
-            $repository
-        );
-    }
-
-    public function testImplementsSeriesInterface()
-    {
-        $repository = new MysqlSeriesRepository(self::$connection);
-
-        $this->assertInstanceOf(
-            'Jacobemerick\Web\Domain\Blog\Series\SeriesRepositoryInterface',
-            $repository
-        );
-    }
-
-    public function testConstructSetsConnections()
-    {
-        $respository = new MysqlSeriesRepository(self::$connection);
-
-        $this->assertAttributeSame(
-            self::$connection,
-            'connections',
-            $respository
-        );
-    }
-
-    public function testGetSeriesForPost()
-    {
-        $testPostData = [
-            [
-                'id' => rand(1, 100),
-                'title' => 'test one',
-                'category' => 'test category',
-                'path' => 'test-one',
-                'display' => 1,
-            ],
-            [
-                'id' => rand(101, 200),
-                'title' => 'test two',
-                'category' => 'test category',
-                'path' => 'test-two',
-                'display' => 1,
-            ],
-        ];
-
-        $testSeriesData = [
-            [
-                'id' => rand(1, 100),
-                'title' => 'test one',
-                'description' => 'test description',
-            ],
-        ];
-
-        $testSeriesPostData = [];
-        foreach ($testPostData as $testPostDataRow) {
-            array_push($testSeriesPostData, [
-                'series' => reset($testSeriesData)['id'],
-                'post' => $testPostDataRow['id'],
-            ]);
-        }
-
-        array_walk($testPostData, [$this, 'insertPostData']);
-        array_walk($testSeriesData, [$this, 'insertSeriesData']);
-        array_walk($testSeriesPostData, [$this, 'insertSeriesPostData']);
-
-        $repository = new MysqlSeriesRepository(self::$connection);
-        $data = $repository->getSeriesForPost(reset($testPostData)['id']);
-
-        $this->assertNotFalse($data);
-        $this->assertInternalType('array', $data);
-        foreach ($testPostData as $key => $testPostRow) {
-            $this->assertInternalType('array', $data[$key]);
-            $this->assertArrayHasKey('series_title', $data[$key]);
-            $this->assertEquals(reset($testSeriesData)['title'], $data[$key]['series_title']);
-            $this->assertArrayHasKey('series_description', $data[$key]);
-            $this->assertEquals(reset($testSeriesData)['description'], $data[$key]['series_description']);
-            $this->assertArrayHasKey('post', $data[$key]);
-            $this->assertEquals($testPostRow['id'], $data[$key]['post']);
-            $this->assertArrayHasKey('title', $data[$key]);
-            $this->assertEquals($testPostRow['title'], $data[$key]['title']);
-            $this->assertArrayHasKey('category', $data[$key]);
-            $this->assertEquals($testPostRow['category'], $data[$key]['category']);
-            $this->assertArrayHasKey('path', $data[$key]);
-            $this->assertEquals($testPostRow['path'], $data[$key]['path']);
-        }
-    }
-
-    public function testGetSeriesForPostOrder()
-    {
-        $testPostData = [
-            [
-                'id' => rand(1, 100),
-                'display' => 1,
-            ],
-            [
-                'id' => rand(101, 200),
-                'display' => 1,
-            ],
-            [
-                'id' => rand(201, 300),
-                'display' => 1,
-            ],
-        ];
-
-        $testSeriesData = [
-            [
-                'id' => rand(1, 100),
-            ],
-        ];
-
-        $order = [1, 2, 3];
-        shuffle($order);
-        $testSeriesPostData = [];
-        foreach ($testPostData as $key => $testPostDataRow) {
-            array_push($testSeriesPostData, [
-                'series' => reset($testSeriesData)['id'],
-                'post' => $testPostDataRow['id'],
-                'order' => $order[$key],
-            ]);
-        }
-
-        array_walk($testPostData, [$this, 'insertPostData']);
-        array_walk($testSeriesData, [$this, 'insertSeriesData']);
-        array_walk($testSeriesPostData, [$this, 'insertSeriesPostData']);
-
-        $repository = new MysqlSeriesRepository(self::$connection);
-        $data = $repository->getSeriesForPost(reset($testPostData)['id']);
-
-        usort($testPostData, function ($rowA, $rowB) use ($testSeriesPostData) {
-            $seriesA = array_filter($testSeriesPostData, function ($row) use ($rowA) {
-                return ($rowA['id'] == $row['post']);
-            });
-            $seriesB = array_filter($testSeriesPostData, function ($row) use ($rowB) {
-                return ($rowB['id'] == $row['post']);
-            });
-
-            return (reset($seriesA)['order'] > reset($seriesB)['order']);
-        });
-
-        $this->assertNotFalse($data);
-        $this->assertInternalType('array', $data);
-        foreach ($testPostData as $key => $testPostRow) {
-            $this->assertInternalType('array', $data[$key]);
-            $this->assertArrayHasKey('post', $data[$key]);
-            $this->assertEquals($testPostRow['id'], $data[$key]['post']);
-        }
-    }
+		);
+
+		self::$connection = new ConnectionLocator(function () use ($extendedPdo) {
+			return $extendedPdo;
+		});
+	}
+
+	public function testIsInstanceOfSeriesRepository()
+	{
+		$repository = new MysqlSeriesRepository(self::$connection);
+
+		$this->assertInstanceOf(
+			'Jacobemerick\Web\Domain\Blog\Series\MysqlSeriesRepository',
+			$repository
+		);
+	}
+
+	public function testImplementsSeriesInterface()
+	{
+		$repository = new MysqlSeriesRepository(self::$connection);
+
+		$this->assertInstanceOf(
+			'Jacobemerick\Web\Domain\Blog\Series\SeriesRepositoryInterface',
+			$repository
+		);
+	}
+
+	public function testConstructSetsConnections()
+	{
+		$respository = new MysqlSeriesRepository(self::$connection);
+
+		$this->assertAttributeSame(
+			self::$connection,
+			'connections',
+			$respository
+		);
+	}
+
+	public function testGetSeriesForPost()
+	{
+		$testPostData = [
+			[
+				'id' => rand(1, 100),
+				'title' => 'test one',
+				'category' => 'test category',
+				'path' => 'test-one',
+				'display' => 1,
+			],
+			[
+				'id' => rand(101, 200),
+				'title' => 'test two',
+				'category' => 'test category',
+				'path' => 'test-two',
+				'display' => 1,
+			],
+		];
+
+		$testSeriesData = [
+			[
+				'id' => rand(1, 100),
+				'title' => 'test one',
+				'description' => 'test description',
+			],
+		];
+
+		$testSeriesPostData = [];
+		foreach ($testPostData as $testPostDataRow) {
+			array_push($testSeriesPostData, [
+				'series' => reset($testSeriesData)['id'],
+				'post' => $testPostDataRow['id'],
+			]);
+		}
+
+		array_walk($testPostData, [$this, 'insertPostData']);
+		array_walk($testSeriesData, [$this, 'insertSeriesData']);
+		array_walk($testSeriesPostData, [$this, 'insertSeriesPostData']);
+
+		$repository = new MysqlSeriesRepository(self::$connection);
+		$data = $repository->getSeriesForPost(reset($testPostData)['id']);
+
+		$this->assertNotFalse($data);
+		$this->assertInternalType('array', $data);
+		foreach ($testPostData as $key => $testPostRow) {
+			$this->assertInternalType('array', $data[$key]);
+			$this->assertArrayHasKey('series_title', $data[$key]);
+			$this->assertEquals(reset($testSeriesData)['title'], $data[$key]['series_title']);
+			$this->assertArrayHasKey('series_description', $data[$key]);
+			$this->assertEquals(reset($testSeriesData)['description'], $data[$key]['series_description']);
+			$this->assertArrayHasKey('post', $data[$key]);
+			$this->assertEquals($testPostRow['id'], $data[$key]['post']);
+			$this->assertArrayHasKey('title', $data[$key]);
+			$this->assertEquals($testPostRow['title'], $data[$key]['title']);
+			$this->assertArrayHasKey('category', $data[$key]);
+			$this->assertEquals($testPostRow['category'], $data[$key]['category']);
+			$this->assertArrayHasKey('path', $data[$key]);
+			$this->assertEquals($testPostRow['path'], $data[$key]['path']);
+		}
+	}
+
+	public function testGetSeriesForPostOrder()
+	{
+		$testPostData = [
+			[
+				'id' => rand(1, 100),
+				'display' => 1,
+			],
+			[
+				'id' => rand(101, 200),
+				'display' => 1,
+			],
+			[
+				'id' => rand(201, 300),
+				'display' => 1,
+			],
+		];
+
+		$testSeriesData = [
+			[
+				'id' => rand(1, 100),
+			],
+		];
+
+		$order = [1, 2, 3];
+		shuffle($order);
+		$testSeriesPostData = [];
+		foreach ($testPostData as $key => $testPostDataRow) {
+			array_push($testSeriesPostData, [
+				'series' => reset($testSeriesData)['id'],
+				'post' => $testPostDataRow['id'],
+				'order' => $order[$key],
+			]);
+		}
+
+		array_walk($testPostData, [$this, 'insertPostData']);
+		array_walk($testSeriesData, [$this, 'insertSeriesData']);
+		array_walk($testSeriesPostData, [$this, 'insertSeriesPostData']);
+
+		$repository = new MysqlSeriesRepository(self::$connection);
+		$data = $repository->getSeriesForPost(reset($testPostData)['id']);
+
+		usort($testPostData, function ($rowA, $rowB) use ($testSeriesPostData) {
+			$seriesA = array_filter($testSeriesPostData, function ($row) use ($rowA) {
+				return ($rowA['id'] == $row['post']);
+			});
+			$seriesB = array_filter($testSeriesPostData, function ($row) use ($rowB) {
+				return ($rowB['id'] == $row['post']);
+			});
+
+			return (reset($seriesA)['order'] > reset($seriesB)['order']);
+		});
+
+		$this->assertNotFalse($data);
+		$this->assertInternalType('array', $data);
+		foreach ($testPostData as $key => $testPostRow) {
+			$this->assertInternalType('array', $data[$key]);
+			$this->assertArrayHasKey('post', $data[$key]);
+			$this->assertEquals($testPostRow['id'], $data[$key]['post']);
+		}
+	}
  
-    public function testGetSeriesForPostSeriesFilter()
-    {
-        $testPostAData = [
-            [
-                'id' => rand(1, 100),
-                'display' => 1,
-            ],
-            [
-                'id' => rand(101, 200),
-                'display' => 1,
-            ],
-        ];
-
-        $testPostBData = [
-            [
-                'id' => rand(501, 600),
-                'display' => 1,
-            ],
-            [
-                'id' => rand(601, 700),
-                'display' => 1,
-            ],
-        ];
-
-        $testSeriesData = [
-            [
-                'id' => rand(1, 100),
-            ],
-            [
-                'id' => rand(101, 200),
-            ],
-        ];
-
-        $testSeriesPostData = [];
-        foreach ($testPostAData as $testPostDataRow) {
-            array_push($testSeriesPostData, [
-                'series' => $testSeriesData[0]['id'],
-                'post' => $testPostDataRow['id'],
-            ]);
-        }
-        foreach ($testPostBData as $testPostDataRow) {
-            array_push($testSeriesPostData, [
-                'series' => $testSeriesData[1]['id'],
-                'post' => $testPostDataRow['id'],
-            ]);
-        }
-
-        $testPostData = array_merge($testPostAData, $testPostBData);
-        array_walk($testPostData, [$this, 'insertPostData']);
-        array_walk($testSeriesData, [$this, 'insertSeriesData']);
-        array_walk($testSeriesPostData, [$this, 'insertSeriesPostData']);
-
-        $repository = new MysqlSeriesRepository(self::$connection);
-        $data = $repository->getSeriesForPost(reset($testPostAData)['id']);
-
-        $this->assertNotFalse($data);
-        $this->assertInternalType('array', $data);
-
-        $testPosts = array_column($testPostAData, 'id');
-        $dataPosts = array_column($data, 'post');
-
-        $this->assertEmpty(array_merge(
-            array_diff($testPosts, $dataPosts),
-            array_diff($dataPosts, $testPosts)
-        ));
-    }
+	public function testGetSeriesForPostSeriesFilter()
+	{
+		$testPostAData = [
+			[
+				'id' => rand(1, 100),
+				'display' => 1,
+			],
+			[
+				'id' => rand(101, 200),
+				'display' => 1,
+			],
+		];
+
+		$testPostBData = [
+			[
+				'id' => rand(501, 600),
+				'display' => 1,
+			],
+			[
+				'id' => rand(601, 700),
+				'display' => 1,
+			],
+		];
+
+		$testSeriesData = [
+			[
+				'id' => rand(1, 100),
+			],
+			[
+				'id' => rand(101, 200),
+			],
+		];
+
+		$testSeriesPostData = [];
+		foreach ($testPostAData as $testPostDataRow) {
+			array_push($testSeriesPostData, [
+				'series' => $testSeriesData[0]['id'],
+				'post' => $testPostDataRow['id'],
+			]);
+		}
+		foreach ($testPostBData as $testPostDataRow) {
+			array_push($testSeriesPostData, [
+				'series' => $testSeriesData[1]['id'],
+				'post' => $testPostDataRow['id'],
+			]);
+		}
+
+		$testPostData = array_merge($testPostAData, $testPostBData);
+		array_walk($testPostData, [$this, 'insertPostData']);
+		array_walk($testSeriesData, [$this, 'insertSeriesData']);
+		array_walk($testSeriesPostData, [$this, 'insertSeriesPostData']);
+
+		$repository = new MysqlSeriesRepository(self::$connection);
+		$data = $repository->getSeriesForPost(reset($testPostAData)['id']);
+
+		$this->assertNotFalse($data);
+		$this->assertInternalType('array', $data);
+
+		$testPosts = array_column($testPostAData, 'id');
+		$dataPosts = array_column($data, 'post');
+
+		$this->assertEmpty(array_merge(
+			array_diff($testPosts, $dataPosts),
+			array_diff($dataPosts, $testPosts)
+		));
+	}
  
-    public function testGetSeriesForPostInactive()
-    {
-        $testPostData = [
-            [
-                'id' => rand(1, 100),
-                'display' => 1,
-            ],
-            [
-                'id' => rand(101, 200),
-                'display' => 0,
-            ],
-            [
-                'id' => rand(201, 300),
-                'display' => 0,
-            ],
-        ];
-
-        $testSeriesData = [
-            [
-                'id' => rand(1, 100),
-            ],
-        ];
-
-        $testSeriesPostData = [];
-        foreach ($testPostData as $testPostDataRow) {
-            array_push($testSeriesPostData, [
-                'series' => reset($testSeriesData)['id'],
-                'post' => $testPostDataRow['id'],
-            ]);
-        }
-
-        array_walk($testPostData, [$this, 'insertPostData']);
-        array_walk($testSeriesData, [$this, 'insertSeriesData']);
-        array_walk($testSeriesPostData, [$this, 'insertSeriesPostData']);
-
-        $repository = new MysqlSeriesRepository(self::$connection);
-        $data = $repository->getSeriesForPost(reset($testPostData)['id']);
-
-        $this->assertNotFalse($data);
-        $this->assertInternalType('array', $data);
-
-        $testPostData = array_filter($testPostData, function ($row) {
-            return ($row['display'] == 1);
-        });
-        $testPosts = array_column($testPostData, 'id');
-        $dataPosts = array_column($data, 'post');
-
-        $this->assertEmpty(array_merge(
-            array_diff($testPosts, $dataPosts),
-            array_diff($dataPosts, $testPosts)
-        ));
-    }
-
-    public function testGetSeriesForPostFailure()
-    {
-        $repository = new MysqlSeriesRepository(self::$connection);
-        $data = $repository->getSeriesForPost(rand(1, 100));
-
-        $this->assertEmpty($data);
-        $this->assertInternalType('array', $data);
-    }
-
-    protected function insertPostData(array $data)
-    {
-        $defaultData = [
-            'id' => null,
-            'title' => '',
-            'path' => '',
-            'category' => '',
-            'date' => '',
-            'body' => '',
-            'display' => 0,
-        ];
-
-        $data = array_merge($defaultData, $data);
-
-        return self::$connection->getDefault()->perform("
+	public function testGetSeriesForPostInactive()
+	{
+		$testPostData = [
+			[
+				'id' => rand(1, 100),
+				'display' => 1,
+			],
+			[
+				'id' => rand(101, 200),
+				'display' => 0,
+			],
+			[
+				'id' => rand(201, 300),
+				'display' => 0,
+			],
+		];
+
+		$testSeriesData = [
+			[
+				'id' => rand(1, 100),
+			],
+		];
+
+		$testSeriesPostData = [];
+		foreach ($testPostData as $testPostDataRow) {
+			array_push($testSeriesPostData, [
+				'series' => reset($testSeriesData)['id'],
+				'post' => $testPostDataRow['id'],
+			]);
+		}
+
+		array_walk($testPostData, [$this, 'insertPostData']);
+		array_walk($testSeriesData, [$this, 'insertSeriesData']);
+		array_walk($testSeriesPostData, [$this, 'insertSeriesPostData']);
+
+		$repository = new MysqlSeriesRepository(self::$connection);
+		$data = $repository->getSeriesForPost(reset($testPostData)['id']);
+
+		$this->assertNotFalse($data);
+		$this->assertInternalType('array', $data);
+
+		$testPostData = array_filter($testPostData, function ($row) {
+			return ($row['display'] == 1);
+		});
+		$testPosts = array_column($testPostData, 'id');
+		$dataPosts = array_column($data, 'post');
+
+		$this->assertEmpty(array_merge(
+			array_diff($testPosts, $dataPosts),
+			array_diff($dataPosts, $testPosts)
+		));
+	}
+
+	public function testGetSeriesForPostFailure()
+	{
+		$repository = new MysqlSeriesRepository(self::$connection);
+		$data = $repository->getSeriesForPost(rand(1, 100));
+
+		$this->assertEmpty($data);
+		$this->assertInternalType('array', $data);
+	}
+
+	protected function insertPostData(array $data)
+	{
+		$defaultData = [
+			'id' => null,
+			'title' => '',
+			'path' => '',
+			'category' => '',
+			'date' => '',
+			'body' => '',
+			'display' => 0,
+		];
+
+		$data = array_merge($defaultData, $data);
+
+		return self::$connection->getDefault()->perform("
             INSERT INTO `jpemeric_blog`.`post`
                 (id, title, path, category, date, body, display)
             VALUES
                 (:id, :title, :path, :category, :date, :body, :display)",
-            $data
-        );
-    }
+			$data
+		);
+	}
 
-    protected function insertSeriesData(array $data)
-    {
-        $defaultData = [
-            'id' => null,
-            'title' => '',
-            'description' => '',
-        ];
+	protected function insertSeriesData(array $data)
+	{
+		$defaultData = [
+			'id' => null,
+			'title' => '',
+			'description' => '',
+		];
 
-        $data = array_merge($defaultData, $data);
+		$data = array_merge($defaultData, $data);
 
-        return self::$connection->getDefault()->perform("
+		return self::$connection->getDefault()->perform("
             INSERT INTO `jpemeric_blog`.`series`
                 (id, title, description)
             VALUES
                 (:id, :title, :description)",
-            $data
-        );
-    }
+			$data
+		);
+	}
 
-    protected function insertSeriesPostData(array $data)
-    {
-        $defaultData = [
-            'series' => '',
-            'post' => '',
-            'order' => 0,
-        ];
+	protected function insertSeriesPostData(array $data)
+	{
+		$defaultData = [
+			'series' => '',
+			'post' => '',
+			'order' => 0,
+		];
 
-        $data = array_merge($defaultData, $data);
+		$data = array_merge($defaultData, $data);
 
-        return self::$connection->getDefault()->perform("
+		return self::$connection->getDefault()->perform("
             INSERT INTO `jpemeric_blog`.`series_post`
                 (series, post, `order`)
             VALUES
                 (:series, :post, :order)",
-            $data
-        );
-    }
-
-    protected function tearDown()
-    {
-        self::$connection->getDefault()->perform("DELETE FROM `jpemeric_blog`.`post`");
-        self::$connection->getDefault()->perform("DELETE FROM `jpemeric_blog`.`series`");
-        self::$connection->getDefault()->perform("DELETE FROM `jpemeric_blog`.`series_post`");
-    }
-
-    public static function tearDownAfterClass()
-    {
-        self::$connection->getDefault()->disconnect();
-        unlink('jpemeric_blog.db');
-    }
+			$data
+		);
+	}
+
+	protected function tearDown()
+	{
+		self::$connection->getDefault()->perform("DELETE FROM `jpemeric_blog`.`post`");
+		self::$connection->getDefault()->perform("DELETE FROM `jpemeric_blog`.`series`");
+		self::$connection->getDefault()->perform("DELETE FROM `jpemeric_blog`.`series_post`");
+	}
+
+	public static function tearDownAfterClass()
+	{
+		self::$connection->getDefault()->disconnect();
+		unlink('jpemeric_blog.db');
+	}
 }

tests/unit/Domain/Blog/Tag/MysqlTagRepositoryTest.php

Indentation +470 added lines, -470 removed lines

@@ -9,14 +9,14 @@ 
 class MysqlTagRepositoryTest extends PHPUnit_Framework_TestCase
 {
 
-    protected static $connection;
+	protected static $connection;
 
-    public static function setUpBeforeClass()
-    {
-        $extendedPdo = new ExtendedPdo('sqlite::memory:');
-        $extendedPdo->exec("ATTACH DATABASE `jpemeric_blog.db` AS `jpemeric_blog`");
+	public static function setUpBeforeClass()
+	{
+		$extendedPdo = new ExtendedPdo('sqlite::memory:');
+		$extendedPdo->exec("ATTACH DATABASE `jpemeric_blog.db` AS `jpemeric_blog`");
 
-        $extendedPdo->exec("
+		$extendedPdo->exec("
             CREATE TABLE IF NOT EXISTS `jpemeric_blog`.`post` (
                 `id` integer PRIMARY KEY AUTOINCREMENT,
                 `title` varchar(60) NOT NULL,
@@ -26,497 +26,497 @@ 
                 `body` text,
                 `display` integer(1) NOT NULL
             )"
-        );
-        $extendedPdo->exec("
+		);
+		$extendedPdo->exec("
             CREATE TABLE IF NOT EXISTS `jpemeric_blog`.`ptlink` (
                 `post_id` integer NOT NULL,
                 `tag_id` integer NOT NULL
             )"
-        );
-        $extendedPdo->exec("
+		);
+		$extendedPdo->exec("
             CREATE TABLE IF NOT EXISTS `jpemeric_blog`.`tag` (
                 `id` integer PRIMARY KEY AUTOINCREMENT,
                 `tag` varchar(25) NOT NULL
             )"
-        );
-
-        self::$connection = new ConnectionLocator(function () use ($extendedPdo) {
-            return $extendedPdo;
-        });
-    }
-
-    public function testIsInstanceOfTagRepository()
-    {
-        $repository = new MysqlTagRepository(self::$connection);
-
-        $this->assertInstanceOf(
-            'Jacobemerick\Web\Domain\Blog\Tag\MysqlTagRepository',
-            $repository
-        );
-    }
-
-    public function testImplementsTagInterface()
-    {
-        $repository = new MysqlTagRepository(self::$connection);
-
-        $this->assertInstanceOf(
-            'Jacobemerick\Web\Domain\Blog\Tag\TagRepositoryInterface',
-            $repository
-        );
-    }
-
-    public function testConstructSetsConnections()
-    {
-        $respository = new MysqlTagRepository(self::$connection);
-
-        $this->assertAttributeSame(
-            self::$connection,
-            'connections',
-            $respository
-        );
-    }
-
-    public function testFindTagByTitle()
-    {
-        $testData = [
-            [
-                'id' => rand(1, 100),
-                'tag' => 'test one',
-            ],
-            [
-                'id' => rand(101, 200),
-                'tag' => 'test two',
-            ],
-        ];
-
-        array_walk($testData, [$this, 'insertTagData']);
-
-        shuffle($testData);
-
-        $repository = new MysqlTagRepository(self::$connection);
-        $data = $repository->findTagByTitle(reset($testData)['tag']);
-
-        $this->assertNotFalse($data);
-        $this->assertInternalType('array', $data);
-        $this->assertArrayHasKey('id', $data);
-        $this->assertEquals(reset($testData)['id'], $data['id']);
-        $this->assertArrayHasKey('tag', $data);
-        $this->assertEquals(reset($testData)['tag'], $data['tag']);
-    }
-
-    public function testFindTagByTitleFailure()
-    {
-        $repository = new MysqlTagRepository(self::$connection);
-        $data = $repository->findTagByTitle('empty tag');
-
-        $this->assertFalse($data);
-    }
-
-    public function testGetAllTags()
-    {
-        $testData = [
-            [
-                'id' => rand(1, 100),
-                'tag' => 'test one',
-            ],
-            [
-                'id' => rand(101, 200),
-                'tag' => 'test two',
-            ],
-        ];
-
-        array_walk($testData, [$this, 'insertTagData']);
-
-        $repository = new MysqlTagRepository(self::$connection);
-        $data = $repository->getAllTags();
-
-        $this->assertNotFalse($data);
-        $this->assertInternalType('array', $data);
-        $this->assertCount(count($testData), $data);
-        foreach ($testData as $key => $testDataRow) {
-            $this->assertArrayHasKey('id', $data[$key]);
-            $this->assertEquals($testDataRow['id'], $data[$key]['id']);
-            $this->assertArrayHasKey('tag', $data[$key]);
-            $this->assertEquals($testDataRow['tag'], $data[$key]['tag']);
-        }
-    }
+		);
+
+		self::$connection = new ConnectionLocator(function () use ($extendedPdo) {
+			return $extendedPdo;
+		});
+	}
+
+	public function testIsInstanceOfTagRepository()
+	{
+		$repository = new MysqlTagRepository(self::$connection);
+
+		$this->assertInstanceOf(
+			'Jacobemerick\Web\Domain\Blog\Tag\MysqlTagRepository',
+			$repository
+		);
+	}
+
+	public function testImplementsTagInterface()
+	{
+		$repository = new MysqlTagRepository(self::$connection);
+
+		$this->assertInstanceOf(
+			'Jacobemerick\Web\Domain\Blog\Tag\TagRepositoryInterface',
+			$repository
+		);
+	}
+
+	public function testConstructSetsConnections()
+	{
+		$respository = new MysqlTagRepository(self::$connection);
+
+		$this->assertAttributeSame(
+			self::$connection,
+			'connections',
+			$respository
+		);
+	}
+
+	public function testFindTagByTitle()
+	{
+		$testData = [
+			[
+				'id' => rand(1, 100),
+				'tag' => 'test one',
+			],
+			[
+				'id' => rand(101, 200),
+				'tag' => 'test two',
+			],
+		];
+
+		array_walk($testData, [$this, 'insertTagData']);
+
+		shuffle($testData);
+
+		$repository = new MysqlTagRepository(self::$connection);
+		$data = $repository->findTagByTitle(reset($testData)['tag']);
+
+		$this->assertNotFalse($data);
+		$this->assertInternalType('array', $data);
+		$this->assertArrayHasKey('id', $data);
+		$this->assertEquals(reset($testData)['id'], $data['id']);
+		$this->assertArrayHasKey('tag', $data);
+		$this->assertEquals(reset($testData)['tag'], $data['tag']);
+	}
+
+	public function testFindTagByTitleFailure()
+	{
+		$repository = new MysqlTagRepository(self::$connection);
+		$data = $repository->findTagByTitle('empty tag');
+
+		$this->assertFalse($data);
+	}
+
+	public function testGetAllTags()
+	{
+		$testData = [
+			[
+				'id' => rand(1, 100),
+				'tag' => 'test one',
+			],
+			[
+				'id' => rand(101, 200),
+				'tag' => 'test two',
+			],
+		];
+
+		array_walk($testData, [$this, 'insertTagData']);
+
+		$repository = new MysqlTagRepository(self::$connection);
+		$data = $repository->getAllTags();
+
+		$this->assertNotFalse($data);
+		$this->assertInternalType('array', $data);
+		$this->assertCount(count($testData), $data);
+		foreach ($testData as $key => $testDataRow) {
+			$this->assertArrayHasKey('id', $data[$key]);
+			$this->assertEquals($testDataRow['id'], $data[$key]['id']);
+			$this->assertArrayHasKey('tag', $data[$key]);
+			$this->assertEquals($testDataRow['tag'], $data[$key]['tag']);
+		}
+	}
  
-    public function testGetAllTagsFailure()
-    {
-        $repository = new MysqlTagRepository(self::$connection);
-        $data = $repository->getAllTags();
-
-        $this->assertEmpty($data);
-        $this->assertInternalType('array', $data);
-    }
-
-    public function testGetTagCloud()
-    {
-        $testPostData = [
-            [
-                'id' => rand(1, 100),
-                'display' => 1,
-            ],
-            [
-                'id' => rand(101, 200),
-                'display' => 1,
-            ],
-        ];
-
-        $testTagData = [
-            [
-                'id' => rand(1, 100),
-                'tag' => 'test one',
-            ],
-            [
-                'id' => rand(101, 200),
-                'tag' => 'test two',
-            ],
-            [
-                'id' => rand(201, 300),
-                'tag' => 'test three',
-            ],
-        ];
-
-        $testPTLinkData = [];
-        foreach ($testPostData as $testPostRow) {
-            $tempTagData = $testTagData;
-            shuffle($tempTagData);
-            for ($i = 0; $i < 2; $i++) {
-                array_push($testPTLinkData, [
-                    'post_id' => $testPostRow['id'],
-                    'tag_id' => $tempTagData[$i]['id'],
-                ]);
-            }
-        }
-
-        array_walk($testPostData, [$this, 'insertPostData']);
-        array_walk($testPTLinkData, [$this, 'insertPTLinkData']);
-        array_walk($testTagData, [$this, 'insertTagData']);
-
-        $repository = new MysqlTagRepository(self::$connection);
-        $data = $repository->getTagCloud();
-
-        $this->assertNotFalse($data);
-        $this->assertInternalType('array', $data);
-
-        $tagCountData = array_map(function ($row) use ($testTagData) {
-            $tag = $row['tag_id'];
-            $tag = array_filter($testTagData, function ($row) use ($tag) {
-                return ($tag == $row['id']);
-            });
-            $tag = current($tag)['tag'];
-            return $tag;
-        }, $testPTLinkData);
-
-        $testCountData = [];
-        foreach ($tagCountData as $tagCountRow) {
-            $incremented = false;
-            foreach ($testCountData as $key => $testCountRow) {
-                if ($tagCountRow == $testCountRow['tag']) {
-                    $testCountData[$key]['count']++;
-                    $incremented = true;
-                    break;
-                }
-            }
-            if (!$incremented) {
-                array_push($testCountData, [
-                    'count' => 1,
-                    'tag' => $tagCountRow,
-                ]);
-            }
-        }
-
-        $this->assertCount(count($testCountData), $data);
-
-        usort($testCountData, function ($rowA, $rowB) {
-            return ($rowA['tag'] > $rowB['tag']);
-        });
-        usort($data, function ($rowA, $rowB) {
-            return ($rowA['tag'] > $rowB['tag']);
-        });
-
-        foreach ($testCountData as $key => $testCountRow) {
-            $this->assertArrayHasKey('count', $data[$key]);
-            $this->assertEquals($testCountRow['count'], $data[$key]['count']);
-            $this->assertArrayHasKey('tag', $data[$key]);
-            $this->assertEquals($testCountRow['tag'], $data[$key]['tag']);
-        }
-    }
-
-    public function testGetTagCloudInactive()
-    {
-        $testPostData = [
-            [
-                'id' => rand(1, 100),
-                'display' => 1,
-            ],
-            [
-                'id' => rand(101, 200),
-                'display' => 1,
-            ],
-            [
-                'id' => rand(201, 300),
-                'display' => 0,
-            ],
-        ];
-
-        $testTagData = [
-            [
-                'id' => rand(1, 100),
-                'tag' => 'test one',
-            ],
-            [
-                'id' => rand(101, 200),
-                'tag' => 'test two',
-            ],
-            [
-                'id' => rand(201, 300),
-                'tag' => 'test three',
-            ],
-        ];
-
-        $testPTLinkData = [];
-        foreach ($testPostData as $testPostRow) {
-            $tempTagData = $testTagData;
-            shuffle($tempTagData);
-            for ($i = 0; $i < 2; $i++) {
-                array_push($testPTLinkData, [
-                    'post_id' => $testPostRow['id'],
-                    'tag_id' => $tempTagData[$i]['id'],
-                ]);
-            }
-        }
-
-        array_walk($testPostData, [$this, 'insertPostData']);
-        array_walk($testPTLinkData, [$this, 'insertPTLinkData']);
-        array_walk($testTagData, [$this, 'insertTagData']);
-
-        $repository = new MysqlTagRepository(self::$connection);
-        $data = $repository->getTagCloud();
-
-        $this->assertNotFalse($data);
-        $this->assertInternalType('array', $data);
-
-        $testPTLinkData = array_filter($testPTLinkData, function ($row) use ($testPostData) {
-            $post = $row['post_id'];
-            $post = array_filter($testPostData, function ($row) use ($post) {
-                return ($post == $row['id']);
-            });
-            $post = current($post);
-            return ($post['display'] == 1);
-        });
-
-        $tagCountData = array_map(function ($row) use ($testTagData) {
-            $tag = $row['tag_id'];
-            $tag = array_filter($testTagData, function ($row) use ($tag) {
-                return ($tag == $row['id']);
-            });
-            $tag = current($tag)['tag'];
-            return $tag;
-        }, $testPTLinkData);
-
-        $testCountData = [];
-        foreach ($tagCountData as $tagCountRow) {
-            $incremented = false;
-            foreach ($testCountData as $key => $testCountRow) {
-                if ($tagCountRow == $testCountRow['tag']) {
-                    $testCountData[$key]['count']++;
-                    $incremented = true;
-                    break;
-                }
-            }
-            if (!$incremented) {
-                array_push($testCountData, [
-                    'count' => 1,
-                    'tag' => $tagCountRow,
-                ]);
-            }
-        }
-
-        $this->assertCount(count($testCountData), $data);
-
-        usort($testCountData, function ($rowA, $rowB) {
-            return ($rowA['tag'] > $rowB['tag']);
-        });
-        usort($data, function ($rowA, $rowB) {
-            return ($rowA['tag'] > $rowB['tag']);
-        });
-
-        foreach ($testCountData as $key => $testCountRow) {
-            $this->assertArrayHasKey('count', $data[$key]);
-            $this->assertEquals($testCountRow['count'], $data[$key]['count']);
-            $this->assertArrayHasKey('tag', $data[$key]);
-            $this->assertEquals($testCountRow['tag'], $data[$key]['tag']);
-        }
-    }
-
-    public function testGetTagCloudFailure()
-    {
-        $testData = [
-            [
-                'id' => rand(1, 100),
-                'tag' => 'test one',
-            ],
-            [
-                'id' => rand(101, 200),
-                'tag' => 'test two',
-            ],
-        ];
-
-        array_walk($testData, [$this, 'insertTagData']);
-
-        $repository = new MysqlTagRepository(self::$connection);
-        $data = $repository->getTagCloud();
-
-        $this->assertEmpty($data);
-        $this->assertInternalType('array', $data);
-    }
+	public function testGetAllTagsFailure()
+	{
+		$repository = new MysqlTagRepository(self::$connection);
+		$data = $repository->getAllTags();
+
+		$this->assertEmpty($data);
+		$this->assertInternalType('array', $data);
+	}
+
+	public function testGetTagCloud()
+	{
+		$testPostData = [
+			[
+				'id' => rand(1, 100),
+				'display' => 1,
+			],
+			[
+				'id' => rand(101, 200),
+				'display' => 1,
+			],
+		];
+
+		$testTagData = [
+			[
+				'id' => rand(1, 100),
+				'tag' => 'test one',
+			],
+			[
+				'id' => rand(101, 200),
+				'tag' => 'test two',
+			],
+			[
+				'id' => rand(201, 300),
+				'tag' => 'test three',
+			],
+		];
+
+		$testPTLinkData = [];
+		foreach ($testPostData as $testPostRow) {
+			$tempTagData = $testTagData;
+			shuffle($tempTagData);
+			for ($i = 0; $i < 2; $i++) {
+				array_push($testPTLinkData, [
+					'post_id' => $testPostRow['id'],
+					'tag_id' => $tempTagData[$i]['id'],
+				]);
+			}
+		}
+
+		array_walk($testPostData, [$this, 'insertPostData']);
+		array_walk($testPTLinkData, [$this, 'insertPTLinkData']);
+		array_walk($testTagData, [$this, 'insertTagData']);
+
+		$repository = new MysqlTagRepository(self::$connection);
+		$data = $repository->getTagCloud();
+
+		$this->assertNotFalse($data);
+		$this->assertInternalType('array', $data);
+
+		$tagCountData = array_map(function ($row) use ($testTagData) {
+			$tag = $row['tag_id'];
+			$tag = array_filter($testTagData, function ($row) use ($tag) {
+				return ($tag == $row['id']);
+			});
+			$tag = current($tag)['tag'];
+			return $tag;
+		}, $testPTLinkData);
+
+		$testCountData = [];
+		foreach ($tagCountData as $tagCountRow) {
+			$incremented = false;
+			foreach ($testCountData as $key => $testCountRow) {
+				if ($tagCountRow == $testCountRow['tag']) {
+					$testCountData[$key]['count']++;
+					$incremented = true;
+					break;
+				}
+			}
+			if (!$incremented) {
+				array_push($testCountData, [
+					'count' => 1,
+					'tag' => $tagCountRow,
+				]);
+			}
+		}
+
+		$this->assertCount(count($testCountData), $data);
+
+		usort($testCountData, function ($rowA, $rowB) {
+			return ($rowA['tag'] > $rowB['tag']);
+		});
+		usort($data, function ($rowA, $rowB) {
+			return ($rowA['tag'] > $rowB['tag']);
+		});
+
+		foreach ($testCountData as $key => $testCountRow) {
+			$this->assertArrayHasKey('count', $data[$key]);
+			$this->assertEquals($testCountRow['count'], $data[$key]['count']);
+			$this->assertArrayHasKey('tag', $data[$key]);
+			$this->assertEquals($testCountRow['tag'], $data[$key]['tag']);
+		}
+	}
+
+	public function testGetTagCloudInactive()
+	{
+		$testPostData = [
+			[
+				'id' => rand(1, 100),
+				'display' => 1,
+			],
+			[
+				'id' => rand(101, 200),
+				'display' => 1,
+			],
+			[
+				'id' => rand(201, 300),
+				'display' => 0,
+			],
+		];
+
+		$testTagData = [
+			[
+				'id' => rand(1, 100),
+				'tag' => 'test one',
+			],
+			[
+				'id' => rand(101, 200),
+				'tag' => 'test two',
+			],
+			[
+				'id' => rand(201, 300),
+				'tag' => 'test three',
+			],
+		];
+
+		$testPTLinkData = [];
+		foreach ($testPostData as $testPostRow) {
+			$tempTagData = $testTagData;
+			shuffle($tempTagData);
+			for ($i = 0; $i < 2; $i++) {
+				array_push($testPTLinkData, [
+					'post_id' => $testPostRow['id'],
+					'tag_id' => $tempTagData[$i]['id'],
+				]);
+			}
+		}
+
+		array_walk($testPostData, [$this, 'insertPostData']);
+		array_walk($testPTLinkData, [$this, 'insertPTLinkData']);
+		array_walk($testTagData, [$this, 'insertTagData']);
+
+		$repository = new MysqlTagRepository(self::$connection);
+		$data = $repository->getTagCloud();
+
+		$this->assertNotFalse($data);
+		$this->assertInternalType('array', $data);
+
+		$testPTLinkData = array_filter($testPTLinkData, function ($row) use ($testPostData) {
+			$post = $row['post_id'];
+			$post = array_filter($testPostData, function ($row) use ($post) {
+				return ($post == $row['id']);
+			});
+			$post = current($post);
+			return ($post['display'] == 1);
+		});
+
+		$tagCountData = array_map(function ($row) use ($testTagData) {
+			$tag = $row['tag_id'];
+			$tag = array_filter($testTagData, function ($row) use ($tag) {
+				return ($tag == $row['id']);
+			});
+			$tag = current($tag)['tag'];
+			return $tag;
+		}, $testPTLinkData);
+
+		$testCountData = [];
+		foreach ($tagCountData as $tagCountRow) {
+			$incremented = false;
+			foreach ($testCountData as $key => $testCountRow) {
+				if ($tagCountRow == $testCountRow['tag']) {
+					$testCountData[$key]['count']++;
+					$incremented = true;
+					break;
+				}
+			}
+			if (!$incremented) {
+				array_push($testCountData, [
+					'count' => 1,
+					'tag' => $tagCountRow,
+				]);
+			}
+		}
+
+		$this->assertCount(count($testCountData), $data);
+
+		usort($testCountData, function ($rowA, $rowB) {
+			return ($rowA['tag'] > $rowB['tag']);
+		});
+		usort($data, function ($rowA, $rowB) {
+			return ($rowA['tag'] > $rowB['tag']);
+		});
+
+		foreach ($testCountData as $key => $testCountRow) {
+			$this->assertArrayHasKey('count', $data[$key]);
+			$this->assertEquals($testCountRow['count'], $data[$key]['count']);
+			$this->assertArrayHasKey('tag', $data[$key]);
+			$this->assertEquals($testCountRow['tag'], $data[$key]['tag']);
+		}
+	}
+
+	public function testGetTagCloudFailure()
+	{
+		$testData = [
+			[
+				'id' => rand(1, 100),
+				'tag' => 'test one',
+			],
+			[
+				'id' => rand(101, 200),
+				'tag' => 'test two',
+			],
+		];
+
+		array_walk($testData, [$this, 'insertTagData']);
+
+		$repository = new MysqlTagRepository(self::$connection);
+		$data = $repository->getTagCloud();
+
+		$this->assertEmpty($data);
+		$this->assertInternalType('array', $data);
+	}
  
-    public function testGetTagsForPost()
-    {
-        $testPostData = [
-            'id' => rand(1, 100),
-            'display' => 1,
-        ];
-
-        $testTagData = [
-            [
-                'id' => rand(1, 100),
-                'tag' => 'test one',
-            ],
-            [
-                'id' => rand(101, 200),
-                'tag' => 'test two',
-            ],
-            [
-                'id' => rand(201, 300),
-                'tag' => 'test three',
-            ],
-        ];
-
-        $testPTLinkData = [];
-        foreach ($testTagData as $testTagRow) {
-            array_push($testPTLinkData, [
-                'post_id' => $testPostData['id'],
-                'tag_id' => $testTagRow['id'],
-            ]);
-        }
-
-        $this->insertPostData($testPostData);
-        array_walk($testPTLinkData, [$this, 'insertPTLinkData']);
-        array_walk($testTagData, [$this, 'insertTagData']);
-
-        $repository = new MysqlTagRepository(self::$connection);
-        $data = $repository->getTagsForPost($testPostData['id']);
-
-        $this->assertNotFalse($data);
-        $this->assertInternalType('array', $data);
-        $this->assertCount(count($testTagData), $data);
-
-        usort($testTagData, function ($rowA, $rowB) {
-            return ($rowA['tag'] > $rowB['tag']);
-        });
-
-        foreach ($testTagData as $key => $testTagRow) {
-            $this->assertArrayHasKey('id', $data[$key]);
-            $this->assertEquals($testTagRow['id'], $data[$key]['id']);
-            $this->assertArrayHasKey('tag', $data[$key]);
-            $this->assertEquals($testTagRow['tag'], $data[$key]['tag']);
-        }
-    }
+	public function testGetTagsForPost()
+	{
+		$testPostData = [
+			'id' => rand(1, 100),
+			'display' => 1,
+		];
+
+		$testTagData = [
+			[
+				'id' => rand(1, 100),
+				'tag' => 'test one',
+			],
+			[
+				'id' => rand(101, 200),
+				'tag' => 'test two',
+			],
+			[
+				'id' => rand(201, 300),
+				'tag' => 'test three',
+			],
+		];
+
+		$testPTLinkData = [];
+		foreach ($testTagData as $testTagRow) {
+			array_push($testPTLinkData, [
+				'post_id' => $testPostData['id'],
+				'tag_id' => $testTagRow['id'],
+			]);
+		}
+
+		$this->insertPostData($testPostData);
+		array_walk($testPTLinkData, [$this, 'insertPTLinkData']);
+		array_walk($testTagData, [$this, 'insertTagData']);
+
+		$repository = new MysqlTagRepository(self::$connection);
+		$data = $repository->getTagsForPost($testPostData['id']);
+
+		$this->assertNotFalse($data);
+		$this->assertInternalType('array', $data);
+		$this->assertCount(count($testTagData), $data);
+
+		usort($testTagData, function ($rowA, $rowB) {
+			return ($rowA['tag'] > $rowB['tag']);
+		});
+
+		foreach ($testTagData as $key => $testTagRow) {
+			$this->assertArrayHasKey('id', $data[$key]);
+			$this->assertEquals($testTagRow['id'], $data[$key]['id']);
+			$this->assertArrayHasKey('tag', $data[$key]);
+			$this->assertEquals($testTagRow['tag'], $data[$key]['tag']);
+		}
+	}
  
-    public function testGetTagsForPostFailure()
-    {
-        $testData = [
-            [
-                'id' => rand(1, 100),
-                'tag' => 'test one',
-            ],
-            [
-                'id' => rand(101, 200),
-                'tag' => 'test two',
-            ],
-        ];
-
-        array_walk($testData, [$this, 'insertTagData']);
-
-        $repository = new MysqlTagRepository(self::$connection);
-        $data = $repository->getTagsForPost(rand(1, 10));
-
-        $this->assertEmpty($data);
-        $this->assertInternalType('array', $data);
-    }
-
-    protected function insertPostData(array $data)
-    {
-        $defaultData = [
-            'id' => null,
-            'title' => '',
-            'path' => '',
-            'category' => '',
-            'date' => '',
-            'body' => '',
-            'display' => 0,
-        ];
-
-        $data = array_merge($defaultData, $data);
-
-        return self::$connection->getDefault()->perform("
+	public function testGetTagsForPostFailure()
+	{
+		$testData = [
+			[
+				'id' => rand(1, 100),
+				'tag' => 'test one',
+			],
+			[
+				'id' => rand(101, 200),
+				'tag' => 'test two',
+			],
+		];
+
+		array_walk($testData, [$this, 'insertTagData']);
+
+		$repository = new MysqlTagRepository(self::$connection);
+		$data = $repository->getTagsForPost(rand(1, 10));
+
+		$this->assertEmpty($data);
+		$this->assertInternalType('array', $data);
+	}
+
+	protected function insertPostData(array $data)
+	{
+		$defaultData = [
+			'id' => null,
+			'title' => '',
+			'path' => '',
+			'category' => '',
+			'date' => '',
+			'body' => '',
+			'display' => 0,
+		];
+
+		$data = array_merge($defaultData, $data);
+
+		return self::$connection->getDefault()->perform("
             INSERT INTO `jpemeric_blog`.`post`
                 (id, title, path, category, date, body, display)
             VALUES
                 (:id, :title, :path, :category, :date, :body, :display)",
-            $data
-        );
-    }
+			$data
+		);
+	}
 
-    protected function insertPTLinkData(array $data)
-    {
-        $defaultData = [
-            'post' => null,
-            'tag' => null,
-        ];
+	protected function insertPTLinkData(array $data)
+	{
+		$defaultData = [
+			'post' => null,
+			'tag' => null,
+		];
 
-        $data = array_merge($defaultData, $data);
+		$data = array_merge($defaultData, $data);
 
-        return self::$connection->getDefault()->perform("
+		return self::$connection->getDefault()->perform("
             INSERT INTO `jpemeric_blog`.`ptlink`
                 (post_id, tag_id)
             VALUES
                 (:post_id, :tag_id)",
-            $data
-        );
-    }
+			$data
+		);
+	}
 
-    protected function insertTagData(array $data)
-    {
-        $defaultData = [
-            'id' => null,
-            'tag' => '',
-        ];
+	protected function insertTagData(array $data)
+	{
+		$defaultData = [
+			'id' => null,
+			'tag' => '',
+		];
 
-        $data = array_merge($defaultData, $data);
+		$data = array_merge($defaultData, $data);
 
-        return self::$connection->getDefault()->perform("
+		return self::$connection->getDefault()->perform("
             INSERT INTO `jpemeric_blog`.`tag`
                 (id, tag)
             VALUES
                 (:id, :tag)",
-            $data
-        );
-    }
-
-    protected function tearDown()
-    {
-        self::$connection->getDefault()->perform("DELETE FROM `jpemeric_blog`.`post`");
-        self::$connection->getDefault()->perform("DELETE FROM `jpemeric_blog`.`ptlink`");
-        self::$connection->getDefault()->perform("DELETE FROM `jpemeric_blog`.`tag`");
-    }
-
-    public static function tearDownAfterClass()
-    {
-        self::$connection->getDefault()->disconnect();
-        unlink('jpemeric_blog.db');
-    }
+			$data
+		);
+	}
+
+	protected function tearDown()
+	{
+		self::$connection->getDefault()->perform("DELETE FROM `jpemeric_blog`.`post`");
+		self::$connection->getDefault()->perform("DELETE FROM `jpemeric_blog`.`ptlink`");
+		self::$connection->getDefault()->perform("DELETE FROM `jpemeric_blog`.`tag`");
+	}
+
+	public static function tearDownAfterClass()
+	{
+		self::$connection->getDefault()->disconnect();
+		unlink('jpemeric_blog.db');
+	}
 }

tests/unit/Domain/Blog/Introduction/MysqlIntroductionRepositoryTest.php

Indentation +131 added lines, -131 removed lines

@@ -9,14 +9,14 @@ 
 class MysqlIntroductionRepositoryTest extends PHPUnit_Framework_TestCase
 {
 
-    protected static $connection;
+	protected static $connection;
 
-    public static function setUpBeforeClass()
-    {
-        $extendedPdo = new ExtendedPdo('sqlite::memory:');
-        $extendedPdo->exec("ATTACH DATABASE `jpemeric_blog.db` AS `jpemeric_blog`");
+	public static function setUpBeforeClass()
+	{
+		$extendedPdo = new ExtendedPdo('sqlite::memory:');
+		$extendedPdo->exec("ATTACH DATABASE `jpemeric_blog.db` AS `jpemeric_blog`");
 
-        $extendedPdo->exec("
+		$extendedPdo->exec("
             CREATE TABLE IF NOT EXISTS `jpemeric_blog`.`introduction` (
                 `id` integer PRIMARY KEY AUTOINCREMENT,
                 `type` varchar(10) NOT NULL,
@@ -25,134 +25,134 @@ 
                 `content` text NOT NULL,
                 `image` image
             )"
-        );
-
-        self::$connection = new ConnectionLocator(function () use ($extendedPdo) {
-            return $extendedPdo;
-        });
-    }
-
-    public function testIsInstanceOfIntroductionRepository()
-    {
-        $repository = new MysqlIntroductionRepository(self::$connection);
-
-        $this->assertInstanceOf(
-            'Jacobemerick\Web\Domain\Blog\Introduction\MysqlIntroductionRepository',
-            $repository
-        );
-    }
-
-    public function testImplementsIntroductionInterface()
-    {
-        $repository = new MysqlIntroductionRepository(self::$connection);
-
-        $this->assertInstanceOf(
-            'Jacobemerick\Web\Domain\Blog\Introduction\IntroductionRepositoryInterface',
-            $repository
-        );
-    }
-
-    public function testConstructSetsConnections()
-    {
-        $respository = new MysqlIntroductionRepository(self::$connection);
-
-        $this->assertAttributeSame(
-            self::$connection,
-            'connections',
-            $respository
-        );
-    }
-
-    public function testFindByType()
-    {
-        $testData = [
-            'id' => rand(1, 100),
-            'type' => 'test',
-            'title' => 'test title',
-            'content' => 'test content',
-            'image' => rand(1, 100),
-        ];
-
-        $this->insertData($testData);
-
-        $repository = new MysqlIntroductionRepository(self::$connection);
-        $data = $repository->findByType('test');
-
-        $this->assertNotFalse($data);
-        $this->assertInternalType('array', $data);
-        $this->assertArrayHasKey('title', $data);
-        $this->assertEquals($testData['title'], $data['title']);
-        $this->assertArrayHasKey('content', $data);
-        $this->assertEquals($testData['content'], $data['content']);
-        $this->assertArrayHasKey('image', $data);
-        $this->assertEquals($testData['image'], $data['image']);
-    }
-
-    public function testFindByTypeFilterValue()
-    {
-        $testData = [
-            [
-                'id' => rand(1, 100),
-                'type' => 'test',
-                'title' => 'title a',
-                'value' => 'value a',
-            ],
-            [
-                'id' => rand(101, 200),
-                'type' => 'test',
-                'title' => 'title b',
-                'value' => 'value b',
-            ],
-        ];
-
-        array_walk($testData, [$this, 'insertData']);
-
-        $repository = new MysqlIntroductionRepository(self::$connection);
-        $data = $repository->findByType('test', reset($testData)['value']);
-
-        $this->assertNotFalse($data);
-        $this->assertInternalType('array', $data);
-        $this->assertEquals(reset($testData)['title'], $data['title']);
-    }
+		);
+
+		self::$connection = new ConnectionLocator(function () use ($extendedPdo) {
+			return $extendedPdo;
+		});
+	}
+
+	public function testIsInstanceOfIntroductionRepository()
+	{
+		$repository = new MysqlIntroductionRepository(self::$connection);
+
+		$this->assertInstanceOf(
+			'Jacobemerick\Web\Domain\Blog\Introduction\MysqlIntroductionRepository',
+			$repository
+		);
+	}
+
+	public function testImplementsIntroductionInterface()
+	{
+		$repository = new MysqlIntroductionRepository(self::$connection);
+
+		$this->assertInstanceOf(
+			'Jacobemerick\Web\Domain\Blog\Introduction\IntroductionRepositoryInterface',
+			$repository
+		);
+	}
+
+	public function testConstructSetsConnections()
+	{
+		$respository = new MysqlIntroductionRepository(self::$connection);
+
+		$this->assertAttributeSame(
+			self::$connection,
+			'connections',
+			$respository
+		);
+	}
+
+	public function testFindByType()
+	{
+		$testData = [
+			'id' => rand(1, 100),
+			'type' => 'test',
+			'title' => 'test title',
+			'content' => 'test content',
+			'image' => rand(1, 100),
+		];
+
+		$this->insertData($testData);
+
+		$repository = new MysqlIntroductionRepository(self::$connection);
+		$data = $repository->findByType('test');
+
+		$this->assertNotFalse($data);
+		$this->assertInternalType('array', $data);
+		$this->assertArrayHasKey('title', $data);
+		$this->assertEquals($testData['title'], $data['title']);
+		$this->assertArrayHasKey('content', $data);
+		$this->assertEquals($testData['content'], $data['content']);
+		$this->assertArrayHasKey('image', $data);
+		$this->assertEquals($testData['image'], $data['image']);
+	}
+
+	public function testFindByTypeFilterValue()
+	{
+		$testData = [
+			[
+				'id' => rand(1, 100),
+				'type' => 'test',
+				'title' => 'title a',
+				'value' => 'value a',
+			],
+			[
+				'id' => rand(101, 200),
+				'type' => 'test',
+				'title' => 'title b',
+				'value' => 'value b',
+			],
+		];
+
+		array_walk($testData, [$this, 'insertData']);
+
+		$repository = new MysqlIntroductionRepository(self::$connection);
+		$data = $repository->findByType('test', reset($testData)['value']);
+
+		$this->assertNotFalse($data);
+		$this->assertInternalType('array', $data);
+		$this->assertEquals(reset($testData)['title'], $data['title']);
+	}
  
-    public function testFindByTypeFailure()
-    {
-        $repository = new MysqlIntroductionRepository(self::$connection);
-        $data = $repository->findByType('empty type');
-
-        $this->assertFalse($data);
-    }
-
-    protected function insertData(array $data)
-    {
-        $defaultData = [
-            'id' => null,
-            'type' => '',
-            'value' => '',
-            'title' => '',
-            'content' => '',
-            'image' => null,
-        ];
-
-        $data = array_merge($defaultData, $data);
-
-        return self::$connection->getDefault()->perform("
+	public function testFindByTypeFailure()
+	{
+		$repository = new MysqlIntroductionRepository(self::$connection);
+		$data = $repository->findByType('empty type');
+
+		$this->assertFalse($data);
+	}
+
+	protected function insertData(array $data)
+	{
+		$defaultData = [
+			'id' => null,
+			'type' => '',
+			'value' => '',
+			'title' => '',
+			'content' => '',
+			'image' => null,
+		];
+
+		$data = array_merge($defaultData, $data);
+
+		return self::$connection->getDefault()->perform("
             INSERT INTO `jpemeric_blog`.`introduction`
                 (id, type, value, title, content, image)
             VALUES
                 (:id, :type, :value, :title, :content, :image)",
-            $data
-        );
-    }
-
-    protected function tearDown()
-    {
-        self::$connection->getDefault()->perform("DELETE FROM `jpemeric_blog`.`introduction`");
-    }
-
-    public static function tearDownAfterClass()
-    {
-        self::$connection->getDefault()->disconnect();
-        unlink('jpemeric_blog.db');
-    }
+			$data
+		);
+	}
+
+	protected function tearDown()
+	{
+		self::$connection->getDefault()->perform("DELETE FROM `jpemeric_blog`.`introduction`");
+	}
+
+	public static function tearDownAfterClass()
+	{
+		self::$connection->getDefault()->disconnect();
+		unlink('jpemeric_blog.db');
+	}
 }