archtechx/tenancy
1
0
Fork 0
mirror of https://github.com/archtechx/tenancy.git synced 2025-12-12 18:04:03 +00:00
Code Activity

Extract JobPipelines to a separate package

Browse source
This commit is contained in:
Samuel Štancl 2020-05-15 18:26:08 +02:00
parent 1008db2d43
commit 1833622170
12 changed files with 11 additions and 285 deletions
Download patch file Download diff file Expand all files Collapse all files

95
src/Listeners/JobPipeline.php
View file

@ -1,95 +0,0 @@
<?php
namespace Stancl\Tenancy\Listeners;
use Closure;
use Illuminate\Contracts\Queue\ShouldQueue;
class JobPipeline implements ShouldQueue
{
/** @var bool */
public static $shouldBeQueuedByDefault = false;
/** @var callable[]|string[] */
public $jobs;
/** @var callable|null */
public $send;
/**
* A value passed to the jobs. This is the return value of $send.
*/
public $passable;
/** @var bool */
public $shouldBeQueued;
public function __construct($jobs, callable $send = null, bool $shouldBeQueued = null)
{
$this->jobs = $jobs;
$this->send = $send ?? function ($event) {
// If no $send callback is set, we'll just pass the event through the jobs.
return $event;
};
$this->shouldBeQueued = $shouldBeQueued ?? static::$shouldBeQueuedByDefault;
}
/** @param callable[]|string[] $jobs */
public static function make(array $jobs): self
{
return new static($jobs);
}
public function send(callable $send): self
{
$this->send = $send;
return $this;
}
public function shouldBeQueued(bool $shouldBeQueued)
{
$this->shouldBeQueued = $shouldBeQueued;
return $this;
}
public function handle(): void
{
foreach ($this->jobs as $job) {
app()->call([new $job(...$this->passable), 'handle']);
}
}
/**
* Generate a closure that can be used as a listener.
*/
public function toListener(): Closure
{
return function (...$args) {
$executable = $this->executable($args);
if ($this->shouldBeQueued) {
dispatch($executable);
} else {
dispatch_now($executable);
}
};
}
/**
* Return a serializable version of the current object.
*/
public function executable($listenerArgs): self
{
$clone = clone $this;
$passable = ($clone->send)(...$listenerArgs);
$passable = is_array($passable) ? $passable : [$passable];
$clone->passable = $passable;
unset($clone->send);
return $clone;
}
}