1:   2:   3:   4:   5:   6:   7:   8:   9:  10:  11:  12:  13:  14:  15:  16:  17:  18:  19:  20:  21:  22:  23:  24:  25:  26:  27:  28:  29:  30:  31:  32:  33:  34:  35:  36:  37:  38:  39:  40:  41:  42:  43:  44:  45:  46:  47:  48:  49:  50:  51:  52:  53:  54:  55:  56:  57:  58:  59:  60:  61:  62:  63:  64:  65:  66:  67:  68:  69:  70:  71:  72:  73:  74:  75:  76:  77:  78:  79:  80:  81:  82:  83:  84:  85:  86:  87:  88:  89:  90:  91:  92:  93:  94:  95:  96:  97:  98:  99: 100: 101: 102: 103: 104: 105: 106: 107: 108: 109: 110: 111: 112: 113: 114: 115: 116: 117: 118: 119: 120: 121: 122: 123: 124: 125: 126: 127: 128: 129: 130: 131: 132: 133: 134: 135: 136: 137: 138: 139: 140: 141: 142: 143: 144: 145: 146: 147: 148: 149: 150: 151: 152: 153: 154: 155: 156: 157: 158: 159: 160: 161: 162: 163: 164: 165: 166: 167: 168: 169: 170: 171: 172: 173: 174: 175: 176: 177: 178: 179: 180: 181: 182: 183: 184: 185: 186: 187: 188: 189: 190: 191: 192: 193: 194: 195: 196: 197: 198: 199: 200: 201: 202: 203: 204: 205: 206: 207: 208: 209: 210: 211: 212: 213: 214: 215: 216: 217: 218: 219: 220: 221: 222: 223: 224: 225: 226: 227: 228: 229: 230: 231: 232: 233: 234: 235: 236: 237: 238: 239: 240: 241: 242: 243: 244: 245: 246: 247: 248: 249: 250: 251: 252: 253: 254: 255: 256: 257: 258: 259: 260: 261: 262: 263: 264: 265: 266: 267: 268: 269: 270: 271: 272: 273: 274: 275: 276: 277: 278: 279: 280: 281: 282: 283: 284: 285: 286: 287: 288: 289: 290: 291: 292: 293: 294: 295: 296: 297: 298: 299: 300: 301: 302: 303: 304: 305: 306: 307: 308: 309: 310: 311: 312: 313: 314: 315: 316: 317: 318: 319: 320: 321: 322: 323: 324: 325: 326: 327: 328: 329: 330: 331: 332: 333: 334: 335: 336: 337: 338: 339: 340: 341: 342: 343: 344: 345: 346: 347: 348: 349: 350: 351: 352: 353: 354: 355: 356: 357: 358: 359: 360: 361: 362: 363: 364: 365: 366: 367: 368: 369: 370: 371: 372: 373: 374: 375: 376: 377: 378: 379: 380: 381: 382: 383: 384: 385: 386: 387: 388: 389: 390: 391: 392: 393: 394: 395: 396: 397: 398: 399: 400: 401: 402: 403: 404: 405: 406: 407: 408: 409: 410: 411: 412: 413: 414: 415: 416: 417: 418: 419: 420: 421: 422: 423: 424: 425: 426: 427: 428: 429: 430: 431: 432: 433: 434: 435: 436: 437: 438: 439: 440: 441: 442: 443: 444: 445: 446: 447: 448: 449: 450: 451: 452: 453: 454: 455: 456: 457: 458: 459: 460: 461: 462: 463: 464: 465: 466: 467: 468: 469: 470: 471: 472: 473: 474: 475: 476: 477: 478: 479: 480: 481: 482: 483: 484: 485: 486: 487: 488: 489: 490: 491: 492: 493: 494: 495: 496: 497: 498: 499: 500: 501: 502: 503: 504: 505: 506: 507: 508: 509: 510: 511: 512: 513: 514: 515: 516: 517: 518: 519: 520: 521: 522: 523: 524: 525: 526: 527: 528: 529: 530: 531: 532: 533: 534: 535: 536: 537: 538: 539: 540: 541: 542: 543: 544: 545: 546: 547: 548: 549: 550: 551: 552: 553: 554: 555: 556: 557: 558: 559: 560: 561: 562: 563: 564: 565: 566: 567: 568: 569: 570: 571: 572: 573: 574: 575: 576: 577: 578: 579: 580: 581: 582: 583: 584: 585: 586: 587: 588: 589: 590: 591: 592: 593: 594: 595: 596: 597: 598: 599: 600: 601: 602: 603: 604: 605: 606: 607: 608: 609: 610: 611: 612: 613: 614: 615: 616: 617: 618: 619: 620: 621: 622: 623: 624: 625: 626: 627: 628: 629: 630: 631: 632: 633: 634: 635: 636: 637: 638: 639: 640: 641: 642: 643: 644: 645: 646: 647: 648: 649: 650: 651: 652: 653: 654: 655: 656: 657: 658: 659: 660: 661: 662: 663: 664: 665: 666: 667: 668: 669: 670: 671: 672: 673: 674: 675: 676: 677: 678: 679: 680: 681: 682: 683: 684: 685: 686: 687: 688: 689: 690: 691: 692: 693: 694: 695: 696: 697: 698: 699: 700: 701: 702: 703: 704: 705: 706: 707: 708: 

