jacobemerick / web

src/Domain/Comment/Comment/MysqlCommentRepository.php

Doc Comments +1 added lines, -1 removed lines

@@ -11,7 +11,7 @@
     protected $connections;
 
     /**
-     * @param Aura\Sql\ConnectionLocator $connections
+     * @param ConnectionLocator $connections
      */
     public function __construct(ConnectionLocator $connections)
     {

Indentation +36 added lines, -36 removed lines

@@ -7,26 +7,26 @@ 
 class MysqlCommentRepository implements CommentRepositoryInterface
 {
 
-    /** @var  Aura\Sql\ConnectionLocator */
-    protected $connections;
-
-    /**
-     * @param Aura\Sql\ConnectionLocator $connections
-     */
-    public function __construct(ConnectionLocator $connections)
-    {
-        $this->connections = $connections;
-    }
-
-    public function getActiveCommentsBySite($site, $limit = null, $offset = 0)
-    {
-        if ($site == 'blog') {
-            $site_id = 2;
-        } else {
-            throw new Exception('Unrecognized site id in comment repository');
-        }
-
-        $query = "
+	/** @var  Aura\Sql\ConnectionLocator */
+	protected $connections;
+
+	/**
+	 * @param Aura\Sql\ConnectionLocator $connections
+	 */
+	public function __construct(ConnectionLocator $connections)
+	{
+		$this->connections = $connections;
+	}
+
+	public function getActiveCommentsBySite($site, $limit = null, $offset = 0)
+	{
+		if ($site == 'blog') {
+			$site_id = 2;
+		} else {
+			throw new Exception('Unrecognized site id in comment repository');
+		}
+
+		$query = "
             SELECT `comment_meta`.`id`, `comment_meta`.`date`, `comment`.`body`, `commenter`.`name`,
                    `post`.`title`, `post`.`category`, `post`.`path`
             FROM `jpemeric_comment`.`comment_meta`
@@ -39,21 +39,21 @@ 
                                                  `post`.`display` = :display_post
             WHERE `comment_meta`.`display` = :active_comment
             ORDER BY `comment_meta`.`date` DESC";
-        if ($limit != null) {
-            $query .= "
+		if ($limit != null) {
+			$query .= "
             LIMIT {$offset}, {$limit}";
-        }
-
-        $bindings = [
-            'trusted_commenter' => 1,
-            'comment_site' => $site_id,
-            'display_post' => 1,
-            'active_comment' => 1,
-        ];
-
-        return $this
-            ->connections
-            ->getRead()
-            ->fetchAll($query, $bindings);
-    }
+		}
+
+		$bindings = [
+			'trusted_commenter' => 1,
+			'comment_site' => $site_id,
+			'display_post' => 1,
+			'active_comment' => 1,
+		];
+
+		return $this
+			->connections
+			->getRead()
+			->fetchAll($query, $bindings);
+	}
 }

src/Domain/Comment/Comment/CommentRepositoryInterface.php

Indentation +1 added lines, -1 removed lines

@@ -4,5 +4,5 @@
 
 interface CommentRepositoryInterface
 {
-    public function getActiveCommentsBySite($site, $limit = null, $offset= 0);
+	public function getActiveCommentsBySite($site, $limit = null, $offset= 0);
 }

Spacing +1 added lines, -1 removed lines

@@ -4,5 +4,5 @@
 
 interface CommentRepositoryInterface
 {
-    public function getActiveCommentsBySite($site, $limit = null, $offset= 0);
+    public function getActiveCommentsBySite($site, $limit = null, $offset = 0);
 }

script/cron/generate-rss-feeds.php

Spacing +1 added lines, -1 removed lines

@@ -16,7 +16,7 @@
  * @param string $folder
  * @return boolean
  */
-$buildFeed = function (Feed $feed, $folder, $name = 'rss') {
+$buildFeed = function(Feed $feed, $folder, $name = 'rss') {
     $tempFeed = __DIR__ . "/../../public/{$folder}/{$name}-new.xml";
     $finalFeed = __DIR__ . "/../../public/{$folder}/{$name}.xml";
 

Unused Use Statements -1 removed lines

@@ -3,7 +3,6 @@
 require_once __DIR__ . '/../index.php';
 
 use Github\Client;
-
 use Jacobemerick\Web\Domain\Stream\Changelog\MysqlChangelogRepository as ChangelogRepository;
 
 $client = new Client();

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 = "http://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 = "http://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("http://blog.jacobemerick.com{$firstPhotoPath}", $firstPhotoSize, $firstPhotoType);
-    }
-
-    $blogPostItem->appendTo($blogPostChannel);
+	$blogPostItem = new Item();
+
+	$blogPostItem->title($blogPost['title']);
+
+	$url = "http://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 = "http://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("http://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 = "http://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 = "http://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');

src/Domain/Stream/BlogComment/MysqlBlogCommentRepository.php

Indentation +55 added lines, -55 removed lines

@@ -8,80 +8,80 @@
 class MysqlBlogCommentRepository implements BlogCommentRepositoryInterface
 {
 
-    /** @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 getBlogComments($limit = null, $offset = 0)
-    {
-        $query = "
+	/**
+	 * @param integer $limit
+	 * @param integer $offset
+	 *
+	 * @return array|false
+	 */
+	public function getBlogComments($limit = null, $offset = 0)
+	{
+		$query = "
             SELECT `id`, `permalink`, `datetime`
             FROM `jpemeric_stream`.`blog_comment`
             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);
+	}
 
-    /**
-     * @param string $permalink
-     *
-     * @return array|false
-     */
-    public function getBlogCommentByPermalink($permalink)
-    {
-        $query = "
+	/**
+	 * @param string $permalink
+	 *
+	 * @return array|false
+	 */
+	public function getBlogCommentByPermalink($permalink)
+	{
+		$query = "
             SELECT *
             FROM `jpemeric_stream`.`blog_comment`
             WHERE `permalink` = :permalink
             LIMIT 1";
 
-        $bindings = [
-            'permalink' => $permalink,
-        ];
+		$bindings = [
+			'permalink' => $permalink,
+		];
 
-        return $this
-            ->connections
-            ->getRead()
-            ->fetchOne($query, $bindings);
-    }
+		return $this
+			->connections
+			->getRead()
+			->fetchOne($query, $bindings);
+	}
 
-    public function insertBlogComment($permalink, DateTime $datetime, array $metadata)
-    {
-        $query = "
+	public function insertBlogComment($permalink, DateTime $datetime, array $metadata)
+	{
+		$query = "
             INSERT INTO `jpemeric_stream`.`blog_comment`
                 (`permalink`, `datetime`, `metadata`)
             VALUES
                 (:permalink, :datetime, :metadata)";
 
-        $bindings = [
-            'permalink' => $permalink,
-            'datetime' => $datetime->format('Y-m-d H:i:s'),
-            'metadata' => json_encode($metadata),
-        ];
+		$bindings = [
+			'permalink' => $permalink,
+			'datetime' => $datetime->format('Y-m-d H:i:s'),
+			'metadata' => json_encode($metadata),
+		];
 
-        return $this
-            ->connections
-            ->getWrite()
-            ->perform($query, $bindings);
-    }
+		return $this
+			->connections
+			->getWrite()
+			->perform($query, $bindings);
+	}
 }

script/cron/fetch-goodreads-activity.php

Indentation +20 added lines, -20 removed lines

@@ -6,7 +6,7 @@ 
 use Jacobemerick\Web\Domain\Stream\Goodread\MysqlGoodreadRepository as GoodreadRepository;
 
 $client = new Client([
-    'base_uri' => 'http://www.goodreads.com',
+	'base_uri' => 'http://www.goodreads.com',
 ]);
 
 $goodreadRepository = new GoodreadRepository($container['db_connection_locator']);
@@ -20,23 +20,23 @@ 
 $reviews = simplexml_load_string($reviews, 'SimpleXMLElement', LIBXML_NOCDATA);
 
 foreach ($reviews->channel->item as $review) {
-    $datetime = new DateTime((string) $review->pubDate);
-    if ($datetime <= $mostRecentReviewDateTime) {
-        break;
-    }
-
-    $uniqueReviewCheck = $goodreadRepository->getReviewByPermalink((string) $review->guid);
-    if ($uniqueReviewCheck !== false) {
-        continue;
-    }
-
-    $datetime->setTimezone($container['default_timezone']);
-    $metadata = json_decode(json_encode($review), true);
-
-    $goodreadRepository->insertReview(
-        (string) $review->guid,
-        (string) $review->book_id,
-        $datetime,
-        $metadata
-    );
+	$datetime = new DateTime((string) $review->pubDate);
+	if ($datetime <= $mostRecentReviewDateTime) {
+		break;
+	}
+
+	$uniqueReviewCheck = $goodreadRepository->getReviewByPermalink((string) $review->guid);
+	if ($uniqueReviewCheck !== false) {
+		continue;
+	}
+
+	$datetime->setTimezone($container['default_timezone']);
+	$metadata = json_decode(json_encode($review), true);
+
+	$goodreadRepository->insertReview(
+		(string) $review->guid,
+		(string) $review->book_id,
+		$datetime,
+		$metadata
+	);
 }

script/manual/historic-twitter-fetch.php

Indentation +29 added lines, -29 removed lines

@@ -4,17 +4,17 @@ 
 
 $options = getopt('f:');
 if (empty($options['f'])) {
-    exit('Must pass in a file with the f parameter.');
+	exit('Must pass in a file with the f parameter.');
 }
 
 use Abraham\TwitterOAuth\TwitterOAuth;
 use Jacobemerick\Web\Domain\Stream\Twitter\MysqlTwitterRepository as TwitterRepository;
 
 $client = new TwitterOAuth(
-    $config->twitter->consumer_key,
-    $config->twitter->consumer_secret,
-    $config->twitter->access_token,
-    $config->twitter->access_token_secret
+	$config->twitter->consumer_key,
+	$config->twitter->consumer_secret,
+	$config->twitter->access_token,
+	$config->twitter->access_token_secret
 );
 $client->setDecodeJsonAsArray(true);
 
@@ -24,29 +24,29 @@ 
 
 $handle = fopen(__DIR__ . '/' . $options['f'], 'r');
 while ($row = fgets($handle)) {
-    array_push($idList, trim($row));
-    if (count($idList) == 100) {
-        $tweetLookup = $client->get('statuses/lookup', [
-            'id' => implode(',', $idList),
-            'trim_user' => true,
-        ]);
-
-        foreach ($tweetLookup as $tweet) {
-            $uniqueTweetCheck = $twitterRepository->getTwitterByTweetId($tweet['id_str']);
-            if ($uniqueTweetCheck !== false) {
-                if ($uniqueTweetCheck['metadata'] != json_encode($tweet)) {
-                    $twitterRepository->updateTweetMetadata($tweet['id_str'], $tweet);
-                }
-                continue;
-            }
-
-            $twitterRepository->insertTweet(
-                $tweet['id_str'],
-                (new DateTime($tweet['created_at']))->setTimezone($container['default_timezone']),
-                $tweet
-            );
-        }
-        $idList = [];
-    }
+	array_push($idList, trim($row));
+	if (count($idList) == 100) {
+		$tweetLookup = $client->get('statuses/lookup', [
+			'id' => implode(',', $idList),
+			'trim_user' => true,
+		]);
+
+		foreach ($tweetLookup as $tweet) {
+			$uniqueTweetCheck = $twitterRepository->getTwitterByTweetId($tweet['id_str']);
+			if ($uniqueTweetCheck !== false) {
+				if ($uniqueTweetCheck['metadata'] != json_encode($tweet)) {
+					$twitterRepository->updateTweetMetadata($tweet['id_str'], $tweet);
+				}
+				continue;
+			}
+
+			$twitterRepository->insertTweet(
+				$tweet['id_str'],
+				(new DateTime($tweet['created_at']))->setTimezone($container['default_timezone']),
+				$tweet
+			);
+		}
+		$idList = [];
+	}
 }
 fclose($handle);

src/Domain/Stream/Activity/ActivityRepositoryInterface.php

Indentation +5 added lines, -5 removed lines

@@ -4,9 +4,9 @@
 
 interface ActivityRepositoryInterface
 {
-    public function getActivityById($id);
-    public function getActivities($limit = null, $offset = 0);
-    public function getActivitiesCount();
-    public function getActivitiesByType($type, $limit = null, $offset = 0);
-    public function getActivitiesByTypeCount($type);
+	public function getActivityById($id);
+	public function getActivities($limit = null, $offset = 0);
+	public function getActivitiesCount();
+	public function getActivitiesByType($type, $limit = null, $offset = 0);
+	public function getActivitiesByTypeCount($type);
 }

src/Domain/Stream/Activity/MysqlActivityRepository.php

Indentation +146 added lines, -146 removed lines

@@ -8,192 +8,192 @@
 class MysqlActivityRepository implements ActivityRepositoryInterface
 {
 
-    /** @var  ConnectionLocator */
-    protected $connections;
-
-    /**
-     * @param ConnectonLocator $connections
-     */
-    public function __construct(ConnectionLocator $connections)
-    {
-        $this->connections = $connections;
-    }
-
-    /**
-     * @param integer $id
-     *
-     * @return array|false
-     */
-    public function getActivityById($id)
-    {
-        $query = "
+	/** @var  ConnectionLocator */
+	protected $connections;
+
+	/**
+	 * @param ConnectonLocator $connections
+	 */
+	public function __construct(ConnectionLocator $connections)
+	{
+		$this->connections = $connections;
+	}
+
+	/**
+	 * @param integer $id
+	 *
+	 * @return array|false
+	 */
+	public function getActivityById($id)
+	{
+		$query = "
             SELECT *
             FROM `jpemeric_stream`.`activity`
             WHERE `id` = :id
             LIMIT 1";
-        $bindings = [
-            'id' => $id,
-        ];
-
-        return $this
-            ->connections
-            ->getRead()
-            ->fetchOne($query, $bindings);
-    }
-
-    public function getActivityByTypeId($type, $typeId)
-    {
-        $query = "
+		$bindings = [
+			'id' => $id,
+		];
+
+		return $this
+			->connections
+			->getRead()
+			->fetchOne($query, $bindings);
+	}
+
+	public function getActivityByTypeId($type, $typeId)
+	{
+		$query = "
             SELECT *
             FROM `jpemeric_stream`.`activity`
             WHERE `type` = :type && `type_id` = :type_id
             LIMIT 1";
-        $bindings = [
-            'type'    => $type,
-            'type_id' => $typeId,
-        ];
-
-        return $this
-            ->connections
-            ->getRead()
-            ->fetchOne($query, $bindings);
-    }
-
-    public function getActivityLastUpdateByType($type)
-    {
-        $query = "
+		$bindings = [
+			'type'    => $type,
+			'type_id' => $typeId,
+		];
+
+		return $this
+			->connections
+			->getRead()
+			->fetchOne($query, $bindings);
+	}
+
+	public function getActivityLastUpdateByType($type)
+	{
+		$query = "
             SELECT *
             FROM `jpemeric_stream`.`activity`
             WHERE `type` = :type
             ORDER BY `updated_at` DESC
             LIMIT 1";
 
-        $bindings = [
-            'type' => $type,
-        ];
-
-        return $this
-            ->connections
-            ->getRead()
-            ->fetchOne($query, $bindings);
-    }
-
-    /**
-     * @param integer $limit
-     * @param integer $offset
-     *
-     * @return array|false
-     */
-    public function getActivities($limit = null, $offset = 0)
-    {
-        $query = "
+		$bindings = [
+			'type' => $type,
+		];
+
+		return $this
+			->connections
+			->getRead()
+			->fetchOne($query, $bindings);
+	}
+
+	/**
+	 * @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,
-        ];
-
-        return $this
-            ->connections
-            ->getRead()
-            ->fetchAll($query, $bindings);
-    }
-
-    public function getActivitiesByTypeCount($type)
-    {
-        $query = "
+		}
+		$bindings = [
+			'type' => $type,
+		];
+
+		return $this
+			->connections
+			->getRead()
+			->fetchAll($query, $bindings);
+	}
+
+	public function getActivitiesByTypeCount($type)
+	{
+		$query = "
             SELECT COUNT(1) AS `count`
             FROM `jpemeric_stream`.`activity`
             WHERE `type` = :type";
-        $bindings = [
-            'type' => $type,
-        ];
-
-        return $this
-            ->connections
-            ->getRead()
-            ->fetchValue($query, $bindings);
-    }
-
-    public function insertActivity(
-        $message,
-        $messageLong,
-        DateTime $datetime,
-        array $metadata,
-        $type,
-        $typeId
-    ) {
-        $query = "
+		$bindings = [
+			'type' => $type,
+		];
+
+		return $this
+			->connections
+			->getRead()
+			->fetchValue($query, $bindings);
+	}
+
+	public function insertActivity(
+		$message,
+		$messageLong,
+		DateTime $datetime,
+		array $metadata,
+		$type,
+		$typeId
+	) {
+		$query = "
             INSERT INTO `jpemeric_stream`.`activity`
                 (`message`, `message_long`, `datetime`, `metadata`, `type`, `type_id`)
             VALUES
                 (:message, :message_long, :datetime, :metadata, :type, :type_id)";
 
-        $bindings = [
-            'message' => $message,
-            'message_long' => $messageLong,
-            'datetime' => $datetime->format('Y-m-d H:i:s'),
-            'metadata' => json_encode($metadata),
-            'type' => $type,
-            'type_id' => $typeId,
-        ];
-
-        return $this
-            ->connections
-            ->getWrite()
-            ->perform($query, $bindings);
-    }
-
-    public function updateActivityMetadata($activityId, array $metadata)
-    {
-        $query = "
+		$bindings = [
+			'message' => $message,
+			'message_long' => $messageLong,
+			'datetime' => $datetime->format('Y-m-d H:i:s'),
+			'metadata' => json_encode($metadata),
+			'type' => $type,
+			'type_id' => $typeId,
+		];
+
+		return $this
+			->connections
+			->getWrite()
+			->perform($query, $bindings);
+	}
+
+	public function updateActivityMetadata($activityId, array $metadata)
+	{
+		$query = "
             UPDATE `jpemeric_stream`.`activity`
             SET `metadata` = :metadata
             WHERE `id` = :id";
 
-        $bindings = [
-            'metadata' => json_encode($metadata),
-            'id' => $activityId,
-        ];
+		$bindings = [
+			'metadata' => json_encode($metadata),
+			'id' => $activityId,
+		];
 
-        return $this
-            ->connections
-            ->getWrite()
-            ->perform($query, $bindings);
-    }
+		return $this
+			->connections
+			->getWrite()
+			->perform($query, $bindings);
+	}
 }

src/Domain/Stream/DailyMile/MysqlDailyMileRepository.php

Indentation +82 added lines, -82 removed lines

@@ -8,106 +8,106 @@
 class MysqlDailyMileRepository implements DailyMileRepositoryInterface
 {
 
-    /** @var  ConnectionLocator */
-    protected $connections;
-
-    /**
-     * @param ConnectonLocator $connections
-     */
-    public function __construct(ConnectionLocator $connections)
-    {
-        $this->connections = $connections;
-    }
-
-    /**
-     * @param integer $limit
-     * @param integer $offset
-     *
-     * @return array|false
-     */
-    public function getEntries($limit = null, $offset = 0)
-    {
-        $query = "
+	/** @var  ConnectionLocator */
+	protected $connections;
+
+	/**
+	 * @param ConnectonLocator $connections
+	 */
+	public function __construct(ConnectionLocator $connections)
+	{
+		$this->connections = $connections;
+	}
+
+	/**
+	 * @param integer $limit
+	 * @param integer $offset
+	 *
+	 * @return array|false
+	 */
+	public function getEntries($limit = null, $offset = 0)
+	{
+		$query = "
             SELECT `id`, `entry_id`, `datetime`
             FROM `jpemeric_stream`.`dailymile`
             ORDER BY `datetime` DESC";
-        if (!is_null($limit)) {
-          $query .= "
+		if (!is_null($limit)) {
+		  $query .= "
           LIMIT {$offset}, {$limit}";
-        }
-
-        return $this
-            ->connections
-            ->getRead()
-            ->fetchAll($query);
-    }
-
-    /**
-     * @param integer $entryId
-     *
-     * @return array|false
-     */
-    public function getEntryByEntryId($entryId)
-    {
-        $query = "
+		}
+
+		return $this
+			->connections
+			->getRead()
+			->fetchAll($query);
+	}
+
+	/**
+	 * @param integer $entryId
+	 *
+	 * @return array|false
+	 */
+	public function getEntryByEntryId($entryId)
+	{
+		$query = "
             SELECT *
             FROM `jpemeric_stream`.`dailymile`
             WHERE `entry_id` = :entry_id
             LIMIT 1";
 
-        $bindings = [
-            'entry_id' => $entryId,
-        ];
+		$bindings = [
+			'entry_id' => $entryId,
+		];
 
-        return $this
-            ->connections
-            ->getRead()
-            ->fetchOne($query, $bindings);
-    }
+		return $this
+			->connections
+			->getRead()
+			->fetchOne($query, $bindings);
+	}
 
-    public function getDailyMilesUpdatedSince(DateTime $datetime)
-    {
-        $query = "
+	public function getDailyMilesUpdatedSince(DateTime $datetime)
+	{
+		$query = "
             SELECT *
             FROM `jpemeric_stream`.`dailymile`
             WHERE `updated_at` >= :last_update";
 
-        $bindings = [
-            'last_update' => $datetime->format('Y-m-d H:i:s'),
-        ];
-
-        return $this
-            ->connections
-            ->getRead()
-            ->fetchAll($query, $bindings);
-    }
-
-    /**
-     * @param integer  $entryId
-     * @param string   $entryType
-     * @param DateTime $datetime
-     * @param array    $metadata
-     *
-     * @return
-     */
-    public function insertEntry($entryId, $entryType, DateTime $datetime, array $metadata)
-    {
-        $query = "
+		$bindings = [
+			'last_update' => $datetime->format('Y-m-d H:i:s'),
+		];
+
+		return $this
+			->connections
+			->getRead()
+			->fetchAll($query, $bindings);
+	}
+
+	/**
+	 * @param integer  $entryId
+	 * @param string   $entryType
+	 * @param DateTime $datetime
+	 * @param array    $metadata
+	 *
+	 * @return
+	 */
+	public function insertEntry($entryId, $entryType, DateTime $datetime, array $metadata)
+	{
+		$query = "
             INSERT INTO `jpemeric_stream`.`dailymile`
                 (`entry_id`, `type`, `datetime`, `metadata`)
             VALUES
                 (:entry_id, :entry_type, :datetime, :metadata)";
 
-        $bindings = [
-            'entry_id' => $entryId,
-            'entry_type' => $entryType,
-            'datetime' => $datetime->format('Y-m-d H:i:s'),
-            'metadata' => json_encode($metadata),
-        ];
-
-        return $this
-            ->connections
-            ->getWrite()
-            ->perform($query, $bindings);
-    }
+		$bindings = [
+			'entry_id' => $entryId,
+			'entry_type' => $entryType,
+			'datetime' => $datetime->format('Y-m-d H:i:s'),
+			'metadata' => json_encode($metadata),
+		];
+
+		return $this
+			->connections
+			->getWrite()
+			->perform($query, $bindings);
+	}
 }