devilbox/.devilbox/www/htdocs/vendor/phpredmin/controllers/keys.php

173 lines
5.6 KiB
PHP
Raw Normal View History

2018-08-12 08:51:32 +00:00
<?php
class Keys_Controller extends Controller
{
public function searchAction()
{
$key = $this->inputs->get('key', null);
$keys = array();
if (isset($key) && trim($key) != '') {
$keys = $this->db->keys($key);
asort($keys);
}
Template::factory()->render('keys/search', array('keys' => $keys, 'search' => $key));
}
public function moveAction($key)
{
$moved = null;
if ($this->router->method == Router::POST) {
$db = $this->inputs->post('db', null);
$key = $this->inputs->post('key', null);
if (!isset($db) || trim($db) == '' || !isset($key) || trim($key) == '') {
$moved = false;
} else {
$moved = $this->db->move($key, $db);
}
}
Template::factory()->render('keys/move', array('moved' => $moved, 'key' => urldecode($key)));
}
public function renameAction($key)
{
$renamed = null;
if ($this->router->method == Router::POST) {
$newkey = $this->inputs->post('newkey', null);
$key = $this->inputs->post('key', null);
if (!isset($newkey) || trim($newkey) == '' || !isset($key) || trim($key) == '') {
$renamed = false;
} else {
$renamed = $this->db->rename($key, $newkey);
}
}
Template::factory()->render('keys/rename', array('renamed' => $renamed, 'key' => urldecode($key)));
}
public function expireAction($key)
{
$updated = null;
$oldttl = $this->db->ttl(urldecode($key));
if ($this->router->method == Router::POST) {
$ttl = $this->inputs->post('ttl', null);
$key = $this->inputs->post('key', null);
if (!isset($ttl) || trim($ttl) == '' || !isset($key) || trim($key) == '') {
$updated = false;
} elseif ((int)$ttl > 0) {
$updated = $this->db->expire($key, $ttl);
} elseif ($oldttl > 0) {
$updated = $this->db->persist($key);
} else {
$updated = true;
}
}
Template::factory()->render('keys/ttl', array('updated' => $updated, 'key' => urldecode($key), 'ttl' => $oldttl));
}
public function moveallAction()
{
if ($this->router->method == Router::POST) {
$results = array();
$values = $this->inputs->post('values', array());
$destination = $this->inputs->post('destination');
foreach ($values as $key => $value) {
$results[$value] = $this->db->move($value, $destination);
}
Template::factory('json')->render($results);
}
}
public function delallAction()
{
if ($this->router->method == Router::POST) {
$results = array();
$values = $this->inputs->post('values', array());
foreach ($values as $key => $value) {
$results[$value] = $this->db->del($value);
}
Template::factory('json')->render($results);
}
}
public function bulkdeleteAction()
{
if ($this->router->method == Router::POST) {
$key = $this->inputs->post('key', null);
if (isset($key) && trim($key) != '') {
$config = App::instance()->config;
$client = new GearmanClient();
$client->addServer($config['gearman']['host'], $config['gearman']['port']);
$client->doBackground('delete_keys',
serialize(array(
'key' => $key,
'server' => $this->app->current,
))
);
}
}
}
public function deleteinfoAction($key)
{
$this->db->incrBy("phpredmin:gearman:requests:{$key}", 1);
$this->db->expireAt("phpredmin:gearman:requests:{$key}", strtotime('+10 minutes'));
$key = urldecode($key);
$total = $this->db->get("phpredmin:gearman:deletecount:{$key}");
$count = $this->db->get("phpredmin:gearman:deleted:{$key}");
$requests = $this->db->get("phpredmin:gearman:requests:{$key}");
if ($total === false && $count !== false && $requests == 1) {
$total = $count;
}
$result = array($total, $count);
Template::factory('json')->render($result);
}
public function deleteAction($key)
{
Template::factory('json')->render($this->db->del(urldecode($key)));
}
public function viewAction($key)
{
switch ($this->db->type(urldecode($key))) {
case Redis::REDIS_STRING:
$this->router->redirect("strings/view/{$this->app->current['serverId']}/{$this->app->current['database']}/{$key}");
break;
case Redis::REDIS_SET:
$this->router->redirect("sets/view/{$this->app->current['serverId']}/{$this->app->current['database']}/{$key}");
break;
case Redis::REDIS_LIST:
$this->router->redirect("lists/view/{$this->app->current['serverId']}/{$this->app->current['database']}/{$key}");
break;
case Redis::REDIS_ZSET:
$this->router->redirect("zsets/view/{$this->app->current['serverId']}/{$this->app->current['database']}/{$key}");
break;
case Redis::REDIS_HASH:
$this->router->redirect("hashes/view/{$this->app->current['serverId']}/{$this->app->current['database']}/{$key}");
break;
}
}
}