jacobemerick / web

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

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

src/Domain/Stream/Goodread/MysqlGoodreadRepository.php

Indentation +65 added lines, -65 removed lines

@@ -8,93 +8,93 @@
 class MysqlGoodreadRepository implements GoodreadRepositoryInterface
 {
 
-    /** @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 getReviews($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 getReviews($limit = null, $offset = 0)
+	{
+		$query = "
             SELECT `id`, `permalink`, `datetime`
             FROM `jpemeric_stream`.`goodread`
             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 getReviewByPermalink($permalink)
-    {
-        $query = "
+	public function getReviewByPermalink($permalink)
+	{
+		$query = "
             SELECT *
             FROM `jpemeric_stream`.`goodread`
             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 getGoodreadsUpdatedSince(DateTime $datetime)
-    {
-        $query = "
+	public function getGoodreadsUpdatedSince(DateTime $datetime)
+	{
+		$query = "
             SELECT *
             FROM `jpemeric_stream`.`goodread`
             WHERE `updated_at` >= :last_update";
 
-        $bindings = [
-            'last_update' => $datetime->format('Y-m-d H:i:s'),
-        ];
+		$bindings = [
+			'last_update' => $datetime->format('Y-m-d H:i:s'),
+		];
 
-        return $this
-            ->connections
-            ->getRead()
-            ->fetchAll($query, $bindings);
-    }
+		return $this
+			->connections
+			->getRead()
+			->fetchAll($query, $bindings);
+	}
 
-    public function insertReview($permalink, $bookId, DateTime $datetime, array $metadata)
-    {
-        $query = "
+	public function insertReview($permalink, $bookId, DateTime $datetime, array $metadata)
+	{
+		$query = "
             INSERT INTO `jpemeric_stream`.`goodread`
                 (`permalink`, `book_id`, `datetime`, `metadata`)
             VALUES
                 (:permalink, :book_id, :datetime, :metadata)";
 
-        $bindings = [
-            'permalink' => $permalink,
-            'book_id' => $bookId,
-            'datetime' => $datetime->format('Y-m-d H:i:s'),
-            'metadata' => json_encode($metadata),
-        ];
-
-        return $this
-            ->connections
-            ->getWrite()
-            ->perform($query, $bindings);
-    }
+		$bindings = [
+			'permalink' => $permalink,
+			'book_id' => $bookId,
+			'datetime' => $datetime->format('Y-m-d H:i:s'),
+			'metadata' => json_encode($metadata),
+		];
+
+		return $this
+			->connections
+			->getWrite()
+			->perform($query, $bindings);
+	}
 }

src/Domain/Stream/Github/MysqlGithubRepository.php

Indentation +75 added lines, -75 removed lines

@@ -8,104 +8,104 @@
 class MysqlGithubRepository implements GithubRepositoryInterface
 {
 
-    /** @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 getEvents($limit = null, $offset = 0)
-    {
-        $query = "
+	/**
+	 * @param integer $limit
+	 * @param integer $offset
+	 *
+	 * @return array|false
+	 */
+	public function getEvents($limit = null, $offset = 0)
+	{
+		$query = "
             SELECT `id`, `event_id`, `datetime`
             FROM `jpemeric_stream`.`github`
             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 integer $eventId
-     *
-     * @return array|false
-     */
-    public function getEventByEventId($eventId)
-    {
-        $query = "
+	/**
+	 * @param integer $eventId
+	 *
+	 * @return array|false
+	 */
+	public function getEventByEventId($eventId)
+	{
+		$query = "
             SELECT *
             FROM `jpemeric_stream`.`github`
             WHERE `event_id` = :event_id
             LIMIT 1";
 
-        $bindings = [
-            'event_id' => $eventId,
-        ];
+		$bindings = [
+			'event_id' => $eventId,
+		];
 
-        return $this
-            ->connections
-            ->getRead()
-            ->fetchOne($query, $bindings);
-    }
+		return $this
+			->connections
+			->getRead()
+			->fetchOne($query, $bindings);
+	}
 
-    public function getGithubsUpdatedSince(DateTime $datetime)
-    {
-        $query = "
+	public function getGithubsUpdatedSince(DateTime $datetime)
+	{
+		$query = "
             SELECT *
             FROM `jpemeric_stream`.`github`
             WHERE `updated_at` >= :last_update";
-        $bindings = [
-            'last_update' => $datetime->format('Y-m-d H:i:s'),
-        ];
-        return $this
-            ->connections
-            ->getRead()
-            ->fetchAll($query, $bindings);
-    }
+		$bindings = [
+			'last_update' => $datetime->format('Y-m-d H:i:s'),
+		];
+		return $this
+			->connections
+			->getRead()
+			->fetchAll($query, $bindings);
+	}
 
-    /**
-     * @param integer  $eventId
-     * @param string   $eventType
-     * @param DateTime $datetime
-     * @param array    $metadata
-     *
-     * @return
-     */
-    public function insertEvent($eventId, $eventType, DateTime $datetime, array $metadata)
-    {
-        $query = "
+	/**
+	 * @param integer  $eventId
+	 * @param string   $eventType
+	 * @param DateTime $datetime
+	 * @param array    $metadata
+	 *
+	 * @return
+	 */
+	public function insertEvent($eventId, $eventType, DateTime $datetime, array $metadata)
+	{
+		$query = "
             INSERT INTO `jpemeric_stream`.`github`
                 (`event_id`, `type`, `datetime`, `metadata`)
             VALUES
                 (:event_id, :event_type, :datetime, :metadata)";
 
-        $bindings = [
-            'event_id' => $eventId,
-            'event_type' => $eventType,
-            'datetime' => $datetime->format('Y-m-d H:i:s'),
-            'metadata' => json_encode($metadata),
-        ];
+		$bindings = [
+			'event_id' => $eventId,
+			'event_type' => $eventType,
+			'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/build-activity-stream.php

Spacing +1 added lines, -1 removed lines

@@ -406,7 +406,7 @@
 
     $messageLong = $twitterData['text'];
     krsort($entityHolder);
-    foreach($entityHolder as $entity)
+    foreach ($entityHolder as $entity)
     {
         $messageLong = substr_replace(
             $messageLong,

Indentation +402 added lines, -402 removed lines

@@ -11,42 +11,42 @@ 
 
 $lastBlogActivity = $activityRepository->getActivityLastUpdateByType('blog');
 if ($lastBlogActivity === false) {
-    $lastBlogActivityDateTime = new DateTime('2008-05-03');
+	$lastBlogActivityDateTime = new DateTime('2008-05-03');
 } else {
-    $lastBlogActivityDateTime = new DateTime($lastBlogActivity['updated_at']);
-    $lastBlogActivityDateTime->modify('-5 days');
+	$lastBlogActivityDateTime = new DateTime($lastBlogActivity['updated_at']);
+	$lastBlogActivityDateTime->modify('-5 days');
 }
 $newBlogActivity = $blogRepository->getBlogsUpdatedSince($lastBlogActivityDateTime);
 foreach ($newBlogActivity as $blog) {
-    $uniqueBlogCheck = $activityRepository->getActivityByTypeId('blog', $blog['id']);
-    if ($uniqueBlogCheck !== false) {
-        continue;
-    }
-
-    $blogData = json_decode($blog['metadata'], true);
-    $message = sprintf(
-        'Blogged about %s | %s.',
-        str_replace('-', ' ', $blogData['category']),
-        $blogData['title']
-    );
-    $messageLong = sprintf(
-        "<h4><a href=\"%s\" title=\"Jacob Emerick's Blog | %s\">%s</a></h4>\n" .
-        "<p>%s [<a href=\"%s\">read more</a></a>]</p>",
-        $blogData['link'],
-        $blogData['title'],
-        $blogData['title'],
-        htmlentities($blogData['description']),
-        $blogData['link']
-    );
-
-    $activityRepository->insertActivity(
-        $message,
-        $messageLong,
-        (new DateTime($blog['datetime'])),
-        [],
-        'blog',
-        $blog['id']
-    );
+	$uniqueBlogCheck = $activityRepository->getActivityByTypeId('blog', $blog['id']);
+	if ($uniqueBlogCheck !== false) {
+		continue;
+	}
+
+	$blogData = json_decode($blog['metadata'], true);
+	$message = sprintf(
+		'Blogged about %s | %s.',
+		str_replace('-', ' ', $blogData['category']),
+		$blogData['title']
+	);
+	$messageLong = sprintf(
+		"<h4><a href=\"%s\" title=\"Jacob Emerick's Blog | %s\">%s</a></h4>\n" .
+		"<p>%s [<a href=\"%s\">read more</a></a>]</p>",
+		$blogData['link'],
+		$blogData['title'],
+		$blogData['title'],
+		htmlentities($blogData['description']),
+		$blogData['link']
+	);
+
+	$activityRepository->insertActivity(
+		$message,
+		$messageLong,
+		(new DateTime($blog['datetime'])),
+		[],
+		'blog',
+		$blog['id']
+	);
 }
 
 use Jacobemerick\Web\Domain\Stream\BlogComment\MysqlBlogCommentRepository as BlogCommentRepository;
@@ -54,30 +54,30 @@ 
 $blogCommentActivity = $blogCommentRepository->getBlogComments();
 $blogCommentHolder = [];
 foreach ($blogCommentActivity as $blogComment) {
-    $blogPermalink = $blogComment['permalink'];
-    $blogPermalink = explode('#', $blogPermalink);
-    $blogPermalink = current($blogPermalink);
-
-    $blog = $blogRepository->getBlogByPermalink($blogPermalink);
-    if (!array_key_exists($blog['id'], $blogCommentHolder)) {
-        $blogCommentHolder[$blog['id']] = 1;
-    } else {
-        $blogCommentHolder[$blog['id']]++;
-    }
+	$blogPermalink = $blogComment['permalink'];
+	$blogPermalink = explode('#', $blogPermalink);
+	$blogPermalink = current($blogPermalink);
+
+	$blog = $blogRepository->getBlogByPermalink($blogPermalink);
+	if (!array_key_exists($blog['id'], $blogCommentHolder)) {
+		$blogCommentHolder[$blog['id']] = 1;
+	} else {
+		$blogCommentHolder[$blog['id']]++;
+	}
 }
 
 foreach ($blogCommentHolder as $blogId => $commentCount) {
-    $blogActivity = $activityRepository->getActivityByTypeId('blog', $blogId);
-    $blogActivityMetadata = json_decode($blogActivity['metadata'], true);
-    if (
-        !isset($blogActivityMetadata['comments']) ||
-        $blogActivityMetadata['comments'] != $commentCount
-    ) {
-        $activityRepository->updateActivityMetadata(
-            $blogActivity['id'],
-            ['comments' => $commentCount]
-        );
-    }
+	$blogActivity = $activityRepository->getActivityByTypeId('blog', $blogId);
+	$blogActivityMetadata = json_decode($blogActivity['metadata'], true);
+	if (
+		!isset($blogActivityMetadata['comments']) ||
+		$blogActivityMetadata['comments'] != $commentCount
+	) {
+		$activityRepository->updateActivityMetadata(
+			$blogActivity['id'],
+			['comments' => $commentCount]
+		);
+	}
 }
 
 // distance
@@ -86,67 +86,67 @@ 
 
 $lastDailyMileActivity = $activityRepository->getActivityLastUpdateByType('distance');
 if ($lastDailyMileActivity === false) {
-    $lastDailyMileActivityDateTime = new DateTime('2008-05-03');
+	$lastDailyMileActivityDateTime = new DateTime('2008-05-03');
 } else {
-    $lastDailyMileActivityDateTime = new DateTime($lastDailyMileActivity['updated_at']);
-    $lastDailyMileActivityDateTime->modify('-5 days');
+	$lastDailyMileActivityDateTime = new DateTime($lastDailyMileActivity['updated_at']);
+	$lastDailyMileActivityDateTime->modify('-5 days');
 }
 $newDailyMileActivity = $dailyMileRepository->getDailyMilesUpdatedSince($lastDailyMileActivityDateTime);
 foreach ($newDailyMileActivity as $dailyMile) {
-    $uniqueDailyMileCheck = $activityRepository->getActivityByTypeId('distance', $dailyMile['id']);
-    if ($uniqueDailyMileCheck !== false) {
-        continue;
-    }
-
-    $dailyMileData = json_decode($dailyMile['metadata'], true);
-    if ($dailyMile['type'] == 'Hiking') {
-        $message = sprintf(
-            '%s %.2f %s and felt %s.',
-            'Hiked',
-            $dailyMileData['workout']['distance']['value'],
-            $dailyMileData['workout']['distance']['units'],
-            $dailyMileData['workout']['felt']
-        );
-        $messageLong = "<p>{$message}</p>";
-        if (isset($dailyMileData['workout']['title'])) {
-            $messageLong .= "\n<p>I was hiking up around the {$dailyMileData['workout']['title']} area.</p>";
-        }
-    } else if ($dailyMile['type'] == 'Running') {
-        $message = sprintf(
-            '%s %.2f %s and felt %s.',
-            'Ran',
-            $dailyMileData['workout']['distance']['value'],
-            $dailyMileData['workout']['distance']['units'],
-            $dailyMileData['workout']['felt']
-        );
-        $messageLong = "<p>{$message}</p>";
-        if (isset($dailyMileData['message'])) {
-            $messageLong .= "\n<p>Afterwards, I was all like '{$dailyMileData['message']}'.</p>";
-        }
-    } else if ($dailyMile['type'] == 'Walking') {
-        $message = sprintf(
-            '%s %.2f %s and felt %s.',
-            'Walked',
-            $dailyMileData['workout']['distance']['value'],
-            $dailyMileData['workout']['distance']['units'],
-            $dailyMileData['workout']['felt']
-        );
-        $messageLong = "<p>{$message}</p>";
-        if (isset($dailyMileData['message'])) {
-            $messageLong .= "\n<p>{$dailyMileData['message']}</p>";
-        }
-    } else {
-        continue;
-    }
-
-    $activityRepository->insertActivity(
-        $message,
-        $messageLong,
-        (new DateTime($dailyMile['datetime'])),
-        [],
-        'distance',
-        $dailyMile['id']
-    );
+	$uniqueDailyMileCheck = $activityRepository->getActivityByTypeId('distance', $dailyMile['id']);
+	if ($uniqueDailyMileCheck !== false) {
+		continue;
+	}
+
+	$dailyMileData = json_decode($dailyMile['metadata'], true);
+	if ($dailyMile['type'] == 'Hiking') {
+		$message = sprintf(
+			'%s %.2f %s and felt %s.',
+			'Hiked',
+			$dailyMileData['workout']['distance']['value'],
+			$dailyMileData['workout']['distance']['units'],
+			$dailyMileData['workout']['felt']
+		);
+		$messageLong = "<p>{$message}</p>";
+		if (isset($dailyMileData['workout']['title'])) {
+			$messageLong .= "\n<p>I was hiking up around the {$dailyMileData['workout']['title']} area.</p>";
+		}
+	} else if ($dailyMile['type'] == 'Running') {
+		$message = sprintf(
+			'%s %.2f %s and felt %s.',
+			'Ran',
+			$dailyMileData['workout']['distance']['value'],
+			$dailyMileData['workout']['distance']['units'],
+			$dailyMileData['workout']['felt']
+		);
+		$messageLong = "<p>{$message}</p>";
+		if (isset($dailyMileData['message'])) {
+			$messageLong .= "\n<p>Afterwards, I was all like '{$dailyMileData['message']}'.</p>";
+		}
+	} else if ($dailyMile['type'] == 'Walking') {
+		$message = sprintf(
+			'%s %.2f %s and felt %s.',
+			'Walked',
+			$dailyMileData['workout']['distance']['value'],
+			$dailyMileData['workout']['distance']['units'],
+			$dailyMileData['workout']['felt']
+		);
+		$messageLong = "<p>{$message}</p>";
+		if (isset($dailyMileData['message'])) {
+			$messageLong .= "\n<p>{$dailyMileData['message']}</p>";
+		}
+	} else {
+		continue;
+	}
+
+	$activityRepository->insertActivity(
+		$message,
+		$messageLong,
+		(new DateTime($dailyMile['datetime'])),
+		[],
+		'distance',
+		$dailyMile['id']
+	);
 }
 
 // github
@@ -155,127 +155,127 @@ 
 
 $lastGithubActivity = $activityRepository->getActivityLastUpdateByType('git');
 if ($lastGithubActivity === false) {
-    $lastGithubActivityDateTime = new DateTime('2015-10-01');
+	$lastGithubActivityDateTime = new DateTime('2015-10-01');
 } else {
-    $lastGithubActivityDateTime = new DateTime($lastGithubActivity['updated_at']);
-    $lastGithubActivityDateTime->modify('-5 days');
+	$lastGithubActivityDateTime = new DateTime($lastGithubActivity['updated_at']);
+	$lastGithubActivityDateTime->modify('-5 days');
 }
 $newGithubActivity = $githubRepository->getGithubsUpdatedSince($lastGithubActivityDateTime);
 foreach ($newGithubActivity as $github) {
-    $uniqueGithubCheck = $activityRepository->getActivityByTypeId('git', $github['id']);
-    if ($uniqueGithubCheck !== false) {
-        continue;
-    }
-
-    $githubData = json_decode($github['metadata'], true);
-
-    if ($github['type'] == 'CreateEvent') {
-        if (
-            $githubData['payload']['ref_type'] == 'branch' ||
-            $githubData['payload']['ref_type'] == 'tag'
-        ) {
-            $message = sprintf(
-                'Created %s %s at %s.',
-                $githubData['payload']['ref_type'],
-                $githubData['payload']['ref'],
-                $githubData['repo']['name']
-            );
-            $messageLong = sprintf(
-                '<p>Created %s %s at <a href="%s" target="_blank" title="Github | %s">%s</a>.</p>',
-                $githubData['payload']['ref_type'],
-                $githubData['payload']['ref'],
-                "https://github.com/{$githubData['repo']['name']}",
-                $githubData['repo']['name'],
-                $githubData['repo']['name']
-            );
-        } else if ($githubData['payload']['ref_type'] == 'repository') {
-            $message = sprintf(
-                'Created %s %s.',
-                $githubData['payload']['ref_type'],
-                $githubData['repo']['name']
-            );
-            $messageLong = sprintf(
-                '<p>Created %s <a href="%s" target="_blank" title="Github | %s">%s</a>.</p>',
-                $githubData['payload']['ref_type'],
-                "https://github.com/{$githubData['repo']['name']}",
-                $githubData['repo']['name'],
-                $githubData['repo']['name']
-            );
-        } else {
-            continue;
-        }
-    } else if ($github['type'] == 'ForkEvent') {
-        $message = sprintf(
-            'Forked %s to %s',
-            $githubData['repo']['name'],
-            $githubData['payload']['forkee']['full_name']
-        );
-        $messageLong = sprintf(
-            '<p>Forked <a href="%s" target="_blank" title="Github | %s">%s</a> to <a href="%s" target="_blank" title="Github | %s">%s</a>.',
-            "https://github.com/{$githubData['repo']['name']}",
-            $githubData['repo']['name'],
-            $githubData['repo']['name'],
-            $githubData['payload']['forkee']['html_url'],
-            $githubData['payload']['forkee']['full_name'],
-            $githubData['payload']['forkee']['full_name']
-        );
-    } else if ($github['type'] == 'PullRequestEvent') {
-        $message = sprintf(
-            '%s a pull request at %s',
-            ucwords($githubData['payload']['action']),
-            $githubData['repo']['name']
-        );
-        $messageLong = sprintf(
-            '<p>%s pull request <a href="%s" target="_blank" title="Github | %s PR %d">%d</a> at <a href="%s" target="_blank" title="Github | %s">%s</a>.</p>',
-            ucwords($githubData['payload']['action']),
-            $githubData['payload']['pull_request']['html_url'],
-            $githubData['repo']['name'],
-            $githubData['payload']['number'],
-            $githubData['payload']['number'],
-            "https://github.com/{$githubData['repo']['name']}",
-            $githubData['repo']['name'],
-            $githubData['repo']['name']
-        );
-    } else if ($github['type'] == 'PushEvent') {
-        $message = sprintf(
-            'Pushed some code at %s.',
-            $githubData['repo']['name']
-        );
-        $messageLong = sprintf(
-            "<p>Pushed some code at <a href=\"%s\" target=\"_blank\" title=\"Github | %s\">%s</a>.</p>\n",
-            $githubData['payload']['ref'],
-            "https://github.com/{$githubData['repo']['name']}",
-            $githubData['repo']['name'],
-            $githubData['repo']['name']
-        );
-        $messageLong .= "<ul>\n";
-        foreach ($githubData['payload']['commits'] as $commit) {
-            $messageShort = $commit['message'];
-            $messageShort = strtok($messageShort, "\n");
-            if (strlen($messageShort) > 72) {
-                $messageShort = wordwrap($messageShort, 65);
-                $messageShort = strtok($messageShort, "\n");
-                $messageShort .= '...';
-            }
-            $messageLong .= sprintf(
-                "<li><a href=\"%s\" target=\"_blank\" title=\"Github | %s\">%s</a> %s.</p>\n",
-                "https://github.com/{$githubData['repo']['name']}/commit/{$commit['sha']}",
-                substr($commit['sha'], 0, 7),
-                substr($commit['sha'], 0, 7),
-                $messageShort
-            );
-        }
-        $messageLong .= "</ul>";
-    }
-
-    $activityRepository->insertActivity(
-        $message,
-        $messageLong,
-        (new DateTime($github['datetime'])),
-        [],
-        'git',
-        $github['id']
-    );
+	$uniqueGithubCheck = $activityRepository->getActivityByTypeId('git', $github['id']);
+	if ($uniqueGithubCheck !== false) {
+		continue;
+	}
+
+	$githubData = json_decode($github['metadata'], true);
+
+	if ($github['type'] == 'CreateEvent') {
+		if (
+			$githubData['payload']['ref_type'] == 'branch' ||
+			$githubData['payload']['ref_type'] == 'tag'
+		) {
+			$message = sprintf(
+				'Created %s %s at %s.',
+				$githubData['payload']['ref_type'],
+				$githubData['payload']['ref'],
+				$githubData['repo']['name']
+			);
+			$messageLong = sprintf(
+				'<p>Created %s %s at <a href="%s" target="_blank" title="Github | %s">%s</a>.</p>',
+				$githubData['payload']['ref_type'],
+				$githubData['payload']['ref'],
+				"https://github.com/{$githubData['repo']['name']}",
+				$githubData['repo']['name'],
+				$githubData['repo']['name']
+			);
+		} else if ($githubData['payload']['ref_type'] == 'repository') {
+			$message = sprintf(
+				'Created %s %s.',
+				$githubData['payload']['ref_type'],
+				$githubData['repo']['name']
+			);
+			$messageLong = sprintf(
+				'<p>Created %s <a href="%s" target="_blank" title="Github | %s">%s</a>.</p>',
+				$githubData['payload']['ref_type'],
+				"https://github.com/{$githubData['repo']['name']}",
+				$githubData['repo']['name'],
+				$githubData['repo']['name']
+			);
+		} else {
+			continue;
+		}
+	} else if ($github['type'] == 'ForkEvent') {
+		$message = sprintf(
+			'Forked %s to %s',
+			$githubData['repo']['name'],
+			$githubData['payload']['forkee']['full_name']
+		);
+		$messageLong = sprintf(
+			'<p>Forked <a href="%s" target="_blank" title="Github | %s">%s</a> to <a href="%s" target="_blank" title="Github | %s">%s</a>.',
+			"https://github.com/{$githubData['repo']['name']}",
+			$githubData['repo']['name'],
+			$githubData['repo']['name'],
+			$githubData['payload']['forkee']['html_url'],
+			$githubData['payload']['forkee']['full_name'],
+			$githubData['payload']['forkee']['full_name']
+		);
+	} else if ($github['type'] == 'PullRequestEvent') {
+		$message = sprintf(
+			'%s a pull request at %s',
+			ucwords($githubData['payload']['action']),
+			$githubData['repo']['name']
+		);
+		$messageLong = sprintf(
+			'<p>%s pull request <a href="%s" target="_blank" title="Github | %s PR %d">%d</a> at <a href="%s" target="_blank" title="Github | %s">%s</a>.</p>',
+			ucwords($githubData['payload']['action']),
+			$githubData['payload']['pull_request']['html_url'],
+			$githubData['repo']['name'],
+			$githubData['payload']['number'],
+			$githubData['payload']['number'],
+			"https://github.com/{$githubData['repo']['name']}",
+			$githubData['repo']['name'],
+			$githubData['repo']['name']
+		);
+	} else if ($github['type'] == 'PushEvent') {
+		$message = sprintf(
+			'Pushed some code at %s.',
+			$githubData['repo']['name']
+		);
+		$messageLong = sprintf(
+			"<p>Pushed some code at <a href=\"%s\" target=\"_blank\" title=\"Github | %s\">%s</a>.</p>\n",
+			$githubData['payload']['ref'],
+			"https://github.com/{$githubData['repo']['name']}",
+			$githubData['repo']['name'],
+			$githubData['repo']['name']
+		);
+		$messageLong .= "<ul>\n";
+		foreach ($githubData['payload']['commits'] as $commit) {
+			$messageShort = $commit['message'];
+			$messageShort = strtok($messageShort, "\n");
+			if (strlen($messageShort) > 72) {
+				$messageShort = wordwrap($messageShort, 65);
+				$messageShort = strtok($messageShort, "\n");
+				$messageShort .= '...';
+			}
+			$messageLong .= sprintf(
+				"<li><a href=\"%s\" target=\"_blank\" title=\"Github | %s\">%s</a> %s.</p>\n",
+				"https://github.com/{$githubData['repo']['name']}/commit/{$commit['sha']}",
+				substr($commit['sha'], 0, 7),
+				substr($commit['sha'], 0, 7),
+				$messageShort
+			);
+		}
+		$messageLong .= "</ul>";
+	}
+
+	$activityRepository->insertActivity(
+		$message,
+		$messageLong,
+		(new DateTime($github['datetime'])),
+		[],
+		'git',
+		$github['id']
+	);
 }
 
 // books
@@ -284,46 +284,46 @@ 
 
 $lastGoodreadActivity = $activityRepository->getActivityLastUpdateByType('book');
 if ($lastGoodreadActivity === false) {
-    $lastGoodreadActivityDateTime = new DateTime('2010-08-28');
+	$lastGoodreadActivityDateTime = new DateTime('2010-08-28');
 } else {
-    $lastGoodreadActivityDateTime = new DateTime($lastGoodreadActivity['updated_at']);
-    $lastGoodreadActivityDateTime->modify('-5 days');
+	$lastGoodreadActivityDateTime = new DateTime($lastGoodreadActivity['updated_at']);
+	$lastGoodreadActivityDateTime->modify('-5 days');
 }
 $newGoodreadActivity = $goodreadRepository->getGoodreadsUpdatedSince($lastGoodreadActivityDateTime);
 foreach ($newGoodreadActivity as $goodread) {
-    $uniqueGoodreadCheck = $activityRepository->getActivityByTypeId('book', $goodread['id']);
-    if ($uniqueGoodreadCheck !== false) {
-        continue;
-    }
-
-    $goodreadData = json_decode($goodread['metadata'], true);
-
-    if (empty($goodreadData['user_read_at'])) {
-        continue;
-    }
-
-    $message = sprintf(
-        'Read %s by %s.',
-        $goodreadData['title'],
-        $goodreadData['author_name']
-    );
-    if (isset($goodreadData['book_large_image_url'])) {
-        $messageLong = sprintf(
-            "<img alt=\"Goodreads | %s\" src=\"%s\" />\n",
-            $goodreadData['title'],
-            $goodreadData['book_large_image_url']
-        );
-    }
-    $messageLong .= "<p>{$message}</p>";
-
-    $activityRepository->insertActivity(
-        $message,
-        $messageLong,
-        (new DateTime($goodread['datetime'])),
-        [],
-        'book',
-        $goodread['id']
-    );
+	$uniqueGoodreadCheck = $activityRepository->getActivityByTypeId('book', $goodread['id']);
+	if ($uniqueGoodreadCheck !== false) {
+		continue;
+	}
+
+	$goodreadData = json_decode($goodread['metadata'], true);
+
+	if (empty($goodreadData['user_read_at'])) {
+		continue;
+	}
+
+	$message = sprintf(
+		'Read %s by %s.',
+		$goodreadData['title'],
+		$goodreadData['author_name']
+	);
+	if (isset($goodreadData['book_large_image_url'])) {
+		$messageLong = sprintf(
+			"<img alt=\"Goodreads | %s\" src=\"%s\" />\n",
+			$goodreadData['title'],
+			$goodreadData['book_large_image_url']
+		);
+	}
+	$messageLong .= "<p>{$message}</p>";
+
+	$activityRepository->insertActivity(
+		$message,
+		$messageLong,
+		(new DateTime($goodread['datetime'])),
+		[],
+		'book',
+		$goodread['id']
+	);
 }
 
 // twitter
@@ -332,118 +332,118 @@ 
 
 $lastTwitterActivity = $activityRepository->getActivityLastUpdateByType('twitter');
 if ($lastTwitterActivity === false) {
-    $lastTwitterActivityDateTime = new DateTime('2010-03-10');
+	$lastTwitterActivityDateTime = new DateTime('2010-03-10');
 } else {
-    $lastTwitterActivityDateTime = new DateTime($lastTwitterActivity['updated_at']);
-    $lastTwitterActivityDateTime->modify('-5 days');
+	$lastTwitterActivityDateTime = new DateTime($lastTwitterActivity['updated_at']);
+	$lastTwitterActivityDateTime->modify('-5 days');
 }
 $newTwitterActivity = $twitterRepository->getTwittersUpdatedSince($lastTwitterActivityDateTime);
 foreach ($newTwitterActivity as $twitter) {
-    $twitterData = json_decode($twitter['metadata'], true);
-
-    $uniqueTwitterCheck = $activityRepository->getActivityByTypeId('twitter', $twitter['id']);
-    if ($uniqueTwitterCheck !== false) {
-        $metadata = [];
-        if ($twitterData['favorite_count'] > 0) {
-            $metadata['favorites'] = $twitterData['favorite_count'];
-        }
-        if ($twitterData['retweet_count'] > 0) {
-            $metadata['retweets'] = $twitterData['retweet_count'];
-        }
-
-        $activityRepository->updateActivityMetadata($twitter['id'], $metadata);
-        continue;
-    }
-
-    if (
-        ($twitterData['in_reply_to_user_id'] != null || substr($twitterData['text'], 0, 1) === '@') &&
-        $twitterData['favorite_count'] == 0 &&
-        $twitterData['retweet_count'] == 0
-    ) {
-        continue;
-    }
-
-    $message = "Tweeted | {$twitterData['text']}";
-    $message = trim(preg_replace('/\s+/', ' ', $message));
-    $message = mb_convert_encoding($message, 'HTML-ENTITIES', 'UTF-8');
-
-    $entityHolder = [];
-    foreach ($twitterData['entities'] as $entityType => $entities) {
-        foreach ($entities as $entity) {
-            if ($entityType == 'hashtags') {
-                $replace = sprintf(
-                    '<a href="https://twitter.com/search?q=%%23%s&src=hash" rel="nofollow" target="_blank">#%s</a>',
-                    $entity['text'],
-                    $entity['text']
-                );
-            } else if ($entityType == 'urls') {
-                $replace = sprintf(
-                    '<a href="%s" rel="nofollow" target="_blank" title="%s">%s</a>',
-                    $entity['url'],
-                    $entity['expanded_url'],
-                    $entity['display_url']
-                );
-            } else if ($entityType == 'user_mentions') {
-                $replace = sprintf(
-                    '<a href="https://twitter.com/%s" rel="nofollow" target="_blank" title="Twitter | %s">@%s</a>',
-                    strtolower($entity['screen_name']),
-                    $entity['name'],
-                    $entity['screen_name']
-                );
-            } else if ($entityType == 'media') {
-                $replace = sprintf(
-                    "<a href=\"%s\" rel=\"nofollow\" target=\"_blank\" title=\"%s\">\n" .
-                    "<img src=\"%s:%s\" alt=\"%s\" height=\"%s\" width=\"%s\" />\n" .
-                    "</a>",
-                    $entity['url'],
-                    $entity['display_url'],
-                    $entity['media_url'],
-                    'large',
-                    $entity['display_url'],
-                    $entity['sizes']['large']['h'],
-                    $entity['sizes']['large']['w']
-                );
-            } else {
-                continue 2;
-            }
-
-            $entityHolder[$entity['indices'][0]] = [
-                'start' => $entity['indices'][0],
-                'end' => $entity['indices'][1],
-                'replace' => $replace,
-            ];
-        }
-    }
-
-    $messageLong = $twitterData['text'];
-    krsort($entityHolder);
-    foreach($entityHolder as $entity)
-    {
-        $messageLong =
-            mb_substr($messageLong, 0, $entity['start']) .
-            $entity['replace'] .
-            mb_substr($messageLong, $entity['end'], null, 'UTF-8');
-    }
-    $messageLong = mb_convert_encoding($messageLong, 'HTML-ENTITIES', 'UTF-8');
-    $messageLong = nl2br($messageLong, true);
-    $messageLong = "<p>{$messageLong}</p>";
-
-    $metadata = [];
-    if ($twitterData['favorite_count'] > 0) {
-        $metadata['favorites'] = $twitterData['favorite_count'];
-    }
-    if ($twitterData['retweet_count'] > 0) {
-        $metadata['retweets'] = $twitterData['retweet_count'];
-    }
-
-    $activityRepository->insertActivity(
-        $message,
-        $messageLong,
-        (new DateTime($twitter['datetime'])),
-        $metadata,
-        'twitter',
-        $twitter['id']
-    );
+	$twitterData = json_decode($twitter['metadata'], true);
+
+	$uniqueTwitterCheck = $activityRepository->getActivityByTypeId('twitter', $twitter['id']);
+	if ($uniqueTwitterCheck !== false) {
+		$metadata = [];
+		if ($twitterData['favorite_count'] > 0) {
+			$metadata['favorites'] = $twitterData['favorite_count'];
+		}
+		if ($twitterData['retweet_count'] > 0) {
+			$metadata['retweets'] = $twitterData['retweet_count'];
+		}
+
+		$activityRepository->updateActivityMetadata($twitter['id'], $metadata);
+		continue;
+	}
+
+	if (
+		($twitterData['in_reply_to_user_id'] != null || substr($twitterData['text'], 0, 1) === '@') &&
+		$twitterData['favorite_count'] == 0 &&
+		$twitterData['retweet_count'] == 0
+	) {
+		continue;
+	}
+
+	$message = "Tweeted | {$twitterData['text']}";
+	$message = trim(preg_replace('/\s+/', ' ', $message));
+	$message = mb_convert_encoding($message, 'HTML-ENTITIES', 'UTF-8');
+
+	$entityHolder = [];
+	foreach ($twitterData['entities'] as $entityType => $entities) {
+		foreach ($entities as $entity) {
+			if ($entityType == 'hashtags') {
+				$replace = sprintf(
+					'<a href="https://twitter.com/search?q=%%23%s&src=hash" rel="nofollow" target="_blank">#%s</a>',
+					$entity['text'],
+					$entity['text']
+				);
+			} else if ($entityType == 'urls') {
+				$replace = sprintf(
+					'<a href="%s" rel="nofollow" target="_blank" title="%s">%s</a>',
+					$entity['url'],
+					$entity['expanded_url'],
+					$entity['display_url']
+				);
+			} else if ($entityType == 'user_mentions') {
+				$replace = sprintf(
+					'<a href="https://twitter.com/%s" rel="nofollow" target="_blank" title="Twitter | %s">@%s</a>',
+					strtolower($entity['screen_name']),
+					$entity['name'],
+					$entity['screen_name']
+				);
+			} else if ($entityType == 'media') {
+				$replace = sprintf(
+					"<a href=\"%s\" rel=\"nofollow\" target=\"_blank\" title=\"%s\">\n" .
+					"<img src=\"%s:%s\" alt=\"%s\" height=\"%s\" width=\"%s\" />\n" .
+					"</a>",
+					$entity['url'],
+					$entity['display_url'],
+					$entity['media_url'],
+					'large',
+					$entity['display_url'],
+					$entity['sizes']['large']['h'],
+					$entity['sizes']['large']['w']
+				);
+			} else {
+				continue 2;
+			}
+
+			$entityHolder[$entity['indices'][0]] = [
+				'start' => $entity['indices'][0],
+				'end' => $entity['indices'][1],
+				'replace' => $replace,
+			];
+		}
+	}
+
+	$messageLong = $twitterData['text'];
+	krsort($entityHolder);
+	foreach($entityHolder as $entity)
+	{
+		$messageLong =
+			mb_substr($messageLong, 0, $entity['start']) .
+			$entity['replace'] .
+			mb_substr($messageLong, $entity['end'], null, 'UTF-8');
+	}
+	$messageLong = mb_convert_encoding($messageLong, 'HTML-ENTITIES', 'UTF-8');
+	$messageLong = nl2br($messageLong, true);
+	$messageLong = "<p>{$messageLong}</p>";
+
+	$metadata = [];
+	if ($twitterData['favorite_count'] > 0) {
+		$metadata['favorites'] = $twitterData['favorite_count'];
+	}
+	if ($twitterData['retweet_count'] > 0) {
+		$metadata['retweets'] = $twitterData['retweet_count'];
+	}
+
+	$activityRepository->insertActivity(
+		$message,
+		$messageLong,
+		(new DateTime($twitter['datetime'])),
+		$metadata,
+		'twitter',
+		$twitter['id']
+	);
 }
 
 // youtube
@@ -452,39 +452,39 @@ 
 
 $lastYouTubeActivity = $activityRepository->getActivityLastUpdateByType('youtube');
 if ($lastYouTubeActivity === false) {
-    $lastYouTubeActivityDateTime = new DateTime('2010-08-28');
+	$lastYouTubeActivityDateTime = new DateTime('2010-08-28');
 } else {
-    $lastYouTubeActivityDateTime = new DateTime($lastYouTubeActivity['updated_at']);
-    $lastYouTubeActivityDateTime->modify('-5 days');
+	$lastYouTubeActivityDateTime = new DateTime($lastYouTubeActivity['updated_at']);
+	$lastYouTubeActivityDateTime->modify('-5 days');
 }
 $newYouTubeActivity = $youTubeRepository->getYouTubesUpdatedSince($lastYouTubeActivityDateTime);
 foreach ($newYouTubeActivity as $youTube) {
-    $uniqueYouTubeCheck = $activityRepository->getActivityByTypeId('youtube', $youTube['id']);
-    if ($uniqueYouTubeCheck !== false) {
-        continue;
-    }
-
-    $youTubeData = json_decode($youTube['metadata'], true);
-
-    $message = sprintf(
-        'Favorited %s on YouTube.',
-        $youTubeData['snippet']['title']
-    );
-    $messageLong = sprintf(
-        "<iframe src=\"%s\" frameborder=\"0\" allowfullscreen></iframe>\n" .
-        "<p>Favorited <a href=\"%s\" target=\"_blank\" title=\"YouTube | %s\">%s</a> on YouTube.</p>",
-        "https://www.youtube.com/embed/{$youTubeData['contentDetails']['videoId']}",
-        "https://youtu.be/{$youTubeData['contentDetails']['videoId']}",
-        $youTubeData['snippet']['title'],
-        $youTubeData['snippet']['title']
-    );
-
-    $activityRepository->insertActivity(
-        $message,
-        $messageLong,
-        (new DateTime($youTube['datetime'])),
-        [],
-        'youtube',
-        $youTube['id']
-    );
+	$uniqueYouTubeCheck = $activityRepository->getActivityByTypeId('youtube', $youTube['id']);
+	if ($uniqueYouTubeCheck !== false) {
+		continue;
+	}
+
+	$youTubeData = json_decode($youTube['metadata'], true);
+
+	$message = sprintf(
+		'Favorited %s on YouTube.',
+		$youTubeData['snippet']['title']
+	);
+	$messageLong = sprintf(
+		"<iframe src=\"%s\" frameborder=\"0\" allowfullscreen></iframe>\n" .
+		"<p>Favorited <a href=\"%s\" target=\"_blank\" title=\"YouTube | %s\">%s</a> on YouTube.</p>",
+		"https://www.youtube.com/embed/{$youTubeData['contentDetails']['videoId']}",
+		"https://youtu.be/{$youTubeData['contentDetails']['videoId']}",
+		$youTubeData['snippet']['title'],
+		$youTubeData['snippet']['title']
+	);
+
+	$activityRepository->insertActivity(
+		$message,
+		$messageLong,
+		(new DateTime($youTube['datetime'])),
+		[],
+		'youtube',
+		$youTube['id']
+	);
 }