Skip to content

Commit

Permalink
feat: add command to send raw commands to redis
Browse files Browse the repository at this point in the history
Signed-off-by: Robin Appelman <[email protected]>
  • Loading branch information
icewind1991 committed Jun 14, 2024
1 parent 3a60e40 commit fd1d0e6
Show file tree
Hide file tree
Showing 2 changed files with 61 additions and 0 deletions.
59 changes: 59 additions & 0 deletions core/Command/Memcache/RedisCommand.php
Original file line number Diff line number Diff line change
@@ -0,0 +1,59 @@
<?php

declare(strict_types=1);
/**
* SPDX-FileCopyrightText: 2024 Robin Appelman <[email protected]>
* SPDX-License-Identifier: AGPL-3.0-or-later
*/

namespace OC\Core\Command\Memcache;

use OC\Core\Command\Base;
use OC\RedisFactory;
use OCP\ICertificateManager;
use OCP\IL10N;
use Symfony\Component\Console\Input\InputArgument;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Output\OutputInterface;

class RedisCommand extends Base {
protected IL10N $l;

public function __construct(
protected ICertificateManager $certificateManager,
protected RedisFactory $redisFactory,
) {
parent::__construct();
}

protected function configure() {
$this
->setName('memcache:redis')
->setDescription('Send raw redis command to the configured redis server')
->addArgument('redis-command', InputArgument::REQUIRED | InputArgument::IS_ARRAY, 'The command to run');
parent::configure();
}

protected function execute(InputInterface $input, OutputInterface $output): int {
$command = $input->getArgument('redis-command');
if (!$this->redisFactory->isAvailable()) {
$output->writeln("<error>No redis server configured</error>");
return 1;
}
try {
$redis = $this->redisFactory->getInstance();
} catch (\Exception $e) {
$output->writeln('Failed to connect to redis: ' . $e->getMessage());
return 1;
}

$redis->setOption(\Redis::OPT_REPLY_LITERAL, true);
$result = $redis->rawCommand(...$command);
if ($result === false) {
$output->writeln("<error>Redis command failed</error>");
return 1;
}
$output->writeln($result);
return 0;
}
}
2 changes: 2 additions & 0 deletions core/register_command.php
Original file line number Diff line number Diff line change
Expand Up @@ -140,6 +140,8 @@
$application->add(Server::get(Command\Security\BruteforceResetAttempts::class));
$application->add(Server::get(Command\SetupChecks::class));
$application->add(Server::get(Command\FilesMetadata\Get::class));

$application->add(Server::get(Command\Memcache\RedisCommand::class));
} else {
$application->add(Server::get(Command\Maintenance\Install::class));
}

0 comments on commit fd1d0e6

Please sign in to comment.