Files
predis/lib/Predis/Commands/Command.php
T
2011-04-11 23:23:55 +02:00

87 lines
2.3 KiB
PHP

<?php
namespace Predis\Commands;
use Predis\Distribution\INodeKeyGenerator;
abstract class Command implements ICommand {
private $_hash;
private $_arguments = array();
protected function filterArguments(Array $arguments) {
return $arguments;
}
public function setArguments(Array $arguments) {
$this->_arguments = $this->filterArguments($arguments);
unset($this->_hash);
}
public function getArguments() {
return $this->_arguments;
}
public function getArgument($index = 0) {
if (isset($this->_arguments[$index]) === true) {
return $this->_arguments[$index];
}
}
protected function canBeHashed() {
return isset($this->_arguments[0]);
}
protected function getHashablePart($key) {
$start = strpos($key, '{');
if ($start !== false) {
$end = strpos($key, '}', $start);
if ($end !== false) {
$key = substr($key, ++$start, $end - $start);
}
}
return $key;
}
protected function checkSameHashForKeys(Array $keys) {
if (($count = count($keys)) === 0) {
return false;
}
$currentKey = $this->getHashablePart($keys[0]);
for ($i = 1; $i < $count; $i++) {
$nextKey = $this->getHashablePart($keys[$i]);
if ($currentKey !== $nextKey) {
return false;
}
$currentKey = $nextKey;
}
return true;
}
public function getHash(INodeKeyGenerator $distributor) {
if (isset($this->_hash)) {
return $this->_hash;
}
if ($this->canBeHashed()) {
$key = $this->getHashablePart($this->_arguments[0]);
$this->_hash = $distributor->generateKey($key);
return $this->_hash;
}
return null;
}
public function parseResponse($data) {
return $data;
}
public function __toString() {
$reducer = function($acc, $arg) {
if (strlen($arg) > 32) {
$arg = substr($arg, 0, 32) . '[...]';
}
$acc .= " $arg";
return $acc;
};
return array_reduce($this->getArguments(), $reducer, $this->getId());
}
}