jacobemerick / web

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

script/cron/build-activity-stream.php

Indentation +148 added lines, -148 removed lines

@@ -11,44 +11,44 @@ 
 
 $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: <a href="%s" title="Jacob Emerick\'s Blog | %s">%s</a>.',
-        str_replace('-', ' ', $blogData['category']),
-        $blogData['link'],
-        $blogData['title'],
-        $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: <a href="%s" title="Jacob Emerick\'s Blog | %s">%s</a>.',
+		str_replace('-', ' ', $blogData['category']),
+		$blogData['link'],
+		$blogData['title'],
+		$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;
@@ -56,30 +56,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
@@ -88,67 +88,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']
+	);
 }
 
 // books
@@ -157,46 +157,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(
-        'Just finished reading %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(
+		'Just finished reading %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']
+	);
 }