File "DataPipeline.php"
Full Path: /var/www/html/back/vendor/spatie/laravel-data/src/DataPipeline.php
File size: 2.48 KB
MIME-type: text/x-php
Charset: utf-8
<?php
namespace Spatie\LaravelData;
use Spatie\LaravelData\DataPipes\DataPipe;
use Spatie\LaravelData\Normalizers\Normalizer;
use Spatie\LaravelData\Support\DataConfig;
use Spatie\LaravelData\Support\ResolvedDataPipeline;
class DataPipeline
{
protected array $normalizers = [];
protected array $pipes = [];
protected mixed $value;
protected string $classString;
public function __construct(protected DataConfig $dataConfig)
{
}
public static function create(): static
{
return app(static::class);
}
public function into(string $classString): static
{
$this->classString = $classString;
return $this;
}
public function normalizer(string|Normalizer $normalizer): static
{
$this->normalizers[] = $normalizer;
return $this;
}
public function through(string|DataPipe $pipe): static
{
$this->pipes[] = $pipe;
return $this;
}
public function firstThrough(string|DataPipe $pipe): static
{
array_unshift($this->pipes, $pipe);
return $this;
}
public function endThrough(string|DataPipe $pipe): static
{
return $this->through($pipe);
}
public function replace(
string|DataPipe $pipe,
string|DataPipe $replacement
): static {
$pipeClass = is_string($pipe) ? $pipe : $pipe::class;
foreach ($this->pipes as $key => $existingPipe) {
$existingPipeClass = is_string($existingPipe) ? $existingPipe : $existingPipe::class;
if ($existingPipeClass === $pipeClass) {
$this->pipes[$key] = $replacement;
}
}
return $this;
}
public function resolve(): ResolvedDataPipeline
{
$normalizers = array_merge(
$this->normalizers,
$this->classString::normalizers()
);
/** @var \Spatie\LaravelData\Normalizers\Normalizer[] $normalizers */
$normalizers = array_map(
fn (string|Normalizer $normalizer) => is_string($normalizer) ? app($normalizer) : $normalizer,
$normalizers
);
/** @var \Spatie\LaravelData\DataPipes\DataPipe[] $pipes */
$pipes = array_map(
fn (string|DataPipe $pipe) => is_string($pipe) ? app($pipe) : $pipe,
$this->pipes
);
return new ResolvedDataPipeline(
$normalizers,
$pipes,
$this->dataConfig->getDataClass($this->classString)
);
}
}