Popstas\Transmission\Console\WeburgClient

Complexity

Total Complexity

30

Size/Duplication

Total Lines	202
Duplicated Lines	2.97 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes	5
Bugs	1	Features	1

15 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	getUrlBody()	3	18	2
A	downloadTorrent()	3	19	2
A	cleanMovieId()	0	9	3
A	getMovieInfoById()	0	8	1
A	getMovieTorrentUrlsById()	0	7	1
A	getSeriesTorrents()	0	18	3
A	getMoviesIds()	0	16	1
A	getMovieUrl()	0	4	1
A	isTorrentPopular()	0	7	4
A	getMovieTorrentUrl()	0	6	2
B	getMovieInfo()	0	22	4
A	checkTorrentDate()	0	10	3
A	getInfoUrls()	0	6	1
A	getTorrentsUrls()	0	7	1

<?php

namespace Popstas\Transmission\Console;

use GuzzleHttp\ClientInterface;
use GuzzleHttp\Cookie\CookieJar;

class WeburgClient
{
    /**
     * @var ClientInterface
     */
    private $httpClient;

    public function __construct(ClientInterface $httpClient)
    {
        $this->httpClient = $httpClient;
    }

    public function getMovieInfoById($movieId)
    {
        $movieUrl = $this->getMovieUrl($movieId);
        $body = $this->getUrlBody($movieUrl);
        $body = iconv('WINDOWS-1251', 'UTF-8', $body);
        $info = $this->getMovieInfo($body);
        return $info;
    }

    /**
     * @param $movieId
     * @return array urls of movie (not series)
     */
    public function getMovieTorrentUrlsById($movieId)
    {
        $torrentUrl = $this->getMovieTorrentUrl($movieId);
        $body = $this->getUrlBody($torrentUrl);
        $torrentsUrls = $this->getTorrentsUrls($body);
        return $torrentsUrls;
    }

    /**
     * @param $movieId
     * @param $hashes array hashes of torrents from movieInfo
     * @param int $daysMax torrents older last days will not matched
     * @return array urls of matched torrent files
     */
    public function getSeriesTorrents($movieId, $hashes, $daysMax = 1)
    {
        $torrentsUrls = [];
        $timestampFrom = strtotime('-' . $daysMax . 'days');

        $hashes = array_reverse($hashes);
        foreach ($hashes as $hash) {
            $torrentUrl = $this->getMovieTorrentUrl($movieId, $hash);
            $body = $this->getUrlBody($torrentUrl);

            if (!$this->checkTorrentDate($body, $timestampFrom)) {
                break;
            }
            $torrentsUrls = array_merge($torrentsUrls, $this->getTorrentsUrls($body));
        }

        return $torrentsUrls;
    }

    public function getMoviesIds()
    {
        $moviesUrl = 'http://weburg.net/movies/new/?clever_title=1&template=0&last=0';

        $jsonRaw = $this->getUrlBody($moviesUrl, [
            'Content-Type'     => 'text/html; charset=utf-8',
            'User-Agent'       => 'Mozilla/5.0 (X11; Ubuntu; Linux x86_64; rv:27.0) Gecko/20100101 Firefox/27.0',
            'X-Requested-With' => 'XMLHttpRequest',
        ]);

        $moviesJson = json_decode($jsonRaw);

        $moviesIds = $this->getInfoUrls($moviesJson->items);

        return $moviesIds;
    }

    public function getMovieUrl($movieId)
    {
        return 'http://weburg.net/movies/info/' . $movieId;
    }

    public function getUrlBody($url, $headers = [])
    {
        $jar = new CookieJar();

        $res = $this->httpClient->request('GET', $url, [
            'headers' => $headers,
            'cookies' => $jar,
        ]);

        // TODO: it should return 200 or not 200 code, never 0
        if ($res->getStatusCode() != 200) {

This code seems to be duplicated across your project.

            throw new \RuntimeException('Error ' . $res->getStatusCode() . 'while get url ' . $url);
        }

        $body = $res->getBody();

        return $body;
    }

    public function isTorrentPopular($movieInfo, $commentsMin, $imdbMin, $kinopoiskMin, $votesMin)
    {
        return $movieInfo['comments'] >= $commentsMin
        || $movieInfo['rating_imdb'] >= $imdbMin
        || $movieInfo['rating_kinopoisk'] >= $kinopoiskMin
        || $movieInfo['rating_votes'] >= $votesMin;
    }

    public function downloadTorrent($url, $torrentsDir)
    {
        $jar = new CookieJar();

        $res = $this->httpClient->request('GET', $url, ['cookies' => $jar]);

        if ($res->getStatusCode() != 200) {

This code seems to be duplicated across your project.

            throw new \RuntimeException('Error ' . $res->getStatusCode() . 'while get url ' . $url);
        }

        $torrentBody = $res->getBody();

        $disposition = $res->getHeader('content-disposition');
        preg_match('/filename="(.*?)"/', $disposition[0], $res);
        $filename = $res[1];

        $filePath = $torrentsDir . '/' . $filename;
        file_put_contents($filePath, $torrentBody);
    }

    public function cleanMovieId($idOrUrl)
    {
        if (preg_match('/^\d+$/', $idOrUrl)) {
            return $idOrUrl;
        }
        preg_match('/^http:\/\/weburg\.net\/(series|movies)\/info\/(\d+)$/', $idOrUrl, $res);
        $movieId = count($res) ? $res[2] : null;
        return $movieId;
    }

    private function getMovieTorrentUrl($movieId, $hash = '')
    {
        return 'http://weburg.net/ajax/download/movie?'
        . ($hash ? 'hash=' . $hash . '&' : '')
        . 'obj_id=' . $movieId;
    }

    private function getMovieInfo($body)
    {
        $info = [];

        $checks = [
            'title'            => '<title>(.*?) — Weburg<\/title>',
            'comments'         => 'Комментариев:&nbsp;(\d+)',
            'rating_kinopoisk' => 'external-ratings-link_type_kinopoisk.*?>(\d+\.\d+)',
            'rating_imdb'      => 'external-ratings-link_type_imdb.*?>(\d+\.\d+)',
            'rating_votes'     => 'count-votes" value="([0-9]+)"',
        ];

        foreach ($checks as $name => $regexp) {
            preg_match('/' . $regexp . '/mis', $body, $res);
            $info[$name] = count($res) ? $res[1] : null;
        }

        preg_match_all('/js-search-button.*?hash="(.*?)"/mis', $body, $res);
        $info['hashes'] = count($res) ? $res[1] : null;

        return $info;
    }

    /**
     * @param $body
     * @param $fromTimestamp
     * @return bool|string date if matched, false if not
     */
    private function checkTorrentDate($body, $fromTimestamp)
    {
        preg_match('/(\d{2})\.(\d{2})\.(\d{4})/mis', $body, $res);
        if (empty($res)) {
            return false;
        }

        $torrentTimestamp = mktime(0, 0, 0, $res[2], $res[1], $res[3]);
        return $torrentTimestamp >= $fromTimestamp ? $res[0] : false;
    }

    private function getInfoUrls($body)
    {
        preg_match_all('/\/movies\/info\/([0-9]+)/', $body, $res);
        $moviesIds = array_unique($res[1]);
        return $moviesIds;
    }

    /**
     * @param $body
     * @return array
     */
    private function getTorrentsUrls($body)
    {
        preg_match_all('/(http:\/\/.*?gettorrent.*?)"/', $body, $res);
        $torrentsUrls = $res[1];
        $torrentsUrls = array_unique($torrentsUrls);
        return $torrentsUrls;
    }
}