Initial commit

.editorconfig

+# This file is for unifying the coding style for different editors and IDEs.
+# More information at http://editorconfig.org
+
+root = true
+
+[*]
+charset = utf-8
+indent_style = space
+indent_size = 4
+end_of_line = lf
+insert_final_newline = true
+trim_trailing_whitespace = true
+
+[*.bat]
+end_of_line = crlf
+
+[*.xml]
+indent_style = space
+indent_size = 4
+
+[*.neon]
+indent_style = tab
+indent_size = 4
+
+[*.{yaml,yml}]
+indent_style = space
+indent_size = 2
+
+[composer.json]
+indent_style = space
+indent_size = 2
+
+[*.md]
+trim_trailing_whitespace = false

.gitignore

+.idea/
+.DS_STORE
+.phpcs.cache
+.phpunit.result.cache
+composer.lock
+Makefile
+phpcs.xml
+phpstan.neon
+phpunit.xml
+vendor/
\ No newline at end of file

EndPointTest.php

+<?php
+// generated code, do not edit.
+declare(strict_types=1);
+
+namespace Jiwei\Test\SDK\Endpoint;
+
+use Closure;
+use Jiwei\EasyHttpSdk\Application;
+use Jiwei\EasyHttpSdk\Exception\SdkException;
+use Jiwei\EasyHttpSdk\Exception\ApplicationException;
+use Jiwei\EasyHttpSdk\Exception\TimeOutExcetpion;
+use Jiwei\EasyHttpSdk\Helper\ArgsRecorder;
+use Jiwei\EasyHttpSdk\Helper\CallBackHelper;
+use Jiwei\EasyHttpSdk\Http\SdkRequest;
+
+
+class Test
+{
+    use ArgsRecorder;
+
+    use CallBackHelper;
+
+    /** @var Application */
+    protected $application;
+
+    /**
+     * @param Application $application
+     */
+    public function __construct(
+        Application $application
+    )
+    {
+        $this->application = $application;
+    }
+
+    /**
+     * 创建表单
+     *
+     * @param array|null $body
+     *
+     * @param Closure|null $catch
+     * @param Closure|null $then
+     * @return array
+     *
+     * @throws ApplicationException
+     * @throws SdkException
+     * @throws TimeOutExcetpion
+     */
+    public function create(?array $body = [], ?Closure $catch = null, ?Closure $then = null): mixed
+    {
+        $url = "/api/form";
+        $request = new SdkRequest("POST", $url, "Test", "create", [], json_encode($body));
+
+        $request = $request->withArgs($this->ArgsRecoder(__METHOD__, func_get_args()))->withRequestID()->withAuthorization();
+
+        try {
+            $response = $this->application->sendRequest($request);
+            $decodedData = $this->application->resultDecode($request, $response);
+            $this->setLastResult($decodedData);
+        } catch (SdkException $sdkException) {
+            $this->setLastException($sdkException);
+            $catch = $catch ?? $this->defaultFailedCallBack();
+            return $catch($this);
+        }
+        $then = $then ?? $this->defaultSuccessCallBack();
+        return $then($this);
+    }
+    
+}

bin/toml.php

+<?php
+
+use Jiwei\EasyHttpSdk\Generation\SdkEndpointBuilder;
+
+require_once __DIR__ . "/../vendor/autoload.php";
+
+$params = getopt("d:e:p:h", [
+    "dist:",
+    "endpoints:",
+    "package:",
+    "help"
+]);
+
+if (isset($params['h']) || isset($params['help'])) {
+    echo "SDK生成工具🧸ver:0.1\n
+-d --dist 
+输出SDK Endpoint 类的目录 默认为 src/Endpoint 
+-e --endpoints 
+获取endpoins toml 描述文件的目录 endpoints 
+-p--package 
+SDK Endpoint 类所使用的命名空间名称 ".PHP_EOL;
+    exit;
+}
+
+
+$packageName = $params['p'] ?? $params['package'] ?? "";
+$distPath = $params['d'] ?? $params['dist'] ?? __DIR__ . "/../src/EndPoint/";
+$endpointPath = $params['e'] ?? $params['endpoints'] ?? __DIR__ . "/../endpoints/";
+
+if ("" === $packageName) {
+    echo "请输入的包名" . PHP_EOL;
+    exit;
+}
+
+var_dump($params);
+
+echo "正在创建{$packageName}" . PHP_EOL;
+echo "目标目录{$distPath}" . PHP_EOL;
+echo "配置来源{$endpointPath}" . PHP_EOL;
+
+
+$builder = new SdkEndpointBuilder(
+    $distPath,
+    $endpointPath,
+    __DIR__ . '/../template/',
+    $packageName
+);
+
+$count = $builder->build();
+
+echo "成功生成{$count}个 Endpoint Class" . PHP_EOL;
\ No newline at end of file

composer.json

+{
+  "name": "jiwei/easy-http-sdk",
+  "description": "http client sdk generation.",
+  "type": "library",
+  "autoload": {
+    "psr-4": {
+      "Jiwei\\EasyHttpSdk\\": "src/"
+    }
+  },
+  "authors": [
+    {
+      "name": "谢宇轩",
+      "email": "y7ut1996@gmail.com"
+    }
+  ],
+  "require": {
+    "php": ">7.2.5",
+    "psr/log": "^1.1",
+    "twig/twig": "^3.0",
+    "symfony/cache": "^5.4",
+    "yosymfony/toml": "^1.0",
+    "guzzlehttp/guzzle": "^7.5",
+    "ramsey/uuid": "^4.7",
+    "ext-json": "*"
+  },
+  "require-dev": {
+    "phpunit/phpunit": "^9",
+    "phpstan/phpstan": "^1.9"
+  },
+  "extra": {
+    "branch-alias": {
+      "dev-master": "1.0.x-dev"
+    }
+  },
+  "scripts": {
+    "phpstan": "vendor/bin/phpstan analyse -c phpstan.neon",
+    "phpunit": "./vendor/bin/phpunit",
+    "phpunit-unit": "./vendor/bin/phpunit --testsuite=unit"
+  }
+}

