jacobemerick / web

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/Goodread/MysqlGoodreadRepository.php

Indentation +51 added lines, -51 removed lines

@@ -8,76 +8,76 @@
 class MysqlGoodreadRepository implements GoodreadRepositoryInterface
 {
 
-    /** @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 getReviews($limit = null, $offset = 0)
-    {
-        $query = "
+	/**
+	 * @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 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),
-        ];
+		$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);
-    }
+		return $this
+			->connections
+			->getWrite()
+			->perform($query, $bindings);
+	}
 }