refactor(Coroutine): Remove Coroutine Model

1. Remove class Rid\Pool\ConnectionPool, Rid\{Database,Redis}\Coroutine,
   We now only keep permanent model.
2. Crontab: only print when function hit.
3. Remove class Rid\Http\Token Component.
4. Not remember empty session as invalid, just quick return false.

CHANGELOG.md

@@ -13,6 +13,7 @@
 - **Process:** Add custom Process Support
 - **Redis:** Add mutiDelete() function for Redis
 - **Tracker:** Add `retry in` field when failed
+- **Tracker:** Move From Timer to Process
 - **UserInfo:** Add Cache Lock of user access_{time,ip} update
 - **ban:** Add table `ban_usernames` and `ban_emails`
 - **csrf:** Add Csrf Support

apps/components/Site.php

@@ -102,8 +102,9 @@ protected function loadCurUser($grant = 'cookies')
     protected function loadCurUserFromCookies()
     {
         $user_session_id = app()->request->cookie(Constant::cookie_name);
-        $user_id = app()->redis->zScore(Constant::mapUserSessionToId, $user_session_id);
-        if (false === $user_id) {
+        if (is_null($user_session_id)) return false;  // quick return when cookies is not exist
+
+        if (false === $user_id = app()->redis->zScore(Constant::mapUserSessionToId, $user_session_id)) {
             // First check cache
             if (false === app()->redis->zScore(Constant::invalidUserSessionZset, $user_session_id)) {
                 // check session from database to avoid lost
@@ -126,7 +127,7 @@ protected function loadCurUserFromPasskey()
         $passkey = app()->request->get('passkey');
         $user_id = app()->redis->zScore(Constant::mapUserPasskeyToId, $passkey);
         if (false === $user_id) {
-            if (app()->redis->zScore(Constant::invalidUserPasskeyZset, $passkey) !== false) {
+            if (app()->redis->zScore(Constant::invalidUserPasskeyZset, $passkey) === false) {
                 $user_id = app()->pdo->createCommand('SELECT `id` FROM `users` WHERE `passkey` = :passkey LIMIT 1;')->bindParams([
                     'passkey' => $passkey
                 ])->queryScalar();

apps/config/http_base.php

@@ -1,5 +1,7 @@
 <?php
 /**
+ * rid-httpd 下运行的 HTTP 服务配置（常驻同步模式）
+ *
  * Created by PhpStorm.
  * User: Rhilip
  * Date: 2018/11/26
@@ -81,31 +83,6 @@
             'maxFileSize' => 0,  // 最大文件尺寸
         ],
 
-        // Token
-        'token'    => [
-            // 类路径
-            'class'         => Rid\Http\Token::class,
-            // 保存处理者
-            'saveHandler'   => [
-                // 类路径
-                'class'    => Rid\Redis\RedisConnection::class,
-                // 主机
-                'host'     => env('REDIS_HOST'),
-                // 端口
-                'port'     => env('REDIS_PORT'),
-                // 数据库
-                'database' => env('REDIS_DATABASE'),
-                // 密码
-                'password' => env('REDIS_PASSWORD'),
-            ],
-            // 保存的Key前缀
-            'saveKeyPrefix' => 'TOKEN:',
-            // 有效期
-            'expiresIn'     => 604800,
-            // token键名
-            'name'          => 'access_token',
-        ],
-
         // Session
         'session'  => [
             // 类路径
@@ -160,7 +137,7 @@
         // 数据库
         'pdo'      => [
             // 类路径
-            'class'         => Rid\Database\PDOConnection::class,
+            'class'         => Rid\Database\Persistent\PDOConnection::class,
             // 数据源格式
             'dsn'           => env('DATABASE_DSN'),
             // 数据库用户名
@@ -177,7 +154,7 @@
         // redis
         'redis'    => [
             // 类路径
-            'class'    => Rid\Redis\RedisConnection::class,
+            'class'    => Rid\Redis\Persistent\RedisConnection::class,
             // 主机
             'host'     => env('REDIS_HOST'),
             // 端口

apps/config/httpd.php

@@ -71,7 +71,7 @@
             'virtualHost' => [
                 'host'       => '127.0.0.1',
                 'port'       => 9501,
-                'configFile' => __DIR__ . '/http_permanent.php',
+                'configFile' => __DIR__ . '/http_base.php',
             ],
 
             // 运行参数：https://wiki.swoole.com/wiki/page/274.html

apps/process/CronTabProcess.php

@@ -12,7 +12,7 @@
 use Rid\Base\Process;
 
 
-class CronTabProcess extends Process
+final class CronTabProcess extends Process
 {
 
     private $_print_flag = 1;  // FIXME debug model on
@@ -67,7 +67,7 @@ public function run()
             }
         }
         $end_time = time();
-        $this->print_log('This Cron Work period Start At ' . $start_time . ', Cost Time: ' . number_format($start_time - $end_time, 10) . 's, With ' . $hit . ' Jobs hits.');
+        if ($hit > 0) $this->print_log('This Cron Work period Start At ' . $start_time . ', Cost Time: ' . number_format($end_time - $start_time, 10) . 's, With ' . $hit . ' Jobs hits.');
     }
 
     protected function clean_expired_zset_cache() {
@@ -92,7 +92,7 @@ protected function clean_expired_zset_cache() {
         foreach ($clean_list as $item) {
             [$field, $msg] = $item;
             $clean_count = app()->redis->zRemRangeByScore($field, 0, $timenow);
-            if ($clean_list) $this->print_log(sprintf($msg, $clean_count));
+            if ($clean_count > 0) $this->print_log(sprintf($msg, $clean_count));
         }
     }
 

framework/Base/Process.php

@@ -17,7 +17,8 @@ class Process implements StaticInstanceInterface
     private $sleep_time;
     protected $_config;
 
-    public function run() {
+    public function run()
+    {
 
     }
 
@@ -42,10 +43,13 @@ protected function resetSleepTime()
         $this->setSleepTime($this->_config['sleep']);
     }
 
-    final public function start($config) {
+    final public function start($config)
+    {
         $this->_config = $config;
         $this->resetSleepTime();
 
+        println('New Custom process `' . static::class . '` added.');
+
         while (true) {
             $this->run();
             sleep($this->getSleepTime());