12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152 |
- <?php
- namespace OC\Command;
- use Laravel\SerializableClosure\SerializableClosure;
- use OCP\BackgroundJob\IJob;
- use OCP\BackgroundJob\IJobList;
- use OCP\Command\ICommand;
- class CronBus extends AsyncBus {
- public function __construct(
- private IJobList $jobList,
- ) {
- }
- protected function queueCommand($command): void {
- $this->jobList->add($this->getJobClass($command), $this->serializeCommand($command));
- }
-
- private function getJobClass($command): string {
- if ($command instanceof \Closure) {
- return ClosureJob::class;
- } elseif (is_callable($command)) {
- return CallableJob::class;
- } elseif ($command instanceof ICommand) {
- return CommandJob::class;
- } else {
- throw new \InvalidArgumentException('Invalid command');
- }
- }
-
- private function serializeCommand($command): string {
- if ($command instanceof \Closure) {
- return serialize(new SerializableClosure($command));
- } elseif (is_callable($command) or $command instanceof ICommand) {
- return serialize($command);
- } else {
- throw new \InvalidArgumentException('Invalid command');
- }
- }
- }
|