<?php

/**
 * MvcCore
 *
 * This source file is subject to the BSD 3 License
 * For the full copyright and license information, please view
 * the LICENSE.md file that are distributed with this source code.
 *
 * @copyright   Copyright (c) 2016 Tom Flidr (https://github.com/mvccore)
 * @license  https://mvccore.github.io/docs/mvccore/5.0.0/LICENCE.md
 */

namespace MvcCore\Ext\Caches;

class Redis implements \MvcCore\Ext\ICache {
    
    /**
     * MvcCore Extension - Cache - Redis - version:
     * Comparison by PHP function version_compare();
     * @see http://php.net/manual/en/function.version-compare.php
     */
    const VERSION = '5.0.0';

    /** @var array */
    protected static $instances = [];

    /** @var array */
    protected static $defaults = [
        \MvcCore\Ext\ICache::CONNECTION_NAME        => 'default',
        \MvcCore\Ext\ICache::CONNECTION_HOST        => '127.0.0.1',
        \MvcCore\Ext\ICache::CONNECTION_PORT        => 6379,
        \MvcCore\Ext\ICache::CONNECTION_DATABASE    => NULL,
        \MvcCore\Ext\ICache::CONNECTION_TIMEOUT     => NULL,
    ];

    /** @var \stdClass|NULL */
    protected $config = NULL;

    /** @var \Redis|NULL */
    protected $redis = NULL;

    /** @var bool */
    protected $enabled = FALSE;

    /** @var bool|NULL */
    protected $connected = NULL;

    /** @var \MvcCore\Application */
    protected $application = TRUE;

    /**
     * @inheritDocs
     * @param string|array|NULL $connectionArguments...
     * If string, it's used as connection name.
     * If array, it's used as connection config array with keys:
     *  - `name`        default: 'default'
     *  - `host`        default: '127.0.0.1'
     *  - `port`        default: 6379
     *  - `database`    default: $_SERVER['SERVER_NAME']
     *  - `timeout`     default: NULL
     *  If NULL, there is returned `default` connection
     *  name with default initial configuration values.
     * @return \MvcCore\Ext\Caches\Redis
     */
    public static function GetInstance (/*...$connectionNameOrArguments = NULL*/) {
        $args = func_get_args();
        $nameKey = self::CONNECTION_NAME;
        $config = static::$defaults;
        $connectionName = $config[$nameKey];
        if (isset($args[0])) {
            $arg = & $args[0];
            if (is_string($arg)) {
                $connectionName = $arg;
            } else if (is_array($arg)) {
                $connectionName = isset($arg[$nameKey])
                    ? $arg[$nameKey]
                    : static::$defaults[$nameKey];
                $config = $arg;
            } else if ($arg !== NULL) {
                throw new \InvalidArgumentException(
                    "[".get_class()."] Cache instance getter argument could be ".
                    "only a string connection name or connection config array."
                );
            }
        }
        if (!isset(self::$instances[$connectionName]))
            self::$instances[$connectionName] = new static($config);
        return self::$instances[$connectionName];
    }

