client; } /** * Run a command against Redis. * * @param string $name * @param array $parameters * @return mixed */ public function command(string $name, array $parameters = []) { $this->lastCommand = null; $debug = $this->config->debug || $this->config->save_commands; $method = strtolower($name); $command = $name === 'getWithMeta' ? 'GET' : strtoupper($name); try { $start = microtime(true); $memory = memory_get_usage(); $result = $this->client->{$method}(...$parameters); $memory = (memory_get_usage() - $memory) ?: 1; $wait = (microtime(true) - $start) * 1000; } catch (Throwable $exception) { $this->log->error("Failed to execute `{$command}` command", [ 'command' => $command, 'parameters' => $parameters, 'exception' => $exception, 'backtrace' => \debug_backtrace(\DEBUG_BACKTRACE_IGNORE_ARGS), ]); throw ConnectionException::from($exception); } $this->lastCommand = [ 'wait' => $wait, 'memory' => $memory, ]; if ($debug) { $ms = \round($wait, 4); $this->log->debug("Executed `{$command}` command in {$ms}ms", [ 'command' => $command, 'parameters' => $parameters, 'time' => $wait, 'memory' => $memory, 'result' => $result, 'backtrace' => \debug_backtrace(\DEBUG_BACKTRACE_IGNORE_ARGS), ]); } return $result; } /** * Execute the callback without data mutations on the connection, * such as serialization and compression algorithms. * * @param callable $callback * @return mixed */ public function withoutMutations(callable $callback) { return $callback($this); } /** * Returns the memoized result from the given command. * * @param string $command * @return mixed */ public function memoize($command) { static $cache; $command = \strtolower($command); if (! isset($cache[$command])) { $cache[$command] = \method_exists($this, $command) ? $this->{$command}() : $this->command($command); } return $cache[$command]; } /** * Pass other method calls down to the underlying client. * * @param string $method * @param array $parameters * @return mixed */ public function __call($method, $parameters) { return $this->command($method, $parameters); } }