From e791b3b96e55f418e2380f362d5a1c69fde01819 Mon Sep 17 00:00:00 2001 From: mkm <727897186@qq.com> Date: Fri, 10 May 2024 11:34:06 +0800 Subject: [PATCH] =?UTF-8?q?=E6=9B=B4=E6=96=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- composer.json | 4 +- composer.lock | 138 ++- config/plugin/webman/push/app.php | 10 + config/plugin/webman/push/process.php | 21 + config/plugin/webman/push/route.php | 87 ++ vendor/composer/autoload_psr4.php | 1 + vendor/composer/autoload_static.php | 5 + vendor/composer/installed.json | 36 + vendor/composer/installed.php | 9 + vendor/webman/push/README.md | 74 ++ vendor/webman/push/composer.json | 13 + vendor/webman/push/src/Api.php | 240 +++++ vendor/webman/push/src/Install.php | 77 ++ vendor/webman/push/src/Server.php | 976 ++++++++++++++++++ .../src/config/plugin/webman/push/app.php | 10 + .../src/config/plugin/webman/push/process.php | 21 + .../src/config/plugin/webman/push/route.php | 87 ++ vendor/webman/push/src/push-uniapp.js | 827 +++++++++++++++ vendor/webman/push/src/push-vue.js | 732 +++++++++++++ vendor/webman/push/src/push.js | 746 +++++++++++++ 20 files changed, 4112 insertions(+), 2 deletions(-) create mode 100644 config/plugin/webman/push/app.php create mode 100644 config/plugin/webman/push/process.php create mode 100644 config/plugin/webman/push/route.php create mode 100644 vendor/webman/push/README.md create mode 100644 vendor/webman/push/composer.json create mode 100644 vendor/webman/push/src/Api.php create mode 100644 vendor/webman/push/src/Install.php create mode 100644 vendor/webman/push/src/Server.php create mode 100644 vendor/webman/push/src/config/plugin/webman/push/app.php create mode 100644 vendor/webman/push/src/config/plugin/webman/push/process.php create mode 100644 vendor/webman/push/src/config/plugin/webman/push/route.php create mode 100644 vendor/webman/push/src/push-uniapp.js create mode 100644 vendor/webman/push/src/push-vue.js create mode 100644 vendor/webman/push/src/push.js diff --git a/composer.json b/composer.json index bb1c52b..420118a 100644 --- a/composer.json +++ b/composer.json @@ -48,7 +48,9 @@ "next/var-dumper": "^0.1.0", "w7corp/easywechat": "^6.8", "hyperf/pimple": "~2.2.0", - "yansongda/pay": "~3.7.3" + "yansongda/pay": "~3.7.3", + "webman/redis-queue": "^1.3", + "webman/push": "^1.0" }, "suggest": { "ext-event": "For better performance. " diff --git a/composer.lock b/composer.lock index 9b5e309..ab857e6 100644 --- a/composer.lock +++ b/composer.lock @@ -4,7 +4,7 @@ "Read more about it at https://getcomposer.org/doc/01-basic-usage.md#installing-dependencies", "This file is @generated automatically" ], - "content-hash": "b985d5bd8942750003fe2a54df074341", + "content-hash": "0b26d49e6bf17b3ddf2200da03a8cc24", "packages": [ { "name": "aliyuncs/oss-sdk-php", @@ -6322,6 +6322,70 @@ }, "time": "2023-12-29T11:36:06+00:00" }, + { + "name": "webman/push", + "version": "v1.0.17", + "source": { + "type": "git", + "url": "https://github.com/webman-php/push.git", + "reference": "f87a588e6775a613a8cd2339bf90b76fdde626da" + }, + "dist": { + "type": "zip", + "url": "https://api.github.com/repos/webman-php/push/zipball/f87a588e6775a613a8cd2339bf90b76fdde626da", + "reference": "f87a588e6775a613a8cd2339bf90b76fdde626da", + "shasum": "" + }, + "require": { + "php": ">=7.2" + }, + "type": "library", + "autoload": { + "psr-4": { + "Webman\\Push\\": "src" + } + }, + "notification-url": "https://packagist.org/downloads/", + "license": [ + "MIT" + ], + "support": { + "issues": "https://github.com/webman-php/push/issues", + "source": "https://github.com/webman-php/push/tree/v1.0.17" + }, + "time": "2024-02-04T14:03:32+00:00" + }, + { + "name": "webman/redis-queue", + "version": "v1.3.2", + "source": { + "type": "git", + "url": "https://github.com/webman-php/redis-queue.git", + "reference": "80b9ddca0405bbb6d02e6b368e8036b3b1a13814" + }, + "dist": { + "type": "zip", + "url": "https://api.github.com/repos/webman-php/redis-queue/zipball/80b9ddca0405bbb6d02e6b368e8036b3b1a13814", + "reference": "80b9ddca0405bbb6d02e6b368e8036b3b1a13814", + "shasum": "" + }, + "require": { + "workerman/redis-queue": "^1.2" + }, + "type": "library", + "autoload": { + "psr-4": { + "Webman\\RedisQueue\\": "./src" + } + }, + "notification-url": "https://packagist.org/downloads/", + "description": "Redis message queue plugin for webman.", + "support": { + "issues": "https://github.com/webman-php/redis-queue/issues", + "source": "https://github.com/webman-php/redis-queue/tree/v1.3.2" + }, + "time": "2024-04-03T02:00:20+00:00" + }, { "name": "webman/think-orm", "version": "v1.1.1", @@ -6414,6 +6478,78 @@ }, "time": "2022-06-03T18:03:27+00:00" }, + { + "name": "workerman/redis", + "version": "v2.0.2", + "source": { + "type": "git", + "url": "https://github.com/walkor/redis.git", + "reference": "542f10c243ba846f1f3b4c07a26136c5fa80d972" + }, + "dist": { + "type": "zip", + "url": "https://api.github.com/repos/walkor/redis/zipball/542f10c243ba846f1f3b4c07a26136c5fa80d972", + "reference": "542f10c243ba846f1f3b4c07a26136c5fa80d972", + "shasum": "" + }, + "require": { + "php": ">=7", + "workerman/workerman": "^4.1.0||^5.0.0" + }, + "type": "library", + "autoload": { + "psr-4": { + "Workerman\\Redis\\": "./src" + } + }, + "notification-url": "https://packagist.org/downloads/", + "license": [ + "MIT" + ], + "homepage": "http://www.workerman.net", + "support": { + "issues": "https://github.com/walkor/redis/issues", + "source": "https://github.com/walkor/redis/tree/v2.0.2" + }, + "time": "2023-06-08T01:39:47+00:00" + }, + { + "name": "workerman/redis-queue", + "version": "v1.2.0", + "source": { + "type": "git", + "url": "https://github.com/walkor/redis-queue.git", + "reference": "7b6aee70d69e5c9427c0411d85f8398027831b42" + }, + "dist": { + "type": "zip", + "url": "https://api.github.com/repos/walkor/redis-queue/zipball/7b6aee70d69e5c9427c0411d85f8398027831b42", + "reference": "7b6aee70d69e5c9427c0411d85f8398027831b42", + "shasum": "" + }, + "require": { + "php": ">=7.0", + "workerman/redis": "^1.0||^2.0", + "workerman/workerman": ">=4.0.20" + }, + "type": "library", + "autoload": { + "psr-4": { + "Workerman\\RedisQueue\\": "./src" + } + }, + "notification-url": "https://packagist.org/downloads/", + "license": [ + "MIT" + ], + "description": "Message queue system written in PHP based on workerman and backed by Redis.", + "homepage": "http://www.workerman.net", + "support": { + "issues": "https://github.com/walkor/redis-queue/issues", + "source": "https://github.com/walkor/redis-queue/tree/v1.2.0" + }, + "time": "2024-02-28T07:00:03+00:00" + }, { "name": "workerman/webman-framework", "version": "v1.5.16", diff --git a/config/plugin/webman/push/app.php b/config/plugin/webman/push/app.php new file mode 100644 index 0000000..6a0c847 --- /dev/null +++ b/config/plugin/webman/push/app.php @@ -0,0 +1,10 @@ + true, + 'websocket' => 'websocket://0.0.0.0:3131', + 'api' => 'http://0.0.0.0:3232', + 'app_key' => '2ce3ce22329517213caa7dad261f5695', + 'app_secret' => 'e77d30638dfc7776e2d41121797bf2b2', + 'channel_hook' => 'http://127.0.0.1:8787/plugin/webman/push/hook', + 'auth' => '/plugin/webman/push/auth' +]; \ No newline at end of file diff --git a/config/plugin/webman/push/process.php b/config/plugin/webman/push/process.php new file mode 100644 index 0000000..01c545d --- /dev/null +++ b/config/plugin/webman/push/process.php @@ -0,0 +1,21 @@ + [ + 'handler' => Server::class, + 'listen' => config('plugin.webman.push.app.websocket'), + 'count' => 1, // 必须是1 + 'reloadable' => false, // 执行reload不重启 + 'constructor' => [ + 'api_listen' => config('plugin.webman.push.app.api'), + 'app_info' => [ + config('plugin.webman.push.app.app_key') => [ + 'channel_hook' => config('plugin.webman.push.app.channel_hook'), + 'app_secret' => config('plugin.webman.push.app.app_secret'), + ], + ] + ] + ] +]; \ No newline at end of file diff --git a/config/plugin/webman/push/route.php b/config/plugin/webman/push/route.php new file mode 100644 index 0000000..ea54c37 --- /dev/null +++ b/config/plugin/webman/push/route.php @@ -0,0 +1,87 @@ + + * @copyright walkor + * @link http://www.workerman.net/ + * @license http://www.opensource.org/licenses/mit-license.php MIT License + */ + +use support\Request; +use Webman\Route; +use Webman\Push\Api; + +/** + * 推送js客户端文件 + */ +Route::get('/plugin/webman/push/push.js', function (Request $request) { + return response()->file(base_path().'/vendor/webman/push/src/push.js'); +}); + +/** + * 私有频道鉴权，这里应该使用session辨别当前用户身份，然后确定该用户是否有权限监听channel_name + */ +Route::post(config('plugin.webman.push.app.auth'), function (Request $request) { + $pusher = new Api(str_replace('0.0.0.0', '127.0.0.1', config('plugin.webman.push.app.api')), config('plugin.webman.push.app.app_key'), config('plugin.webman.push.app.app_secret')); + $channel_name = $request->post('channel_name'); + $session = $request->session(); + // 这里应该通过session和channel_name判断当前用户是否有权限监听channel_name + $has_authority = true; + if ($has_authority) { + return response($pusher->socketAuth($channel_name, $request->post('socket_id'))); + } else { + return response('Forbidden', 403); + } +}); + +/** + * 当频道上线以及下线时触发的回调 + * 频道上线：是指某个频道从没有连接在线到有连接在线的事件 + * 频道下线：是指某个频道的所有连接都断开触发的事件 + */ +Route::post(parse_url(config('plugin.webman.push.app.channel_hook'), PHP_URL_PATH), function (Request $request) { + + // 没有x-pusher-signature头视为伪造请求 + if (!$webhook_signature = $request->header('x-pusher-signature')) { + return response('401 Not authenticated', 401); + } + + $body = $request->rawBody(); + + // 计算签名，$app_secret 是双方使用的密钥，是保密的，外部无从得知 + $expected_signature = hash_hmac('sha256', $body, config('plugin.webman.push.app.app_secret'), false); + + // 安全校验，如果签名不一致可能是伪造的请求，返回401状态码 + if ($webhook_signature !== $expected_signature) { + return response('401 Not authenticated', 401); + } + + // 这里存储这上线 下线的channel数据 + $payload = json_decode($body, true); + + $channels_online = $channels_offline = []; + + foreach ($payload['events'] as $event) { + if ($event['name'] === 'channel_added') { + $channels_online[] = $event['channel']; + } else if ($event['name'] === 'channel_removed') { + $channels_offline[] = $event['channel']; + } + } + + // 业务根据需要处理上下线的channel，例如将在线状态写入数据库，通知其它channel等 + // 上线的所有channel + echo 'online channels: ' . implode(',', $channels_online) . "\n"; + // 下线的所有channel + echo 'offline channels: ' . implode(',', $channels_offline) . "\n"; + + return 'OK'; +}); + + + diff --git a/vendor/composer/autoload_psr4.php b/vendor/composer/autoload_psr4.php index 5aaad5a..70c6d79 100644 --- a/vendor/composer/autoload_psr4.php +++ b/vendor/composer/autoload_psr4.php @@ -22,6 +22,7 @@ return array( 'Webmozart\\Assert\\' => array($vendorDir . '/webmozart/assert/src'), 'Webman\\ThinkOrm\\' => array($vendorDir . '/webman/think-orm/src'), 'Webman\\RedisQueue\\' => array($vendorDir . '/webman/redis-queue/src'), + 'Webman\\Push\\' => array($vendorDir . '/webman/push/src'), 'Webman\\Log\\' => array($vendorDir . '/webman/log/src'), 'Webman\\Console\\' => array($vendorDir . '/webman/console/src'), 'Webman\\' => array($vendorDir . '/workerman/webman-framework/src'), diff --git a/vendor/composer/autoload_static.php b/vendor/composer/autoload_static.php index 976c0d9..6208a9e 100644 --- a/vendor/composer/autoload_static.php +++ b/vendor/composer/autoload_static.php @@ -80,6 +80,7 @@ class ComposerStaticInitb985d5bd8942750003fe2a54df074341 'Webmozart\\Assert\\' => 17, 'Webman\\ThinkOrm\\' => 16, 'Webman\\RedisQueue\\' => 18, + 'Webman\\Push\\' => 12, 'Webman\\Log\\' => 11, 'Webman\\Console\\' => 15, 'Webman\\' => 7, @@ -282,6 +283,10 @@ class ComposerStaticInitb985d5bd8942750003fe2a54df074341 array ( 0 => __DIR__ . '/..' . '/webman/redis-queue/src', ), + 'Webman\\Push\\' => + array ( + 0 => __DIR__ . '/..' . '/webman/push/src', + ), 'Webman\\Log\\' => array ( 0 => __DIR__ . '/..' . '/webman/log/src', diff --git a/vendor/composer/installed.json b/vendor/composer/installed.json index 911aed5..224a393 100644 --- a/vendor/composer/installed.json +++ b/vendor/composer/installed.json @@ -6592,6 +6592,42 @@ }, "install-path": "../webman/log" }, + { + "name": "webman/push", + "version": "v1.0.17", + "version_normalized": "1.0.17.0", + "source": { + "type": "git", + "url": "https://github.com/webman-php/push.git", + "reference": "f87a588e6775a613a8cd2339bf90b76fdde626da" + }, + "dist": { + "type": "zip", + "url": "https://api.github.com/repos/webman-php/push/zipball/f87a588e6775a613a8cd2339bf90b76fdde626da", + "reference": "f87a588e6775a613a8cd2339bf90b76fdde626da", + "shasum": "" + }, + "require": { + "php": ">=7.2" + }, + "time": "2024-02-04T14:03:32+00:00", + "type": "library", + "installation-source": "dist", + "autoload": { + "psr-4": { + "Webman\\Push\\": "src" + } + }, + "notification-url": "https://packagist.org/downloads/", + "license": [ + "MIT" + ], + "support": { + "issues": "https://github.com/webman-php/push/issues", + "source": "https://github.com/webman-php/push/tree/v1.0.17" + }, + "install-path": "../webman/push" + }, { "name": "webman/redis-queue", "version": "v1.3.2", diff --git a/vendor/composer/installed.php b/vendor/composer/installed.php index eb274d9..f1b679f 100644 --- a/vendor/composer/installed.php +++ b/vendor/composer/installed.php @@ -929,6 +929,15 @@ 'aliases' => array(), 'dev_requirement' => false, ), + 'webman/push' => array( + 'pretty_version' => 'v1.0.17', + 'version' => '1.0.17.0', + 'reference' => 'f87a588e6775a613a8cd2339bf90b76fdde626da', + 'type' => 'library', + 'install_path' => __DIR__ . '/../webman/push', + 'aliases' => array(), + 'dev_requirement' => false, + ), 'webman/redis-queue' => array( 'pretty_version' => 'v1.3.2', 'version' => '1.3.2.0', diff --git a/vendor/webman/push/README.md b/vendor/webman/push/README.md new file mode 100644 index 0000000..344eaec --- /dev/null +++ b/vendor/webman/push/README.md @@ -0,0 +1,74 @@ +# push +webman push plugin +具体使用请看：https://www.workerman.net/plugin/2 + +## js文件说明 + +--- + +```sh + push-uniapp.js #适用于uniapp项目内使用 + push-vue.js #适用于vue项目内使用 + push.js #适用于直接引入js常规项目内使用 +``` + +### push-vue.js 使用说明 + +--- + +1、将文件 push-vue.js复制到项目目录下，如：src/utils/push-vue.js + +2、在vue页面内引入 +```js + + + +``` + + + diff --git a/vendor/webman/push/composer.json b/vendor/webman/push/composer.json new file mode 100644 index 0000000..4f162b3 --- /dev/null +++ b/vendor/webman/push/composer.json @@ -0,0 +1,13 @@ +{ + "name": "webman/push", + "type": "library", + "license": "MIT", + "require": { + "php": ">=7.2" + }, + "autoload": { + "psr-4": { + "Webman\\Push\\": "src" + } + } +} \ No newline at end of file diff --git a/vendor/webman/push/src/Api.php b/vendor/webman/push/src/Api.php new file mode 100644 index 0000000..56e4442 --- /dev/null +++ b/vendor/webman/push/src/Api.php @@ -0,0 +1,240 @@ + 2, + ]; + + /** + * @param $api_address + * @param $auth_key + * @param $secret + * @throws PushException + */ + public function __construct($api_address, $auth_key, $secret) + { + $this->checkCompatibility(); + $this->_settings['api_address'] = $api_address; + $this->_settings['auth_key'] = $auth_key; + $this->_settings['secret'] = $secret; + $this->_settings['base_path'] = '/apps/1024'; + } + + /** + * trigger an event by providing event name and payload. + * Optionally provide a socket ID to exclude a client (most likely the sender). + * + * @param array|string $channels An array of channel names to publish the event on. + * @param string $event + * @param mixed $data Event data + * @param string $socket_id [optional] + * @return bool|string + */ + public function trigger($channels, $event, $data, $socket_id = null) + { + if (is_string($channels)) { + $channels = array($channels); + } + $query_params = array(); + $s_url = $this->_settings['base_path'] . '/events'; + $data_encoded = json_encode($data); + $post_params = array(); + $post_params['name'] = $event; + $post_params['data'] = $data_encoded; + $post_params['channels'] = $channels; + if ($socket_id !== null) { + $post_params['socket_id'] = $socket_id; + } + $post_value = json_encode($post_params); + $query_params['body_md5'] = md5($post_value); + $ch = $this->createCurl($this->_settings['api_address'], $s_url, 'POST', $query_params); + curl_setopt($ch, CURLOPT_POSTFIELDS, $post_value); + $response = $this->execCurl($ch); + if ($response['status'] === 200) { + return true; + } else { + return false; + } + } + + public function getChannelInfo($channel, $params = array()) + { + $this->validateChannel($channel); + + $response = $this->get('/channels/' . $channel, $params); + + if ($response['status'] === 200) { + $response = json_decode($response['body']); + } else { + $response = false; + } + + return $response; + } + + public function getChannels($params = array()) + { + return $this->get('/channels', $params); + } + + private function checkCompatibility() + { + if (!in_array('sha256', hash_algos())) { + throw new PushException('SHA256 appears to be unsupported - make sure you have support for it, or upgrade your version of PHP.'); + } + } + + private function validateChannel($channel) + { + if (!preg_match('/\A[-a-zA-Z0-9_=@,.;]+\z/', $channel)) { + throw new PushException('Invalid channel name ' . $channel); + } + } + + private function validateSocketId($socket_id) + { + if ($socket_id !== null && !preg_match('/\A\d+\.\d+\z/', $socket_id)) { + throw new PushException('Invalid socket ID ' . $socket_id); + } + } + + private function createCurl($domain, $s_url, $request_method = 'GET', $query_params = array()) + { + static $ch = null; + $signed_query = self::buildAuthQueryString( + $this->_settings['auth_key'], + $this->_settings['secret'], + $request_method, + $s_url, + $query_params); + + $full_url = $domain . $s_url . '?' . $signed_query; + + if (null === $ch) { + $ch = curl_init(); + if ($ch === false) { + throw new PushException('Could not initialise cURL!'); + } + } + + if (function_exists('curl_reset')) { + curl_reset($ch); + } + + curl_setopt($ch, CURLOPT_URL, $full_url); + curl_setopt($ch, CURLOPT_HTTPHEADER, array( + 'Content-Type: application/json', + 'Expect:', + )); + curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1); + curl_setopt($ch, CURLOPT_TIMEOUT, $this->_settings['timeout']); + if ($request_method === 'POST') { + curl_setopt($ch, CURLOPT_POST, 1); + } elseif ($request_method === 'GET') { + curl_setopt($ch, CURLOPT_POST, 0); + } // Otherwise let the user configure it + + return $ch; + } + + private function execCurl($ch) + { + $response = array(); + $response['body'] = curl_exec($ch); + $response['status'] = curl_getinfo($ch, CURLINFO_HTTP_CODE); + return $response; + } + + public static function buildAuthQueryString($auth_key, $auth_secret, $request_method, $request_path, + $query_params = array()) + { + $params = array(); + $params['auth_key'] = $auth_key; + $params['auth_timestamp'] = time(); + + $params = array_merge($params, $query_params); + ksort($params); + + $string_to_sign = "$request_method\n" . $request_path . "\n" . self::arrayImplode('=', '&', $params); + + $auth_signature = hash_hmac('sha256', $string_to_sign, $auth_secret, false); + + $params['auth_signature'] = $auth_signature; + ksort($params); + + $auth_query_string = self::arrayImplode('=', '&', $params); + + return $auth_query_string; + } + + public static function arrayImplode($glue, $separator, $array) + { + if (!is_array($array)) { + return $array; + } + $string = array(); + foreach ($array as $key => $val) { + if (is_array($val)) { + $val = implode(',', $val); + } + $string[] = "{$key}{$glue}{$val}"; + } + + return implode($separator, $string); + } + + public function get($path, $params = array()) + { + $ch = $this->createCurl($this->_settings['api_address'], $this->_settings['base_path'] . $path, 'GET', $params); + + $response = $this->execCurl($ch); + + if ($response['status'] === 200) { + $response['result'] = json_decode($response['body'], true); + } + + return $response; + } + + public function socketAuth($channel, $socket_id, $custom_data = null) + { + $this->validateChannel($channel); + $this->validateSocketId($socket_id); + + if ($custom_data) { + $signature = hash_hmac('sha256', $socket_id . ':' . $channel . ':' . $custom_data, $this->_settings['secret'], false); + } else { + $signature = hash_hmac('sha256', $socket_id . ':' . $channel, $this->_settings['secret'], false); + } + + $signature = array('auth' => $this->_settings['auth_key'] . ':' . $signature); + if ($custom_data) { + $signature['channel_data'] = $custom_data; + } + + return json_encode($signature); + } + + public function presenceAuth($channel, $socket_id, $user_id, $user_info = null) + { + $user_data = array('user_id' => $user_id); + if ($user_info) { + $user_data['user_info'] = $user_info; + } + + return $this->socketAuth($channel, $socket_id, json_encode($user_data)); + } +} + +class PushException extends \Exception +{ +} diff --git a/vendor/webman/push/src/Install.php b/vendor/webman/push/src/Install.php new file mode 100644 index 0000000..d1c2337 --- /dev/null +++ b/vendor/webman/push/src/Install.php @@ -0,0 +1,77 @@ + 'config/plugin/webman/push' + ]; + + /** + * Install + * @return void + */ + public static function install() + { + $config_app_path = __DIR__ . '/config/plugin/webman/push/app.php'; + $config_app_content = file_get_contents($config_app_path); + $app_key = md5(microtime(true).rand(0, 2100000000)); + $app_secret = md5($app_key.rand(0, 2100000000)); + $config_app_content = str_replace([ + 'APP_KEY_TO_REPLACE', + 'APP_SECRET_TO_REPLACE' + ], [$app_key, $app_secret], $config_app_content); + file_put_contents($config_app_path, $config_app_content); + static::installByRelation(); + } + + /** + * Uninstall + * @return void + */ + public static function uninstall() + { + self::uninstallByRelation(); + } + + /** + * installByRelation + * @return void + */ + public static function installByRelation() + { + foreach (static::$pathRelation as $source => $dest) { + if ($pos = strrpos($dest, '/')) { + $parent_dir = base_path().'/'.substr($dest, 0, $pos); + if (!is_dir($parent_dir)) { + mkdir($parent_dir, 0777, true); + } + } + //symlink(__DIR__ . "/$source", base_path()."/$dest"); + copy_dir(__DIR__ . "/$source", base_path()."/$dest"); + } + } + + /** + * uninstallByRelation + * @return void + */ + public static function uninstallByRelation() + { + foreach (static::$pathRelation as $source => $dest) { + $path = base_path()."/$dest"; + if (!is_dir($path) && !is_file($path)) { + continue; + } + /*if (is_link($path) { + unlink($path); + }*/ + remove_dir($path); + } + } +} diff --git a/vendor/webman/push/src/Server.php b/vendor/webman/push/src/Server.php new file mode 100644 index 0000000..e711439 --- /dev/null +++ b/vendor/webman/push/src/Server.php @@ -0,0 +1,976 @@ + + * @copyright walkor + * @link http://www.workerman.net/ + * @license http://www.opensource.org/licenses/mit-license.php MIT License + */ + +namespace Webman\Push; + +use Workerman\Connection\AsyncTcpConnection; +use Workerman\Connection\TcpConnection; +use Workerman\Protocols\Http\Request; +use Workerman\Protocols\Http\Response; +use Workerman\Timer; +use Workerman\Worker; + + +class Server +{ + /** + * 应用信息 + * + * @var array + */ + public $appInfo = []; + + /** + * 心跳时间 + * + * @var int + */ + public $keepAliveTimeout = 60; + + /** + * api监听的ip端口 + * + * @var string + */ + public $apiListen = 'http://0.0.0.0:1080'; + + /** + * webhook 延迟设置 + * + * @var int + */ + public $webHookDelay = 3; + + /** + * @var array + */ + protected $_globalDataSnapshot = []; + + /** + * 事件对应的客户端链接 + * + * @var array + */ + protected $_eventClients = []; + + /** + * 所有的客户端链接 + * + * @var array + */ + protected $_allClients = []; + + /** + * array( + * 'app_key1' => array( + * 'channel1' => array( + * 'users' => array( + * 'uid1' => array('user_info'=>[], 'ref_count' => x), + * 'uid2' => array('user_info'=>[], 'ref_count' => x), + * ), + * 'type' => 'presence', + * 'subscription_count' => x + * ), + * 'channel2' => array( + * 'users' => array( + * 'uid3' => array('user_info'=>[], 'ref_count' => x) + * ), + * 'type' => 'presence', + * 'subscription_count' => x + * ), + * ), + * 'app_key2' => array( + * 'channel1' => array( + * 'type' => 'private', + * 'subscription_count' => x + * ), + * 'channel2' => array( + * 'type' => 'public', + * 'subscription_count' => x + * ), + * ) + * ) + * @var array + */ + protected $_globalData = []; + + /** + * 当前进程全局唯一订阅id + * + * @var string + */ + protected $_globalID = 1; + + /** + * 构造函数 + * + * @param string $socket_name + * @param array $context + */ + public function __construct($api_listen, $app_info) + { + $this->apiListen = $api_listen; + $this->appInfo = $app_info; + } + + /** + * @param $worker + * @return void + * @throws \Exception + */ + public function onWorkerStart($worker) + { + $api_worker = new Worker($this->apiListen); + $api_worker->onMessage = array($this, 'onApiClientMessage'); + $api_worker->listen(); + Timer::add($this->keepAliveTimeout/2, array($this, 'checkHeartbeat')); + Timer::add($this->webHookDelay, array($this, 'webHookCheck')); + } + + /** + * 客户端连接后 + * + * @param $connection + */ + public function onConnect($connection) { + // 客户端有多少次没在规定时间发送心跳 + $connection->clientNotSendPingCount = 0; + // 设置websocket握手事件回调 + $connection->onWebSocketConnect = array($this, 'onWebSocketConnect'); + } + + /** + * 当websocket握手时 + * @param $connection + * @return mixed + */ + public function onWebSocketConnect(TcpConnection $connection, $header) + { + // /app/1234567890abcdefghig?protocol=7&client=js&version=3.2.4&flash=false + if (!preg_match('/\/app\/([^\/^\?^ ]+)/', (string)$header, $match)) { + echo "app_key not found\n$header\n"; + $connection->pauseRecv(); + return; + } + + $app_key = $match[1]; + if (!isset($this->appInfo[$app_key])) { + echo "Invalid app_key $app_key\n"; + $connection->pauseRecv(); + return; + } + $socket_id = $this->createsocketID($connection); + $connection->appKey = $app_key; + $connection->socketID = $socket_id; + $connection->channels = array(''=>''); + $connection->channelUidMap = []; + $connection->clientNotSendPingCount = 0; + $this->_eventClients[$app_key][''][$socket_id] = $connection; + $this->_allClients[$socket_id] = $connection; + + /* + * 向客户端发送链接成功的消息 + * {"event":"pusher:connection_established","data":"{\"socket_id\":\"208836.27464492\",\"activity_timeout\":120}"} + */ + $data = array( + 'event' => 'pusher:connection_established', + 'data' => json_encode(array( + 'socket_id' => $socket_id, + 'activity_timeout' => 55 + )) + ); + + $connection->send(json_encode($data)); + } + + /** + * 客户端关闭链接时 + * + * @param $connection + */ + public function onClose($connection) + { + if (!isset($connection->socketID)) { + return; + } + $socket_id = $connection->socketID; + $app_key = $connection->appKey; + unset($this->_allClients[$socket_id]); + unset($this->_eventClients[$app_key][''][$socket_id]); + + if (isset($connection->channels)) { + $app_key = $connection->appKey; + foreach ($connection->channels as $channel => $uid) { + if ('' === $channel) { + continue; + } + if ($uid === '') { + $this->unsubscribePublicChannel($connection, $channel); + } else { + $this->unsubscribePresenceChannel($connection, $channel, $uid); + } + unset($this->_eventClients[$app_key][$channel][$socket_id]); + } + } + } + + /** + * 客户端发来消息时 + * + * @param $connection + * @param $data + * + * @return void + */ + public function onMessage($connection, $data) + { + $connection->clientNotSendPingCount = 0; + $data = json_decode($data, true); + if (!$data) { + return; + } + if (!isset($data['event'])) { + $connection->send($this->error(null, 'Empty event')); + return; + } + $event = $data['event']; + switch ($event) { + case 'pusher:ping': + $connection->send('{"event":"pusher:pong","data":"{}"}'); + return; + // {"event":"pusher:subscribe","data":{"channel":"my-channel"}} + case 'pusher:subscribe': + $channel = $data['data']['channel']; + // private- 和 presence- 开头的channel需要验证 + $channel_type = $this->getChannelType($channel); + if ($channel_type === 'presence') { + // {"event":"pusher:subscribe","data":{"auth":"b054014693241bcd9c26:10e3b628cb78e8bc4d1f44d47c9294551b446ae6ec10ef113d3d7e84e99763e6","channel_data":"{\"user_id\":100,\"user_info\":{\"name\":\"123\"}}","channel":"presence-channel"}} + $client_auth = $data['data']['auth']; + + if (!isset($data['data']['channel_data'])) { + $connection->send($this->error(null, 'Empty channel_data')); + return; + } + $auth = $connection->appKey.':'.hash_hmac('sha256', $connection->socketID.':'.$channel.':'.$data['data']['channel_data'], $this->appInfo[$connection->appKey]['app_secret'], false); + + // {"event":"pusher:error","data":{"code":null,"message":"Received invalid JSON"}} + if ($client_auth !== $auth) { + return $connection->send($this->error(null, 'Received invalid Auth '.$auth)); + } + $user_data = json_decode($data['data']['channel_data'], true); + if (!$user_data || !isset($user_data['user_id']) || !isset($user_data['user_info'])) { + $connection->send($this->error(null, 'Bad channel_data')); + return; + } + + $this->subscribePresence($connection, $channel, $user_data['user_id'], $user_data['user_info']); + return; + + } elseif($channel_type === 'private') { + // {"event":"pusher:subscribe","data":{"auth":"b054014693241bcd9c26:10e3b628cb78e8bc4d1f44d47c9294551b446ae6ec10ef113d3d7e84e99763e6","channel_data":"{\"user_id\":100,\"user_info\":{\"name\":\"123\"}}","channel":"presence-channel"}} + $client_auth = $data['data']['auth']; + $auth = $connection->appKey.':'.hash_hmac('sha256', $connection->socketID.':'.$channel, $this->appInfo[$connection->appKey]['app_secret'], false); + // {"event":"pusher:error","data":{"code":null,"message":"Received invalid Auth"}} + if ($client_auth !== $auth) { + return $connection->send($this->error(null, 'Received invalid Auth '.$auth)); + } + $this->subscribePrivateChannel($connection, $channel); + } else { + $this->subscribePublicChannel($connection, $channel); + } + + // {"event":"pusher_internal:subscription_succeeded","data":"{}","channel":"my-channel"} + $connection->send(json_encode( + array( + 'event' => 'pusher_internal:subscription_succeeded', + 'data' => '{}', + 'channel' => $channel + ), JSON_UNESCAPED_UNICODE + )); + return; + // {"event":"pusher:unsubscribe","data":{"channel":"my-channel"}} + case 'pusher:unsubscribe': + $app_key = $connection->appKey; + $channel = $data['data']['channel']; + $channel_type = $this->getChannelType($channel); + switch ($channel_type) { + case 'public': + $this->unsubscribePublicChannel($connection, $channel); + break; + case 'private': + $this->unsubscribePrivateChannel($connection, $channel); + break; + case 'presence': + $uid = $connection->channels[$channel]; + $this->unsubscribePresenceChannel($connection, $channel, $uid); + break; + } + return; + + // {"event":"client-event","data":{"your":"hi"},"channel":"presence-channel"} + default: + if (strpos($event, 'pusher:') === 0) { + return $connection->send($this->error(null, 'Unknown event')); + } + if (!isset($data['channel'])) { + $connection->send($this->error(null, 'Empty channel')); + return; + } + $channel = $data['channel']; + // 客户端触发事件必须是private 或者 presence的channel + $channel_type = $this->getChannelType($channel); + if ($channel_type !== 'private' && $channel_type !== 'presence') { + // {"event":"pusher:error","data":{"code":null,"message":"Client event rejected - only supported on private and presence channels"}} + return $connection->send($this->error(null, 'Client event rejected - only supported on private and presence channels')); + } + // 当前链接没有订阅这个channel + if (!isset($connection->channels[$channel])) { + return $connection->send($this->error(null, 'Client event rejected - you didn\'t subscribe this channel')); + } + // 事件必须以client-为前缀 + if (strpos($event, 'client-') !== 0) { + return $connection->send($this->error(null, 'Client event rejected - client events must be prefixed by \'client-\'')); + } + + // @todo 检查是否设置了可前端发布事件 + // {"event":"pusher:error","data":{"code":null,"message":"To send client events, you must enable this feature in the Settings page of your dashboard."}} + // 全局发布事件 + $this->publishToClients($connection->appKey, $channel, $event, json_encode($data['data'], JSON_UNESCAPED_UNICODE), $connection->socketID); + } + } + + + /** + * 获得channel类型 + * + * @param $channel + * @return string + */ + protected function getChannelType($channel) { + if (strpos($channel, 'private-') === 0) { + return 'private'; + } elseif (strpos($channel, 'presence-') === 0) { + return 'presence'; + } + return 'public'; + } + + /** + * 组装失败信息 + * + * @param $code + * @param $message + * @return string + */ + protected function error($code, $message) + { + return json_encode(array('event'=>'pusher:error', 'data' => array('code' => $code, 'message' => $message)), JSON_UNESCAPED_UNICODE); + } + + + /** + * 客户端订阅channel + * + * @param $connection + * @param $channel + * + * @return void + */ + public function subscribePublicChannel($connection, $channel) { + $app_key = $connection->appKey; + $connection->channels[$channel] = ''; + $this->_eventClients[$app_key][$channel][$connection->socketID] = $connection; + + if (!isset($this->_globalData[$app_key][$channel])) { + $this->_globalData[$app_key][$channel] = array( + 'type' => 'presence', + 'subscription_count' => 0 + ); + } + + $this->_globalData[$app_key][$channel]['subscription_count'] += 1; + } + + /** + * 客户端订阅channel + * + * @param $connection + * @param $channel + * + * @return void + */ + public function subscribePrivateChannel($connection, $channel) { + $this->subscribePublicChannel($connection, $channel); + } + + /** + * 客户端订阅channel + * + * @param $connection + * @param $channel + * + * @return void + */ + public function subscribePresence($connection, $channel, $uid, $user_info) { + $app_key = $connection->appKey; + $connection->channels[$channel] = $uid; + $this->_eventClients[$app_key][$channel][$connection->socketID] = $connection; + + if (!isset($this->_globalData[$app_key][$channel])) { + $this->_globalData[$app_key][$channel] = array( + 'type' => 'presence', + 'users' => [], + 'subscription_count' => 0 + ); + } + $this->_globalData[$app_key][$channel]['subscription_count'] += 1; + + $member_added = false; + if (!isset($this->_globalData[$app_key][$channel]['users'][$uid]['user_info'])) { + $this->_globalData[$app_key][$channel]['users'][$uid] = array('user_info'=>$user_info, 'ref_count' => 0); + $member_added = true; + } + $this->_globalData[$app_key][$channel]['users'][$uid]['ref_count'] += 1; + + + $presence_data = $this->getPresenceChannelDataForSubscribe($app_key, $channel); + if ($member_added) { + // {"event":"pusher_internal:member_added","data":"{\"user_id\":1488465780,\"user_info\":{\"name\":\"123\",\"sex\":\"1\"}}","channel":"presence-channel"} + $this->publishToClients($app_key, $channel, 'pusher_internal:member_added', json_encode(array( + 'user_id' => $uid, + 'user_info' => $user_info + ), JSON_UNESCAPED_UNICODE), $connection->socketID); + } + + // {"event":"pusher_internal:subscription_succeeded","data":"{\"presence\":{\"count\":2,\"ids\":[\"1488465780\",\"14884657802\"],\"hash\":{\"1488465780\":{\"name\":\"123\",\"sex\":\"1\"},\"14884657802\":{\"name\":\"123\",\"sex\":\"1\"}}}}","channel":"presence-channel"} + $connection->send(json_encode(array( + 'event' => 'pusher_internal:subscription_succeeded', + 'data' => json_encode($presence_data), + 'channel' => $channel + ),JSON_UNESCAPED_UNICODE + )); + } + + + public function getPresenceChannelDataForSubscribe($app_key, $channel) + { + $hash = []; + $count = 100; + if (isset($this->_globalData[$app_key][$channel])) { + foreach ($this->_globalData[$app_key][$channel]['users'] as $uid => $item) { + $hash[$uid] = $item['user_info']; + if ($count-- <= 0) { + break; + } + } + //$hash = array_slice($this->_globalData[$app_key][$channel]['users'], 0, 100, true); + } + return array( + 'presence' => array( + 'count' => count($this->_globalData[$app_key][$channel]['users']), + 'ids' => array_keys($hash), + 'hash' => $hash + ) + ); + } + + /** + * 客户端取消订阅channel + * + * @param $connection + * @param $channel + * + * @return void + */ + public function unsubscribePublicChannel($connection, $channel) { + $app_key = $connection->appKey; + $this->_globalData[$app_key][$channel]['subscription_count']--; + if ($this->_globalData[$app_key][$channel]['subscription_count'] <= 0) { + unset($this->_globalData[$app_key][$channel]); + } + unset($connection->channels[$channel], $this->_eventClients[$connection->appKey][$channel][$connection->socketID]); + } + + /** + * 客户端取消订阅channel + * + * @param $connection + * @param $channel + * + * @return void + */ + public function unsubscribePrivateChannel($connection, $channel) { + $this->unsubscribePublicChannel($connection, $channel); + } + + /** + * 客户端取消订阅channel + * + * @param $connection + * @param $channel + * + * @return void + */ + public function unsubscribePresenceChannel($connection, $channel, $uid) { + $app_key = $connection->appKey; + $member_removed = false; + $this->_globalData[$app_key][$channel]['subscription_count']--; + if ($this->_globalData[$app_key][$channel]['subscription_count'] <= 0) { + unset($this->_globalData[$app_key][$channel]); + $member_removed = true; + } else { + if (!isset($this->_globalData[$app_key][$channel]['users'][$uid]['ref_count'])) { + error_log("\$this->_globalData[$app_key][$channel]['users'][$uid]['ref_count'] not exist\n"); + return; + } + $this->_globalData[$app_key][$channel]['users'][$uid]['ref_count']--; + $ref_count = $this->_globalData[$app_key][$channel]['users'][$uid]['ref_count']; + if ($ref_count <= 0) { + unset($this->_globalData[$app_key][$channel]['users'][$uid]); + $member_removed = true; + } + } + if ($member_removed) { + // {"event":"pusher_internal:member_removed","data":"{\"user_id\":\"14884657801\"}","channel":"presence-channel"} + $this->publishToClients($app_key, $channel, 'pusher_internal:member_removed', json_encode(array('user_id'=>$uid), JSON_UNESCAPED_UNICODE)); + } + unset($connection->channels[$channel], $this->_eventClients[$connection->appKey][$channel][$connection->socketID]); + } + + + /** + * 发布事件 + * + * @param $data + */ + public function publishToClients($app_key, $channel, $event, $data, $socket_id = null) + { + if (!isset($this->_eventClients[$app_key][$channel])) { + return; + } + $data = json_encode(array( + 'event' => $event, + 'data' => $data, + 'channel' => $channel + ), JSON_UNESCAPED_UNICODE); + foreach ($this->_eventClients[$app_key][$channel] as $connection) { + if ($connection->socketID === $socket_id) { + continue; + } + $connection->clientNotSendPingCount = 0; + // {"event":"my-event","data":"{\"message\":\"hello world\"}","channel":"my-channel"} + $connection->send($data); + } + } + + + /** + * 检查心跳，将心跳超时的客户端关闭 + * + * @return void + */ + public function checkHeartbeat() + { + foreach ($this->_allClients as $connection) { + if ($connection->clientNotSendPingCount > 1) { + $connection->destroy(); + } + $connection->clientNotSendPingCount ++; + } + } + + /** + * 创建一个全局的客户端id + * + * @param $connection + * @return string + */ + protected function createsocketID($connection) + { + $socket_id = "{$this->_globalID}.{$connection->id}"; + return $socket_id; + } + + /** + * 创建channel key，用于监听分发给该channel的事件 + * + * @param $app_key + * @param $channel + * @return string + */ + protected function createChannelKey($app_key, $channel) + { + return "$app_key:$channel"; + } + + /** + * POST /apps/1024/events?auth_key=b054014693241bcd9c26&auth_signature=ed7f5b604e6bbd21a888a861ed536a430a9d5e4df210937a241a811bd17fcf97&auth_timestamp=1487428415&auth_version=1.0&body_md5=15d251b35306a6da7efa515a0e971f80 HTTP/1.1 + * {"name":"my-event","data":"{\"message\":\"hello world\"}","channels":["my-channel"]} + * {"name":"my-event","data":"{\"message\":\"haha\"}","channels":["my-channel"],"socket_id":"123.456"} + * + * GET /apps/1024/channels/my-channel?auth_key=b054014693241bcd9c26&auth_signature=5226650be00a064b417d50d49229e42bbb918e969c42e63aaa63b9d1c6cf9803&auth_timestamp=1489898340&auth_version=1.0 + * + * GET /apps/1024/channels/presence-channel?auth_key=b054014693241bcd9c26&auth_signature=d46281bf69ccadfe9da270176c85daa88d4b9da55b1f3c2570d48fa1236f0b2c&auth_timestamp=1489903433&auth_version=1.0&info=subscription_count,user_count + * + * GET /apps/1024/channels/presence-channel/users?auth_key=b054014693241bcd9c26&auth_signature=2eee0ca6292e17b00484bdcb0bba686a47e8a7365a1b190248946182fc926309&auth_timestamp=1489904560&auth_version=1.0 + */ + public function onApiClientMessage($connection, Request $request) + { + if (!($app_key = $request->get('auth_key'))) { + return $connection->send(new Response(400, [], 'Bad Request')); + } + + if (!isset($this->appInfo[$app_key])) { + return $connection->send(new Response(401, [], 'Invalid app_key')); + } + + $path = $request->path(); + $explode = explode('/', trim($path, '/')); + if (count($explode) < 3) { + return $connection->send(new Response(400, [], 'Bad Request')); + } + $auth_signature = $request->get('auth_signature'); + $params = $request->get(); + unset($params['auth_signature']); + ksort($params); + $string_to_sign = $request->method()."\n" . $path . "\n" . self::array_implode('=', '&', $params); + + $real_auth_signature = hash_hmac('sha256', $string_to_sign, $this->appInfo[$app_key]['app_secret'], false); + if ($auth_signature !== $real_auth_signature) { + return $connection->send(new Response(401, [], 'Invalid signature')); + } + + $type = $explode[2]; + switch ($type) { + case 'batch_events': + $packages = json_decode($request->rawBody(), true); + if (!$packages || !isset($packages['batch'])) { + return $connection->send(new Response(400, [], 'Bad request')); + } + $packages = $packages['batch']; + foreach ($packages as $package) { + $channel = $package['channel']; + $event = $package['name']; + $data = $package['data']; + $socket_id = isset($package['socket_id']) ? isset($package['socket_id']) : null; + $this->publishToClients($app_key, $channel, $event, $data, $socket_id); + } + return $connection->send('{}'); + break; + case 'events': + $package = json_decode($request->rawBody(), true); + if (!$package) { + return $connection->send(new Response(401, [], 'Invalid signature')); + } + $channels = $package['channels']; + $event = $package['name']; + $data = $package['data']; + foreach ($channels as $channel) { + $socket_id = isset($package['socket_id']) ? isset($package['socket_id']) : null; + $this->publishToClients($app_key, $channel, $event, $data, $socket_id); + } + return $connection->send('{}'); + case 'channels': + // info + $request_info = explode(',', $request->get('info', '')); + if (!isset($explode[3])) { + $channels = []; + $prefix = $request->get('filter_by_prefix'); + $return_subscription_count = in_array('subscription_count', $request_info); + foreach ($this->_globalData[$app_key] ?? [] as $channel => $item) { + if ($prefix !== null) { + if (strpos($channel, $prefix) !== 0) { + continue; + } + } + $channels[$channel] = []; + if ($return_subscription_count) { + $channels[$channel]['subscription_count'] = $item['subscription_count']; + } + } + return $connection->send(json_encode(['channels' => $channels], JSON_UNESCAPED_UNICODE)); + } + $channel = $explode[3]; + // users + if (isset($explode[4])) { + if ($explode[4] !== 'users') { + return $connection->send(new Response(400, [], 'Bad Request')); + } + $id_array = isset($this->_globalData[$app_key][$channel]['users']) ? + array_keys($this->_globalData[$app_key][$channel]['users']) : array(); + $user_id_array = array(); + foreach ($id_array as $id) { + $user_id_array[] = array('id' => $id); + } + + $connection->send(json_encode($user_id_array, JSON_UNESCAPED_UNICODE)); + } + $occupied = isset($this->_globalData[$app_key][$channel]); + $user_count = isset($this->_globalData[$app_key][$channel]['users']) ? count($this->_globalData[$app_key][$channel]['users']) : 0; + $subscription_count = $occupied ? $this->_globalData[$app_key][$channel]['subscription_count'] : 0; + $channel_info = array( + 'occupied' => $occupied + ); + foreach ($request_info as $name) { + switch ($name) { + case 'user_count': + $channel_info['user_count'] = $user_count; + break; + case 'subscription_count': + $channel_info['subscription_count'] = $subscription_count; + break; + } + } + $connection->send(json_encode($channel_info, JSON_UNESCAPED_UNICODE)); + break; + default: + return $connection->send(new Response(400, [], 'Bad Request')); + } + + } + + public function webHookCheck() + { + $channel_events = []; + $user_events = []; + + $all_app_keys = array_unique(array_merge(array_keys($this->_globalData), array_keys($this->_globalDataSnapshot))); + foreach($all_app_keys as $app_key) + { + if (empty($this->appInfo[$app_key])) { + continue; + } + $snapshot_items = isset($this->_globalDataSnapshot[$app_key]) ? $this->_globalDataSnapshot[$app_key] : []; + $items = isset($this->_globalData[$app_key]) ? $this->_globalData[$app_key] : []; + $channels_added = array_diff_key($items, $snapshot_items); + $channels_removed = array_diff_key($snapshot_items, $items); + if ($channels_added) { + $channel_events[$app_key]['channels_added'] = array_keys($channels_added); + } + if ($channels_removed) { + $channel_events[$app_key]['channels_removed'] = array_keys($channels_removed); + } + + $all_channels = []; + foreach ($items as $channel => $foo) { + if ($foo['type'] === 'presence') { + $all_channels[$channel] = $channel; + } + } + foreach ($snapshot_items as $channel => $foo) { + if ($foo['type'] === 'presence' && !isset($all_channels[$channel])) { + $all_channels[$channel] = $channel; + } + } + + foreach ($all_channels as $channel) { + $user_array_snapshot = isset($snapshot_items[$channel]['users']) ? $snapshot_items[$channel]['users'] : []; + $user_array = isset($items[$channel]['users']) ? $items[$channel]['users'] : []; + $user_added = array_diff_key($user_array, $user_array_snapshot); + $user_removed = array_diff_key($user_array_snapshot, $user_array); + if ($user_added) { + $user_events[$app_key][$channel]['user_added'] = array_keys($user_added); + } + if ($user_removed) { + $user_events[$app_key][$channel]['user_removed'] = array_keys($user_removed); + } + } + } + + $this->_globalDataSnapshot = $this->_globalData; + + $this->webHookSend(array('channel_events' => $channel_events, 'user_events' => $user_events)); + } + + protected function webHookSend($data) + { + $channel_events = $data['channel_events']; + $user_events = $data['user_events']; + $time_ms = microtime(true); + foreach ($user_events as $app_key => $items) { + // 没设置user_event回调则忽略 + if (empty($this->appInfo[$app_key]['user_hook'])) { + continue; + } + // {"time_ms":1494300453609,"events":[{"channel":"presence-channel2","user_id":"59094971a","name":"member_added"}]} + $http_events_body = array( + 'time_ms' => $time_ms, + 'events' => [] + ); + + foreach ($items as $channel => $item) { + if (isset($item['user_added'])) { + foreach ($item['user_added'] as $user_id) { + $http_events_body['events'][] = array( + 'channel' => $channel, + 'user_id' => $user_id, + 'name' => 'user_added' + ); + } + } + } + + foreach ($items as $channel => $item) { + if (isset($item['user_removed'])) { + foreach ($item['user_removed'] as $user_id) { + $http_events_body['events'][] = array( + 'channel' => $channel, + 'user_id' => $user_id, + 'name' => 'user_removed' + ); + } + } + } + + if ($http_events_body['events']) { + $this->sendHttpRequest($this->appInfo[$app_key]['user_hook'], + $app_key, + $this->appInfo[$app_key]['app_secret'], + json_encode($http_events_body, JSON_UNESCAPED_UNICODE)); + } + } + + foreach ($channel_events as $app_key => $item) { + // 没设置channel_event回调则忽略 + if (empty($this->appInfo[$app_key]['channel_hook'])) { + continue; + } + // {"time_ms":1494300446592,"events":[{"channel":"presence-channel2","name":"channel_added"}]} + $http_events_body = array( + 'time_ms' => $time_ms, + 'events' => [] + ); + if (isset($item['channels_added'])) { + foreach ($item['channels_added'] as $channel) { + $http_events_body['events'][] = array( + 'channel' => $channel, + 'name' => 'channel_added' + ); + } + } + if (isset($item['channels_removed'])) { + foreach ($item['channels_removed'] as $channel) { + $http_events_body['events'][] = array( + 'channel' => $channel, + 'name' => 'channel_removed' + ); + } + } + if ($http_events_body['events']) { + $this->sendHttpRequest($this->appInfo[$app_key]['channel_hook'], + $app_key, + $this->appInfo[$app_key]['app_secret'], + json_encode($http_events_body, JSON_UNESCAPED_UNICODE)); + } + } + } + + protected function sendHttpRequest($address, $app_key, $secret, $body, $redirect_count = 0) + { + $address_info = parse_url($address); + if (!$address_info) { + echo new \Exception('bad remote_address'); + return false; + } + + $scheme = isset($address_info['scheme']) && $address_info['scheme'] === 'https' ? 'ssl' : 'tcp'; + if (!isset($address_info['port'])) { + $address_info['port'] = $scheme == 'ssl' ? 443 : 80; + } + if (!isset($address_info['path'])) { + $address_info['path'] = '/'; + } + if (!isset($address_info['query'])) { + $address_info['query'] = ''; + } else { + $address_info['query'] = '?' . $address_info['query']; + } + $remote_address = "{$address_info['host']}:{$address_info['port']}"; + $remote_host = $address_info['host']; + $remote_URI = "{$address_info['path']}{$address_info['query']}"; + $signature = hash_hmac('sha256', $body, $secret, false); + $base_url = $scheme == 'ssl' ? "https://$remote_address/" : "http://$remote_address/"; + + $header = "POST $remote_URI HTTP/1.0\r\n"; + $header .= "Host: $remote_host\r\n"; + $header .= "Connection: close\r\n"; + $header .= "X-Pusher-Key: $app_key\r\n"; + $header .= "X-Pusher-Signature: $signature\r\n"; + $header .= "Content-Type: application/json\r\n"; + $header .= "Content-Length: " . strlen($body); + $http_buffer = $header . "\r\n\r\n" . $body; + + $client = new AsyncTcpConnection('tcp://' . $remote_address); + if ($scheme == 'ssl') { + $client->transport = 'ssl'; + } + + $client->onConnect = function ($client) use ($http_buffer) { + $client->send($http_buffer); + }; + $client->onMessage = function ($client, $buffer) use ($address, $app_key, $secret, $body, $base_url, $redirect_count) { + $client->close(); + if (!preg_match("/HTTP\/1\.\d (\d*?) .*?\r\n/", $buffer, $match)) { + echo "http code not found $buffer\n"; + return; + } + $http_code = $match[1]; + $base_code = intval($http_code / 100); + if ($base_code == 3 && preg_match("/Location: (.*?)\r\n/", $buffer, $match)) { + if (++$redirect_count > 3) { + $msg = date('Y-m-d H:i:s') . "\nURL:$address\nAPP_KEY:$app_key ERR:too many redirect\n$buffer"; + echo $msg; + return; + } + $location = $match[1]; + if (strpos($location, 'http://') === 0 || strpos($location, 'https://') === 0) { + $this->sendHttpRequest($location, $app_key, $secret, $body, $redirect_count); + } else { + $this->sendHttpRequest($base_url . $location, $app_key, $secret, $body, $redirect_count); + } + } + if ($base_code !== 2) { + $msg = date('Y-m-d H:i:s') . "\nURL:$address\nAPP_KEY:$app_key\n$buffer"; + echo $msg; + } + }; + Timer::add(10, array($client, 'close'), null, false); + $client->connect(); + } + + /** + * array_implode + * + * @param $glue + * @param $separator + * @param $array + * @return string + */ + public static function array_implode($glue, $separator, $array) + { + if (!is_array($array)) { + return $array; + } + $string = array(); + foreach ($array as $key => $val) { + if (is_array($val)) { + $val = implode(',', $val); + } + $string[] = "{$key}{$glue}{$val}"; + } + + return implode($separator, $string); + } +} + diff --git a/vendor/webman/push/src/config/plugin/webman/push/app.php b/vendor/webman/push/src/config/plugin/webman/push/app.php new file mode 100644 index 0000000..6a0c847 --- /dev/null +++ b/vendor/webman/push/src/config/plugin/webman/push/app.php @@ -0,0 +1,10 @@ + true, + 'websocket' => 'websocket://0.0.0.0:3131', + 'api' => 'http://0.0.0.0:3232', + 'app_key' => '2ce3ce22329517213caa7dad261f5695', + 'app_secret' => 'e77d30638dfc7776e2d41121797bf2b2', + 'channel_hook' => 'http://127.0.0.1:8787/plugin/webman/push/hook', + 'auth' => '/plugin/webman/push/auth' +]; \ No newline at end of file diff --git a/vendor/webman/push/src/config/plugin/webman/push/process.php b/vendor/webman/push/src/config/plugin/webman/push/process.php new file mode 100644 index 0000000..01c545d --- /dev/null +++ b/vendor/webman/push/src/config/plugin/webman/push/process.php @@ -0,0 +1,21 @@ + [ + 'handler' => Server::class, + 'listen' => config('plugin.webman.push.app.websocket'), + 'count' => 1, // 必须是1 + 'reloadable' => false, // 执行reload不重启 + 'constructor' => [ + 'api_listen' => config('plugin.webman.push.app.api'), + 'app_info' => [ + config('plugin.webman.push.app.app_key') => [ + 'channel_hook' => config('plugin.webman.push.app.channel_hook'), + 'app_secret' => config('plugin.webman.push.app.app_secret'), + ], + ] + ] + ] +]; \ No newline at end of file diff --git a/vendor/webman/push/src/config/plugin/webman/push/route.php b/vendor/webman/push/src/config/plugin/webman/push/route.php new file mode 100644 index 0000000..ea54c37 --- /dev/null +++ b/vendor/webman/push/src/config/plugin/webman/push/route.php @@ -0,0 +1,87 @@ + + * @copyright walkor + * @link http://www.workerman.net/ + * @license http://www.opensource.org/licenses/mit-license.php MIT License + */ + +use support\Request; +use Webman\Route; +use Webman\Push\Api; + +/** + * 推送js客户端文件 + */ +Route::get('/plugin/webman/push/push.js', function (Request $request) { + return response()->file(base_path().'/vendor/webman/push/src/push.js'); +}); + +/** + * 私有频道鉴权，这里应该使用session辨别当前用户身份，然后确定该用户是否有权限监听channel_name + */ +Route::post(config('plugin.webman.push.app.auth'), function (Request $request) { + $pusher = new Api(str_replace('0.0.0.0', '127.0.0.1', config('plugin.webman.push.app.api')), config('plugin.webman.push.app.app_key'), config('plugin.webman.push.app.app_secret')); + $channel_name = $request->post('channel_name'); + $session = $request->session(); + // 这里应该通过session和channel_name判断当前用户是否有权限监听channel_name + $has_authority = true; + if ($has_authority) { + return response($pusher->socketAuth($channel_name, $request->post('socket_id'))); + } else { + return response('Forbidden', 403); + } +}); + +/** + * 当频道上线以及下线时触发的回调 + * 频道上线：是指某个频道从没有连接在线到有连接在线的事件 + * 频道下线：是指某个频道的所有连接都断开触发的事件 + */ +Route::post(parse_url(config('plugin.webman.push.app.channel_hook'), PHP_URL_PATH), function (Request $request) { + + // 没有x-pusher-signature头视为伪造请求 + if (!$webhook_signature = $request->header('x-pusher-signature')) { + return response('401 Not authenticated', 401); + } + + $body = $request->rawBody(); + + // 计算签名，$app_secret 是双方使用的密钥，是保密的，外部无从得知 + $expected_signature = hash_hmac('sha256', $body, config('plugin.webman.push.app.app_secret'), false); + + // 安全校验，如果签名不一致可能是伪造的请求，返回401状态码 + if ($webhook_signature !== $expected_signature) { + return response('401 Not authenticated', 401); + } + + // 这里存储这上线 下线的channel数据 + $payload = json_decode($body, true); + + $channels_online = $channels_offline = []; + + foreach ($payload['events'] as $event) { + if ($event['name'] === 'channel_added') { + $channels_online[] = $event['channel']; + } else if ($event['name'] === 'channel_removed') { + $channels_offline[] = $event['channel']; + } + } + + // 业务根据需要处理上下线的channel，例如将在线状态写入数据库，通知其它channel等 + // 上线的所有channel + echo 'online channels: ' . implode(',', $channels_online) . "\n"; + // 下线的所有channel + echo 'offline channels: ' . implode(',', $channels_offline) . "\n"; + + return 'OK'; +}); + + + diff --git a/vendor/webman/push/src/push-uniapp.js b/vendor/webman/push/src/push-uniapp.js new file mode 100644 index 0000000..c9c9e0c --- /dev/null +++ b/vendor/webman/push/src/push-uniapp.js @@ -0,0 +1,827 @@ + +function Push(options) { + this.doNotConnect = 0; + options = options || {}; + options.heartbeat = options.heartbeat || 25000; + options.pingTimeout = options.pingTimeout || 10000; + this.config = options; + this.uid = 0; + this.channels = {}; + this.connection = null; + this.pingTimeoutTimer = 0; + Push.instances.push(this); + this.createConnection(); +} + +Push.prototype.checkoutPing = function() { + var _this = this; + _this.checkoutPingTimer && clearTimeout(_this.checkoutPingTimer); + _this.checkoutPingTimer = setTimeout(function () { + _this.checkoutPingTimer = 0; + if (_this.connection.state === 'connected') { + _this.connection.send('{"event":"pusher:ping","data":{}}'); + if (_this.pingTimeoutTimer) { + clearTimeout(_this.pingTimeoutTimer); + _this.pingTimeoutTimer = 0; + } + _this.pingTimeoutTimer = setTimeout(function () { + _this.connection.closeAndClean(); + if (!_this.connection.doNotConnect) { + _this.connection.waitReconnect(); + } + }, _this.config.pingTimeout); + } + }, this.config.heartbeat); +}; + +Push.prototype.channel = function (name) { + return this.channels.find(name); +}; +Push.prototype.allChannels = function () { + return this.channels.all(); +}; +Push.prototype.createConnection = function () { + if (this.connection) { + throw Error('Connection already exist'); + } + var _this = this; + var url = this.config.url; + function updateSubscribed () { + for (var i in _this.channels) { + _this.channels[i].subscribed = false; + } + } + this.connection = new Connection({ + url: url, + app_key: this.config.app_key, + onOpen: function () { + _this.connection.state = 'connecting'; + _this.checkoutPing(); + }, + onMessage: function(params) { + if(_this.pingTimeoutTimer) { + clearTimeout(_this.pingTimeoutTimer); + _this.pingTimeoutTimer = 0; + } + + params = JSON.parse(params.data); + var event = params.event; + var channel_name = params.channel; + + if (event === 'pusher:pong') { + _this.checkoutPing(); + return; + } + if (event === 'pusher:error') { + throw Error(params.data.message); + } + var data = JSON.parse(params.data), channel; + if (event === 'pusher_internal:subscription_succeeded') { + channel = _this.channels[channel_name]; + channel.subscribed = true; + channel.processQueue(); + channel.emit('pusher:subscription_succeeded'); + return; + } + if (event === 'pusher:connection_established') { + _this.connection.socket_id = data.socket_id; + _this.connection.updateNetworkState('connected'); + _this.subscribeAll(); + } + if (event.indexOf('pusher_internal') !== -1) { + console.log("Event '"+event+"' not implement"); + return; + } + channel = _this.channels[channel_name]; + if (channel) { + channel.emit(event, data); + } + }, + onClose: function () { + updateSubscribed(); + }, + onError: function () { + updateSubscribed(); + } + }); +}; +Push.prototype.disconnect = function () { + this.connection.doNotConnect = 1; + this.connection.close(); +}; + +Push.prototype.subscribeAll = function () { + if (this.connection.state !== 'connected') { + return; + } + for (var channel_name in this.channels) { + //this.connection.send(JSON.stringify({event:"pusher:subscribe", data:{channel:channel_name}})); + this.channels[channel_name].processSubscribe(); + } +}; + +Push.prototype.unsubscribe = function (channel_name) { + if (this.channels[channel_name]) { + delete this.channels[channel_name]; + if (this.connection.state === 'connected') { + this.connection.send(JSON.stringify({event:"pusher:unsubscribe", data:{channel:channel_name}})); + } + } +}; +Push.prototype.unsubscribeAll = function () { + var channels = Object.keys(this.channels); + if (channels.length) { + if (this.connection.state === 'connected') { + for (var channel_name in this.channels) { + this.unsubscribe(channel_name); + } + } + } + this.channels = {}; +}; +Push.prototype.subscribe = function (channel_name) { + if (this.channels[channel_name]) { + return this.channels[channel_name]; + } + if (channel_name.indexOf('private-') === 0) { + return createPrivateChannel(channel_name, this); + } + if (channel_name.indexOf('presence-') === 0) { + return createPresenceChannel(channel_name, this); + } + return createChannel(channel_name, this); +}; +Push.instances = []; + +function createChannel(channel_name, push) +{ + var channel = new Channel(push.connection, channel_name); + push.channels[channel_name] = channel; + channel.subscribeCb = function () { + push.connection.send(JSON.stringify({event:"pusher:subscribe", data:{channel:channel_name}})); + } + channel.processSubscribe(); + return channel; +} + +function createPrivateChannel(channel_name, push) +{ + var channel = new Channel(push.connection, channel_name); + push.channels[channel_name] = channel; + channel.subscribeCb = function () { + __ajax({ + url: push.config.auth, + type: 'POST', + data: {channel_name: channel_name, socket_id: push.connection.socket_id}, + success: function (data) { + data = JSON.parse(data); + data.channel = channel_name; + push.connection.send(JSON.stringify({event:"pusher:subscribe", data:data})); + }, + error: function (e) { + throw Error(e); + } + }); + }; + channel.processSubscribe(); + return channel; +} + +function createPresenceChannel(channel_name, push) +{ + return createPrivateChannel(channel_name, push); +} + +uni.onNetworkStatusChange(function (res) { + if(res.isConnected) { + for (var i in Push.instances) { + con = Push.instances[i].connection; + con.reconnectInterval = 1; + if (con.state === 'connecting') { + con.connect(); + } + } + } +}); + +function Connection(options) { + this.dispatcher = new Dispatcher(); + __extends(this, this.dispatcher); + var properies = ['on', 'off', 'emit']; + for (var i in properies) { + this[properies[i]] = this.dispatcher[properies[i]]; + } + this.options = options; + this.state = 'initialized'; //initialized connecting connected disconnected + this.doNotConnect = 0; + this.reconnectInterval = 1; + this.connection = null; + this.reconnectTimer = 0; + this.connect(); +} + +Connection.prototype.updateNetworkState = function(state){ + var old_state = this.state; + this.state = state; + if (old_state !== state) { + this.emit('state_change', { previous: old_state, current: state }); + } +}; + +Connection.prototype.connect = function () { + this.doNotConnect = 0; + if (this.networkState == 'connecting' || this.networkState == 'established') { + console.log('networkState is ' + this.networkState + ' and do not need connect'); + return; + } + if (this.reconnectTimer) { + clearTimeout(this.reconnectTimer); + this.reconnectTimer = 0; + } + + this.closeAndClean(); + + var options = this.options; + var _this = this; + _this.updateNetworkState('connecting'); + var cb = function(){ + uni.onSocketOpen(function (res) { + _this.reconnectInterval = 1; + if (_this.doNotConnect) { + _this.updateNetworkState('closing'); + uni.closeSocket(); + return; + } + _this.updateNetworkState('established'); + if (options.onOpen) { + options.onOpen(res); + } + }); + + if (options.onMessage) { + uni.onSocketMessage(options.onMessage); + } + + uni.onSocketClose(function (res) { + _this.updateNetworkState('disconnected'); + if (!_this.doNotConnect) { + _this.waitReconnect(); + } + if (options.onClose) { + options.onClose(res); + } + }); + + uni.onSocketError(function (res) { + _this.close(); + if (!_this.doNotConnect) { + _this.waitReconnect(); + } + if (options.onError) { + options.onError(res); + } + }); + }; + uni.connectSocket({ + url: options.url, + fail: function (res) { + console.log('uni.connectSocket fail'); + console.log(res); + _this.updateNetworkState('disconnected'); + _this.waitReconnect(); + }, + success: function() { + + } + }); + cb(); +} + +Connection.prototype.connect = function () { + this.doNotConnect = 0; + if (this.state === 'connected') { + console.log('networkState is "' + this.state + '" and do not need connect'); + return; + } + if (this.reconnectTimer) { + clearTimeout(this.reconnectTimer); + this.reconnectTimer = 0; + } + + this.closeAndClean(); + + var options = this.options; + + this.updateNetworkState('connecting'); + + var _this = this; + var cb = function(){ + uni.onSocketOpen(function (res) { + _this.reconnectInterval = 1; + if (_this.doNotConnect) { + _this.updateNetworkState('disconnected'); + uni.closeSocket(); + return; + } + if (options.onOpen) { + options.onOpen(res); + } + }); + + if (options.onMessage) { + uni.onSocketMessage(options.onMessage); + } + + uni.onSocketClose(function (res) { + _this.updateNetworkState('disconnected'); + if (!_this.doNotConnect) { + _this.waitReconnect(); + } + if (options.onClose) { + options.onClose(res); + } + }); + + uni.onSocketError(function (res) { + _this.close(); + if (!_this.doNotConnect) { + _this.waitReconnect(); + } + if (options.onError) { + options.onError(res); + } + }); + }; + uni.connectSocket({ + url: options.url+'/app/'+options.app_key, + fail: function (res) { + console.log('uni.connectSocket fail'); + console.log(res); + _this.updateNetworkState('disconnected'); + _this.waitReconnect(); + }, + success: function() { + + } + }); + cb(); +} + +Connection.prototype.closeAndClean = function () { + if (this.state === 'connected') { + uni.closeSocket(); + } + this.updateNetworkState('disconnected'); +}; + +Connection.prototype.waitReconnect = function () { + if (this.state === 'connected' || this.state === 'connecting') { + return; + } + if (!this.doNotConnect) { + this.updateNetworkState('connecting'); + var _this = this; + if (this.reconnectTimer) { + clearTimeout(this.reconnectTimer); + } + this.reconnectTimer = setTimeout(function(){ + _this.connect(); + }, this.reconnectInterval); + if (this.reconnectInterval < 1000) { + this.reconnectInterval = 1000; + } else { + // 每次重连间隔增大一倍 + this.reconnectInterval = this.reconnectInterval * 2; + } + // 有网络的状态下，重连间隔最大2秒 + if (this.reconnectInterval > 2000 && navigator.onLine) { + _this.reconnectInterval = 2000; + } + } +} + +Connection.prototype.send = function(data) { + if (this.state !== 'connected') { + console.trace('networkState is "' + this.state + '", can not send ' + data); + return; + } + uni.sendSocketMessage({ + data: data + }); +} + +Connection.prototype.close = function(){ + this.updateNetworkState('disconnected'); + uni.closeSocket(); +} + +var __extends = (this && this.__extends) || function (d, b) { + for (var p in b) if (b.hasOwnProperty(p)) {d[p] = b[p];} + function __() { this.constructor = d; } + d.prototype = b === null ? Object.create(b) : (__.prototype = b.prototype, new __()); +}; + +function Channel(connection, channel_name) { + this.subscribed = false; + this.dispatcher = new Dispatcher(); + this.connection = connection; + this.channelName = channel_name; + this.subscribeCb = null; + this.queue = []; + __extends(this, this.dispatcher); + var properies = ['on', 'off', 'emit']; + for (var i in properies) { + this[properies[i]] = this.dispatcher[properies[i]]; + } +} + +Channel.prototype.processSubscribe = function () { + if (this.connection.state !== 'connected') { + return; + } + this.subscribeCb(); +}; + +Channel.prototype.processQueue = function () { + if (this.connection.state !== 'connected' || !this.subscribed) { + return; + } + for (var i in this.queue) { + this.queue[i](); + } + this.queue = []; +}; + +Channel.prototype.trigger = function (event, data) { + if (event.indexOf('client-') !== 0) { + throw new Error("Event '" + event + "' should start with 'client-'"); + } + var _this = this; + this.queue.push(function () { + _this.connection.send(JSON.stringify({ event: event, data: data, channel: _this.channelName })); + }); + this.processQueue(); +}; + +//////////////// +var Collections = (function () { + var exports = {}; + function extend(target) { + var sources = []; + for (var _i = 1; _i < arguments.length; _i++) { + sources[_i - 1] = arguments[_i]; + } + for (var i = 0; i < sources.length; i++) { + var extensions = sources[i]; + for (var property in extensions) { + if (extensions[property] && extensions[property].constructor && + extensions[property].constructor === Object) { + target[property] = extend(target[property] || {}, extensions[property]); + } + else { + target[property] = extensions[property]; + } + } + } + return target; + } + + exports.extend = extend; + function stringify() { + var m = ["Push"]; + for (var i = 0; i < arguments.length; i++) { + if (typeof arguments[i] === "string") { + m.push(arguments[i]); + } + else { + m.push(safeJSONStringify(arguments[i])); + } + } + return m.join(" : "); + } + + exports.stringify = stringify; + function arrayIndexOf(array, item) { + var nativeIndexOf = Array.prototype.indexOf; + if (array === null) { + return -1; + } + if (nativeIndexOf && array.indexOf === nativeIndexOf) { + return array.indexOf(item); + } + for (var i = 0, l = array.length; i < l; i++) { + if (array[i] === item) { + return i; + } + } + return -1; + } + + exports.arrayIndexOf = arrayIndexOf; + function objectApply(object, f) { + for (var key in object) { + if (Object.prototype.hasOwnProperty.call(object, key)) { + f(object[key], key, object); + } + } + } + + exports.objectApply = objectApply; + function keys(object) { + var keys = []; + objectApply(object, function (_, key) { + keys.push(key); + }); + return keys; + } + + exports.keys = keys; + function values(object) { + var values = []; + objectApply(object, function (value) { + values.push(value); + }); + return values; + } + + exports.values = values; + function apply(array, f, context) { + for (var i = 0; i < array.length; i++) { + f.call(context || (window), array[i], i, array); + } + } + + exports.apply = apply; + function map(array, f) { + var result = []; + for (var i = 0; i < array.length; i++) { + result.push(f(array[i], i, array, result)); + } + return result; + } + + exports.map = map; + function mapObject(object, f) { + var result = {}; + objectApply(object, function (value, key) { + result[key] = f(value); + }); + return result; + } + + exports.mapObject = mapObject; + function filter(array, test) { + test = test || function (value) { + return !!value; + }; + var result = []; + for (var i = 0; i < array.length; i++) { + if (test(array[i], i, array, result)) { + result.push(array[i]); + } + } + return result; + } + + exports.filter = filter; + function filterObject(object, test) { + var result = {}; + objectApply(object, function (value, key) { + if ((test && test(value, key, object, result)) || Boolean(value)) { + result[key] = value; + } + }); + return result; + } + + exports.filterObject = filterObject; + function flatten(object) { + var result = []; + objectApply(object, function (value, key) { + result.push([key, value]); + }); + return result; + } + + exports.flatten = flatten; + function any(array, test) { + for (var i = 0; i < array.length; i++) { + if (test(array[i], i, array)) { + return true; + } + } + return false; + } + + exports.any = any; + function all(array, test) { + for (var i = 0; i < array.length; i++) { + if (!test(array[i], i, array)) { + return false; + } + } + return true; + } + + exports.all = all; + function encodeParamsObject(data) { + return mapObject(data, function (value) { + if (typeof value === "object") { + value = safeJSONStringify(value); + } + return encodeURIComponent(base64_1["default"](value.toString())); + }); + } + + exports.encodeParamsObject = encodeParamsObject; + function buildQueryString(data) { + var params = filterObject(data, function (value) { + return value !== undefined; + }); + return map(flatten(encodeParamsObject(params)), util_1["default"].method("join", "=")).join("&"); + } + + exports.buildQueryString = buildQueryString; + function decycleObject(object) { + var objects = [], paths = []; + return (function derez(value, path) { + var i, name, nu; + switch (typeof value) { + case 'object': + if (!value) { + return null; + } + for (i = 0; i < objects.length; i += 1) { + if (objects[i] === value) { + return {$ref: paths[i]}; + } + } + objects.push(value); + paths.push(path); + if (Object.prototype.toString.apply(value) === '[object Array]') { + nu = []; + for (i = 0; i < value.length; i += 1) { + nu[i] = derez(value[i], path + '[' + i + ']'); + } + } + else { + nu = {}; + for (name in value) { + if (Object.prototype.hasOwnProperty.call(value, name)) { + nu[name] = derez(value[name], path + '[' + JSON.stringify(name) + ']'); + } + } + } + return nu; + case 'number': + case 'string': + case 'boolean': + return value; + } + }(object, '$')); + } + + exports.decycleObject = decycleObject; + function safeJSONStringify(source) { + try { + return JSON.stringify(source); + } + catch (e) { + return JSON.stringify(decycleObject(source)); + } + } + + exports.safeJSONStringify = safeJSONStringify; + return exports; +})(); + +var Dispatcher = (function () { + function Dispatcher(failThrough) { + this.callbacks = new CallbackRegistry(); + this.global_callbacks = []; + this.failThrough = failThrough; + } + Dispatcher.prototype.on = function (eventName, callback, context) { + this.callbacks.add(eventName, callback, context); + return this; + }; + Dispatcher.prototype.on_global = function (callback) { + this.global_callbacks.push(callback); + return this; + }; + Dispatcher.prototype.off = function (eventName, callback, context) { + this.callbacks.remove(eventName, callback, context); + return this; + }; + Dispatcher.prototype.emit = function (eventName, data) { + var i; + for (i = 0; i < this.global_callbacks.length; i++) { + this.global_callbacks[i](eventName, data); + } + var callbacks = this.callbacks.get(eventName); + if (callbacks && callbacks.length > 0) { + for (i = 0; i < callbacks.length; i++) { + callbacks[i].fn.call(callbacks[i].context || (window), data); + } + } + else if (this.failThrough) { + this.failThrough(eventName, data); + } + return this; + }; + return Dispatcher; +}()); + +var CallbackRegistry = (function () { + function CallbackRegistry() { + this._callbacks = {}; + } + CallbackRegistry.prototype.get = function (name) { + return this._callbacks[prefix(name)]; + }; + CallbackRegistry.prototype.add = function (name, callback, context) { + var prefixedEventName = prefix(name); + this._callbacks[prefixedEventName] = this._callbacks[prefixedEventName] || []; + this._callbacks[prefixedEventName].push({ + fn: callback, + context: context + }); + }; + CallbackRegistry.prototype.remove = function (name, callback, context) { + if (!name && !callback && !context) { + this._callbacks = {}; + return; + } + var names = name ? [prefix(name)] : Collections.keys(this._callbacks); + if (callback || context) { + this.removeCallback(names, callback, context); + } + else { + this.removeAllCallbacks(names); + } + }; + CallbackRegistry.prototype.removeCallback = function (names, callback, context) { + Collections.apply(names, function (name) { + this._callbacks[name] = Collections.filter(this._callbacks[name] || [], function (oning) { + return (callback && callback !== oning.fn) || + (context && context !== oning.context); + }); + if (this._callbacks[name].length === 0) { + delete this._callbacks[name]; + } + }, this); + }; + CallbackRegistry.prototype.removeAllCallbacks = function (names) { + Collections.apply(names, function (name) { + delete this._callbacks[name]; + }, this); + }; + return CallbackRegistry; +}()); +function prefix(name) { + return "_" + name; +} + +function __ajax(options){ + options=options||{}; + options.type=(options.type||'GET').toUpperCase(); + options.dataType=options.dataType||'json'; + params=formatParams(options.data); + + var xhr; + if(window.XMLHttpRequest){ + xhr=new XMLHttpRequest(); + }else{ + xhr=ActiveXObject('Microsoft.XMLHTTP'); + } + + xhr.onreadystatechange=function(){ + if(xhr.readyState === 4){ + var status=xhr.status; + if(status>=200 && status<300){ + options.success&&options.success(xhr.responseText,xhr.responseXML); + }else{ + options.error&&options.error(status); + } + } + } + + if(options.type==='GET'){ + xhr.open('GET',options.url+'?'+params,true); + xhr.send(null); + }else if(options.type==='POST'){ + xhr.open('POST',options.url,true); + xhr.setRequestHeader("Content-Type", "application/x-www-form-urlencoded"); + xhr.send(params); + } +} + +function formatParams(data){ + var arr=[]; + for(var name in data){ + arr.push(encodeURIComponent(name)+'='+encodeURIComponent(data[name])); + } + return arr.join('&'); +} + +export default Push diff --git a/vendor/webman/push/src/push-vue.js b/vendor/webman/push/src/push-vue.js new file mode 100644 index 0000000..b769e7d --- /dev/null +++ b/vendor/webman/push/src/push-vue.js @@ -0,0 +1,732 @@ + +export const Push = function (options) { + this.doNotConnect = 0; + options = options || {}; + options.heartbeat = options.heartbeat || 25000; + options.pingTimeout = options.pingTimeout || 10000; + this.config = options; + this.uid = 0; + this.channels = {}; + this.connection = null; + this.pingTimeoutTimer = 0; + Push.instances.push(this); + this.createConnection(); +} + +Push.prototype.checkoutPing = function () { + var _this = this; + setTimeout(function () { + if (_this.connection.state === 'connected') { + _this.connection.send('{"event":"pusher:ping","data":{}}'); + if (_this.pingTimeoutTimer) { + clearTimeout(_this.pingTimeoutTimer); + _this.pingTimeoutTimer = 0; + } + _this.pingTimeoutTimer = setTimeout(function () { + _this.connection.closeAndClean(); + if (!_this.connection.doNotConnect) { + _this.connection.waitReconnect(); + } + }, _this.config.pingTimeout); + } + }, this.config.heartbeat); +}; + +Push.prototype.channel = function (name) { + return this.channels.find(name); +}; + +Push.prototype.allChannels = function () { + return this.channels.all(); +}; + +Push.prototype.createConnection = function () { + if (this.connection) { + throw Error('Connection already exist'); + } + var _this = this; + var url = this.config.url; + function updateSubscribed() { + for (var i in _this.channels) { + _this.channels[i].subscribed = false; + } + } + + this.connection = new Connection({ + url: url, + app_key: this.config.app_key, + onOpen: function () { + _this.connection.state = 'connecting'; + _this.checkoutPing(); + }, + onMessage: function (params) { + if (_this.pingTimeoutTimer) { + clearTimeout(_this.pingTimeoutTimer); + _this.pingTimeoutTimer = 0; + } + + params = JSON.parse(params.data); + var event = params.event; + var channel_name = params.channel; + + if (event === 'pusher:pong') { + _this.checkoutPing(); + return; + } + if (event === 'pusher:error') { + throw Error(params.data.message); + } + var data = JSON.parse(params.data), channel; + if (event === 'pusher_internal:subscription_succeeded') { + channel = _this.channels[channel_name]; + channel.subscribed = true; + channel.processQueue(); + channel.emit('pusher:subscription_succeeded'); + return; + } + if (event === 'pusher:connection_established') { + _this.connection.socket_id = data.socket_id; + _this.connection.state = 'connected'; + _this.subscribeAll(); + } + if (event.indexOf('pusher_internal') !== -1) { + console.log("Event '" + event + "' not implement"); + return; + } + channel = _this.channels[channel_name]; + if (channel) { + channel.emit(event, data); + } + }, + onClose: function () { + updateSubscribed(); + }, + onError: function () { + updateSubscribed(); + } + }); +}; +Push.prototype.disconnect = function () { + this.connection.doNotConnect = 1; + this.connection.close(); +}; + +Push.prototype.subscribeAll = function () { + if (this.connection.state !== 'connected') { + return; + } + for (var channel_name in this.channels) { + //this.connection.send(JSON.stringify({event:"pusher:subscribe", data:{channel:channel_name}})); + this.channels[channel_name].processSubscribe(); + } +}; + +Push.prototype.unsubscribe = function (channel_name) { + if (this.channels[channel_name]) { + delete this.channels[channel_name]; + if (this.connection.state === 'connected') { + this.connection.send(JSON.stringify({ event: "pusher:unsubscribe", data: { channel: channel_name } })); + } + } +}; +Push.prototype.unsubscribeAll = function () { + var channels = Object.keys(this.channels); + if (channels.length) { + if (this.connection.state === 'connected') { + for (var channel_name in this.channels) { + this.unsubscribe(channel_name); + } + } + } + this.channels = {}; +}; +Push.prototype.subscribe = function (channel_name) { + if (this.channels[channel_name]) { + return this.channels[channel_name]; + } + if (channel_name.indexOf('private-') === 0) { + return createPrivateChannel(channel_name, this); + } + if (channel_name.indexOf('presence-') === 0) { + return createPresenceChannel(channel_name, this); + } + return createChannel(channel_name, this); +}; +Push.instances = []; + +function createChannel(channel_name, push) { + var channel = new Channel(push.connection, channel_name); + push.channels[channel_name] = channel; + channel.subscribeCb = function () { + push.connection.send(JSON.stringify({ event: "pusher:subscribe", data: { channel: channel_name } })); + } + return channel; +} + +function createPrivateChannel(channel_name, push) { + var channel = new Channel(push.connection, channel_name); + push.channels[channel_name] = channel; + channel.subscribeCb = function () { + __ajax({ + url: push.config.auth, + type: 'POST', + data: { channel_name: channel_name, socket_id: push.connection.socket_id }, + success: function (data) { + data = JSON.parse(data); + data.channel = channel_name; + push.connection.send(JSON.stringify({ event: "pusher:subscribe", data: data })); + }, + error: function (e) { + throw Error(e); + } + }); + }; + channel.processSubscribe(); + return channel; +} + +function createPresenceChannel(channel_name, push) { + return createPrivateChannel(channel_name, push); +} + +function Connection(options) { + this.dispatcher = new Dispatcher(); + __extends(this, this.dispatcher); + var properies = ['on', 'off', 'emit']; + for (var i in properies) { + this[properies[i]] = this.dispatcher[properies[i]]; + } + this.options = options; + this.state = 'initialized'; //initialized connecting connected disconnected + this.doNotConnect = 0; + this.reconnectInterval = 1; + this.connection = null; + this.reconnectTimer = 0; + this.connect(); +} + +Connection.prototype.updateNetworkState = function (state) { + var old_state = this.state; + this.state = state; + if (old_state !== state) { + this.emit('state_change', { previous: old_state, current: state }); + } +}; + +Connection.prototype.connect = function () { + this.doNotConnect = 0; + if (this.state === 'connected') { + console.log('networkState is "' + this.state + '" and do not need connect'); + return; + } + if (this.reconnectTimer) { + clearTimeout(this.reconnectTimer); + this.reconnectTimer = 0; + } + + this.closeAndClean(); + + var options = this.options; + var websocket = new WebSocket(options.url + '/app/' + options.app_key); + + this.updateNetworkState('connecting'); + + var _this = this; + websocket.onopen = function (res) { + _this.reconnectInterval = 1; + if (_this.doNotConnect) { + _this.updateNetworkState('disconnected'); + websocket.close(); + return; + } + if (options.onOpen) { + options.onOpen(res); + } + }; + + if (options.onMessage) { + websocket.onmessage = options.onMessage; + } + + websocket.onclose = function (res) { + websocket.onmessage = websocket.onopen = websocket.onclose = websocket.onerror = null; + _this.updateNetworkState('disconnected'); + if (!_this.doNotConnect) { + _this.waitReconnect(); + } + if (options.onClose) { + options.onClose(res); + } + }; + + websocket.onerror = function (res) { + _this.close(); + if (!_this.doNotConnect) { + _this.waitReconnect(); + } + if (options.onError) { + options.onError(res); + } + }; + this.connection = websocket; +} + +Connection.prototype.closeAndClean = function () { + if (this.connection) { + var websocket = this.connection; + websocket.onmessage = websocket.onopen = websocket.onclose = websocket.onerror = null; + try { + websocket.close(); + } catch (e) { } + this.updateNetworkState('disconnected'); + } +}; + +Connection.prototype.waitReconnect = function () { + if (this.state === 'connected' || this.state === 'connecting') { + return; + } + if (!this.doNotConnect) { + this.updateNetworkState('connecting'); + var _this = this; + if (this.reconnectTimer) { + clearTimeout(this.reconnectTimer); + } + this.reconnectTimer = setTimeout(function () { + _this.connect(); + }, this.reconnectInterval); + if (this.reconnectInterval < 1000) { + this.reconnectInterval = 1000; + } else { + // 每次重连间隔增大一倍 + this.reconnectInterval = this.reconnectInterval * 2; + } + // 有网络的状态下，重连间隔最大2秒 + if (this.reconnectInterval > 2000 && navigator.onLine) { + _this.reconnectInterval = 2000; + } + } +} + +Connection.prototype.send = function (data) { + if (this.state !== 'connected') { + console.trace('networkState is "' + this.state + '", can not send ' + data); + return; + } + this.connection.send(data); +} + +Connection.prototype.close = function () { + this.updateNetworkState('disconnected'); + this.connection.close(); +} + +var __extends = (this && this.__extends) || function (d, b) { + for (var p in b) if (b.hasOwnProperty(p)) { d[p] = b[p]; } + function __() { this.constructor = d; } + d.prototype = b === null ? Object.create(b) : (__.prototype = b.prototype, new __()); +}; + +function Channel(connection, channel_name) { + this.subscribed = false; + this.dispatcher = new Dispatcher(); + this.connection = connection; + this.channelName = channel_name; + this.subscribeCb = null; + this.queue = []; + __extends(this, this.dispatcher); + var properies = ['on', 'off', 'emit']; + for (var i in properies) { + this[properies[i]] = this.dispatcher[properies[i]]; + } +} + +Channel.prototype.processSubscribe = function () { + if (this.connection.state !== 'connected') { + return; + } + this.subscribeCb(); +}; + +Channel.prototype.processQueue = function () { + if (this.connection.state !== 'connected' || !this.subscribed) { + return; + } + for (var i in this.queue) { + this.queue[i](); + } + this.queue = []; +}; + +Channel.prototype.trigger = function (event, data) { + if (event.indexOf('client-') !== 0) { + throw new Error("Event '" + event + "' should start with 'client-'"); + } + var _this = this; + this.queue.push(function () { + _this.connection.send(JSON.stringify({ event: event, data: data, channel: _this.channelName })); + }); + this.processQueue(); +}; + +//////////////// +var Collections = (function () { + var exports = {}; + function extend(target) { + var sources = []; + for (var _i = 1; _i < arguments.length; _i++) { + sources[_i - 1] = arguments[_i]; + } + for (var i = 0; i < sources.length; i++) { + var extensions = sources[i]; + for (var property in extensions) { + if (extensions[property] && extensions[property].constructor && + extensions[property].constructor === Object) { + target[property] = extend(target[property] || {}, extensions[property]); + } + else { + target[property] = extensions[property]; + } + } + } + return target; + } + + exports.extend = extend; + function stringify() { + var m = ["Push"]; + for (var i = 0; i < arguments.length; i++) { + if (typeof arguments[i] === "string") { + m.push(arguments[i]); + } + else { + m.push(safeJSONStringify(arguments[i])); + } + } + return m.join(" : "); + } + + exports.stringify = stringify; + function arrayIndexOf(array, item) { + var nativeIndexOf = Array.prototype.indexOf; + if (array === null) { + return -1; + } + if (nativeIndexOf && array.indexOf === nativeIndexOf) { + return array.indexOf(item); + } + for (var i = 0, l = array.length; i < l; i++) { + if (array[i] === item) { + return i; + } + } + return -1; + } + + exports.arrayIndexOf = arrayIndexOf; + function objectApply(object, f) { + for (var key in object) { + if (Object.prototype.hasOwnProperty.call(object, key)) { + f(object[key], key, object); + } + } + } + + exports.objectApply = objectApply; + function keys(object) { + var keys = []; + objectApply(object, function (_, key) { + keys.push(key); + }); + return keys; + } + + exports.keys = keys; + function values(object) { + var values = []; + objectApply(object, function (value) { + values.push(value); + }); + return values; + } + + exports.values = values; + function apply(array, f, context) { + for (var i = 0; i < array.length; i++) { + f.call(context || (window), array[i], i, array); + } + } + + exports.apply = apply; + function map(array, f) { + var result = []; + for (var i = 0; i < array.length; i++) { + result.push(f(array[i], i, array, result)); + } + return result; + } + + exports.map = map; + function mapObject(object, f) { + var result = {}; + objectApply(object, function (value, key) { + result[key] = f(value); + }); + return result; + } + + exports.mapObject = mapObject; + function filter(array, test) { + test = test || function (value) { + return !!value; + }; + var result = []; + for (var i = 0; i < array.length; i++) { + if (test(array[i], i, array, result)) { + result.push(array[i]); + } + } + return result; + } + + exports.filter = filter; + function filterObject(object, test) { + var result = {}; + objectApply(object, function (value, key) { + if ((test && test(value, key, object, result)) || Boolean(value)) { + result[key] = value; + } + }); + return result; + } + + exports.filterObject = filterObject; + function flatten(object) { + var result = []; + objectApply(object, function (value, key) { + result.push([key, value]); + }); + return result; + } + + exports.flatten = flatten; + function any(array, test) { + for (var i = 0; i < array.length; i++) { + if (test(array[i], i, array)) { + return true; + } + } + return false; + } + + exports.any = any; + function all(array, test) { + for (var i = 0; i < array.length; i++) { + if (!test(array[i], i, array)) { + return false; + } + } + return true; + } + + exports.all = all; + function encodeParamsObject(data) { + return mapObject(data, function (value) { + if (typeof value === "object") { + value = safeJSONStringify(value); + } + return encodeURIComponent(base64_1["default"](value.toString())); + }); + } + + exports.encodeParamsObject = encodeParamsObject; + function buildQueryString(data) { + var params = filterObject(data, function (value) { + return value !== undefined; + }); + return map(flatten(encodeParamsObject(params)), util_1["default"].method("join", "=")).join("&"); + } + + exports.buildQueryString = buildQueryString; + function decycleObject(object) { + var objects = [], paths = []; + return (function derez(value, path) { + var i, name, nu; + switch (typeof value) { + case 'object': + if (!value) { + return null; + } + for (i = 0; i < objects.length; i += 1) { + if (objects[i] === value) { + return { $ref: paths[i] }; + } + } + objects.push(value); + paths.push(path); + if (Object.prototype.toString.apply(value) === '[object Array]') { + nu = []; + for (i = 0; i < value.length; i += 1) { + nu[i] = derez(value[i], path + '[' + i + ']'); + } + } + else { + nu = {}; + for (name in value) { + if (Object.prototype.hasOwnProperty.call(value, name)) { + nu[name] = derez(value[name], path + '[' + JSON.stringify(name) + ']'); + } + } + } + return nu; + case 'number': + case 'string': + case 'boolean': + return value; + } + }(object, '$')); + } + + exports.decycleObject = decycleObject; + function safeJSONStringify(source) { + try { + return JSON.stringify(source); + } + catch (e) { + return JSON.stringify(decycleObject(source)); + } + } + + exports.safeJSONStringify = safeJSONStringify; + return exports; +})(); + +var Dispatcher = (function () { + function Dispatcher(failThrough) { + this.callbacks = new CallbackRegistry(); + this.global_callbacks = []; + this.failThrough = failThrough; + } + Dispatcher.prototype.on = function (eventName, callback, context) { + this.callbacks.add(eventName, callback, context); + return this; + }; + Dispatcher.prototype.on_global = function (callback) { + this.global_callbacks.push(callback); + return this; + }; + Dispatcher.prototype.off = function (eventName, callback, context) { + this.callbacks.remove(eventName, callback, context); + return this; + }; + Dispatcher.prototype.emit = function (eventName, data) { + var i; + for (i = 0; i < this.global_callbacks.length; i++) { + this.global_callbacks[i](eventName, data); + } + var callbacks = this.callbacks.get(eventName); + if (callbacks && callbacks.length > 0) { + for (i = 0; i < callbacks.length; i++) { + callbacks[i].fn.call(callbacks[i].context || (window), data); + } + } + else if (this.failThrough) { + this.failThrough(eventName, data); + } + return this; + }; + return Dispatcher; +}()); + +var CallbackRegistry = (function () { + function CallbackRegistry() { + this._callbacks = {}; + } + CallbackRegistry.prototype.get = function (name) { + return this._callbacks[prefix(name)]; + }; + CallbackRegistry.prototype.add = function (name, callback, context) { + var prefixedEventName = prefix(name); + this._callbacks[prefixedEventName] = this._callbacks[prefixedEventName] || []; + this._callbacks[prefixedEventName].push({ + fn: callback, + context: context + }); + }; + CallbackRegistry.prototype.remove = function (name, callback, context) { + if (!name && !callback && !context) { + this._callbacks = {}; + return; + } + var names = name ? [prefix(name)] : Collections.keys(this._callbacks); + if (callback || context) { + this.removeCallback(names, callback, context); + } + else { + this.removeAllCallbacks(names); + } + }; + CallbackRegistry.prototype.removeCallback = function (names, callback, context) { + Collections.apply(names, function (name) { + this._callbacks[name] = Collections.filter(this._callbacks[name] || [], function (oning) { + return (callback && callback !== oning.fn) || + (context && context !== oning.context); + }); + if (this._callbacks[name].length === 0) { + delete this._callbacks[name]; + } + }, this); + }; + CallbackRegistry.prototype.removeAllCallbacks = function (names) { + Collections.apply(names, function (name) { + delete this._callbacks[name]; + }, this); + }; + return CallbackRegistry; +}()); + +function prefix(name) { + return "_" + name; +} + +function __ajax(options) { + options = options || {}; + options.type = (options.type || 'GET').toUpperCase(); + options.dataType = options.dataType || 'json'; + params = formatParams(options.data); + + var xhr; + if (window.XMLHttpRequest) { + xhr = new XMLHttpRequest(); + } else { + xhr = ActiveXObject('Microsoft.XMLHTTP'); + } + + xhr.onreadystatechange = function () { + if (xhr.readyState === 4) { + var status = xhr.status; + if (status >= 200 && status < 300) { + options.success && options.success(xhr.responseText, xhr.responseXML); + } else { + options.error && options.error(status); + } + } + } + + if (options.type === 'GET') { + xhr.open('GET', options.url + '?' + params, true); + xhr.send(null); + } else if (options.type === 'POST') { + xhr.open('POST', options.url, true); + xhr.setRequestHeader("Content-Type", "application/x-www-form-urlencoded"); + xhr.send(params); + } +} + +function formatParams(data) { + var arr = []; + for (var name in data) { + arr.push(encodeURIComponent(name) + '=' + encodeURIComponent(data[name])); + } + return arr.join('&'); +} \ No newline at end of file diff --git a/vendor/webman/push/src/push.js b/vendor/webman/push/src/push.js new file mode 100644 index 0000000..92132ea --- /dev/null +++ b/vendor/webman/push/src/push.js @@ -0,0 +1,746 @@ + +function Push(options) { + this.doNotConnect = 0; + options = options || {}; + options.heartbeat = options.heartbeat || 25000; + options.pingTimeout = options.pingTimeout || 10000; + this.config = options; + this.uid = 0; + this.channels = {}; + this.connection = null; + this.pingTimeoutTimer = 0; + Push.instances.push(this); + this.createConnection(); +} + +Push.prototype.checkoutPing = function() { + var _this = this; + _this.checkoutPingTimer && clearTimeout(_this.checkoutPingTimer); + _this.checkoutPingTimer = setTimeout(function () { + _this.checkoutPingTimer = 0; + if (_this.connection.state === 'connected') { + _this.connection.send('{"event":"pusher:ping","data":{}}'); + if (_this.pingTimeoutTimer) { + clearTimeout(_this.pingTimeoutTimer); + _this.pingTimeoutTimer = 0; + } + _this.pingTimeoutTimer = setTimeout(function () { + _this.connection.closeAndClean(); + if (!_this.connection.doNotConnect) { + _this.connection.waitReconnect(); + } + }, _this.config.pingTimeout); + } + }, this.config.heartbeat); +}; + +Push.prototype.channel = function (name) { + return this.channels.find(name); +}; +Push.prototype.allChannels = function () { + return this.channels.all(); +}; +Push.prototype.createConnection = function () { + if (this.connection) { + throw Error('Connection already exist'); + } + var _this = this; + var url = this.config.url; + function updateSubscribed () { + for (var i in _this.channels) { + _this.channels[i].subscribed = false; + } + } + this.connection = new Connection({ + url: url, + app_key: this.config.app_key, + onOpen: function () { + _this.connection.state ='connecting'; + _this.checkoutPing(); + }, + onMessage: function(params) { + if(_this.pingTimeoutTimer) { + clearTimeout(_this.pingTimeoutTimer); + _this.pingTimeoutTimer = 0; + } + + params = JSON.parse(params.data); + var event = params.event; + var channel_name = params.channel; + + if (event === 'pusher:pong') { + _this.checkoutPing(); + return; + } + if (event === 'pusher:error') { + throw Error(params.data.message); + } + var data = JSON.parse(params.data), channel; + if (event === 'pusher_internal:subscription_succeeded') { + channel = _this.channels[channel_name]; + channel.subscribed = true; + channel.processQueue(); + channel.emit('pusher:subscription_succeeded'); + return; + } + if (event === 'pusher:connection_established') { + _this.connection.socket_id = data.socket_id; + _this.connection.updateNetworkState('connected'); + _this.subscribeAll(); + } + if (event.indexOf('pusher_internal') !== -1) { + console.log("Event '"+event+"' not implement"); + return; + } + channel = _this.channels[channel_name]; + if (channel) { + channel.emit(event, data); + } + }, + onClose: function () { + updateSubscribed(); + }, + onError: function () { + updateSubscribed(); + } + }); +}; +Push.prototype.disconnect = function () { + this.connection.doNotConnect = 1; + this.connection.close(); +}; + +Push.prototype.subscribeAll = function () { + if (this.connection.state !== 'connected') { + return; + } + for (var channel_name in this.channels) { + //this.connection.send(JSON.stringify({event:"pusher:subscribe", data:{channel:channel_name}})); + this.channels[channel_name].processSubscribe(); + } +}; + +Push.prototype.unsubscribe = function (channel_name) { + if (this.channels[channel_name]) { + delete this.channels[channel_name]; + if (this.connection.state === 'connected') { + this.connection.send(JSON.stringify({event:"pusher:unsubscribe", data:{channel:channel_name}})); + } + } +}; +Push.prototype.unsubscribeAll = function () { + var channels = Object.keys(this.channels); + if (channels.length) { + if (this.connection.state === 'connected') { + for (var channel_name in this.channels) { + this.unsubscribe(channel_name); + } + } + } + this.channels = {}; +}; +Push.prototype.subscribe = function (channel_name) { + if (this.channels[channel_name]) { + return this.channels[channel_name]; + } + if (channel_name.indexOf('private-') === 0) { + return createPrivateChannel(channel_name, this); + } + if (channel_name.indexOf('presence-') === 0) { + return createPresenceChannel(channel_name, this); + } + return createChannel(channel_name, this); +}; +Push.instances = []; + +function createChannel(channel_name, push) +{ + var channel = new Channel(push.connection, channel_name); + push.channels[channel_name] = channel; + channel.subscribeCb = function () { + push.connection.send(JSON.stringify({event:"pusher:subscribe", data:{channel:channel_name}})); + } + channel.processSubscribe(); + return channel; +} + +function createPrivateChannel(channel_name, push) +{ + var channel = new Channel(push.connection, channel_name); + push.channels[channel_name] = channel; + channel.subscribeCb = function () { + __ajax({ + url: push.config.auth, + type: 'POST', + data: {channel_name: channel_name, socket_id: push.connection.socket_id}, + success: function (data) { + data = JSON.parse(data); + data.channel = channel_name; + push.connection.send(JSON.stringify({event:"pusher:subscribe", data:data})); + }, + error: function (e) { + throw Error(e); + } + }); + }; + channel.processSubscribe(); + return channel; +} + +function createPresenceChannel(channel_name, push) +{ + return createPrivateChannel(channel_name, push); +} + +/*window.addEventListener('online', function(){ + var con; + for (var i in Push.instances) { + con = Push.instances[i].connection; + con.reconnectInterval = 1; + if (con.state === 'connecting') { + con.connect(); + } + } +});*/ + + +function Connection(options) { + this.dispatcher = new Dispatcher(); + __extends(this, this.dispatcher); + var properies = ['on', 'off', 'emit']; + for (var i in properies) { + this[properies[i]] = this.dispatcher[properies[i]]; + } + this.options = options; + this.state = 'initialized'; //initialized connecting connected disconnected + this.doNotConnect = 0; + this.reconnectInterval = 1; + this.connection = null; + this.reconnectTimer = 0; + this.connect(); +} + +Connection.prototype.updateNetworkState = function(state){ + var old_state = this.state; + this.state = state; + if (old_state !== state) { + this.emit('state_change', { previous: old_state, current: state }); + } +}; + +Connection.prototype.connect = function () { + this.doNotConnect = 0; + if (this.state === 'connected') { + console.log('networkState is "' + this.state + '" and do not need connect'); + return; + } + if (this.reconnectTimer) { + clearTimeout(this.reconnectTimer); + this.reconnectTimer = 0; + } + + this.closeAndClean(); + + var options = this.options; + var websocket = new WebSocket(options.url+'/app/'+options.app_key); + + this.updateNetworkState('connecting'); + + var _this = this; + websocket.onopen = function (res) { + _this.reconnectInterval = 1; + if (_this.doNotConnect) { + _this.updateNetworkState('disconnected'); + websocket.close(); + return; + } + if (options.onOpen) { + options.onOpen(res); + } + }; + + if (options.onMessage) { + websocket.onmessage = options.onMessage; + } + + websocket.onclose = function (res) { + websocket.onmessage = websocket.onopen = websocket.onclose = websocket.onerror = null; + _this.updateNetworkState('disconnected'); + if (!_this.doNotConnect) { + _this.waitReconnect(); + } + if (options.onClose) { + options.onClose(res); + } + }; + + websocket.onerror = function (res) { + _this.close(); + if (!_this.doNotConnect) { + _this.waitReconnect(); + } + if (options.onError) { + options.onError(res); + } + }; + this.connection = websocket; +} + +Connection.prototype.closeAndClean = function () { + if(this.connection) { + var websocket = this.connection; + websocket.onmessage = websocket.onopen = websocket.onclose = websocket.onerror = null; + try { + websocket.close(); + } catch (e) {} + this.updateNetworkState('disconnected'); + } +}; + +Connection.prototype.waitReconnect = function () { + if (this.state === 'connected' || this.state === 'connecting') { + return; + } + if (!this.doNotConnect) { + this.updateNetworkState('connecting'); + var _this = this; + if (this.reconnectTimer) { + clearTimeout(this.reconnectTimer); + } + this.reconnectTimer = setTimeout(function(){ + _this.connect(); + }, this.reconnectInterval); + if (this.reconnectInterval < 1000) { + this.reconnectInterval = 1000; + } else { + // 每次重连间隔增大一倍 + this.reconnectInterval = this.reconnectInterval * 2; + } + // 有网络的状态下，重连间隔最大2秒 + if (this.reconnectInterval > 2000 && navigator.onLine) { + _this.reconnectInterval = 2000; + } + } +} + +Connection.prototype.send = function(data) { + if (this.state !== 'connected') { + console.trace('networkState is "' + this.state + '", can not send ' + data); + return; + } + this.connection.send(data); +} + +Connection.prototype.close = function(){ + this.updateNetworkState('disconnected'); + this.connection.close(); +} + +var __extends = (this && this.__extends) || function (d, b) { + for (var p in b) if (b.hasOwnProperty(p)) {d[p] = b[p];} + function __() { this.constructor = d; } + d.prototype = b === null ? Object.create(b) : (__.prototype = b.prototype, new __()); +}; + +function Channel(connection, channel_name) { + this.subscribed = false; + this.dispatcher = new Dispatcher(); + this.connection = connection; + this.channelName = channel_name; + this.subscribeCb = null; + this.queue = []; + __extends(this, this.dispatcher); + var properies = ['on', 'off', 'emit']; + for (var i in properies) { + this[properies[i]] = this.dispatcher[properies[i]]; + } +} + +Channel.prototype.processSubscribe = function () { + if (this.connection.state !== 'connected') { + return; + } + this.subscribeCb(); +}; + +Channel.prototype.processQueue = function () { + if (this.connection.state !== 'connected' || !this.subscribed) { + return; + } + for (var i in this.queue) { + this.queue[i](); + } + this.queue = []; +}; + +Channel.prototype.trigger = function (event, data) { + if (event.indexOf('client-') !== 0) { + throw new Error("Event '" + event + "' should start with 'client-'"); + } + var _this = this; + this.queue.push(function () { + _this.connection.send(JSON.stringify({ event: event, data: data, channel: _this.channelName })); + }); + this.processQueue(); +}; + +//////////////// +var Collections = (function () { + var exports = {}; + function extend(target) { + var sources = []; + for (var _i = 1; _i < arguments.length; _i++) { + sources[_i - 1] = arguments[_i]; + } + for (var i = 0; i < sources.length; i++) { + var extensions = sources[i]; + for (var property in extensions) { + if (extensions[property] && extensions[property].constructor && + extensions[property].constructor === Object) { + target[property] = extend(target[property] || {}, extensions[property]); + } + else { + target[property] = extensions[property]; + } + } + } + return target; + } + + exports.extend = extend; + function stringify() { + var m = ["Push"]; + for (var i = 0; i < arguments.length; i++) { + if (typeof arguments[i] === "string") { + m.push(arguments[i]); + } + else { + m.push(safeJSONStringify(arguments[i])); + } + } + return m.join(" : "); + } + + exports.stringify = stringify; + function arrayIndexOf(array, item) { + var nativeIndexOf = Array.prototype.indexOf; + if (array === null) { + return -1; + } + if (nativeIndexOf && array.indexOf === nativeIndexOf) { + return array.indexOf(item); + } + for (var i = 0, l = array.length; i < l; i++) { + if (array[i] === item) { + return i; + } + } + return -1; + } + + exports.arrayIndexOf = arrayIndexOf; + function objectApply(object, f) { + for (var key in object) { + if (Object.prototype.hasOwnProperty.call(object, key)) { + f(object[key], key, object); + } + } + } + + exports.objectApply = objectApply; + function keys(object) { + var keys = []; + objectApply(object, function (_, key) { + keys.push(key); + }); + return keys; + } + + exports.keys = keys; + function values(object) { + var values = []; + objectApply(object, function (value) { + values.push(value); + }); + return values; + } + + exports.values = values; + function apply(array, f, context) { + for (var i = 0; i < array.length; i++) { + f.call(context || (window), array[i], i, array); + } + } + + exports.apply = apply; + function map(array, f) { + var result = []; + for (var i = 0; i < array.length; i++) { + result.push(f(array[i], i, array, result)); + } + return result; + } + + exports.map = map; + function mapObject(object, f) { + var result = {}; + objectApply(object, function (value, key) { + result[key] = f(value); + }); + return result; + } + + exports.mapObject = mapObject; + function filter(array, test) { + test = test || function (value) { + return !!value; + }; + var result = []; + for (var i = 0; i < array.length; i++) { + if (test(array[i], i, array, result)) { + result.push(array[i]); + } + } + return result; + } + + exports.filter = filter; + function filterObject(object, test) { + var result = {}; + objectApply(object, function (value, key) { + if ((test && test(value, key, object, result)) || Boolean(value)) { + result[key] = value; + } + }); + return result; + } + + exports.filterObject = filterObject; + function flatten(object) { + var result = []; + objectApply(object, function (value, key) { + result.push([key, value]); + }); + return result; + } + + exports.flatten = flatten; + function any(array, test) { + for (var i = 0; i < array.length; i++) { + if (test(array[i], i, array)) { + return true; + } + } + return false; + } + + exports.any = any; + function all(array, test) { + for (var i = 0; i < array.length; i++) { + if (!test(array[i], i, array)) { + return false; + } + } + return true; + } + + exports.all = all; + function encodeParamsObject(data) { + return mapObject(data, function (value) { + if (typeof value === "object") { + value = safeJSONStringify(value); + } + return encodeURIComponent(base64_1["default"](value.toString())); + }); + } + + exports.encodeParamsObject = encodeParamsObject; + function buildQueryString(data) { + var params = filterObject(data, function (value) { + return value !== undefined; + }); + return map(flatten(encodeParamsObject(params)), util_1["default"].method("join", "=")).join("&"); + } + + exports.buildQueryString = buildQueryString; + function decycleObject(object) { + var objects = [], paths = []; + return (function derez(value, path) { + var i, name, nu; + switch (typeof value) { + case 'object': + if (!value) { + return null; + } + for (i = 0; i < objects.length; i += 1) { + if (objects[i] === value) { + return {$ref: paths[i]}; + } + } + objects.push(value); + paths.push(path); + if (Object.prototype.toString.apply(value) === '[object Array]') { + nu = []; + for (i = 0; i < value.length; i += 1) { + nu[i] = derez(value[i], path + '[' + i + ']'); + } + } + else { + nu = {}; + for (name in value) { + if (Object.prototype.hasOwnProperty.call(value, name)) { + nu[name] = derez(value[name], path + '[' + JSON.stringify(name) + ']'); + } + } + } + return nu; + case 'number': + case 'string': + case 'boolean': + return value; + } + }(object, '$')); + } + + exports.decycleObject = decycleObject; + function safeJSONStringify(source) { + try { + return JSON.stringify(source); + } + catch (e) { + return JSON.stringify(decycleObject(source)); + } + } + + exports.safeJSONStringify = safeJSONStringify; + return exports; +})(); + +var Dispatcher = (function () { + function Dispatcher(failThrough) { + this.callbacks = new CallbackRegistry(); + this.global_callbacks = []; + this.failThrough = failThrough; + } + Dispatcher.prototype.on = function (eventName, callback, context) { + this.callbacks.add(eventName, callback, context); + return this; + }; + Dispatcher.prototype.on_global = function (callback) { + this.global_callbacks.push(callback); + return this; + }; + Dispatcher.prototype.off = function (eventName, callback, context) { + this.callbacks.remove(eventName, callback, context); + return this; + }; + Dispatcher.prototype.emit = function (eventName, data) { + var i; + for (i = 0; i < this.global_callbacks.length; i++) { + this.global_callbacks[i](eventName, data); + } + var callbacks = this.callbacks.get(eventName); + if (callbacks && callbacks.length > 0) { + for (i = 0; i < callbacks.length; i++) { + callbacks[i].fn.call(callbacks[i].context || (window), data); + } + } + else if (this.failThrough) { + this.failThrough(eventName, data); + } + return this; + }; + return Dispatcher; +}()); + +var CallbackRegistry = (function () { + function CallbackRegistry() { + this._callbacks = {}; + } + CallbackRegistry.prototype.get = function (name) { + return this._callbacks[prefix(name)]; + }; + CallbackRegistry.prototype.add = function (name, callback, context) { + var prefixedEventName = prefix(name); + this._callbacks[prefixedEventName] = this._callbacks[prefixedEventName] || []; + this._callbacks[prefixedEventName].push({ + fn: callback, + context: context + }); + }; + CallbackRegistry.prototype.remove = function (name, callback, context) { + if (!name && !callback && !context) { + this._callbacks = {}; + return; + } + var names = name ? [prefix(name)] : Collections.keys(this._callbacks); + if (callback || context) { + this.removeCallback(names, callback, context); + } + else { + this.removeAllCallbacks(names); + } + }; + CallbackRegistry.prototype.removeCallback = function (names, callback, context) { + Collections.apply(names, function (name) { + this._callbacks[name] = Collections.filter(this._callbacks[name] || [], function (oning) { + return (callback && callback !== oning.fn) || + (context && context !== oning.context); + }); + if (this._callbacks[name].length === 0) { + delete this._callbacks[name]; + } + }, this); + }; + CallbackRegistry.prototype.removeAllCallbacks = function (names) { + Collections.apply(names, function (name) { + delete this._callbacks[name]; + }, this); + }; + return CallbackRegistry; +}()); +function prefix(name) { + return "_" + name; +} + +function __ajax(options){ + options=options||{}; + options.type=(options.type||'GET').toUpperCase(); + options.dataType=options.dataType||'json'; + params=formatParams(options.data); + + var xhr; + if(window.XMLHttpRequest){ + xhr=new XMLHttpRequest(); + }else{ + xhr=ActiveXObject('Microsoft.XMLHTTP'); + } + + xhr.onreadystatechange=function(){ + if(xhr.readyState === 4){ + var status=xhr.status; + if(status>=200 && status<300){ + options.success&&options.success(xhr.responseText,xhr.responseXML); + }else{ + options.error&&options.error(status); + } + } + } + + if(options.type==='GET'){ + xhr.open('GET',options.url+'?'+params,true); + xhr.send(null); + }else if(options.type==='POST'){ + xhr.open('POST',options.url,true); + xhr.setRequestHeader("Content-Type", "application/x-www-form-urlencoded"); + xhr.send(params); + } +} + +function formatParams(data){ + var arr=[]; + for(var name in data){ + arr.push(encodeURIComponent(name)+'='+encodeURIComponent(data[name])); + } + return arr.join('&'); +}