    /**
     * @inheritDocs
     * @param array $config Connection config array with keys:
     *  - `name`        default: 'default'
     *  - `host`        default: '127.0.0.1'
     *  - `port`        default: 6379
     *  - `database`    default: $_SERVER['SERVER_NAME']
     *  - `timeout`     default: NULL
     */
    protected function __construct (array $config = []) {
        $hostKey    = self::CONNECTION_HOST;
        $portKey    = self::CONNECTION_PORT;
        $timeoutKey = self::CONNECTION_TIMEOUT;
        $dbKey      = self::CONNECTION_DATABASE;

        if (!isset($config[$hostKey]))
            $config[$hostKey] = static::$defaults[$hostKey];
        if (!isset($config[$portKey]))
            $config[$portKey] = static::$defaults[$portKey];
        if (
            !isset($config[$timeoutKey]) && 
            static::$defaults[$timeoutKey] !== NULL
        ) 
            $config[$timeoutKey] = static::$defaults[$timeoutKey];
        if (!isset($config[$dbKey]))
            $config[$dbKey] = static::$defaults[$dbKey];

        $this->config = (object) $config;
        $this->application = \MvcCore\Application::GetInstance();
    }

    /**
     * @inheritDocs
     * @return bool
     */
    public function Connect () {
        if (!class_exists('\Redis')) {
            $this->enabled = FALSE;
            $this->connected = FALSE;
        } else {
            $toolClass = $this->application->GetToolClass();
            $debugClass = $this->application->GetDebugClass();
            $timeoutKey = self::CONNECTION_TIMEOUT;

            $connectionArguments = [
                $this->config->{self::CONNECTION_HOST},
                $this->config->{self::CONNECTION_PORT}
            ];
            if (isset($this->config->{$timeoutKey})) {
                $connectionArguments[] = $this->config->{$timeoutKey};
            } else if (static::$defaults[$timeoutKey] !== NULL) {
                $connectionArguments[] = static::$defaults[$timeoutKey];
            }

            try {
                $this->redis = new \Redis();
                $connected = $toolClass::Invoke(
                    [$this->redis, 'connect'],
                    $connectionArguments,
                    function ($errMsg, $errLevel, $errLine, $errContext) use (& $connected) {
                        $connected = FALSE;
                    }
                );
                $this->connected = !!$connected;
                $this->enabled = $this->connected;
                if ($this->enabled)
                    $this->redis->setOption(
                        \Redis::OPT_PREFIX, 
                        $this->config->{self::CONNECTION_DATABASE}.':'
                    );

            } catch (\Exception $e) { // backward compatibility
                $debugClass::Log($e);
                $this->connected = FALSE;
                $this->enabled = FALSE;
            } catch (\Throwable $e) {
                $debugClass::Log($e);
                $this->connected = FALSE;
                $this->enabled = FALSE;
            }
        }
        return $this->connected;
    }

    /**
     * @inheritDocs
     * @return \Redis|NULL
     */
    public function GetResource () {
        return $this->redis;
    }

    /**
     * @inheritDocs
     * @param \Redis $resource
     * @return \MvcCore\Ext\Caches\Redis
     */
    public function SetResource ($resource) {
        $this->redis = $resource;
        return $this;
    }

    /**
     * @inheritDocs
     * @return \stdClass
     */
    public function GetConfig () {
        return $this->config;
    }

    /**
     * Enable/disable cache component.
     * @param bool $enable
     * @return \MvcCore\Ext\Caches\Redis
     */
    public function SetEnabled ($enabled) {
        if ($enabled) {
            $enabled = (class_exists('\Redis') && (
                $this->connected === NULL ||
                $this->connected === TRUE
            ));
        }
        $this->enabled = $enabled;
        return $this;
    }

    /**
     * @inheritDocs
     * @return bool
     */
    public function GetEnabled () {
        return $this->enabled;
    }

    /**
     * @inheritDocs
     * @param array $ops Keys are redis functions names, values are functions arguments.
     * @return array
     */
    public function ProcessTransaction (array $ops = []) {
        $result = [];
        try {
            $multiRedis = $this->redis->multi();
            foreach ($ops as $oppName => $args)
                $multiRedis = $multiRedis->{$oppName}($args);
            $result = $multiRedis->exec();
        } catch (\Exception $e) { // backward compatibility
            if ($this->application->GetEnvironment()->IsDevelopment()) {
                throw $e;
            } else {
                $debugClass = $this->application->GetDebugClass();
                $debugClass::Log($e);
            }
        } catch (\Throwable $e) {
            if ($this->application->GetEnvironment()->IsDevelopment()) {
                throw $e;
            } else {
                $debugClass = $this->application->GetDebugClass();
                $debugClass::Log($e);
            }
        }
        return $result;
    }

