* @link https://github.com/fengqi/transmission-rss */ class Transmission { private $server; private $user; private $password; private $session_id; /** * 构造函数, 初始化配置 * * @param $server * @param string $port * @param string $rpcPath * @param string $user * @param string $password * * @return \Transmission */ public function __construct($server, $port = '9091', $rpcPath = '/transmission/rpc', $user = '', $password = '') { $this->server = $server.':'.$port.$rpcPath; $this->user = $user; $this->password = $password; $this->session_id = $this->getSessionId(); } /** * 添加种子, 如果是种子的原始二进制, 需要先进行 base64 编码 * * @param $url * @param bool $isEncode * @param array $options * @return mixed */ public function add($url, $isEncode = false, $options = array()) { return $this->request('torrent-add', array_merge($options, array( $isEncode ? 'metainfo' : 'filename' => $url, ))); } /** * 获取 Transmission 服务器状态 * * @return mixed */ public function status() { return $this->request("session-stats"); } /** * 获取 Transmission session-id, 每次 rpc 请求都需要带上 session-id * * @return string */ public function getSessionId() { $ch = curl_init(); curl_setopt($ch, CURLOPT_URL, $this->server); curl_setopt($ch, CURLOPT_HTTPAUTH, CURLAUTH_BASIC); curl_setopt($ch, CURLOPT_USERPWD, $this->user.':'.$this->password); curl_setopt($ch, CURLOPT_HEADER, false); curl_setopt($ch, CURLOPT_RETURNTRANSFER, true); curl_setopt($ch, CURLOPT_TIMEOUT, 10); $content = curl_exec($ch); curl_close($ch); preg_match("/

(X-Transmission-Session-Id: .*)<\/code>/", $content, $content);
        $this->session_id = isset($content[1]) ? $content[1] : null;

        return $this->session_id;
    }

    /**
     * 执行 rpc 请求
     *
     * @param $method 请求类型/方法, 详见 $this->allowMethods
     * @param array $arguments 附加参数, 可选
     * @return mixed
     */
    private function request($method, $arguments = array())
    {
        $data = array(
            'method' => $method,
            'arguments' => $arguments
        );

        $header = array(
            'Content-Type: application/json',
            'Authorization: Basic '.base64_encode(sprintf("%s:%s", $this->user, $this->password)),
            $this->session_id
        );

        $ch = curl_init();
        curl_setopt($ch, CURLOPT_URL, $this->server);
        curl_setopt($ch, CURLOPT_HTTPHEADER, $header);
        curl_setopt($ch, CURLOPT_HTTPAUTH, CURLAUTH_BASIC);
        curl_setopt($ch, CURLOPT_USERPWD, $this->user.':'.$this->password);
        curl_setopt($ch, CURLOPT_HEADER, false);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
        curl_setopt($ch, CURLOPT_POST, true);
        curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($data));
        curl_setopt($ch, CURLOPT_TIMEOUT, 10);
        $content = curl_exec($ch);
        curl_close($ch);

        if (!$content)  $content = json_encode(array('result' => 'failed'));
        return $content;

    }

    /**
     * 获取 rss 的种子列表
     *
     * @param $rss
     * @return array
     */
    function getRssItems($rss)
    {
        $ch = curl_init();
        curl_setopt($ch, CURLOPT_HEADER, false);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
        curl_setopt($ch, CURLOPT_TIMEOUT, 20);
        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
        curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);

        $items = array();
        foreach ($rss as $link) {
            curl_setopt($ch, CURLOPT_URL, $link);
            $content = curl_exec($ch);
            if (!$content) continue;

            $xml = new DOMDocument();
            $xml->loadXML($content);
            $elements = $xml->getElementsByTagName('item');

            foreach ($elements as $item) {
                $link = $item->getElementsByTagName('enclosure')->item(0) != null ?
                        $item->getElementsByTagName('enclosure')->item(0)->getAttribute('url') :
                        $item->getElementsByTagName('link')->item(0)->nodeValue;

                $guid = $item->getElementsByTagName('guid')->item(0) != null ?
                    $item->getElementsByTagName('guid')->item(0)->nodeValue:
                    md5($link);

                $items[] = array(
                    'title' => $item->getElementsByTagName('title')->item(0)->nodeValue,
                    'link' => $link,
                    'guid' => $guid
                );
            }
        }
        curl_close($ch);

        return $items;
    }
}

// 配置
$rss = array(
    'http://chdbits.org/torrentrss.php...',
    'http://totheglory.im/putrssmc.php...',
    'https://hdcmct.org/torrentrss.php...',
    'https://open.cd/torrentrss.php?.....',
    'https://mv.open.cd/torrentrss.php?..',
    'http://hdwing.com/rss.php?..........',
    'http://hdtime.org/torrentrss.php?...'
);
$server = 'http://127.0.0.1';
$port = 9091;
$rpcPath = '/transmission/rpc';
$user = '';
$password = '';

$stash = '/tmp/fengqi-transmission-rss';
!file_exists($stash) && mkdir($stash, 0777, true);

$trans = new Transmission($server, $port, $rpcPath, $user, $password);
$torrents = $trans->getRssItems($rss);
foreach ($torrents as $torrent) {
    $lock_file = $stash.'/'.base64_encode($torrent['guid']);
    if (file_exists($lock_file)) {
        printf("%s: skip add: %s\n", date('Y-m-d H:i:s'), $torrent['title']);
        continue;
    }

    $response = json_decode($trans->add($torrent['link']));
    if ($response->result == 'success') {
        file_put_contents($lock_file, '1');
        printf("%s: success add: %s\n", date('Y-m-d H:i:s'), $torrent['title']);
    }
}