src/Application.php

+<?php
+declare(strict_types=1);
+
+namespace Jiwei\EasyHttpSdk;
+
+use GuzzleHttp\Client;
+use GuzzleHttp\Exception\GuzzleException;
+use GuzzleHttp\Exception\TransferException;
+use GuzzleHttp\HandlerStack;
+use GuzzleHttp\Psr7\Request;
+use InvalidArgumentException;
+use Jiwei\EasyHttpSdk\Exception\ApplicationException;
+use Jiwei\EasyHttpSdk\Exception\SdkException;
+use Jiwei\EasyHttpSdk\Exception\TimeOutExcetpion;
+use Jiwei\EasyHttpSdk\Http\SdkRequest;
+use Jiwei\EasyHttpSdk\Middleware\JwtMiddleware;
+use Psr\Cache\CacheItemPoolInterface;
+use Psr\Http\Client\ClientInterface;
+use Psr\Http\Message\RequestInterface;
+use Psr\Http\Message\ResponseInterface;
+use Psr\Log\LoggerInterface;
+use Psr\Cache\InvalidArgumentException as CacheInvalidArgumentException;
+use RuntimeException;
+use Symfony\Component\Cache\Adapter\FilesystemAdapter;
+
+
+class Application implements ClientInterface
+{
+
+    private const TOKEN_CACHE_KEY = "Auth.%s";
+
+    private const EXPIRES_AT = 30000;
+
+    /** @var Option $option */
+    private $option;
+
+    /** @var string jwtToken */
+    private $jwtToken = "";
+
+    /** @var null|LoggerInterface 日志记录器 */
+    protected $logger = null;
+
+    /** @var null|Client Guzzle客户端 */
+    protected $client = null;
+
+    /** @var null|CacheItemPoolInterface PS-6缓存 */
+    protected $cache = null;
+
+    /** @var array<string, mixed> 最后的一次请求调用上下文 */
+    protected $lastRequestContext = [];
+
+    /**
+     * 初始化一个 SDK 应用，目前 config 中必填的有 app_key 和 app_secret, 剩余 stage 默认为 development, debug 默认为 false, timeout 默认为3.0,
+     * 最后也可以传入 PSR 规范下的日志接口, 当然也可以不进行日志记录,
+     * Cache的需要实现PSR规范的缓存接口, 默认使用 symfony/cache 的实现, 也可以自行替换为 Redis (需要实现 PSR-6 ),
+     *
+     * @param Option $option
+     * @param LoggerInterface|null $logger
+     * @param CacheItemPoolInterface|null $cache
+     */
+    public function __construct(
+        Option                  $option,
+        ?LoggerInterface        $logger = null,
+        ?CacheItemPoolInterface $cache = null
+    )
+    {
+
+        if (empty($option->getAppId())) {
+            throw new RuntimeException("请完善配置信息中的App Key");
+        }
+
+        if (empty($option->getAppSecret())) {
+            throw new RuntimeException("请完善配置信息中的App Secret");
+        }
+
+        $this->option = $option;
+
+        $base_url = $option->getBaseUrl();
+
+        if (empty($base_url)) {
+            throw new RuntimeException("请检查配置信息中的Base Url");
+        }
+
+        if ($logger) {
+            $this->logger = $logger;
+        }
+
+        $this->cache = new FilesystemAdapter();
+        if ($cache) {
+            $this->cache = $cache;
+        }
+
+        $this->client = new Client([
+            'headers' => [
+                "Content-Type" => 'application/json; charset=utf8',
+            ],
+            "base_uri" => $base_url,
+            "timeout" => $this->option->getTimeOut(),
+            "http_errors" => false,
+            "debug" => $this->option->isDebug(),
+        ]);
+    }
+
+    /**
+     * 发送SDK的请求
+     *
+     * @param RequestInterface $request
+     * @return ResponseInterface
+     * @throws ApplicationException
+     * @throws GuzzleException
+     *
+     */
+    public function sendRequest(RequestInterface $request): ResponseInterface
+    {
+
+        $stack = HandlerStack::create();
+
+        $this->lastRequestContext = [
+            'request' => $request,
+            "stage" => $this->option->getStage(),
+        ];
+        $start = microtime(true);
+        // 应该使用的是 SDKRequest
+        if ($request instanceof SdkRequest) {
+
+            $this->lastRequestContext['request_id'] = $request->getUuid();
+            $this->lastRequestContext['args'] = $request->getArgs();
+            $this->lastRequestContext['endpoint'] = $request->getEndpoint();
+            $this->lastRequestContext['action'] = $request->getAction();
+
+            $start = $request->getStartAt();
+            $middlewares = $request->getMiddlewares();
+            foreach ($middlewares as $middleware) {
+                $stack->push($middleware);
+            }
+            if ($request->authorization()) {
+                if ($this->jwtToken === "") {
+                    try {
+                        $this->jwtToken = $this->getAccessTokenFromCache($this->option->getAppId(), $this->option->getAppSecret());
+                    } catch (RuntimeException $exception) {
+                        if ($this->logger) {
+                            $this->logger->error("sdk error, bad Auth with: " . $exception->getMessage());
+                        }
+                        throw new TimeOutExcetpion($request);
+                    } catch (InvalidArgumentException $exception) {
+                        if ($this->logger) {
+                            $this->logger->error("sdk error, bad Auth with:" . $exception->getMessage());
+                        }
+                        throw new ApplicationException($exception->getMessage(), $request, [], $exception);
+                    }
+                }
+                $stack->push(new JwtMiddleware($this->jwtToken));
+            }
+        }
+
+        $options = [
+            'handler' => $stack
+        ];
+
+        try {
+            $response = $this->client->send($request, $options);
+        } catch (TransferException $exception) {
+            $this->lastRequestContext['expend'] = sprintf("%dms", microtime(true) * 1000 - $start * 1000);
+            if ($this->logger) {
+                $this->logger->error("time out!");
+            }
+            if (!($request instanceof SdkRequest)) {
+                throw $exception;
+            }
+            throw new TimeOutExcetpion($request, $exception);
+        } catch (GuzzleException $exception) {
+            if ($this->logger) {
+                $this->logger->error("sdk etrror, bad client!");
+            }
+            if (!($request instanceof SdkRequest)) {
+                throw $exception;
+            }
+            throw new ApplicationException($exception->getMessage(), $request, [], $exception);
+        }
+
+        $this->lastRequestContext['expend'] = sprintf("%dms", microtime(true) * 1000 - $start * 1000);
+        $this->lastRequestContext['http_status'] = $response->getStatusCode();
+        $this->lastRequestContext['response'] = $response;
+        return $response;
+    }
+
+    /**
+     * 解析SDK的响应结果，并处理异常
+     *
+     * @param SdkRequest $request
+     * @param ResponseInterface $response
+     * @return array<string, mixed>
+     * @throws ApplicationException
+     * @throws SdkException
+     */
+    public function resultDecode(SdkRequest $request, ResponseInterface $response): array
+    {
+
+        $context = $this->lastRequestContext;
+
+        if ($context['request']) {
+            unset($context['request']);
+        }
+        if ($context['response']) {
+            unset($context['response']);
+        }
+
+        if ($response->getStatusCode() >= 500) {
+            if ($this->logger) {
+                $this->logger->error("sdk error, paypal service fail", $context);
+            }
+            throw new SdkException("SDK Upstram Failed", $request, $response, []);
+        }
+
+        if (in_array($response->getStatusCode(), [404, 405])) {
+            if ($this->logger) {
+                $this->logger->error("sdk error, endpoint not found", $context);
+            }
+            throw new ApplicationException("Api Endpoint Not Found.", $request, []);
+        }
+
+        $rpcResult = [];
+
+        if ($response->getStatusCode() != 304) {
+            $responseInfo = $response->getBody()->getContents();
+            $rpcResult = json_decode($responseInfo, true);
+            if (json_last_error()) {
+                if ($this->logger) {
+                    $this->logger->error("sdk error, bad response content.", $context);
+                }
+                throw new ApplicationException("Content Format error.", $request, []);
+            }
+        }
+
+        $errorName = $rpcResult['name'] ?? "";
+        // Paypal的API错误结果是通用的，所以这里简单处理一下
+        if (!empty($errorName) && $response->getStatusCode() >= 400) {
+            $errorMessage = sprintf("%s : %s", $errorName, $rpcResult['message'] ?? "");
+            $this->lastRequestContext['error'] = $errorMessage;
+            $this->lastRequestContext['error_detail'] = $rpcResult;
+            if ($this->logger) {
+                $this->logger->warning("Error", $this->lastRequestContext);
+            }
+            throw new SdkException($errorMessage, $request, $response, $rpcResult);
+        }
+
+        $version = $response->getHeader('ETag');
+
+        if (!empty($version)) {
+            $rpcResult = array_merge($rpcResult, [
+                'version' => $version[0]
+            ]);
+        }
+        if ($this->logger) {
+            $this->logger->info("Success", $context);
+        }
+
+
+        return $rpcResult;
+    }
+
+    /**
+     * 获取上一次请求的上下文
+     *
+     * @return array<string, mixed>
+     */
+    public function getLastRequestContext(): array
+    {
+        return $this->lastRequestContext;
+    }
+
+    /**
+     * 从缓存中获取accessToken 使用PSR-6缓存接口
+     *
+     * @param string $app_key
+     * @param string $app_secret
+     * @return string
+     */
+    private function getAccessTokenFromCache(string $app_key, string $app_secret): string
+    {
+        $cacheKey = sprintf(self::TOKEN_CACHE_KEY, $app_key);
+        try {
+            $currentToken = $this->cache->getItem($cacheKey);
+        } catch (CacheInvalidArgumentException $e) {
+            throw new InvalidArgumentException("cache use invalid args" . $e->getMessage());
+        }
+
+        if (!$currentToken->isHit()) {
+            $token = $this->getAccessToken($app_key, $app_secret);
+
+            $currentToken->set($token)->expiresAfter(self::EXPIRES_AT);
+            $this->cache->save($currentToken);
+        }
+
+        return $currentToken->get();
+    }
+
+    /**
+     * 鉴权
+     *
+     * @param string $app_key
+     * @param string $app_secret
+     * @return string
+     */
+    private function getAccessToken(string $app_key, string $app_secret): string
+    {
+        try {
+            $request = $this->option->getAuthMoudel()($app_key, $app_secret);
+            $response = $this->client->send($request);
+        } catch (TransferException $exception) {
+            throw new RuntimeException('time out!');
+        } catch (GuzzleException $exception) {
+            if ($this->logger) {
+                $this->logger->error("sdk error, Auth error");
+            }
+            throw new InvalidArgumentException("auth error." . $exception->getMessage());
+        }
+
+        if ($response->getStatusCode() >= 400) {
+            throw new InvalidArgumentException("invalid account.");
+        }
+
+        $rpcResult = json_decode($response->getBody()->getContents(), true);
+
+        if (json_last_error()) {
+            throw new InvalidArgumentException("invalid auth response");
+        }
+
+        $token = $rpcResult["access_token"] ?? "";
+
+        if ($token === "") {
+            throw new InvalidArgumentException("invalid account.");
+        }
+        return $token;
+    }
+}