    /**
     * @inheritDocs
     * @param string $key
     * @param mixed  $content
     * @param int    $expirationSeconds
     * @param array  $cacheTags
     * @return bool
     */
    public function Save ($key, $content, $expirationSeconds = NULL, $cacheTags = []) {
        $result = FALSE;
        if (!$this->enabled)
            return $result;
        try {
            if ($expirationSeconds === NULL) {
                $this->redis->set($key, serialize($content));
            } else {
                $this->redis->setEx($key, $expirationSeconds, serialize($content));
            }
            if ($cacheTags)
                foreach ($cacheTags as $tag)
                    $this->redis->sAdd(self::TAG_PREFIX . $tag, $key);
            $result = TRUE;
        } catch (\Exception $e) { // backward compatibility
            if ($this->application->GetEnvironment()->IsDevelopment()) {
                throw $e;
            } else {
                $debugClass = $this->application->GetDebugClass();
                $debugClass::Log($e);
            }
        } catch (\Throwable $e) {
            if ($this->application->GetEnvironment()->IsDevelopment()) {
                throw $e;
            } else {
                $debugClass = $this->application->GetDebugClass();
                $debugClass::Log($e);
            }
        }
        return $result;
    }

    /**
     * @inheritDocs
     * @param array $keysAndContents
     * @param int   $expirationSeconds
     * @param array $cacheTags
     * @return bool
     */
    public function SaveMultiple ($keysAndContents, $expirationSeconds = NULL, $cacheTags = []) {
        $result = FALSE;
        if (!$this->enabled || $keysAndContents === NULL)
            return $result;
        try {
            $keysAndContents = array_map('serialize', $keysAndContents);
            if ($expirationSeconds === NULL) {
                $this->redis->mSet($keysAndContents);
            } else {
                foreach ($keysAndContents as $key => $serializedContent)
                    $this->redis->setEx($key, $expirationSeconds, $serializedContent);
            }
            if ($cacheTags) {
                $args = array_keys($keysAndContents);
                if ($args !== NULL) {
                    array_unshift($args, '');
                    foreach ($cacheTags as $tag) {
                        $args[0] = self::TAG_PREFIX . $tag;
                        call_user_func_array([$this->redis, 'sAdd'], $args);
                    }
                }
            }
            $result = TRUE;
        } catch (\Exception $e) { // backward compatibility
            if ($this->application->GetEnvironment()->IsDevelopment()) {
                throw $e;
            } else {
                $debugClass = $this->application->GetDebugClass();
                $debugClass::Log($e);
            }
        } catch (\Throwable $e) {
            if ($this->application->GetEnvironment()->IsDevelopment()) {
                throw $e;
            } else {
                $debugClass = $this->application->GetDebugClass();
                $debugClass::Log($e);
            }
        }
        return $result;
    }

    /**
     * @inheritDocs
     * @param string        $key
     * @param callable|NULL $notFoundCallback function ($cache, $cacheKey) { ... $cache->Save($cacheKey, $data); return $data; }
     * @return mixed|NULL
     */
    public function Load ($key, callable $notFoundCallback = NULL) {
        $result = NULL;
        $debugClass = $this->application->GetDebugClass();
        if (!$this->enabled) {
            if ($notFoundCallback !== NULL) {
                try {
                    $result = call_user_func_array($notFoundCallback, [$this, $key]);
                } catch (\Exception $e1) { // backward compatibility
                    if ($this->application->GetEnvironment()->IsDevelopment()) {
                        throw $e1;
                    } else {
                        $debugClass::Log($e1);
                        $result = NULL;
                    }
                } catch (\Throwable $e1) {
                    if ($this->application->GetEnvironment()->IsDevelopment()) {
                        throw $e1;
                    } else {
                        $debugClass::Log($e1);
                        $result = NULL;
                    }
                }
            }
            return $result;
        }
        try {
            $rawContent = $this->redis->get($key);
            if ($rawContent !== FALSE) {
                $result = unserialize($rawContent);
            } else if ($notFoundCallback !== NULL) {
                $result = call_user_func_array($notFoundCallback, [$this, $key]);
            }
        } catch (\Exception $e2) { // backward compatibility
            if ($this->application->GetEnvironment()->IsDevelopment()) {
                throw $e2;
            } else {
                $debugClass::Log($e2);
                $result = NULL;
            }
        } catch (\Throwable $e2) {
            if ($this->application->GetEnvironment()->IsDevelopment()) {
                throw $e2;
            } else {
                $debugClass::Log($e2);
                $result = NULL;
            }
        }
        return $result;
    }

