flox/backend/app/Services/FileParser.php

<?php

  namespace App\Services;

  use App\AlternativeTitle;
  use App\Episode;
  use App\Item;
  use Illuminate\Database\Eloquent\Collection;

  class FileParser {

    private $item;
    private $episode;
    private $tmdb;
    private $storage;
    private $alternativeTitle;
    private $itemCategory;

    public function __construct(Item $item, Episode $episode, TMDB $tmdb, Storage $storage, AlternativeTitle $alternativeTitle)
    {
      $this->item = $item;
      $this->episode = $episode;
      $this->tmdb = $tmdb;
      $this->storage = $storage;
      $this->alternativeTitle = $alternativeTitle;
    }

    /**
     * Make a request to flox-file-parser and get local files data.
     *
     * @return array
     */
    public function fetch()
    {
      return json_decode(
        file_get_contents(base_path('tests/fixtures/Files/all.json'))
      );
    }

    /**
     * Loop over local files and see if it can find them in database. Otherwise search in TMDb.
     *
     * @param $files
     */
    public function store($files)
    {
      foreach($files as $type => $items) {
        $this->itemCategory = $type;

        foreach($items as $item) {
          $title = $item->name;

          // See if file is already in our database.
          if($found = $this->foundInDatabase($title, 'title')) {
            $this->handleStatus($item, $found->tmdb_id);

            continue;
          }

          // Otherwise make a new TMDb request.
          $this->tmdbSearch($title, $item);
        }
      }
    }

    /**
     * Make a new request to TMDb and check against the database. Otherwise create a new item.
     *
     * @param $title
     * @param $item
     * @return bool|\Exception|mixed
     */
    private function tmdbSearch($title, $item)
    {
      $result = $this->tmdb->search($title);

      if( ! $result) {
        return false;
      }

      return $this->findOrCreateItem($result[0], $item);
    }

    /**
     * Check tmdb_id against the database or create a new item.
     *
     * @param $firstResult
     * @param $item
     * @return \Exception|mixed
     */
    private function findOrCreateItem($firstResult, $item)
    {
      $tmdbId = $firstResult['tmdb_id'];

      // Check against our database.
      if($this->foundInDatabase($tmdbId, 'tmdb_id')) {
        return $this->handleStatus($item, $tmdbId);
      }

      // Otherwise create a new item from the result.
      $created = $this->item->store($firstResult, $this->tmdb, $this->storage, $this->episode, $this->alternativeTitle);

      return $this->handleStatus($item, $created->tmdb_id);
    }

    /**
     * See if we can find a item by title or tmdb_id in our database.
     *
     * @param $indicator
     * @return Collection
     */
    public function foundInDatabase($value, $type)
    {
      if($type == 'title') {
        return $this->item->findByTitle($value)->first();
      }

      return $this->item->findByTmdbId($value)->first();
    }

    /**
     * Check which status the file has.
     * Create new src if the status is 'added'.
     * Update src if status is 'updated'.
     * Remove src if status is 'removed'.
     *
     * @param $item
     * @param $tmdb_id
     * @return mixed
     */
    public function handleStatus($item, $tmdbId)
    {
      if($item->status == 'added') {
        return $this->storeSrc($item, $tmdbId);
      }
    }

    /**
     * Store src from local file into items for movies or episodes for tv shows.
     *
     * @param $item
     * @param $tmdb_id
     */
    private function storeSrc($item, $tmdbId)
    {
      if($this->itemCategory == 'tv') {
        $model = $this->episode->findEpisode($tmdbId, $item);
      } else {
        $model = $this->item->findByTmdbId($tmdbId);
      }

      return $model->update([
        'src' => $item->src,
      ]);
    }
  }