Merge pull request #2 from reallyli/add-pusher-component

添加 pusher 组件

Author: geekjourneyx

config/unicomponent.php

@@ -0,0 +1,38 @@
+<?php
+/**
+ * Created by PhpStorm.
+ * User: reallyli
+ * Date: 18/10/11
+ * Time: 下午2:06.
+ */
+
+return [
+    'components' => [
+        /*
+        |--------------------------------------------------------------------------
+        | Log Formatter
+        |--------------------------------------------------------------------------
+        |
+        | Log formatting
+        |
+        */
+        'log_formatter' => [
+            'provider' => \Reallyli\LaravelUnicomponent\Components\LogFormatter\LogFormatterService::class,
+            'configs' => [],
+        ],
+        /*
+        |--------------------------------------------------------------------------
+        | Pusher
+        |--------------------------------------------------------------------------
+        |
+        | Internal message push
+        |
+        */
+        'pusher' => [
+            'provider' => \Reallyli\LaravelUnicomponent\Components\Pusher\PusherService::class,
+            'configs' => [
+                'pusher_url' => env('UNICOMPONENT_PUSHER_URL'),
+            ],
+        ],
+    ],
+];

src/Components/Pusher/Pusher.php

@@ -0,0 +1,83 @@
+<?php
+/**
+ * Created by PhpStorm.
+ * User: uniqueway
+ * Date: 2018/11/20
+ * Time: 上午11:39.
+ */
+
+namespace Reallyli\LaravelUnicomponent\Components\Pusher;
+
+class Pusher
+{
+    /**
+     * trigger.
+     *
+     * @author reallyli <[email protected]>
+     * @since 2018/11/20
+     * @param mixed $channels
+     * @param string $eventName
+     * @param array $data
+     * @param array $params
+     * @return mixed
+     */
+    public function trigger($channels, string $eventName, array $data, array $params = [])
+    {
+        $params['channel'] = is_string($channels) ? [$channels] : (array) $channels;
+        $params['data'] = $data;
+        $params['name'] = $eventName;
+
+        $this->sendRequest($this->getPusherUrl(), $params);
+    }
+
+    /**
+     * Send Request.
+     *
+     * @author reallyli <[email protected]>
+     * @since 2018/11/20
+     * @param string $url
+     * @param array $data
+     * @return mixed
+     */
+    protected function sendRequest(string $url, array $data)
+    {
+        $ch = curl_init($url);
+        curl_setopt($ch, CURLOPT_CUSTOMREQUEST, 'POST');
+        curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($data));
+        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
+        curl_setopt(
+            $ch,
+            CURLOPT_HTTPHEADER,
+            [
+                'Content-Type: application/json',
+                'Content-Length: '.strlen($data),
+            ]
+        );
+
+        $response = curl_exec($ch);
+
+        if ($response === false) {
+            logger()->error('[LaravelUnicomponent] Pusher Send Request Error, data:'.json_encode($data));
+
+            return false;
+        }
+
+        return $response;
+    }
+
+    /**
+     * Get Pusher Url.
+     *
+     * @author reallyli <[email protected]>
+     * @since 2018/11/20
+     * @return string
+     */
+    protected function getPusherUrl()
+    {
+        $pusherUrl = config('unicomponent.pusher.configs.pusher_url');
+
+        throw_unless(filter_var($pusherUrl, FILTER_VALIDATE_URL), '\Exception', 'pusher url illegal');
+
+        return $pusherUrl;
+    }
+}

src/Components/Pusher/PusherService.php

@@ -0,0 +1,24 @@
+<?php
+/**
+ * Created by PhpStorm.
+ * User: uniqueway
+ * Date: 2018/11/20
+ * Time: 上午11:38.
+ */
+
+namespace Reallyli\LaravelUnicomponent\Components\Pusher;
+
+use Reallyli\LaravelUnicomponent\UnicomponentServiceInterface;
+
+class PusherService implements UnicomponentServiceInterface
+{
+    public function alias()
+    {
+        return 'pusher';
+    }
+
+    public function provider()
+    {
+        return Pusher::class;
+    }
+}

src/UnicomponentConfig.php

@@ -16,20 +16,20 @@ class UnicomponentServiceManager
     private $servicesComponents = [];
 
     /**
-     * @var array
+     * @var mixed
      */
     private $config;
 
     /**
-     * Method description:__construct.
+     * Construct.
      *
      * @author reallyli <[email protected]>
      * @since 18/10/11
-     * @param array $config
-     * @return mixed
+     * @param mixed $config
+     * @return void
      * 返回值类型：string，array，object，mixed（多种，不确定的），void（无返回值）
      */