    /**
     * @inheritDocs
     * @param \string[]     $keys
     * @param callable|NULL $notFoundCallback function ($cache, $cacheKey) { ... $cache->Save($cacheKey, $data); return $data; }
     * @return mixed|NULL
     */
    public function LoadMultiple (array $keys, callable $notFoundCallback = NULL) {
        $results = [];
        $keysArr = func_get_args();
        if (count($keysArr) === 1) {
            if (is_array($keys)) {
                $keysArr = $keys;
            } else if (is_string($keys)) {
                $keysArr = [$keys];
            }
        }
        $debugClass = $this->application->GetDebugClass();
        if (!$this->enabled) {
            if ($notFoundCallback !== NULL) {
                foreach ($keysArr as $index => $key) {
                    try {
                        $results[$index] = call_user_func_array(
                            $notFoundCallback, [$this, $key]
                        );
                    } catch (\Exception $e1) { // backward compatibility
                        if ($this->application->GetEnvironment()->IsDevelopment()) {
                            throw $e1;
                        } else {
                            $debugClass::Log($e1);
                            $results[$index] = NULL;
                        }
                    } catch (\Throwable $e1) {
                        if ($this->application->GetEnvironment()->IsDevelopment()) {
                            throw $e1;
                        } else {
                            $debugClass::Log($e1);
                            $results[$index] = NULL;
                        }
                    }
                }
                return $results;
            } else {
                return NULL;
            }
        }
        try {
            $rawContents = $this->redis->mGet($keysArr);
        } catch (\Exception $e2) { // backward compatibility
            if ($this->application->GetEnvironment()->IsDevelopment()) {
                throw $e2;
            } else {
                $debugClass::Log($e2);
            }
        } catch (\Throwable $e2) {
            if ($this->application->GetEnvironment()->IsDevelopment()) {
                throw $e2;
            } else {
                $debugClass::Log($e2);
            }
        }
        foreach ($rawContents as $index => $rawContent) {
            try {
                if ($rawContent !== FALSE) {
                    $results[$index] = unserialize($rawContent);
                } else if ($notFoundCallback !== NULL) {
                    $results[$index] = call_user_func_array($notFoundCallback, [$this, $keys[$index]]);
                }
            } catch (\Exception $e2) { // backward compatibility
                if ($this->application->GetEnvironment()->IsDevelopment()) {
                    throw $e3;
                } else {
                    $debugClass::Log($e3);
                    $results[$index] = NULL;
                }
            } catch (\Throwable $e3) {
                if ($this->application->GetEnvironment()->IsDevelopment()) {
                    throw $e3;
                } else {
                    $debugClass::Log($e3);
                    $results[$index] = NULL;
                }
            }
        }
        return $results;
    }

    /**
     * @inheritDocs
     * @param string $key
     * @return bool
     */
    public function Delete ($key) {
        if (!$this->enabled) return FALSE;
        $deletedKeysCount = 0;
        try {
            $deletedKeysCount = $this->redis->del($key);
        } catch (\Exception $e) { // backward compatibility
            if ($this->application->GetEnvironment()->IsDevelopment()) {
                throw $e;
            } else {
                $debugClass = $this->application->GetDebugClass();
                $debugClass::Log($e);
            }
        } catch (\Throwable $e) {
            if ($this->application->GetEnvironment()->IsDevelopment()) {
                throw $e;
            } else {
                $debugClass = $this->application->GetDebugClass();
                $debugClass::Log($e);
            }
        }
        return $deletedKeysCount;
    }

    /**
     * @inheritDocs
     * @param \string[] $keys
     * @param array $keysTags
     * @return int
     */
    public function DeleteMultiple (array $keys, array $keysTags = []) {
        if (!$this->enabled) return 0;
        $deletedKeysCount = 0;
        try {
            if (count($keys) > 0) {
                $deletedKeysCount = call_user_func_array(
                    [$this->redis, 'del'],
                    $keys
                );
            }
            if (count($keysTags) > 0) {
                $setsAndKeysToRemove = [];
                foreach ($keysTags as $key => $tags) {
                    foreach ($tags as $tag) {
                        $cacheTag = self::TAG_PREFIX . $tag;
                        if (!isset($setsAndKeysToRemove[$cacheTag]))
                            $setsAndKeysToRemove[$cacheTag] = [];
                        $setsAndKeysToRemove[$cacheTag][] = $key;
                    }
                }
                foreach ($setsAndKeysToRemove as $cacheTag => $keysToRemove) {
                    if ($keysToRemove === NULL) continue;
                    array_unshift($keysToRemove, $cacheTag);
                    call_user_func_array(
                        [$this->redis, 'sRem'],
                        $keysToRemove
                    );
                }
            }
        } catch (\Exception $e) { // backward compatibility
            if ($this->application->GetEnvironment()->IsDevelopment()) {
                throw $e;
            } else {
                $debugClass = $this->application->GetDebugClass();
                $debugClass::Log($e);
            }
        } catch (\Throwable $e) {
            if ($this->application->GetEnvironment()->IsDevelopment()) {
                throw $e;
            } else {
                $debugClass = $this->application->GetDebugClass();
                $debugClass::Log($e);
            }
        }
        return $deletedKeysCount;
    }

