jacobemerick / web

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

Indentation +175 added lines, -175 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,201 +26,201 @@ 
                 `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 = [
-            [
-                'series' => reset($testSeriesData)['id'],
-                'post' => $testPostData[0]['id'],
-                'order' => 1,
-            ],
-            [
-                'series' => reset($testSeriesData)['id'],
-                'post' => $testPostData[1]['id'],
-                'order' => 2,
-            ],
-        ];
-
-        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() {}
-
-    public function testGetSeriesForPostSeriesFilter() {}
-
-    public function testGetSeriesForPostInactive() {}
-
-    public function testGetSeriesForPostFailure() {}
-
-    protected function tearDown()
-    {
-        self::$connection->getDefault()->perform("DELETE FROM `jpemeric_blog`.`series`");
-    }
-
-    public static function tearDownAfterClass()
-    {
-        self::$connection->getDefault()->disconnect();
-        unlink('jpemeric_blog.db');
-    }
-
-    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("
+		);
+
+		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 = [
+			[
+				'series' => reset($testSeriesData)['id'],
+				'post' => $testPostData[0]['id'],
+				'order' => 1,
+			],
+			[
+				'series' => reset($testSeriesData)['id'],
+				'post' => $testPostData[1]['id'],
+				'order' => 2,
+			],
+		];
+
+		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() {}
+
+	public function testGetSeriesForPostSeriesFilter() {}
+
+	public function testGetSeriesForPostInactive() {}
+
+	public function testGetSeriesForPostFailure() {}
+
+	protected function tearDown()
+	{
+		self::$connection->getDefault()->perform("DELETE FROM `jpemeric_blog`.`series`");
+	}
+
+	public static function tearDownAfterClass()
+	{
+		self::$connection->getDefault()->disconnect();
+		unlink('jpemeric_blog.db');
+	}
+
+	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
-        );
-    }
+			$data
+		);
+	}
 }

tests/unit/Domain/Stream/Activity/MysqlActivityRepositoryTest.php

Indentation +426 added lines, -426 removed lines

@@ -9,14 +9,14 @@ 
 class MysqlActivityRepositoryTest extends PHPUnit_Framework_TestCase
 {
 
-    protected static $connection;
+	protected static $connection;
 
-    public static function setUpBeforeClass()
-    {
-        $extendedPdo = new ExtendedPdo('sqlite::memory:');
-        $extendedPdo->exec("ATTACH DATABASE `jpemeric_stream.db` AS `jpemeric_stream`");
+	public static function setUpBeforeClass()
+	{
+		$extendedPdo = new ExtendedPdo('sqlite::memory:');
+		$extendedPdo->exec("ATTACH DATABASE `jpemeric_stream.db` AS `jpemeric_stream`");
 
-        $extendedPdo->exec("
+		$extendedPdo->exec("
             CREATE TABLE IF NOT EXISTS `jpemeric_stream`.`activity` (
                 `id` integer PRIMARY KEY AUTOINCREMENT,
                 `message` text NOT NULL,
@@ -28,428 +28,428 @@ 
                 `created_at` datetime,
                 `updated_at` datetime
             )"
-        );
-
-        self::$connection = new ConnectionLocator(function () use ($extendedPdo) {
-            return $extendedPdo;
-        });
-    }
-
-    public function testIsInstanceOfActivityRepository()
-    {
-        $repository = new MysqlActivityRepository(self::$connection);
-
-        $this->assertInstanceOf(
-            'Jacobemerick\Web\Domain\Stream\Activity\MysqlActivityRepository',
-            $repository
-        );
-    }
-
-    public function testImplementsActivityInterface()
-    {
-        $repository = new MysqlActivityRepository(self::$connection);
-
-        $this->assertInstanceOf(
-            'Jacobemerick\Web\Domain\Stream\Activity\ActivityRepositoryInterface',
-            $repository
-        );
-    }
-
-    public function testConstructSetsConnections()
-    {
-        $respository = new MysqlActivityRepository(self::$connection);
-
-        $this->assertAttributeSame(
-            self::$connection,
-            'connections',
-            $respository
-        );
-    }
-
-    public function testGetActivityById()
-    {
-        $testData = [
-            'id' => rand(1, 100),
-            'message' => 'test data',
-        ];
-
-        $this->insertData($testData);
-
-        $repository = new MysqlActivityRepository(self::$connection);
-        $data = $repository->getActivityById($testData['id']);
-
-        $this->assertNotFalse($data);
-        $this->assertInternalType('array', $data);
-        $this->assertArraySubset($testData, $data);
-    }
-
-    public function testGetActivityByIdFailure()
-    {
-        $testData = [
-            'id' => rand(1, 100),
-            'message' => 'test data',
-        ];
-
-        $this->insertData($testData);
-
-        $repository = new MysqlActivityRepository(self::$connection);
-        $data = $repository->getActivityById($testData['id'] + 1);
-
-        $this->assertFalse($data);
-    }
-
-    public function testGetActivities()
-    {
-        $testData = [
-            [
-                'id' => rand(1, 100),
-                'message' => 'test one',
-            ],
-            [
-                'id' => rand(101, 200),
-                'message' => 'test two',
-            ],
-        ];
-
-        array_walk($testData, [$this, 'insertData']);
-
-        $repository = new MysqlActivityRepository(self::$connection);
-        $data = $repository->getActivities();
-
-        $this->assertNotFalse($data);
-        $this->assertInternalType('array', $data);
-        foreach ($testData as $key => $testRow) {
-            $this->assertInternalType('array', $data[$key]);
-            $this->assertArraySubset($testRow, $data[$key]);
-        }
-    }
-
-    public function testGetActivitiesFailure()
-    {
-        $repository = new MysqlActivityRepository(self::$connection);
-        $data = $repository->getActivities();
-
-        $this->assertEmpty($data);
-        $this->assertInternalType('array', $data);
-    }
-
-    public function testGetActivitiesRange()
-    {
-        $testData = [
-            [
-                'id' => rand(1, 100),
-                'message' => 'test one',
-            ],
-            [
-                'id' => rand(101, 200),
-                'message' => 'test two',
-            ],
-            [
-                'id' => rand(201, 300),
-                'message' => 'test three',
-            ],
-        ];
-
-        array_walk($testData, [$this, 'insertData']);
-
-        $repository = new MysqlActivityRepository(self::$connection);
-        $data = $repository->getActivities(2, 1);
-
-        $this->assertNotFalse($data);
-        $this->assertInternalType('array', $data);
-        $this->assertCount(2, $data);
-
-        $testData = array_slice($testData, 1, 2);
-
-        foreach ($testData as $key => $testRow) {
-            $this->assertInternalType('array', $data[$key]);
-            $this->assertArraySubset($testRow, $data[$key]);
-        }
-    }
-
-    public function testGetActivitiesRangeFailure()
-    {
-        $testData = [
-            [
-                'id' => rand(1, 100),
-                'message' => 'test one',
-            ],
-            [
-                'id' => rand(101, 200),
-                'message' => 'test two',
-            ],
-        ];
-
-        array_walk($testData, [$this, 'insertData']);
-
-        $repository = new MysqlActivityRepository(self::$connection);
-        $data = $repository->getActivities(1, 3);
-
-        $this->assertEmpty($data);
-        $this->assertInternalType('array', $data);
-    }
-
-    public function testGetActivitiesCount()
-    {
-        $testData = [
-            [
-                'id' => rand(1, 100),
-                'message' => 'test one',
-            ],
-            [
-                'id' => rand(101, 200),
-                'message' => 'test two',
-            ],
-        ];
-
-        array_walk($testData, [$this, 'insertData']);
-
-        $repository = new MysqlActivityRepository(self::$connection);
-        $data = $repository->getActivitiesCount();
-
-        $this->assertNotFalse($data);
-        $this->assertStringMatchesFormat('%d', $data);
-        $this->assertEquals(count($testData), $data);
-    }
-
-    public function testGetActivitiesCountEmpty()
-    {
-        $repository = new MysqlActivityRepository(self::$connection);
-        $data = $repository->getActivitiesCount();
-
-        $this->assertNotFalse($data);
-        $this->assertStringMatchesFormat('%d', $data);
-        $this->assertEquals('0', $data);
-    }
-
-    public function testGetActivitiesByType()
-    {
-        $testData = [
-            [
-                'id' => rand(1, 100),
-                'message' => 'test one',
-                'type' => 'type one',
-            ],
-            [
-                'id' => rand(101, 200),
-                'message' => 'test two',
-                'type' => 'type two',
-            ],
-            [
-                'id' => rand(201, 300),
-                'message' => 'test three',
-                'type' => 'type one',
-            ],
-        ];
-
-        array_walk($testData, [$this, 'insertData']);
-
-        $repository = new MysqlActivityRepository(self::$connection);
-        $data = $repository->getActivitiesByType('type one');
-
-        $this->assertNotFalse($data);
-        $this->assertInternalType('array', $data);
-
-        $testData = array_filter($testData, function ($row) {
-            return ($row['type'] == 'type one');
-        });
-        $testData = array_values($testData);
-
-        foreach ($testData as $key => $testRow) {
-            $this->assertInternalType('array', $data[$key]);
-            $this->assertArraySubset($testRow, $data[$key]);
-        }
-    }
-
-    public function testGetActivitiesByTypeFailure()
-    {
-        $testData = [
-            [
-                'id' => rand(1, 100),
-                'message' => 'test one',
-                'type' => 'type one',
-            ],
-            [
-                'id' => rand(101, 200),
-                'message' => 'test two',
-                'type' => 'type one',
-            ],
-        ];
-
-        array_walk($testData, [$this, 'insertData']);
-
-        $repository = new MysqlActivityRepository(self::$connection);
-        $data = $repository->getActivitiesByType('type two');
-
-        $this->assertEmpty($data);
-        $this->assertInternalType('array', $data);
-    }
-
-    public function testGetActivitiesByTypeRange()
-    {
-        $testData = [
-            [
-                'id' => rand(1, 100),
-                'message' => 'test one',
-                'type' => 'type one',
-            ],
-            [
-                'id' => rand(101, 200),
-                'message' => 'test two',
-                'type' => 'type two',
-            ],
-            [
-                'id' => rand(201, 300),
-                'message' => 'test three',
-                'type' => 'type one',
-            ],
-            [
-                'id' => rand(301, 400),
-                'message' => 'test four',
-                'type' => 'type one',
-            ],
-        ];
-
-        array_walk($testData, [$this, 'insertData']);
-
-        $repository = new MysqlActivityRepository(self::$connection);
-        $data = $repository->getActivitiesByType('type one', 2, 1);
-
-        $this->assertNotFalse($data);
-        $this->assertInternalType('array', $data);
-        $this->assertCount(2, $data);
-
-        $testData = array_filter($testData, function ($row) {
-            return ($row['type'] == 'type one');
-        });
-        $testData = array_values($testData);
-        $testData = array_slice($testData, 1, 2);
-
-        foreach ($testData as $key => $testRow) {
-            $this->assertInternalType('array', $data[$key]);
-            $this->assertArraySubset($testRow, $data[$key]);
-        }
-    }
-
-    public function testGetActivitiesByTypeRangeFailure()
-    {
-        $testData = [
-            [
-                'id' => rand(1, 100),
-                'message' => 'test one',
-                'type' => 'type one',
-            ],
-            [
-                'id' => rand(101, 200),
-                'message' => 'test two',
-                'type' => 'type one',
-            ],
-            [
-                'id' => rand(201, 300),
-                'message' => 'test three',
-                'type' => 'type one',
-            ],
-        ];
-
-        array_walk($testData, [$this, 'insertData']);
-
-        $repository = new MysqlActivityRepository(self::$connection);
-        $data = $repository->getActivitiesByType('type two', 2, 1);
-
-        $this->assertEmpty($data);
-        $this->assertInternalType('array', $data);
-    }
-
-    public function testGetActivitiesByTypeCount()
-    {
-        $testData = [
-            [
-                'id' => rand(1, 100),
-                'message' => 'test one',
-                'type' => 'type one',
-            ],
-            [
-                'id' => rand(101, 200),
-                'message' => 'test two',
-                'type' => 'type two',
-            ],
-            [
-                'id' => rand(201, 300),
-                'message' => 'test three',
-                'type' => 'type one',
-            ],
-        ];
-
-        array_walk($testData, [$this, 'insertData']);
-
-        $repository = new MysqlActivityRepository(self::$connection);
-        $data = $repository->getActivitiesByTypeCount('type one');
-
-        $testData = array_filter($testData, function ($row) {
-            return ($row['type'] == 'type one');
-        });
-
-        $this->assertNotFalse($data);
-        $this->assertStringMatchesFormat('%d', $data);
-        $this->assertEquals(count($testData), $data);
-    }
-
-    public function testGetActivitiesByTypeCountEmpty()
-    {
-        $testData = [
-            [
-                'id' => rand(1, 100),
-                'message' => 'test one',
-                'type' => 'type one',
-            ],
-            [
-                'id' => rand(101, 200),
-                'message' => 'test two',
-                'type' => 'type one',
-            ],
-        ];
-
-        array_walk($testData, [$this, 'insertData']);
-
-        $repository = new MysqlActivityRepository(self::$connection);
-        $data = $repository->getActivitiesByTypeCount('type two');
-
-        $this->assertNotFalse($data);
-        $this->assertStringMatchesFormat('%d', $data);
-        $this->assertEquals('0', $data);
-    }
-
-    protected function tearDown()
-    {
-        self::$connection->getDefault()->perform("DELETE FROM `jpemeric_stream`.`activity`");
-    }
-
-    public static function tearDownAfterClass()
-    {
-        self::$connection->getDefault()->disconnect();
-        unlink('jpemeric_stream.db');
-    }
-
-    protected function insertData(array $data)
-    {
-        $defaultData = [
-            'id' => null,
-            'message' => '',
-            'message_long' => '',
-            'datetime' => '',
-            'metadata' => '',
-            'type' => '',
-            'type_id' => '',
-        ];
-
-        $data = array_merge($defaultData, $data);
-
-        return self::$connection->getDefault()->perform("
+		);
+
+		self::$connection = new ConnectionLocator(function () use ($extendedPdo) {
+			return $extendedPdo;
+		});
+	}
+
+	public function testIsInstanceOfActivityRepository()
+	{
+		$repository = new MysqlActivityRepository(self::$connection);
+
+		$this->assertInstanceOf(
+			'Jacobemerick\Web\Domain\Stream\Activity\MysqlActivityRepository',
+			$repository
+		);
+	}
+
+	public function testImplementsActivityInterface()
+	{
+		$repository = new MysqlActivityRepository(self::$connection);
+
+		$this->assertInstanceOf(
+			'Jacobemerick\Web\Domain\Stream\Activity\ActivityRepositoryInterface',
+			$repository
+		);
+	}
+
+	public function testConstructSetsConnections()
+	{
+		$respository = new MysqlActivityRepository(self::$connection);
+
+		$this->assertAttributeSame(
+			self::$connection,
+			'connections',
+			$respository
+		);
+	}
+
+	public function testGetActivityById()
+	{
+		$testData = [
+			'id' => rand(1, 100),
+			'message' => 'test data',
+		];
+
+		$this->insertData($testData);
+
+		$repository = new MysqlActivityRepository(self::$connection);
+		$data = $repository->getActivityById($testData['id']);
+
+		$this->assertNotFalse($data);
+		$this->assertInternalType('array', $data);
+		$this->assertArraySubset($testData, $data);
+	}
+
+	public function testGetActivityByIdFailure()
+	{
+		$testData = [
+			'id' => rand(1, 100),
+			'message' => 'test data',
+		];
+
+		$this->insertData($testData);
+
+		$repository = new MysqlActivityRepository(self::$connection);
+		$data = $repository->getActivityById($testData['id'] + 1);
+
+		$this->assertFalse($data);
+	}
+
+	public function testGetActivities()
+	{
+		$testData = [
+			[
+				'id' => rand(1, 100),
+				'message' => 'test one',
+			],
+			[
+				'id' => rand(101, 200),
+				'message' => 'test two',
+			],
+		];
+
+		array_walk($testData, [$this, 'insertData']);
+
+		$repository = new MysqlActivityRepository(self::$connection);
+		$data = $repository->getActivities();
+
+		$this->assertNotFalse($data);
+		$this->assertInternalType('array', $data);
+		foreach ($testData as $key => $testRow) {
+			$this->assertInternalType('array', $data[$key]);
+			$this->assertArraySubset($testRow, $data[$key]);
+		}
+	}
+
+	public function testGetActivitiesFailure()
+	{
+		$repository = new MysqlActivityRepository(self::$connection);
+		$data = $repository->getActivities();
+
+		$this->assertEmpty($data);
+		$this->assertInternalType('array', $data);
+	}
+
+	public function testGetActivitiesRange()
+	{
+		$testData = [
+			[
+				'id' => rand(1, 100),
+				'message' => 'test one',
+			],
+			[
+				'id' => rand(101, 200),
+				'message' => 'test two',
+			],
+			[
+				'id' => rand(201, 300),
+				'message' => 'test three',
+			],
+		];
+
+		array_walk($testData, [$this, 'insertData']);
+
+		$repository = new MysqlActivityRepository(self::$connection);
+		$data = $repository->getActivities(2, 1);
+
+		$this->assertNotFalse($data);
+		$this->assertInternalType('array', $data);
+		$this->assertCount(2, $data);
+
+		$testData = array_slice($testData, 1, 2);
+
+		foreach ($testData as $key => $testRow) {
+			$this->assertInternalType('array', $data[$key]);
+			$this->assertArraySubset($testRow, $data[$key]);
+		}
+	}
+
+	public function testGetActivitiesRangeFailure()
+	{
+		$testData = [
+			[
+				'id' => rand(1, 100),
+				'message' => 'test one',
+			],
+			[
+				'id' => rand(101, 200),
+				'message' => 'test two',
+			],
+		];
+
+		array_walk($testData, [$this, 'insertData']);
+
+		$repository = new MysqlActivityRepository(self::$connection);
+		$data = $repository->getActivities(1, 3);
+
+		$this->assertEmpty($data);
+		$this->assertInternalType('array', $data);
+	}
+
+	public function testGetActivitiesCount()
+	{
+		$testData = [
+			[
+				'id' => rand(1, 100),
+				'message' => 'test one',
+			],
+			[
+				'id' => rand(101, 200),
+				'message' => 'test two',
+			],
+		];
+
+		array_walk($testData, [$this, 'insertData']);
+
+		$repository = new MysqlActivityRepository(self::$connection);
+		$data = $repository->getActivitiesCount();
+
+		$this->assertNotFalse($data);
+		$this->assertStringMatchesFormat('%d', $data);
+		$this->assertEquals(count($testData), $data);
+	}
+
+	public function testGetActivitiesCountEmpty()
+	{
+		$repository = new MysqlActivityRepository(self::$connection);
+		$data = $repository->getActivitiesCount();
+
+		$this->assertNotFalse($data);
+		$this->assertStringMatchesFormat('%d', $data);
+		$this->assertEquals('0', $data);
+	}
+
+	public function testGetActivitiesByType()
+	{
+		$testData = [
+			[
+				'id' => rand(1, 100),
+				'message' => 'test one',
+				'type' => 'type one',
+			],
+			[
+				'id' => rand(101, 200),
+				'message' => 'test two',
+				'type' => 'type two',
+			],
+			[
+				'id' => rand(201, 300),
+				'message' => 'test three',
+				'type' => 'type one',
+			],
+		];
+
+		array_walk($testData, [$this, 'insertData']);
+
+		$repository = new MysqlActivityRepository(self::$connection);
+		$data = $repository->getActivitiesByType('type one');
+
+		$this->assertNotFalse($data);
+		$this->assertInternalType('array', $data);
+
+		$testData = array_filter($testData, function ($row) {
+			return ($row['type'] == 'type one');
+		});
+		$testData = array_values($testData);
+
+		foreach ($testData as $key => $testRow) {
+			$this->assertInternalType('array', $data[$key]);
+			$this->assertArraySubset($testRow, $data[$key]);
+		}
+	}
+
+	public function testGetActivitiesByTypeFailure()
+	{
+		$testData = [
+			[
+				'id' => rand(1, 100),
+				'message' => 'test one',
+				'type' => 'type one',
+			],
+			[
+				'id' => rand(101, 200),
+				'message' => 'test two',
+				'type' => 'type one',
+			],
+		];
+
+		array_walk($testData, [$this, 'insertData']);
+
+		$repository = new MysqlActivityRepository(self::$connection);
+		$data = $repository->getActivitiesByType('type two');
+
+		$this->assertEmpty($data);
+		$this->assertInternalType('array', $data);
+	}
+
+	public function testGetActivitiesByTypeRange()
+	{
+		$testData = [
+			[
+				'id' => rand(1, 100),
+				'message' => 'test one',
+				'type' => 'type one',
+			],
+			[
+				'id' => rand(101, 200),
+				'message' => 'test two',
+				'type' => 'type two',
+			],
+			[
+				'id' => rand(201, 300),
+				'message' => 'test three',
+				'type' => 'type one',
+			],
+			[
+				'id' => rand(301, 400),
+				'message' => 'test four',
+				'type' => 'type one',
+			],
+		];
+
+		array_walk($testData, [$this, 'insertData']);
+
+		$repository = new MysqlActivityRepository(self::$connection);
+		$data = $repository->getActivitiesByType('type one', 2, 1);
+
+		$this->assertNotFalse($data);
+		$this->assertInternalType('array', $data);
+		$this->assertCount(2, $data);
+
+		$testData = array_filter($testData, function ($row) {
+			return ($row['type'] == 'type one');
+		});
+		$testData = array_values($testData);
+		$testData = array_slice($testData, 1, 2);
+
+		foreach ($testData as $key => $testRow) {
+			$this->assertInternalType('array', $data[$key]);
+			$this->assertArraySubset($testRow, $data[$key]);
+		}
+	}
+
+	public function testGetActivitiesByTypeRangeFailure()
+	{
+		$testData = [
+			[
+				'id' => rand(1, 100),
+				'message' => 'test one',
+				'type' => 'type one',
+			],
+			[
+				'id' => rand(101, 200),
+				'message' => 'test two',
+				'type' => 'type one',
+			],
+			[
+				'id' => rand(201, 300),
+				'message' => 'test three',
+				'type' => 'type one',
+			],
+		];
+
+		array_walk($testData, [$this, 'insertData']);
+
+		$repository = new MysqlActivityRepository(self::$connection);
+		$data = $repository->getActivitiesByType('type two', 2, 1);
+
+		$this->assertEmpty($data);
+		$this->assertInternalType('array', $data);
+	}
+
+	public function testGetActivitiesByTypeCount()
+	{
+		$testData = [
+			[
+				'id' => rand(1, 100),
+				'message' => 'test one',
+				'type' => 'type one',
+			],
+			[
+				'id' => rand(101, 200),
+				'message' => 'test two',
+				'type' => 'type two',
+			],
+			[
+				'id' => rand(201, 300),
+				'message' => 'test three',
+				'type' => 'type one',
+			],
+		];
+
+		array_walk($testData, [$this, 'insertData']);
+
+		$repository = new MysqlActivityRepository(self::$connection);
+		$data = $repository->getActivitiesByTypeCount('type one');
+
+		$testData = array_filter($testData, function ($row) {
+			return ($row['type'] == 'type one');
+		});
+
+		$this->assertNotFalse($data);
+		$this->assertStringMatchesFormat('%d', $data);
+		$this->assertEquals(count($testData), $data);
+	}
+
+	public function testGetActivitiesByTypeCountEmpty()
+	{
+		$testData = [
+			[
+				'id' => rand(1, 100),
+				'message' => 'test one',
+				'type' => 'type one',
+			],
+			[
+				'id' => rand(101, 200),
+				'message' => 'test two',
+				'type' => 'type one',
+			],
+		];
+
+		array_walk($testData, [$this, 'insertData']);
+
+		$repository = new MysqlActivityRepository(self::$connection);
+		$data = $repository->getActivitiesByTypeCount('type two');
+
+		$this->assertNotFalse($data);
+		$this->assertStringMatchesFormat('%d', $data);
+		$this->assertEquals('0', $data);
+	}
+
+	protected function tearDown()
+	{
+		self::$connection->getDefault()->perform("DELETE FROM `jpemeric_stream`.`activity`");
+	}
+
+	public static function tearDownAfterClass()
+	{
+		self::$connection->getDefault()->disconnect();
+		unlink('jpemeric_stream.db');
+	}
+
+	protected function insertData(array $data)
+	{
+		$defaultData = [
+			'id' => null,
+			'message' => '',
+			'message_long' => '',
+			'datetime' => '',
+			'metadata' => '',
+			'type' => '',
+			'type_id' => '',
+		];
+
+		$data = array_merge($defaultData, $data);
+
+		return self::$connection->getDefault()->perform("
             INSERT INTO `jpemeric_stream`.`activity`
                 (id, message, message_long, datetime, metadata, type, type_id)
             VALUES
                 (:id, :message, :message_long, :datetime, :metadata, :type, :type_id)",
-            $data
-        );
-    }
+			$data
+		);
+	}
 }

tests/unit/Domain/Stream/Changelog/MysqlChangelogRepositoryTest.php

Indentation +169 added lines, -169 removed lines

@@ -9,14 +9,14 @@ 
 class MysqlChangelogRepositoryTest extends PHPUnit_Framework_TestCase
 {
 
-    protected static $connection;
+	protected static $connection;
 
-    public static function setUpBeforeClass()
-    {
-        $extendedPdo = new ExtendedPdo('sqlite::memory:');
-        $extendedPdo->exec("ATTACH DATABASE `jpemeric_stream.db` AS `jpemeric_stream`");
+	public static function setUpBeforeClass()
+	{
+		$extendedPdo = new ExtendedPdo('sqlite::memory:');
+		$extendedPdo->exec("ATTACH DATABASE `jpemeric_stream.db` AS `jpemeric_stream`");
 
-        $extendedPdo->exec("
+		$extendedPdo->exec("
             CREATE TABLE IF NOT EXISTS `jpemeric_stream`.`changelog` (
                 `id` integer PRIMARY KEY AUTOINCREMENT,
                 `hash` char(40) NOT NULL,
@@ -28,171 +28,171 @@ 
                 `created_at` datetime,
                 `updated_at` datetime
             )"
-        );
-
-        self::$connection = new ConnectionLocator(function () use ($extendedPdo) {
-            return $extendedPdo;
-        });
-    }
-
-    public function testIsInstanceOfChangelogRepository()
-    {
-        $repository = new MysqlChangelogRepository(self::$connection);
-
-        $this->assertInstanceOf(
-            'Jacobemerick\Web\Domain\Stream\Changelog\MysqlChangelogRepository',
-            $repository
-        );
-    }
-
-    public function testImplementsChangelogInterface()
-    {
-        $repository = new MysqlChangelogRepository(self::$connection);
-
-        $this->assertInstanceOf(
-            'Jacobemerick\Web\Domain\Stream\Changelog\ChangelogRepositoryInterface',
-            $repository
-        );
-    }
-
-    public function testConstructSetsConnections()
-    {
-        $respository = new MysqlChangelogRepository(self::$connection);
-
-        $this->assertAttributeSame(
-            self::$connection,
-            'connections',
-            $respository
-        );
-    }
-
-    public function testGetChanges()
-    {
-        $testData = [
-            [
-                'id' => rand(1, 100),
-                'message' => 'test one',
-            ],
-            [
-                'id' => rand(101, 200),
-                'message' => 'test two',
-            ],
-        ];
-
-        array_walk($testData, [$this, 'insertData']);
-
-        $repository = new MysqlChangelogRepository(self::$connection);
-        $data = $repository->getChanges();
-
-        $this->assertNotFalse($data);
-        $this->assertInternalType('array', $data);
-        foreach ($testData as $key => $testRow) {
-            $this->assertInternalType('array', $data[$key]);
-            $this->assertArraySubset($testRow, $data[$key]);
-            $this->assertArrayHasKey('id', $data[$key]);
-            $this->assertArrayHasKey('message', $data[$key]);
-            $this->assertArrayHasKey('message_short', $data[$key]);
-            $this->assertArrayHasKey('datetime', $data[$key]);
-            $this->assertArrayHasKey('commit_link', $data[$key]);
-        }
-    }
-
-    public function testGetChangesFailure()
-    {
-        $repository = new MysqlChangelogRepository(self::$connection);
-        $data = $repository->getChanges();
-
-        $this->assertEmpty($data);
-        $this->assertInternalType('array', $data);
-    }
-
-    public function testGetChangesRange()
-    {
-        $testData = [
-            [
-                'id' => rand(1, 100),
-                'message' => 'test one',
-            ],
-            [
-                'id' => rand(101, 200),
-                'message' => 'test two',
-            ],
-            [
-                'id' => rand(201, 300),
-                'message' => 'test three',
-            ],
-        ];
-
-        array_walk($testData, [$this, 'insertData']);
-
-        $repository = new MysqlChangelogRepository(self::$connection);
-        $data = $repository->getChanges(2, 1);
-
-        $this->assertNotFalse($data);
-        $this->assertInternalType('array', $data);
-        $this->assertCount(2, $data);
-
-        $testData = array_slice($testData, 1, 2);
-
-        foreach ($testData as $key => $testRow) {
-            $this->assertInternalType('array', $testRow);
-            $this->assertArraySubset($testRow, $data[$key]);
-        }
-    }
-
-    public function testGetChangesRangeFailure()
-    {
-        $testData = [
-            [
-                'id' => rand(1, 100),
-                'message' => 'test one',
-            ],
-            [
-                'id' => rand(101, 200),
-                'message' => 'test two',
-            ],
-        ];
-
-        array_walk($testData, [$this, 'insertData']);
-
-        $repository = new MysqlChangelogRepository(self::$connection);
-        $data = $repository->getChanges(1, 3);
-
-        $this->assertEmpty($data);
-        $this->assertInternalType('array', $data);
-    }
-
-    protected function tearDown()
-    {
-        self::$connection->getDefault()->perform("DELETE FROM `jpemeric_stream`.`changelog`");
-    }
-
-    public static function tearDownAfterClass()
-    {
-        self::$connection->getDefault()->disconnect();
-        unlink('jpemeric_stream.db');
-    }
-
-    protected function insertData(array $data)
-    {
-        $defaultData = [
-            'id' => null,
-            'hash' => '',
-            'message' => null,
-            'message_short' => null,
-            'datetime' => '',
-            'author' => '',
-            'commit_link' => '',
-        ];
-
-        $data = array_merge($defaultData, $data);
-
-        return self::$connection->getDefault()->perform("
+		);
+
+		self::$connection = new ConnectionLocator(function () use ($extendedPdo) {
+			return $extendedPdo;
+		});
+	}
+
+	public function testIsInstanceOfChangelogRepository()
+	{
+		$repository = new MysqlChangelogRepository(self::$connection);
+
+		$this->assertInstanceOf(
+			'Jacobemerick\Web\Domain\Stream\Changelog\MysqlChangelogRepository',
+			$repository
+		);
+	}
+
+	public function testImplementsChangelogInterface()
+	{
+		$repository = new MysqlChangelogRepository(self::$connection);
+
+		$this->assertInstanceOf(
+			'Jacobemerick\Web\Domain\Stream\Changelog\ChangelogRepositoryInterface',
+			$repository
+		);
+	}
+
+	public function testConstructSetsConnections()
+	{
+		$respository = new MysqlChangelogRepository(self::$connection);
+
+		$this->assertAttributeSame(
+			self::$connection,
+			'connections',
+			$respository
+		);
+	}
+
+	public function testGetChanges()
+	{
+		$testData = [
+			[
+				'id' => rand(1, 100),
+				'message' => 'test one',
+			],
+			[
+				'id' => rand(101, 200),
+				'message' => 'test two',
+			],
+		];
+
+		array_walk($testData, [$this, 'insertData']);
+
+		$repository = new MysqlChangelogRepository(self::$connection);
+		$data = $repository->getChanges();
+
+		$this->assertNotFalse($data);
+		$this->assertInternalType('array', $data);
+		foreach ($testData as $key => $testRow) {
+			$this->assertInternalType('array', $data[$key]);
+			$this->assertArraySubset($testRow, $data[$key]);
+			$this->assertArrayHasKey('id', $data[$key]);
+			$this->assertArrayHasKey('message', $data[$key]);
+			$this->assertArrayHasKey('message_short', $data[$key]);
+			$this->assertArrayHasKey('datetime', $data[$key]);
+			$this->assertArrayHasKey('commit_link', $data[$key]);
+		}
+	}
+
+	public function testGetChangesFailure()
+	{
+		$repository = new MysqlChangelogRepository(self::$connection);
+		$data = $repository->getChanges();
+
+		$this->assertEmpty($data);
+		$this->assertInternalType('array', $data);
+	}
+
+	public function testGetChangesRange()
+	{
+		$testData = [
+			[
+				'id' => rand(1, 100),
+				'message' => 'test one',
+			],
+			[
+				'id' => rand(101, 200),
+				'message' => 'test two',
+			],
+			[
+				'id' => rand(201, 300),
+				'message' => 'test three',
+			],
+		];
+
+		array_walk($testData, [$this, 'insertData']);
+
+		$repository = new MysqlChangelogRepository(self::$connection);
+		$data = $repository->getChanges(2, 1);
+
+		$this->assertNotFalse($data);
+		$this->assertInternalType('array', $data);
+		$this->assertCount(2, $data);
+
+		$testData = array_slice($testData, 1, 2);
+
+		foreach ($testData as $key => $testRow) {
+			$this->assertInternalType('array', $testRow);
+			$this->assertArraySubset($testRow, $data[$key]);
+		}
+	}
+
+	public function testGetChangesRangeFailure()
+	{
+		$testData = [
+			[
+				'id' => rand(1, 100),
+				'message' => 'test one',
+			],
+			[
+				'id' => rand(101, 200),
+				'message' => 'test two',
+			],
+		];
+
+		array_walk($testData, [$this, 'insertData']);
+
+		$repository = new MysqlChangelogRepository(self::$connection);
+		$data = $repository->getChanges(1, 3);
+
+		$this->assertEmpty($data);
+		$this->assertInternalType('array', $data);
+	}
+
+	protected function tearDown()
+	{
+		self::$connection->getDefault()->perform("DELETE FROM `jpemeric_stream`.`changelog`");
+	}
+
+	public static function tearDownAfterClass()
+	{
+		self::$connection->getDefault()->disconnect();
+		unlink('jpemeric_stream.db');
+	}
+
+	protected function insertData(array $data)
+	{
+		$defaultData = [
+			'id' => null,
+			'hash' => '',
+			'message' => null,
+			'message_short' => null,
+			'datetime' => '',
+			'author' => '',
+			'commit_link' => '',
+		];
+
+		$data = array_merge($defaultData, $data);
+
+		return self::$connection->getDefault()->perform("
             INSERT INTO `jpemeric_stream`.`changelog`
                 (id, hash, message, message_short, datetime, author, commit_link)
             VALUES
                 (:id, :hash, :message, :message_short, :datetime, :author, :commit_link)",
-            $data
-        );
-    }
+			$data
+		);
+	}
 }