-    public function __construct(array $config = [])
+    public function __construct($config)
     {
         $this->config = $config;
         $this->registerDefaultComponent();
@@ -65,8 +65,8 @@ public function registerDefaultComponent()
             return;
         }
 
-        foreach ($this->config['component_provider'] as $component) {
-            $this->registerComponent(new $component);
+        foreach ($this->config['components'] as $component) {
+            $this->registerComponent(new $component['provider']);
         }
     }
 
@@ -130,4 +130,17 @@ public function __call(string $method, array $parameters)
     {
         return $this->getServiceComponent($method);
     }
+
+    /**
+     * Method description:__get.
+     *
+     * @author reallyli <[email protected]>
+     * @since 2018/11/20
+     * @param string $componentName
+     * @return mixed
+     */
+    public function __get(string $componentName)
+    {
+        return $this->getServiceComponent($componentName);
+    }
 }

src/UnicomponentServiceManager.php

@@ -12,13 +12,23 @@
 
 class UnicomponentServiceProvider extends ServiceProvider
 {
+    /**
+     * Bootstrap the application services.
+     */
+    public function boot()
+    {
+        $this->publishes([
+            __DIR__.'/../config/unicomponent.php' => config_path('unicomponent.php'),
+        ], 'config');
+    }
+
     /**
      * @return void
      */
     public function register()
     {
-        $this->app->singleton('unicomponent', function () {
-            return new UnicomponentServiceManager(include_once(__DIR__.'/UnicomponentConfig.php'));
+        $this->app->singleton('unicomponent', function ($app) {
+            return new UnicomponentServiceManager($app['config']['unicomponent']);
         });
     }
 

src/UnicomponentServiceProvider.php

@@ -9,6 +9,7 @@
 namespace Reallyli\LaravelUnicomponent\Tests;
 
 use PHPUnit\Framework\TestCase;
+use Reallyli\LaravelUnicomponent\Components\Pusher\Pusher;
 use Reallyli\LaravelUnicomponent\UnicomponentServiceManager;
 use Reallyli\LaravelUnicomponent\Tests\Example\ExampleService;
 
@@ -19,13 +20,12 @@ class UnicomponentTest extends TestCase
      *
      * @author reallyli <[email protected]>
      * @since 18/10/11
-     * @param
      * @return mixed
      * 返回值类型：string，array，object，mixed（多种，不确定的），void（无返回值）
      */
     public function testRegisterComponent()
     {
-        $unicomponentServiceManager = new UnicomponentServiceManager();
+        $unicomponentServiceManager = new UnicomponentServiceManager([]);
 
         $unicomponentServiceManager->registerComponent(new ExampleService());
 
@@ -37,7 +37,6 @@ public function testRegisterComponent()
      *
      * @author reallyli <[email protected]>
      * @since 18/10/11
-     * @param
      * @return mixed
      * 返回值类型：string，array，object，mixed（多种，不确定的），void（无返回值）
      */
@@ -54,16 +53,15 @@ public function testConfigurationComponents()
      *
      * @author reallyli <[email protected]>
      * @since 18/10/11
-     * @param
      * @return mixed
      * 返回值类型：string，array，object，mixed（多种，不确定的），void（无返回值）
      */
     public function testGetComponent()
     {
-        $unicompoentConfig = include_once __DIR__.'/../src/UnicomponentConfig.php';
+        $unicompoentConfig = include_once __DIR__.'/../config/unicomponent.php';
 
         $unicomponentServiceManager = new UnicomponentServiceManager($unicompoentConfig);
 
-        $this->assertEquals(1, is_callable($unicomponentServiceManager->logFormatter()));
+        $this->assertInstanceOf(Pusher::class, $unicomponentServiceManager->pusher);
     }
 }

tests/UnicomponentTest.php

@@ -7,7 +7,10 @@
  */
 
 return [
-    'component_provider' => [
-       \Reallyli\LaravelUnicomponent\Tests\Example\ExampleService::class,
+    'components' => [
+        'example' => [
+            'provider' => \Reallyli\LaravelUnicomponent\Tests\Example\ExampleService::class,
+            'configs' => [],
+        ],
     ],
 ];