    /**
     * @inheritDocs
     * @param string|array $tags
     * @return int
     */
    public function DeleteByTags ($tags) {
        if (!$this->enabled) return 0;
        $tagsArr = func_get_args();
        if (count($tagsArr) === 1) {
            if (is_array($tags)) {
                $tagsArr = $tags;
            } else if (is_string($tags)) {
                $tagsArr = [$tags];
            }
        }
        $keysToDelete = [];
        foreach ($tagsArr as $tag) {
            $cacheTag = self::TAG_PREFIX . $tag;
            $keysToDelete[] = $cacheTag;
            $keysToDeleteLocal = $this->redis->sMembers($cacheTag);
            $keysToDelete = array_merge($keysToDelete, $keysToDeleteLocal);
        }
        $deletedKeysCount = 0;
        if (count($keysToDelete) > 0) {
            try {
                $deletedKeysCount = call_user_func_array(
                    [$this->redis, 'del'],
                    $keysToDelete
                );
            } catch (\Exception $e) { // backward compatibility
                if ($this->application->GetEnvironment()->IsDevelopment()) {
                    throw $e;
                } else {
                    $debugClass = $this->application->GetDebugClass();
                    $debugClass::Log($e);
                }
            } catch (\Throwable $e) {
                if ($this->application->GetEnvironment()->IsDevelopment()) {
                    throw $e;
                } else {
                    $debugClass = $this->application->GetDebugClass();
                    $debugClass::Log($e);
                }
            }
        }
        return $deletedKeysCount;
    }

    /**
     * @inheritDocs
     * @param string $key
     * @return int
     */
    public function Has ($key) {
        $result = 0;
        if (!$this->enabled) return $result;
        try {
            $result = $this->redis->exists($key);
        } catch (\Exception $e) { // backward compatibility
            if ($this->application->GetEnvironment()->IsDevelopment()) {
                throw $e;
            } else {
                $debugClass = $this->application->GetDebugClass();
                $debugClass::Log($e);
            }
        } catch (\Throwable $e) {
            if ($this->application->GetEnvironment()->IsDevelopment()) {
                throw $e;
            } else {
                $debugClass = $this->application->GetDebugClass();
                $debugClass::Log($e);
            }
        }
        return $result;
    }

    /**
     * @inheritDocs
     * @param \string[] $key
     * @return int
     */
    public function HasMultiple ($keys) {
        $result = 0;
        if (!$this->enabled) return $result;
        $keysArr = func_get_args();
        if (count($keysArr) === 1) {
            if (is_array($keys)) {
                $keysArr = $keys;
            } else if (is_string($keys)) {
                $keysArr = [$keys];
            }
        }
        try {
            $result = call_user_func_array(
                [$this->redis, 'exists'],
                $keysArr
            );
        } catch (\Exception $e) { // backward compatibility
            if ($this->application->GetEnvironment()->IsDevelopment()) {
                throw $e;
            } else {
                $debugClass = $this->application->GetDebugClass();
                $debugClass::Log($e);
            }
        } catch (\Throwable $e) {
            if ($this->application->GetEnvironment()->IsDevelopment()) {
                throw $e;
            } else {
                $debugClass = $this->application->GetDebugClass();
                $debugClass::Log($e);
            }
        }
        return $result;
    }

    /**
     * @inheritDocs
     * @return bool
     */
    public function Clear () {
        $result = FALSE;
        if (!$this->enabled) return $result;
        try {
            $result = $this->redis->flushDb();
        } catch (\Exception $e) { // backward compatibility
            if ($this->application->GetEnvironment()->IsDevelopment()) {
                throw $e;
            } else {
                $debugClass = $this->application->GetDebugClass();
                $debugClass::Log($e);
            }
        } catch (\Throwable $e) {
            if ($this->application->GetEnvironment()->IsDevelopment()) {
                throw $e;
            } else {
                $debugClass = $this->application->GetDebugClass();
                $debugClass::Log($e);
            }
        }
        return $result;
    }
}