Server IP : 184.154.167.98 / Your IP : 3.145.14.239 Web Server : Apache System : Linux pink.dnsnetservice.com 4.18.0-553.22.1.lve.1.el8.x86_64 #1 SMP Tue Oct 8 15:52:54 UTC 2024 x86_64 User : puertode ( 1767) PHP Version : 7.2.34 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : ON | Pkexec : ON Directory : /home/puertode/www/sesiones/lib/private/Command/ |
Upload File : |
<?php /** * @copyright Copyright (c) 2017 Robin Appelman <robin@icewind.nl> * * @author Morris Jobke <hey@morrisjobke.de> * @author Robin Appelman <robin@icewind.nl> * * @license GNU AGPL version 3 or any later version * * This program is free software: you can redistribute it and/or modify * it under the terms of the GNU Affero General Public License as * published by the Free Software Foundation, either version 3 of the * License, or (at your option) any later version. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU Affero General Public License for more details. * * You should have received a copy of the GNU Affero General Public License * along with this program. If not, see <http://www.gnu.org/licenses/>. * */ namespace OC\Command; use OCP\Command\ICommand; use SuperClosure\Serializer; class CronBus extends AsyncBus { /** * @var \OCP\BackgroundJob\IJobList */ private $jobList; /** * @param \OCP\BackgroundJob\IJobList $jobList */ public function __construct($jobList) { $this->jobList = $jobList; } protected function queueCommand($command) { $this->jobList->add($this->getJobClass($command), $this->serializeCommand($command)); } /** * @param \OCP\Command\ICommand | callable $command * @return string */ private function getJobClass($command) { if ($command instanceof \Closure) { return ClosureJob::class; } else if (is_callable($command)) { return CallableJob::class; } else if ($command instanceof ICommand) { return CommandJob::class; } else { throw new \InvalidArgumentException('Invalid command'); } } /** * @param \OCP\Command\ICommand | callable $command * @return string */ private function serializeCommand($command) { if ($command instanceof \Closure) { $serializer = new Serializer(); return $serializer->serialize($command); } else if (is_callable($command) or $command instanceof ICommand) { return serialize($command); } else { throw new \InvalidArgumentException('Invalid command'); } } }