src/Exception/ApplicationException.php

+<?php
+
+namespace Jiwei\EasyHttpSdk\Exception;
+
+use GuzzleHttp\Exception\ConnectException;
+use Jiwei\EasyHttpSdk\Helper\QueryPath;
+use Jiwei\EasyHttpSdk\Http\SdkRequest;
+use Throwable;
+
+class ApplicationException extends ConnectException implements SdkExceptionInterface
+{
+    use QueryPath;
+
+    /**
+     * @param string $message
+     * @param SdkRequest $request
+     * @param array<string, mixed> $handlerContext
+     * @param Throwable|null $previous
+     */
+    public function __construct(
+        string $message,
+        SdkRequest $request,
+        array $handlerContext = [],
+        ?\Throwable $previous = null,
+    ) {
+        $this->endpoint = $request->getEndpoint();
+        $this->action = $request->getAction();
+        parent::__construct($message, $request, $previous, $handlerContext);
+    }
+}
\ No newline at end of file

src/Exception/SdkException.php

+<?php
+
+namespace Jiwei\EasyHttpSdk\Exception;
+
+use GuzzleHttp\Exception\BadResponseException;
+use Jiwei\EasyHttpSdk\Helper\QueryPath;
+use Jiwei\EasyHttpSdk\Http\SdkRequest;
+use Psr\Http\Message\ResponseInterface;
+use Throwable;
+
+
+class SdkException extends BadResponseException implements SdkExceptionInterface
+{
+    use QueryPath;
+
+    /**
+     * @param string $message
+     * @param SdkRequest $request
+     * @param ResponseInterface $response
+     * @param array<string, mixed> $handlerContext
+     * @param Throwable|null $previous
+     */
+    public function __construct(
+        string            $message,
+        SdkRequest        $request,
+        ResponseInterface $response,
+        array             $handlerContext = [],
+        ?\Throwable       $previous = null
+    )
+    {
+        $this->endpoint = $request->getEndpoint();
+        $this->action = $request->getAction();
+        parent::__construct($message, $request, $response, $previous, $handlerContext);
+    }
+
+    /**
+     * 获取上下文中错误集合
+     *
+     * @return array<string, mixed>
+     */
+    public function getSdkErrors(): array
+    {
+        return $this->getHandlerContext();
+    }
+}
\ No newline at end of file

