AliMedia\Core\UploadClient::sendRequest()

Complexity

Conditions	12
Paths	450

Size

Total Lines	67
Code Lines	50

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    protected function sendRequest($method, $url, UploadPolicy $uploadPolicy, UploadOption $uploadOption)
    {
        $success = false;
        $http_code = 0;
        $result = array();
        /**
         * @var resource $ch
         */
        $ch = curl_init();
        try {
            //构建Http请求头和请求体
            $_headers = array('Expect:');
            $token = $this->_getUploadToken($uploadPolicy);

The method _getUploadToken() does not exist on AliMedia\Core\UploadClient. Did you maybe mean getUploadToken()?

            array_push($_headers, "Authorization: {$token}");
            array_push($_headers, "User-Agent: {$this->getUserAgent()}");
            $length = 0;
            if (!empty($uploadOption)) {
                list($contentType, $httpBody) = $this->buildMultipartForm($uploadOption);
                $length = @strlen($httpBody);
                array_push($_headers, "Content-Type: {$contentType}");
                curl_setopt($ch, CURLOPT_POSTFIELDS, $httpBody);            //请求体
            }
            array_push($_headers, "Content-Length: {$length}");
            curl_setopt($ch, CURLOPT_HEADER, 1);                            //设置头部
            curl_setopt($ch, CURLOPT_HTTPHEADER, $_headers);                //请求头
            curl_setopt($ch, CURLOPT_TIMEOUT, $uploadOption->timeout);  //持续时长
            curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 10);               //连接超时时长
            curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1); //成功，只返回结果，不自动输出任何内容。如果失败返回FALSE
            curl_setopt($ch, CURLOPT_FOLLOWLOCATION, 0);
            curl_setopt($ch, CURLOPT_URL, $url);
            curl_setopt($ch, CURLOPT_CUSTOMREQUEST, $method);           //自定义请求
            //设置请求方式(GET或POST等)
            if ($method == 'PUT' || $method == 'POST') {
                curl_setopt($ch, CURLOPT_POST, 1);
            } else {
                curl_setopt($ch, CURLOPT_POST, 0);
            }
            //执行上传，然后获取服务端返回，决定是否重试
            $response = curl_exec($ch);
            if ($response === false && $uploadOption->httpReTry != 0) {
                //如果执行curl失败，且需要重试，则进行重试
                $this->recordCurlErrorLog($ch); //记录最近一次curl执行错误日志
                $response = curl_exec($ch);
            }
            if ($response === false) {
                $this->recordCurlErrorLog($ch); //记录最近一次curl执行错误日志
                $result = $this->errorResponse("curl error", "curl request failed");
                $result['errno'] = curl_errno($ch); //错误码
            } else {
                //解析返回结果，并判断是否上传成功
                $http_code = curl_getinfo($ch, CURLINFO_HTTP_CODE);
                $success = ($http_code == 200) ? true : false;                  //判断是否上传成功
                $resStr = explode("\r\n\r\n", $response, 2);

It seems like $response can also be of type true; however, parameter $string of explode() does only seem to accept string, maybe add an additional type check?

                $resBody = isset($resStr[1]) ? $resStr[1] : '';
                $resArray = json_decode($resBody, true);                        //解析得到结果
                $result = (empty($resArray) ? $result : $resArray);
            }
        } catch (Exception $e) {
            $result = $this->errorResponse("HTTPRequestException#" . $e->getLine(), $e->getMessage());
        }

        curl_close($ch); //PHP5.3中不支持finally关键字。因此，为了兼容，这里取消finally
        if (!$success) {
            throw new UploadException($result['message'], $http_code);
        }
        $result['isSuccess'] = $success;
        return $result;
    }