jacobemerick / web

src/Domain/Stream/Changelog/MysqlChangelogRepository.php

Indentation +74 added lines, -74 removed lines

@@ -8,100 +8,100 @@
 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);
+	}
 
-    /**
-     * @param string $hash
-     *
-     * @return array|false
-     */
-    public function getChangeByHash($hash)
-    {
-        $query = "
+	/**
+	 * @param string $hash
+	 *
+	 * @return array|false
+	 */
+	public function getChangeByHash($hash)
+	{
+		$query = "
             SELECT *
             FROM `jpemeric_stream`.`changelog`
             WHERE `hash` = :hash
             LIMIT 1";
 
-        $bindings = [
-            'hash' => $hash,
-        ];
+		$bindings = [
+			'hash' => $hash,
+		];
 
-        return $this
-            ->connections
-            ->getRead()
-            ->fetchOne($query, $bindings);
-    }
+		return $this
+			->connections
+			->getRead()
+			->fetchOne($query, $bindings);
+	}
 
-    /**
-     * @param string   $hash
-     * @param string   $message
-     * @param DateTime $datetime
-     * @param string   $author
-     * @param string   $commit_link
-     *
-     * @return
-     */
-    public function insertChange($hash, $message, DateTime $datetime, $author, $commit_link)
-    {
-        $message_short = $message;
-        $message_short = strtok($message_short, "\n");
-        if (strlen($message_short) > 72) {
-            $message_short = wordwrap($message_short, 65);
-            $message_short = strtok($message_short, "\n");
-            $message_short .= '...';
-        }
+	/**
+	 * @param string   $hash
+	 * @param string   $message
+	 * @param DateTime $datetime
+	 * @param string   $author
+	 * @param string   $commit_link
+	 *
+	 * @return
+	 */
+	public function insertChange($hash, $message, DateTime $datetime, $author, $commit_link)
+	{
+		$message_short = $message;
+		$message_short = strtok($message_short, "\n");
+		if (strlen($message_short) > 72) {
+			$message_short = wordwrap($message_short, 65);
+			$message_short = strtok($message_short, "\n");
+			$message_short .= '...';
+		}
 
-        $query = "
+		$query = "
             INSERT INTO `jpemeric_stream`.`changelog`
                 (`hash`, `message`, `message_short`, `datetime`, `author`, `commit_link`)
             VALUES
                 (:hash, :message, :message_short, :datetime, :author, :commit_link)";
 
-        $bindings = [
-            'hash' => $hash,
-            'message' => $message,
-            'message_short' => $message_short,
-            'datetime' => $datetime->format('Y-m-d H:i:s'),
-            'author' => $author,
-            'commit_link' => $commit_link
-        ];
+		$bindings = [
+			'hash' => $hash,
+			'message' => $message,
+			'message_short' => $message_short,
+			'datetime' => $datetime->format('Y-m-d H:i:s'),
+			'author' => $author,
+			'commit_link' => $commit_link
+		];
 
-        return $this
-            ->connections
-            ->getWrite()
-            ->perform($query, $bindings);
-    }
+		return $this
+			->connections
+			->getWrite()
+			->perform($query, $bindings);
+	}
 }

script/cron/fetch-twitter-activity.php

Indentation +22 added lines, -22 removed lines

@@ -6,36 +6,36 @@
 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);
 
 $twitterRepository = new TwitterRepository($container['db_connection_locator']);
 
 $recentTweets = $client->get('statuses/user_timeline', [
-    'screen_name' => 'jpemeric',
-    'count' => 50,
-    'trim_user' => true,
+	'screen_name' => 'jpemeric',
+	'count' => 50,
+	'trim_user' => true,
 ]);
 
 foreach ($recentTweets as $tweet) {
-    $uniqueTweetCheck = $twitterRepository->getTwitterByTweetId($tweet['id_str']);
-    if ($uniqueTweetCheck !== false) {
-        $currentTweetHash = md5($uniqueTweetCheck['metadata']);
-        $newTweetHash = md5(json_encode($tweet));
-        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
-    );
+	$uniqueTweetCheck = $twitterRepository->getTwitterByTweetId($tweet['id_str']);
+	if ($uniqueTweetCheck !== false) {
+		$currentTweetHash = md5($uniqueTweetCheck['metadata']);
+		$newTweetHash = md5(json_encode($tweet));
+		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
+	);
 }
 

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);
 }

src/Domain/Comment/Comment/MysqlCommentRepository.php

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/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);
+	}
 }

src/Domain/Stream/Blog/BlogRepositoryInterface.php

Indentation +2 added lines, -2 removed lines