src/Exception/SdkExceptionInterface.php

+<?php
+
+namespace Jiwei\EasyHttpSdk\Exception;
+
+interface SdkExceptionInterface
+{
+
+}
\ No newline at end of file

src/Exception/TimeOutExcetpion.php

+<?php
+
+namespace Jiwei\EasyHttpSdk\Exception;
+
+use Jiwei\EasyHttpSdk\Http\SdkRequest;
+use Throwable;
+
+class TimeOutExcetpion extends ApplicationException implements SdkExceptionInterface
+{
+
+    /** @var int 错误码 */
+    protected $code = 408;
+
+    /** @var string The error message */
+    protected $message = "time out.";
+
+    /**
+     * @param SdkRequest $request
+     * @param Throwable|null $previous
+     */
+    public function __construct(
+        SdkRequest  $request,
+        ?\Throwable $previous = null,
+    )
+    {
+        parent::__construct($this->message, $request, [], $previous);
+    }
+}
\ No newline at end of file

src/Generation/SdkEndpointBuilder.php

+<?php
+declare(strict_types=1);
+
+namespace Jiwei\EasyHttpSdk\Generation;
+
+use Twig\Environment;
+use Twig\Error\LoaderError;
+use Twig\Error\RuntimeError;
+use Twig\Error\SyntaxError;
+use Twig\Loader\FilesystemLoader;
+use Yosymfony\Toml\Toml;
+
+class SdkEndpointBuilder
+{
+
+    /** @var string Toml目录 */
+    private $endpointSrcPath;
+
+    /** @var string 目标Endpoint目录 */
+    private $endpointDstPath;
+
+    /** @var string twig模板目录 */
+    private $twigPath;
+
+    /** @var array<string, mixed> 读取的配置 */
+    protected $tomlSetting = [];
+
+    /** @var Environment twig生成器 */
+    protected $twig;
+
+    /** @var string 包命名空间 */
+    protected $package;
+
+    /**
+     * @param string $endpointDstPath
+     * @param string $endpointSrcPath
+     * @param string $twigPath
+     * @param string $package
+     */
+    public function __construct(string $endpointDstPath, string $endpointSrcPath, string $twigPath, string $package)
+    {
+        $this->endpointDstPath = $endpointDstPath;
+        $this->endpointSrcPath = $endpointSrcPath;
+        $this->twigPath = $twigPath;
+        $this->package = $package;
+
+        $loader = new FilesystemLoader($this->twigPath);
+        $this->twig = new Environment($loader);
+    }
+
+    /**
+     * 加载目录
+     *
+     * @return void
+     */
+    private function LoadToml(): void
+    {
+        $dh = opendir($this->endpointSrcPath);
+        if (!$dh) {
+            throw new \RuntimeException(sprintf("src path [%s] can not open ", $this->endpointSrcPath));
+        }
+        while (($file = readdir($dh)) !== false) {
+
+            if (in_array($file, [".", ".."])) {
+                continue;
+            }
+            $actions = [];
+            if (str_contains($file, ".toml")) {
+                $actions = Toml::ParseFile($this->endpointSrcPath . $file);
+            }
+            $endpointName = ucfirst(str_replace(".toml", "", $file));
+
+            $this->tomlSetting[$endpointName] = $actions;
+        }
+        closedir($dh);
+    }
+
+    /**
+     * 根据配置创建Endpoint类
+     *
+     * @return int
+     */
+    public function build(): int
+    {
+        $this->LoadToml();
+
+        $renderResult = [];
+
+        foreach ($this->tomlSetting as $name => $endpoints) {
+
+
+            $endpointFunc = [];
+            foreach ($endpoints as $func => $endpoint) {
+                $description = $endpoint["description"] ?? $func;
+                $uri = $endpoint['endpoint'] ?? "";
+                if (empty($uri)) {
+                    throw new \RuntimeException(sprintf("endpoint [%s] method %s required a uri ", $name, $func));
+                }
+                $method = $endpoint['method'] ?? "";
+                if (empty($method)) {
+                    throw new \RuntimeException(sprintf("endpoint [%s] method %s required a http method ", $name, $func));
+                }
+                $query = $endpoint['query'] ?? [];
+                $body = $endpoint['body'] ?? false;
+                $cache = $endpoint['cache'] ?? false;
+                $auth = $endpoint['auth'] ?? false;
+
+                $args = "";
+                $params = [];
+
+                $middlewareRuleCode = "";
+
+                if ($auth) {
+                    $middlewareRuleCode .= '->withAuthorization()';
+                }
+
+                $require_regex = '~{([\w.]+)}~s';
+
+                $matched = preg_match_all($require_regex, $uri, $matches);
+
+                // 检测重复元素
+                if ($matched != count(array_unique($matches[1]))){
+                    throw new \RuntimeException(sprintf("endpoint [%s] method %s required has same args ", $name, $func));
+                }
+
+                if ($matched > 0) {
+                    foreach ($matches[1] as $item) {
+                        $args .= 'string $' . $item . ', ';
+                        $params[] = [
+                            "type" => "string",
+                            "name" => '$' . $item,
+                        ];
+                        if (!str_contains($uri, "{$item}")) {
+                            throw new \RuntimeException(sprintf("endpoint [%s] method %s required argument not found in uri ", $name, $func));
+                        }
+                        $uri = str_replace("{" . $item . "}", '{$' . $item . '}', $uri);
+                    }
+                }
+
+                if ($cache) {
+                    $args .= '?string $version = "", ';
+                    $params[] = [
+                        "type" => "string|null",
+                        "name" => '$version',
+                    ];
+                    $middlewareRuleCode .= '->withEtag($version)';
+                }
+
+                $queryJoin = [];
+                if (count($query) != count(array_unique($query))){
+                    throw new \RuntimeException(sprintf("endpoint [%s] method %s query has same args ", $name, $func));
+                }
+                foreach ($query as $item) {
+                    $args .= '?string $' . $item . ' = "", ';
+                    $params[] = [
+                        "type" => "string|null",
+                        "name" => '$' . $item,
+                    ];
+                    $queryJoin[] = [
+                        "name" => "$" . $item,
+                        "query" => sprintf('"%s={%s}&"', $item, "$" . $item),
+                    ];
+                }
+
+                $bodyStr = "";
+                if ($body) {
+                    $args .= '?array $body = [], ';
+                    $bodyStr = ', json_encode($body)';
+                    $params[] = [
+                        "type" => "array|null",
+                        "name" => '$body',
+                    ];
+                }
+
+                $currentFunc = [
+                    "Action" => $func,
+                    "Description" => $description,
+                    "Method" => $method,
+                    "Uri" => $uri,
+                    "Body" => $bodyStr,
+                    "Args" => $args,
+                    "Params" => $params,
+                    "Middleware" => $middlewareRuleCode,
+                    "Join" => $queryJoin,
+                ];
+                $endpointFunc[] = $currentFunc;
+            }
+            $endpointSchema = [
+                "Endpoint" => $name,
+                "Package" => $this->package,
+                "Func" => $endpointFunc,
+            ];
+            try {
+                $phpCode = $this->twig->render('Endpoint.temp', $endpointSchema);
+                $renderResult[$name] = $phpCode;
+                echo sprintf("Render Class[%s] ...", $name) . PHP_EOL;
+            } catch (LoaderError|RuntimeError|SyntaxError $e) {
+                echo sprintf("Render Error : %s", $e->getRawMessage()) . PHP_EOL;
+            }
+        }
+
+        foreach ($renderResult as $name => $phpCode) {
+            file_put_contents($this->endpointDstPath . $name . ".php", $phpCode);
+            echo sprintf("Save Class[%s] ...", $name) . PHP_EOL;
+        }
+
+        return count($this->tomlSetting);
+    }
+
+}
\ No newline at end of file

src/Helper/ArgsRecorder.php

+<?php
+
+namespace Jiwei\EasyHttpSdk\Helper;
+
+trait ArgsRecorder
+{
+    /**
+     * @param string $func
+     * @param array $params
+     * @return array
+     */
+    private function ArgsRecoder(string $func, array $params): array
+    {
+        $result = [];
+        try {
+            $reflectionFunction = new \ReflectionMethod($func);
+            foreach ($reflectionFunction->getParameters() as $key => $parameter) {
+                $result[$parameter->name] = $params[$key] ?? null;
+            }
+        }catch (\ReflectionException $exception) {
+            throw new \RuntimeException("Refection get args error.");
+        }
+        return $result;
+    }
+}
\ No newline at end of file

src/Helper/CallBackHelper.php

+<?php
+
+namespace  Jiwei\EasyHttpSdk\Helper;
+
+use Closure;
+use  Jiwei\EasyHttpSdk\Exception\SdkException;
+
+trait CallBackHelper
+{
+
+    /**
+     * @var SdkException|null
+     */
+    private $lastException = null;
+
+    /**
+     * @var mixed
+     */
+    private $lastResult = [];
+
+    /**
+     * @return mixed
+     */
+    public function getLastResult()
+    {
+        return $this->lastResult;
+    }
+
+    /**
+     * @param mixed $lastResult
+     */
+    public function setLastResult($lastResult): void
+    {
+        $this->lastResult = $lastResult;
+    }
+
+    /**
+     * @return SdkException|null
+     */
+    public function getLastException(): ?SdkException
+    {
+        return $this->lastException;
+    }
+
+    /**
+     * @param SdkException $lastException
+     */
+    public function setLastException(SdkException $lastException): void
+    {
+        $this->lastException = $lastException;
+    }
+
+    /**
+     * @return Closure
+     */
+    public function defaultSuccessCallBack(): Closure
+    {
+        // 这里使用默认作用域
+        return function () {
+            return $this->getLastResult();
+        };
+    }
+
+    /**
+     * @return Closure
+     */
+    public function defaultFailedCallBack(): Closure
+    {
+        // 这里使用默认作用域
+        return function () {
+            throw $this->getLastException();
+        };
+    }
+
+    /**
+     * @return array
+     */
+    public function getContext(): array
+    {
+        return array_merge($this->application->getLastRequestContext(), [
+            'data' => $this->getLastResult(),
+            'exception' => $this->getLastException(),
+        ]);
+    }
+
+
+}
\ No newline at end of file

src/Helper/QueryPath.php

+<?php
+
+namespace Jiwei\EasyHttpSdk\Helper;
+
+trait QueryPath
+{
+    /** @var string Endpoint */
+    protected $endpoint;
+
+    /** @var string Endpoint */
+    protected $action;
+
+    /**
+     * 获取错误详情位置
+     *
+     * @return string
+     */
+    public function getPath(): string
+    {
+        return $this->endpoint . ":" . $this->action;
+    }
+}
\ No newline at end of file

src/Http/SdkRequest.php

+<?php
+declare(strict_types=1);
+
+namespace Jiwei\EasyHttpSdk\Http;
+
+use GuzzleHttp\Psr7\Request;
+use Jiwei\EasyHttpSdk\Middleware\EtagMiddleware;
+use Jiwei\EasyHttpSdk\Middleware\MiddlewareInterface;
+use Jiwei\EasyHttpSdk\Middleware\RequestIDMiddleware;
+use Psr\Http\Message\StreamInterface;
+use Psr\Http\Message\UriInterface;
+
+class SdkRequest extends Request
+{
+
+    /** @var string SDK uuid */
+    private $uuid;
+
+    /** @var string SDK Endpoint */
+    private $endpoint;
+
+    /** @var string SDK方法 */
+    private $action;
+
+    /** @var float 开始时间 */
+    private $startAt;
+
+    /** @var array<string, mixed> 调用参数列表 */
+    private $args;
+
+    /** @var MiddlewareInterface[] Guzzle中间件列表 */
+    private $middlewares = [];
+
+    /** @var bool 鉴权开关 */
+    private $authorization = false;
+
+    /**
+     * Construct of SdkRequest style by psr-7
+     *
+     * @param string $method HTTP method
+     * @param string|UriInterface $uri URI
+     * @param string $endpoint Endponit
+     * @param string $action  action
+     * @param array<string, string|string[]> $headers Request headers
+     * @param string|resource|StreamInterface|null $body Request body
+     * @param string $version Protocol version
+     */
+    public function __construct(
+        string $method,
+               $uri,
+               $endpoint,
+               $action,
+        array  $headers = [],
+               $body = null,
+        string $version = '1.1'
+    )
+    {
+        parent::__construct($method, $uri, $headers, $body, $version);
+        $this->startAt = microtime(true);
+        $this->endpoint = $endpoint;
+        $this->action = $action;
+    }
+
+
+    /**
+     * 获取本次请求的方法参数
+     *
+     * @return array<string, mixed>
+     */
+    public function getArgs(): array
+    {
+        return $this->args;
+    }
+
+    /**
+     * 设置本次请求的方法参数
+     *
+     * @param array<string, mixed> $args
+     * @return SdkRequest
+     */
+    public function withArgs(array $args): self
+    {
+        $this->args = $args;
+        return $this;
+    }
+
+    /**
+     * 获取本次请求需要使用的中间件
+     *
+     * @return MiddlewareInterface[]
+     */
+    public function getMiddlewares(): array
+    {
+        return $this->middlewares;
+    }
+
+    /**
+     * 获取 SDK Endpoint
+     *
+     * @return string
+     */
+    public function getEndpoint(): string
+    {
+        return $this->endpoint;
+    }
+
+    /**
+     * 获取 SDK Action
+     *
+     * @return string
+     */
+    public function getAction(): string
+    {
+        return $this->action;
+    }
+
+    /**
+     * 判断鉴权
+     *
+     * @return bool
+     */
+    public function authorization(): bool
+    {
+        return $this->authorization;
+    }
+
+    /**
+     * 开启鉴权
+     *
+     * @return SdkRequest
+     */
+    public function withAuthorization(): self
+    {
+        $this->authorization = true;
+        return $this;
+    }
+
+    /**
+     * 使用ETAG中间件来传递version
+     *
+     * @param string $version
+     * @return SdkRequest
+     */
+    public function withEtag(string $version): self
+    {
+        $EtgMiddleware = new EtagMiddleware($version);
+        $this->middlewares[] = $EtgMiddleware;
+        return $this;
+    }
+
+
+    /**
+     * 获取请求ID
+     *
+     * @return string
+     */
+    public function getUuid(): string
+    {
+        return $this->uuid;
+    }
+
+    /**
+     * 使用 RequestID 中间件
+     *
+     * @param string|null $uuid
+     * @return SdkRequest
+     */
+    public function withRequestID(?string $uuid = null): self
+    {
+        $this->uuid = $uuid;
+        $RequestIDMiddleware = new RequestIDMiddleware($this->uuid);
+        $this->middlewares[] = $RequestIDMiddleware;
+        return $this;
+    }
+
+    /**
+     * 获取初始化时间
+     *
+     * @return float
+     */
+    public function getStartAt(): float
+    {
+        return $this->startAt;
+    }
+
+}
\ No newline at end of file

src/Middleware/EtagMiddleware.php

+<?php
+
+namespace Jiwei\EasyHttpSdk\Middleware;
+
+use Psr\Http\Message\RequestInterface;
+
+class EtagMiddleware implements MiddlewareInterface
+{
+    /** @var string Version */
+    private $version;
+
+    /**
+     * @param string $version
+     */
+    public function __construct(string $version)
+    {
+        $this->version = $version;
+    }
+
+    /**
+     * 为请求添加Etag的中间件
+     *
+     * @param callable $handler
+     * @return callable
+     */
+    public function __invoke(callable $handler): callable
+    {
+        return function (
+            RequestInterface $request,
+            array            $options
+        ) use ($handler) {
+            if ($this->version !== "") {
+                $ETagHeaderAttribute = "If-Match";
+                if ($request->getMethod() == "GET") {
+                    $ETagHeaderAttribute = "If-None-Match";
+                }
+                $request = $request->withHeader($ETagHeaderAttribute, $this->version);
+            }
+            return $handler($request, $options);
+        };
+    }
+}
\ No newline at end of file

src/Middleware/JwtMiddleware.php

+<?php
+
+namespace Jiwei\EasyHttpSdk\Middleware;
+
+use Psr\Http\Message\RequestInterface;
+
+class JwtMiddleware implements MiddlewareInterface
+{
+    /** @var string jwtToken */
+    protected $token;
+
+    public function __construct(string $token){
+        $this->token = $token;
+    }
+
+    /**
+     * 为请求添加Jwt Token的中间件
+     *
+     * @param callable $handler
+     * @return callable
+     */
+    public function __invoke(callable $handler): callable
+    {
+        return function (
+            RequestInterface $request,
+            array $options
+        ) use ($handler) {
+            $request = $request->withHeader("Authorization", "Bearer " . $this->token );
+            return $handler($request, $options);
+        };
+    }
+}
\ No newline at end of file

src/Middleware/MiddlewareInterface.php

+<?php
+
+namespace Jiwei\EasyHttpSdk\Middleware;
+
+interface MiddlewareInterface
+{
+
+}
\ No newline at end of file

src/Middleware/RequestIDMiddleware.php

+<?php
+
+namespace Jiwei\EasyHttpSdk\Middleware;
+
+use Psr\Http\Message\RequestInterface;
+use Ramsey\Uuid\Uuid;
+
+class RequestIDMiddleware implements MiddlewareInterface
+{
+    /** @var string UUID */
+    protected $uuid;
+
+    /**
+     * @param string|null $uuid
+     */
+    public function __construct(string $uuid = null){
+        if (!$uuid) {
+            $uuid = substr(Uuid::uuid4()->toString(), 0, 8);
+        }
+        $this->uuid = $uuid;
+    }
+
+    /**
+     * 为请求添加ID的中间件
+     *
+     * @param callable $handler
+     * @return callable
+     */
+    public function __invoke(callable $handler): callable
+    {
+        return function (
+            RequestInterface $request,
+            array $options
+        ) use ($handler) {
+            $request = $request->withHeader("X-Request-ID", $this->uuid);
+            return $handler($request, $options);
+        };
+    }
+}
\ No newline at end of file

src/Option.php

+<?php
+
+namespace Jiwei\EasyHttpSdk;
+
+use GuzzleHttp\Psr7\Request;
+use http\Exception\InvalidArgumentException;
+
+abstract class Option
+{
+    const ENDPONIT_HOSTS = [
+        'local' => '',
+        'development' => '',
+        'production' => ''
+    ];
+    /** @var string App Key 应用标志 */
+    private $app_id;
+    /** @var string App Secret 应用密钥 */
+    private $app_secret;
+    /** @var string SDK 的 Stage 环境 */
+    private $stage = "development";
+    /** @var float 超时时间 */
+    private $time_out = 3.0;
+    /** @var bool 调试模式 */
+    private $debug = false;
+
+    /**
+     * @return \Closure
+     */
+    abstract public function getAuthMoudel(): \Closure;
+
+    /**
+     * @param string $app_id
+     * @return Option
+     */
+    public function setAppId(string $app_id): self
+    {
+        $this->app_id = $app_id;
+        return $this;
+    }
+
+    /**
+     * @param string $app_secret
+     * @return Option
+     */
+    public function setAppSecret(string $app_secret): self
+    {
+        $this->app_secret = $app_secret;
+        return $this;
+    }
+
+    /**
+     * @param string $stage
+     * @return Option
+     */
+    public function setStage(string $stage): self
+    {
+        $this->stage = $stage;
+        return $this;
+    }
+
+    /**
+     * @param float $time_out
+     * @return Option
+     */
+    public function setTimeout(float $time_out): self
+    {
+        $this->time_out = $time_out;
+        return $this;
+    }
+
+    /**
+     * @param bool $debug
+     * @return Option
+     */
+    public function setDebug(bool $debug): self
+    {
+        $this->debug = $debug;
+        return $this;
+    }
+
+    /**
+     * @return string
+     */
+    public function getAppSecret(): string
+    {
+        return $this->app_secret;
+    }
+
+    /**
+     * @return string
+     */
+    public function getBaseUrl(): string
+    {
+
+        return self::ENDPONIT_HOSTS[$this->getStage()] ?? "";
+    }
+
+    /**
+     * @return string
+     */
+    public function getStage(): string
+    {
+        return $this->stage;
+    }
+
+    /**
+     * @return float
+     */
+    public function getTimeOut(): float
+    {
+        return $this->time_out;
+    }
+
+    /**
+     * @return string
+     */
+    public function getAppId(): string
+    {
+        return $this->app_id;
+    }
+
+    /**
+     * @return bool
+     */
+    public function isDebug(): bool
+    {
+        return $this->debug;
+    }
+}

src/XXXSDKOption.php

+<?php
+
+namespace Jiwei\EasyHttpSdk;
+
+use GuzzleHttp\Psr7\Request;
+
+class XXXSDKOption extends Option
+{
+    private const AUTH_API_ROUTE = "/api/access/token";
+
+    const ENDPONIT_HOSTS = [
+        'local' => 'localhost:8080',
+        'development' => 'localhost:8080',
+        'production' => 'localhost:8080'
+    ];
+
+    public function getAuthMoudel(): \Closure
+    {
+        return function (string $appId, string $appSecret): Request {
+            return new Request('post', self::AUTH_API_ROUTE, [
+                "body" => json_encode([
+                    "app_key" => $appId,
+                    "app_secret" => $appSecret
+                ])
+            ]);
+        };
+
+    }
+}

template/Endpoint.temp

+{% autoescape false %}
+<?php
+// generated code, do not edit.
+declare(strict_types=1);
+
+namespace Jiwei\{{ Package }}\Endpoint;
+
+use Closure;
+use Jiwei\EasyHttpSdk\Application;
+use Jiwei\EasyHttpSdk\Exception\SdkException;
+use Jiwei\EasyHttpSdk\Exception\ApplicationException;
+use Jiwei\EasyHttpSdk\Exception\TimeOutExcetpion;
+use Jiwei\EasyHttpSdk\Helper\ArgsRecorder;
+use Jiwei\EasyHttpSdk\Helper\CallBackHelper;
+use Jiwei\EasyHttpSdk\Http\SdkRequest;
+
+
+class {{ Endpoint }}
+{
+    use ArgsRecorder;
+
+    use CallBackHelper;
+
+    /** @var Application */
+    protected $application;
+
+    /**
+     * @param Application $application
+     */
+    public function __construct(
+        Application $application
+    )
+    {
+        $this->application = $application;
+    }
+
+    {% for item in Func %}
+/**
+     * {{ item.Description }}
+     *
+     {% for param in item.Params %}
+* @param {{ param.type }} {{ param.name }}
+     {% endfor %}
+*
+     * @param Closure|null $catch
+     * @param Closure|null $then
+     * @return array
+     *
+     * @throws ApplicationException
+     * @throws SdkException
+     * @throws TimeOutExcetpion
+     */
+    public function {{ item.Action }}({{ item.Args }}?Closure $catch = null, ?Closure $then = null): mixed
+    {
+        $url = "{{ item.Uri }}";
+{% if item.Join|length > 0 %}
+        $url .= "?";
+{% endif%}
+{% for join in item.Join %}
+        if ({{ join.name }} != "") {
+            $url .= {{ join.query }};
+        }
+{% endfor %}
+        $request = new SdkRequest("{{ item.Method }}", $url, "{{ Endpoint }}", "{{ item.Action }}", []{{ item.Body }});
+
+        $request = $request->withArgs($this->ArgsRecoder(__METHOD__, func_get_args()))->withRequestID(){{ item.Middleware }};
+
+        try {
+            $response = $this->application->sendRequest($request);
+            $decodedData = $this->application->resultDecode($request, $response);
+            $this->setLastResult($decodedData);
+        } catch (SdkException $sdkException) {
+            $this->setLastException($sdkException);
+            $catch = $catch ?? $this->defaultFailedCallBack();
+            return $catch($this);
+        }
+        $then = $then ?? $this->defaultSuccessCallBack();
+        return $then($this);
+    }
+    {% endfor %}
+
+}
+{% endautoescape %}
\ No newline at end of file

tests/unit/BaseTest.php

+<?php
+
+use PHPUnit\Framework\TestCase;
+
+final class ApplicationTest extends TestCase
+{
+
+}
\ No newline at end of file