Merge pull request #16 from SDPM-lab/dev

Added Enhanced the getServiceData method.

Author: monkenWu

src/Exception/ActionException.php

@@ -117,6 +117,11 @@ public static function forServiceDataNotFound(string $serviceName): ActionExcept
         return new self("尚未定義 {$serviceName} 服務進服務列表內，請檢查服務的 serviceName 是否正確。");
     }
 
+    public static function forServiceDataCallbackTypeError(string $serviceName): ActionException
+    {
+        return new self("Action {$serviceName} 定義的回呼函數回傳型別錯誤，請檢查回傳型別是否為 \SDPMlab\Anser\Service\ServiceSettings 或 null。");
+    }
+
     /**
      * 取得發生錯誤的 Restponse 實體
      *

src/Service/ServiceList.php

@@ -4,7 +4,7 @@
 
 use SDPMlab\Anser\Service\ServiceSettings;
 use GuzzleHttp\HandlerStack;
-
+use SDPMlab\Anser\Exception\ActionException;
 class ServiceList
 {
 
@@ -22,6 +22,13 @@ class ServiceList
      */
     protected static $globalHandlerCallback = null;
 
+    /**
+     * ServiceList Update callback From Anser-Gateway 
+     *
+     * @var null|callable
+     */
+    protected static $serviceDataHandlerCallback = null;
+
     /**
      * Guzzle7 HTTP Client Instance
      *
@@ -57,6 +64,17 @@ public static function setGlobalHandlerStack(callable $handler)
         static::$globalHandlerCallback = $handler;
     }
 
+    /**
+     * Action will use this Handler to handle the Service Data.
+     *
+     * @param callable $handler
+     * @return void
+     */
+    public static function setServiceDataHandler(callable $handler)
+    {
+        static::$serviceDataHandlerCallback = $handler;
+    }
+
     /**
      * Add a new service to local service list.
      *
@@ -94,25 +112,33 @@ public static function getServiceList(): array
      */
     public static function getServiceData(string $serviceName): ?ServiceSettings
     {
-        if (filter_var($serviceName, FILTER_VALIDATE_URL) !== false) {
-            $parseUrl = parse_url($serviceName);
-            if(isset($parseUrl["port"])){
-                $port = (int)$parseUrl["port"];
-            }else{
-                $port = $parseUrl["scheme"] === "https" ? 443 : 80;
+        if(static::$serviceDataHandlerCallback === null){
+            if (filter_var($serviceName, FILTER_VALIDATE_URL) !== false) {
+                $parseUrl = parse_url($serviceName);
+                if(isset($parseUrl["port"])){
+                    $port = (int)$parseUrl["port"];
+                }else{
+                    $port = $parseUrl["scheme"] === "https" ? 443 : 80;
+                }
+                return new \SDPMlab\Anser\Service\ServiceSettings(
+                    $parseUrl["host"],
+                    $parseUrl["host"],
+                    $port,
+                    $parseUrl["scheme"] === "https"
+                );
+            }
+            
+            if (isset(static::$localServiceList[$serviceName])) {
+                return static::$localServiceList[$serviceName];
+            } else {
+                return null;
             }
-            return new \SDPMlab\Anser\Service\ServiceSettings(
-                $parseUrl["host"],
-                $parseUrl["host"],
-                $port,
-                $parseUrl["scheme"] === "https"
-            );
-        }
-        
-        if (isset(static::$localServiceList[$serviceName])) {
-            return static::$localServiceList[$serviceName];
         } else {
-            return null;
+            $callableResult = call_user_func(static::$serviceDataHandlerCallback);
+            if (!$callableResult instanceof ServiceSettings) {
+                throw ActionException::forServiceDataCallbackTypeError($serviceName);
+            }
+            return $callableResult; 
         }
     }