icy2003\php\ihelpers\Http

Complexity

Total Complexity

14

Size/Duplication

Total Lines	157
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes	2
Bugs	0	Features	0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	download()	0	10	2
A	postAsync()	0	11	3
A	body()	0	8	1
A	get()	0	7	1
A	bodyAsync()	0	11	3
A	post()	0	8	1
A	getAsync()	0	10	3

<?php
/**
 * Class Http
 *
 * @link https://www.icy2003.com/
 * @author icy2003 <2317216477@qq.com>
 * @copyright Copyright (c) 2017, icy2003
 */

namespace icy2003\php\ihelpers;

use GuzzleHttp\Client;
use GuzzleHttp\Exception\RequestException;
use icy2003\php\I;
use icy2003\php\icomponents\file\LocalFile;
use Psr\Http\Message\ResponseInterface;

/**
 * 用 guzzlehttp 封装的简单的方法，更复杂的请使用 guzzlehttp
 */
class Http
{
    /**
     * 发送一个 GET 请求
     *
     * @param string $url 请求地址
     * @param array $get GET 参数
     * @param array $options 额外参数，默认不检测 https
     *
     * @return string
     */
    public static function get($url, $get = [], $options = [])
    {
        $client = new Client(Arrays::merge(['verify' => false], $options));
        $response = $client->request('GET', $url, [
            'query' => $get,
        ]);
        return $response->getBody()->getContents();
    }

    /**
     * 发送一个异步的 GET 请求
     *
     * @param string $url 请求地址
     * @param array $get GET 参数
     * @param array $options 额外参数，默认不检测 https
     * @param callback $success 成功时的回调 function($res1, $res2) $res1 是内容，$res2 是结果对象
     * @param callback $error 失败时的回调 function($res) $res 是结果对象
     *
     * @return void
     */
    public static function getAsync($url, $get = [], $options = [], $success = null, $error = null)
    {
        $client = new Client(Arrays::merge(['verify' => false], $options));
        $promise = $client->requestAsync('GET', $url, [
            'query' => $get,
        ]);
        $promise->then(function (ResponseInterface $res) use ($success) {
            $success && $success($res->getBody()->getContents(), $res);
        }, function (RequestException $err) use ($error) {
            $error && $error($err);
        });
    }

    /**
     * 发送一个表单 POST 请求
     *
     * @param string $url 请求地址
     * @param array $post POST 参数
     * @param array $get GET 参数
     * @param array $options 额外参数，默认不检测 https
     *
     * @return string
     */
    public static function post($url, $post = [], $get = [], $options = [])
    {
        $client = new Client(Arrays::merge(['verify' => false], $options));
        $response = $client->request('POST', $url, [
            'query' => $get,
            'form_params' => $post,
        ]);
        return $response->getBody()->getContents();
    }

    /**
     * 发送一个异步的表单 POST 请求
     *
     * @param string $url 请求地址
     * @param array $post POST 参数
     * @param array $get GET 参数
     * @param array $options 额外参数，默认不检测 https
     * @param callback $success 成功时的回调 function($res1, $res2) $res1 是内容，$res2 是结果对象
     * @param callback $error 失败时的回调 function($res) $res 是结果对象
     *
     * @return void
     */
    public static function postAsync($url, $post = [], $get = [], $options = [], $success = null, $error = null)
    {
        $client = new Client(Arrays::merge(['verify' => false], $options));
        $promise = $client->requestAsync('POST', $url, [
            'query' => $get,
            'form_params' => $post,
        ]);
        $promise->then(function (ResponseInterface $res) use ($success) {
            $success && $success($res->getBody()->getContents(), $res);
        }, function (RequestException $err) use ($error) {
            $error && $error($err);
        });
    }

    /**
     * 发送一个文本 POST 请求
     *
     * @param string $url 请求地址
     * @param string $body POST 文本
     * @param array $get GET 参数
     * @param array $options 额外参数，默认不检测 https
     *
     * @return string
     */
    public static function body($url, $body = '', $get = [], $options = [])
    {
        $client = new Client(Arrays::merge(['verify' => false], $options));
        $response = $client->request('POST', $url, [
            'query' => $get,
            'body' => $body,
        ]);
        return $response->getBody()->getContents();
    }

    /**
     * 发送一个异步的文本 POST 请求
     *
     * @param string $url 请求地址
     * @param string $body POST 文本
     * @param array $get GET 参数
     * @param array $options 额外参数，默认不检测 https
     * @param callback $success 成功时的回调 function($res1, $res2) $res1 是内容，$res2 是结果对象
     * @param callback $error 失败时的回调 function($res) $res 是结果对象
     *
     * @return void
     */
    public static function bodyAsync($url, $body = '', $get = [], $options = [], $success = null, $error = null)
    {
        $client = new Client(Arrays::merge(['verify' => false], $options));
        $promise = $client->requestAsync('POST', $url, [
            'query' => $get,
            'body' => $body,
        ]);
        $promise->then(function (ResponseInterface $res) use ($success) {
            $success && $success($res->getBody()->getContents(), $res);
        }, function (RequestException $err) use ($error) {
            $error && $error($err);
        });
    }

    /**
     * 下载文件
     *
     * - $file 是字符串，则会从远程文件下载到当前目录的同名文件
     * - $file 是数组，必须为两元素数组，如果元素二是路径，则下载到对应路径，如果元素二是文件，则下载为指定文件
     * - 支持中文
     *
     * @param string|array $file
     *
     * @return boolean
     */
    public function download($file)
    {
        list($from, $to) = (new LocalFile())->fileMap($file);
        try{
            (new Http())->get($from, [], [
                'save_to' => I::getAlias($to),
            ]);
            return true;
        }catch(RequestException $e){
            return false;
        }
    }
}