Laravel Pipes is a PHP library that allows you to easily chain and execute multiple actions on a single data object. It is inspired by the Unix pipe concept, where the output of one command can be used as the input to another command.
$user = $createUser->execute($request->validated());
$sendWelcomeEmail->execute($user);
you can write this:
$user = pipe($request->validated(), [
CreateUser::class,
SendWelcomeEmail::class,
]);
You can install the package via composer:
composer require kylwes/pipe
You can create a pipe by use the pipe
function:
$user = pipe($request->validated(), [
CreateUser::class,
SendWelcomeEmail::class,
]); // $user is an instance of App\Models\User
When one of your actions expects another parameter, you can use the with
method:
// App\Actions\AssignRoleToUser.php
class AssignRoleToUser
{
public function execute(User $user, $role)
{
$user->assignRole($role);
return $user;
}
}
// App\Http\Controllers\UserController.php
$user = pipe($request->validated())
->with(['role' => Role::find(1)])
->through([
CreateUser::class,
AssignRoleToUser::class,
SendWelcomeEmail::class,
]); // $user is an instance of App\Models\User
You can also use pass anonymous functions:
$user = pipe($data, [
CreateUser::class,
function ($user) {
$user->assignRole(Role::find(1));
return $user;
},
SendWelcomeEmail::class,
]); // $user is an instance of App\Models\User
or call a function:
$title = pipe(' My awesome title ', [
'trim',
'strtoupper',
]); // $title is 'MY AWESOME TITLE'
You can also pipe each individual item in an array or collection by using the ->each()
method:
$users = pipe($users)
->each()
->through([
ResetAnswers::class,
InviteForNextSession::class,
]);
composer test
Please see CHANGELOG for more information on what has changed recently.
Contributions are welcome! If you find a bug or have a feature request, please open an issue on GitHub. If you would like to contribute code, please fork the repository and submit a pull request.
Laravel Pipes is licensed under the MIT license. See the LICENSE file for details.