Stand: SMTP-Test, Admin-Mail-Tab, Notifiable-Fix, Lazy-Quill
- Fix: Notifiable-Trait zum User-Model hinzugefuegt (behebt notify()-500er) - Installer: SMTP-Verbindungstest mit EsmtpTransport + Ueberspringen-Link - Admin: Neuer E-Mail-Tab mit SMTP-Konfiguration + Verbindungstest - Admin: Lazy Quill-Initialisierung (nur sichtbare Locale wird geladen) - Uebersetzungen: 17 neue Mail-Keys in allen 6 Sprachen Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
This commit is contained in:
104
vendor/laravel/framework/src/Illuminate/Process/Pipe.php
vendored
Executable file
104
vendor/laravel/framework/src/Illuminate/Process/Pipe.php
vendored
Executable file
@@ -0,0 +1,104 @@
|
||||
<?php
|
||||
|
||||
namespace Illuminate\Process;
|
||||
|
||||
use Illuminate\Support\Collection;
|
||||
use InvalidArgumentException;
|
||||
|
||||
/**
|
||||
* @mixin \Illuminate\Process\Factory
|
||||
* @mixin \Illuminate\Process\PendingProcess
|
||||
*/
|
||||
class Pipe
|
||||
{
|
||||
/**
|
||||
* The process factory instance.
|
||||
*
|
||||
* @var \Illuminate\Process\Factory
|
||||
*/
|
||||
protected $factory;
|
||||
|
||||
/**
|
||||
* The callback that resolves the pending processes.
|
||||
*
|
||||
* @var callable
|
||||
*/
|
||||
protected $callback;
|
||||
|
||||
/**
|
||||
* The array of pending processes.
|
||||
*
|
||||
* @var array
|
||||
*/
|
||||
protected $pendingProcesses = [];
|
||||
|
||||
/**
|
||||
* Create a new series of piped processes.
|
||||
*
|
||||
* @param \Illuminate\Process\Factory $factory
|
||||
* @param callable $callback
|
||||
*/
|
||||
public function __construct(Factory $factory, callable $callback)
|
||||
{
|
||||
$this->factory = $factory;
|
||||
$this->callback = $callback;
|
||||
}
|
||||
|
||||
/**
|
||||
* Add a process to the pipe with a key.
|
||||
*
|
||||
* @param string $key
|
||||
* @return \Illuminate\Process\PendingProcess
|
||||
*/
|
||||
public function as(string $key)
|
||||
{
|
||||
return tap($this->factory->newPendingProcess(), function ($pendingProcess) use ($key) {
|
||||
$this->pendingProcesses[$key] = $pendingProcess;
|
||||
});
|
||||
}
|
||||
|
||||
/**
|
||||
* Runs the processes in the pipe.
|
||||
*
|
||||
* @param callable|null $output
|
||||
* @return \Illuminate\Contracts\Process\ProcessResult
|
||||
*
|
||||
* @throws \InvalidArgumentException
|
||||
*/
|
||||
public function run(?callable $output = null)
|
||||
{
|
||||
call_user_func($this->callback, $this);
|
||||
|
||||
return (new Collection($this->pendingProcesses))
|
||||
->reduce(function ($previousProcessResult, $pendingProcess, $key) use ($output) {
|
||||
if (! $pendingProcess instanceof PendingProcess) {
|
||||
throw new InvalidArgumentException('Process pipe must only contain pending processes.');
|
||||
}
|
||||
|
||||
if ($previousProcessResult && $previousProcessResult->failed()) {
|
||||
return $previousProcessResult;
|
||||
}
|
||||
|
||||
return $pendingProcess->when(
|
||||
$previousProcessResult,
|
||||
fn () => $pendingProcess->input($previousProcessResult->output())
|
||||
)->run(output: $output ? function ($type, $buffer) use ($key, $output) {
|
||||
$output($type, $buffer, $key);
|
||||
} : null);
|
||||
});
|
||||
}
|
||||
|
||||
/**
|
||||
* Dynamically proxy methods calls to a new pending process.
|
||||
*
|
||||
* @param string $method
|
||||
* @param array $parameters
|
||||
* @return \Illuminate\Process\PendingProcess
|
||||
*/
|
||||
public function __call($method, $parameters)
|
||||
{
|
||||
return tap($this->factory->{$method}(...$parameters), function ($pendingProcess) {
|
||||
$this->pendingProcesses[] = $pendingProcess;
|
||||
});
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user