jacobemerick / web

src/Domain/Stream/YouTube/MysqlYouTubeRepository.php

Indentation +65 added lines, -65 removed lines

@@ -8,95 +8,95 @@
 class MysqlYouTubeRepository implements YouTubeRepositoryInterface
 {
 
-    /** @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;
+	}
 
-    public function getYouTubes($limit = null, $offset = 0)
-    {
-        $query = "
+	public function getYouTubes($limit = null, $offset = 0)
+	{
+		$query = "
             SELECT `id`, `video_id`, `datetime`
             FROM `jpemeric_stream`.`youtube`
             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 $id
-     *
-     * @return array|false
-     */
-    public function getYouTubeById($id)
-    {
-        $query = "
+	/**
+	 * @param integer $id
+	 *
+	 * @return array|false
+	 */
+	public function getYouTubeById($id)
+	{
+		$query = "
             SELECT *
             FROM `jpemeric_stream`.`youtube`
             WHERE `id` = :id
             LIMIT 1";
-        $bindings = [
-            'id' => $id,
-        ];
+		$bindings = [
+			'id' => $id,
+		];
 
-        return $this
-            ->connections
-            ->getRead()
-            ->fetchOne($query, $bindings);
-    }
+		return $this
+			->connections
+			->getRead()
+			->fetchOne($query, $bindings);
+	}
 
-    /**
-     * @param string $title
-     *
-     * @return array|false
-     */
-    public function getYouTubeByVideoId($videoId)
-    {
-        $query = "
+	/**
+	 * @param string $title
+	 *
+	 * @return array|false
+	 */
+	public function getYouTubeByVideoId($videoId)
+	{
+		$query = "
             SELECT *
             FROM `jpemeric_stream`.`youtube`
             WHERE `video_id` = :video_id
             LIMIT 1";
-        $bindings = [
-            'video_id' => $videoId,
-        ];
+		$bindings = [
+			'video_id' => $videoId,
+		];
 
-        return $this
-            ->connections
-            ->getRead()
-            ->fetchOne($query, $bindings);
-    }
+		return $this
+			->connections
+			->getRead()
+			->fetchOne($query, $bindings);
+	}
 
-    public function insertVideo($videoId, DateTime $datetime, array $metadata)
-    {
-        $query = "
+	public function insertVideo($videoId, DateTime $datetime, array $metadata)
+	{
+		$query = "
             INSERT INTO `jpemeric_stream`.`youtube`
                 (`video_id`, `datetime`, `metadata`)
             VALUES
                 (:video_id, :datetime, :metadata)";
 
-        $bindings = [
-            'video_id' => $videoId,
-            'datetime' => $datetime->format('Y-m-d H:i:s'),
-            'metadata' => json_encode($metadata),
-        ];
+		$bindings = [
+			'video_id' => $videoId,
+			'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/YouTube/YouTubeRepositoryInterface.php

Indentation +2 added lines, -2 removed lines

@@ -4,6 +4,6 @@
 
 interface YouTubeRepositoryInterface
 {
-    public function getYouTubeById($id);
-    public function getYouTubeByVideoId($videoId);
+	public function getYouTubeById($id);
+	public function getYouTubeByVideoId($videoId);
 }

script/cron/fetch-youtube-activity.php

Indentation +19 added lines, -19 removed lines

@@ -16,23 +16,23 @@
 $playlist = $client->getPlaylistItemsByPlaylistId($config->youtube->favorites_playlist, 10);
 
 foreach ($playlist as $playlistItem) {
-    $datetime = new DateTime($playlistItem->snippet->publishedAt);
-    if ($datetime <= $mostRecentVideoDateTime) {
-        break;
-    }
-
-    $videoId = $playlistItem->contentDetails->videoId;
-    $uniqueVideoCheck = $youTubeRepository->getYouTubeByVideoId($videoId);
-    if ($uniqueVideoCheck !== false) {
-        continue;
-    }
-
-    $datetime->setTimezone($container['default_timezone']);
-    $metadata = json_decode(json_encode($playlistItem), true);
-
-    $youTubeRepository->insertVideo(
-        $videoId,
-        $datetime,
-        $metadata
-    );
+	$datetime = new DateTime($playlistItem->snippet->publishedAt);
+	if ($datetime <= $mostRecentVideoDateTime) {
+		break;
+	}
+
+	$videoId = $playlistItem->contentDetails->videoId;
+	$uniqueVideoCheck = $youTubeRepository->getYouTubeByVideoId($videoId);
+	if ($uniqueVideoCheck !== false) {
+		continue;
+	}
+
+	$datetime->setTimezone($container['default_timezone']);
+	$metadata = json_decode(json_encode($playlistItem), true);
+
+	$youTubeRepository->insertVideo(
+		$videoId,
+		$datetime,
+		$metadata
+	);
 }