@@ -4,6 +4,6 @@
 
 interface BlogRepositoryInterface
 {
-    public function getBlogById($id);
-    public function getBlogByTitle($title);
+	public function getBlogById($id);
+	public function getBlogByTitle($title);
 }

src/Domain/Stream/Twitter/TwitterRepositoryInterface.php

Indentation +2 added lines, -2 removed lines

@@ -4,6 +4,6 @@
 
 interface TwitterRepositoryInterface
 {
-    public function getTwitterById($id);
-    public function getUnmappedTwitters();
+	public function getTwitterById($id);
+	public function getUnmappedTwitters();
 }

controller/blog/DefaultPageController.class.inc.php

Indentation +9 added lines, -9 removed lines

@@ -20,14 +20,14 @@ 
 
 	protected function set_head_data()
 	{
-    $this->set_head('rss_link', [
-      'title' => 'Jacob Emerick Blog Feed',
-      'url' => '/rss.xml'
-    ]);
-    $this->set_head('rss_comment_link', [
-      'title' => 'Jacob Emerick Blog Comment Feed',
-      'url' => '/rss-comments.xml'
-    ]);
+	$this->set_head('rss_link', [
+	  'title' => 'Jacob Emerick Blog Feed',
+	  'url' => '/rss.xml'
+	]);
+	$this->set_head('rss_comment_link', [
+	  'title' => 'Jacob Emerick Blog Comment Feed',
+	  'url' => '/rss-comments.xml'
+	]);
 		
 		$this->add_css('normalize');
 		$this->add_css('blog');
@@ -92,7 +92,7 @@ 
 		Loader::load('collector', 'blog/TagCollector');
 		
 		$tag_result = TagCollector::getTagsForPost($post->id);
-        $tag_array = array();
+		$tag_array = array();
 		foreach($tag_result as $tag)
 		{
 			$tag_object = new stdclass();

script/cron/fetch-blog-activity.php

Indentation +36 added lines, -36 removed lines

@@ -13,24 +13,24 @@ 
 
 $blogFeed = Feed::loadRss('http://blog.jacobemerick.com/rss.xml');
 foreach ($blogFeed->item as $item) {
-    $datetime = new DateTime($item->pubDate);
-    if ($datetime <= $mostRecentBlogDateTime) {
-        break;
-    }
-
-    $uniqueBlogCheck = $blogRepository->getBlogByPermalink((string) $item->guid);
-    if ($uniqueBlogCheck !== false) {
-        continue;
-    }
-
-    $datetime->setTimezone($container['default_timezone']);
-    $metadata = json_decode(json_encode($item), true);
-
-    $blogRepository->insertBlog(
-        (string) $item->guid,
-        $datetime,
-        $metadata
-    );
+	$datetime = new DateTime($item->pubDate);
+	if ($datetime <= $mostRecentBlogDateTime) {
+		break;
+	}
+
+	$uniqueBlogCheck = $blogRepository->getBlogByPermalink((string) $item->guid);
+	if ($uniqueBlogCheck !== false) {
+		continue;
+	}
+
+	$datetime->setTimezone($container['default_timezone']);
+	$metadata = json_decode(json_encode($item), true);
+
+	$blogRepository->insertBlog(
+		(string) $item->guid,
+		$datetime,
+		$metadata
+	);
 }
 
 $blogCommentRepository = new BlogCommentRepository($container['db_connection_locator']);
@@ -41,22 +41,22 @@ 
 
 $commentFeed = Feed::loadRss('http://blog.jacobemerick.com/rss-comments.xml');
 foreach ($commentFeed->item as $item) {
-    $datetime = new DateTime($item->pubDate);
-    if ($datetime <= $mostRecentBlogCommentDateTime) {
-        break;
-    }
-
-    $uniqueBlogCommentCheck = $blogCommentRepository->getBlogCommentByPermalink((string) $item->guid);
-    if ($uniqueBlogCommentCheck !== false) {
-        continue;
-    }
-
-    $datetime->setTimezone($container['default_timezone']);
-    $metadata = json_decode(json_encode($item), true);
-
-    $blogCommentRepository->insertBlogComment(
-        (string) $item->guid,
-        $datetime,
-        $metadata
-    );
+	$datetime = new DateTime($item->pubDate);
+	if ($datetime <= $mostRecentBlogCommentDateTime) {
+		break;
+	}
+
+	$uniqueBlogCommentCheck = $blogCommentRepository->getBlogCommentByPermalink((string) $item->guid);
+	if ($uniqueBlogCommentCheck !== false) {
+		continue;
+	}
+
+	$datetime->setTimezone($container['default_timezone']);
+	$metadata = json_decode(json_encode($item), true);
+
+	$blogCommentRepository->insertBlogComment(
+		(string) $item->guid,
+		$datetime,
+		$metadata
+	);
 }