4702166895

Build Type

push

github

Committed by twinh

Commit Message

feat(plugin): 增加 `httpComplete` 事件，在 HTTP 请求完成时触发

Run Details

0 of 1 new or added line in 1 file covered. (0.0%)

9 existing lines in 1 file now uncovered.

855 of 2262 relevant lines covered (37.8%)

18.45 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/src/Callback/HttpCallback.php

<?php

namespace Miaoxing\Plugin\Callback;

use Wei\Event;
use Wei\Http;

abstract class HttpCallback
{
    public const MAX_LOG_LENGTH = 1024;

    /**
     * @param mixed $response
     * @param Http $http
     */
    public static function success($response, Http $http)
    {
        $retries = $http->getOption('retries');
        $leftRetries = $http->getOption('leftRetries');

        if ($retries && $retries != $leftRetries) {
            // 上报是第几次重试才成功
            $curRetry = $retries - $leftRetries;
            wei()->statsD->increment('http.retries.' . $curRetry . '.success');
        }
    }

    /**
     * cURL请求发送失败的回调,记录错误原因和异常堆栈
     *
     * @param Http $http
     */
    public static function error(Http $http)
    {
        // 只有重试了仍然错误才记录日志
        if ($http->getOption('leftRetries')) {
            return;
        }

        $level = $http->getOption('errorLevel') ?: 'error';

        $response = $http->getResponseText();
        if (mb_strlen($response) > static::MAX_LOG_LENGTH) {
            $body = mb_substr($response, 0, static::MAX_LOG_LENGTH) . '...';
        } else {
            $body = $response;
        }

        $exception = $http->getErrorException();
        wei()->logger->log($level, $exception->getMessage(), [
            'url' => $http->getUrl(),
            'method' => $http->getMethod(),
            'data' => $http->getData(),
            'curlInfo' => $http->getCurlInfo(),
            'curlOptions' => $http->getOption('curlOptions'),
            'responseBody' => $body,
            'code' => $exception->getCode(),
            'exception' => (string) $exception,
        ]);
    }

    public static function complete(Http $http)
    {
        Event::trigger('httpComplete', $http);
    }
}

1	<?php
2
3	namespace Miaoxing\Plugin\Callback;
4
5	use Wei\Event;
6	use Wei\Http;
7
8	abstract class HttpCallback
9	{
10	public const MAX_LOG_LENGTH = 1024;
11
12	/**
13	* @param mixed $response
14	* @param Http $http
15	*/
16	public static function success($response, Http $http)
17	{
UNCOV 18	$retries = $http->getOption('retries');	×
UNCOV 19	$leftRetries = $http->getOption('leftRetries');	×
20
21	if ($retries && $retries != $leftRetries) {	×
22	// 上报是第几次重试才成功
UNCOV 23	$curRetry = $retries - $leftRetries;	×
24	wei()->statsD->increment('http.retries.' . $curRetry . '.success');	×
25	}
26	}
27
28	/**
29	* cURL请求发送失败的回调,记录错误原因和异常堆栈
30	*
31	* @param Http $http
32	*/
33	public static function error(Http $http)
34	{
35	// 只有重试了仍然错误才记录日志
UNCOV 36	if ($http->getOption('leftRetries')) {	×
UNCOV 37	return;	×
38	}
39
40	$level = $http->getOption('errorLevel') ?: 'error';	×
41
UNCOV 42	$response = $http->getResponseText();	×
43	if (mb_strlen($response) > static::MAX_LOG_LENGTH) {	×
UNCOV 44	$body = mb_substr($response, 0, static::MAX_LOG_LENGTH) . '...';	×
45	} else {
46	$body = $response;	×
47	}
48
49	$exception = $http->getErrorException();	×
UNCOV 50	wei()->logger->log($level, $exception->getMessage(), [	×
UNCOV 51	'url' => $http->getUrl(),	×
52	'method' => $http->getMethod(),	×
53	'data' => $http->getData(),	×
54	'curlInfo' => $http->getCurlInfo(),	×
55	'curlOptions' => $http->getOption('curlOptions'),	×
56	'responseBody' => $body,	×
57	'code' => $exception->getCode(),	×
58	'exception' => (string) $exception,	×
59	]);	×
60	}
61
62	public static function complete(Http $http)
63	{
NEW 64	Event::trigger('httpComplete', $http);	×
65	}
66	}

miaoxing / plugin / 4702166895

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous