From 1eef6a7303c5474cdb058fa67294558df8124489 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Mr=C2=B7x?= <as2252258@163.com>
Date: Thu, 12 Aug 2021 15:53:31 +0800
Subject: [PATCH] =?UTF-8?q?=E6=94=B9=E5=90=8D?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 Annotation/Route/RpcProducer.php | 57 --------------------------------
 Annotation/Rpc/RpcClient.php     | 55 ------------------------------
 2 files changed, 112 deletions(-)
 delete mode 100644 Annotation/Route/RpcProducer.php
 delete mode 100644 Annotation/Rpc/RpcClient.php

diff --git a/Annotation/Route/RpcProducer.php b/Annotation/Route/RpcProducer.php
deleted file mode 100644
index cf0bfd82..00000000
--- a/Annotation/Route/RpcProducer.php
+++ /dev/null
@@ -1,57 +0,0 @@
-<?php
-
-
-namespace Annotation\Route;
-
-
-use Annotation\Attribute;
-use Exception;
-use HttpServer\Http\Request;
-use HttpServer\Route\Router;
-use JetBrains\PhpStorm\Pure;
-use Rpc\Actuator;
-use Kiri\Kiri;
-
-
-/**
- * Class RpcProducer
- * @package Annotation\Route
- */
-#[\Attribute(\Attribute::TARGET_METHOD)] class RpcProducer extends Attribute
-{
-
-    const PROTOCOL_JSON = 'json';
-    const PROTOCOL_SERIALIZE = 'serialize';
-
-
-    /**
-     * Route constructor.
-     * @param string $cmd
-     * @param string $protocol
-     * @param int $port
-     */
-    #[Pure] public function __construct(public string $cmd, public string $protocol = self::PROTOCOL_SERIALIZE, public int $port = 443)
-    {
-    }
-
-
-	/**
-	 * @param mixed $class
-	 * @param mixed|null $method
-	 * @return Router
-	 * @throws Exception
-	 */
-    public function execute(mixed $class, mixed $method = null): Router
-    {
-        // TODO: Implement setHandler() method.
-        $router = Kiri::app()->getRouter();
-        $cmd = $this->cmd;
-        $callback = function (Actuator $actuator) use ($cmd, $class, $method) {
-            $actuator->addListener($cmd, $class::class . '@' . $method);
-        };
-        $router->addRpcService($this->port, $callback);
-        return $router;
-    }
-
-
-}
diff --git a/Annotation/Rpc/RpcClient.php b/Annotation/Rpc/RpcClient.php
deleted file mode 100644
index cebec17c..00000000
--- a/Annotation/Rpc/RpcClient.php
+++ /dev/null
@@ -1,55 +0,0 @@
-<?php
-
-
-namespace Annotation\Rpc;
-
-
-use Annotation\Attribute;
-use Exception;
-use Kiri\Kiri;
-
-
-/**
- * Class RpcClient
- * @package Annotation\Rpc
- */
-#[\Attribute(\Attribute::TARGET_CLASS)] class RpcClient extends Attribute
-{
-
-    private array $config;
-
-
-    /**
-     * RpcClient constructor.
-     * @param string $cmd
-     * @param int $port
-     * @param int $timeout
-     * @param int $mode
-     */
-    public function __construct(
-        public string $cmd,
-        public int $port,
-        public int $timeout,
-        public int $mode
-    )
-    {
-        $this->config = ['port' => $port, 'mode' => $mode, 'timeout' => $timeout];
-    }
-
-
-	/**
-	 * @param mixed $class
-	 * @param mixed $method
-	 * @return bool
-	 * @throws Exception
-	 */
-    public function execute(mixed $class, mixed $method = ''): bool
-    {
-        $rpc = Kiri::app()->getRpc();
-        $rpc->addProducer($this->cmd, [$class, $method], $this->config);
-
-        return true;
-    }
-
-
-}