Apply pipelines in OfficeController

app/Http/Controllers/OfficeController.php

@@ -2,50 +2,50 @@
 
 namespace App\Http\Controllers;
 
-use App\Http\Resources\OfficeResource;
+use App\Models\User;
 use App\Models\Office;
 use App\Models\Reservation;
-use App\Models\User;
-use App\Models\Validators\OfficeValidator;
-use App\Notifications\OfficePendingApproval;
-use Illuminate\Http\Resources\Json\JsonResource;
-use Illuminate\Http\Response;
 use Illuminate\Support\Arr;
+use Illuminate\Http\Response;
+use Illuminate\Validation\Rule;
+use Illuminate\Pipeline\Pipeline;
 use Illuminate\Support\Facades\DB;
-use Illuminate\Support\Facades\Notification;
+use App\Http\Resources\OfficeResource;
 use Illuminate\Support\Facades\Storage;
-use Illuminate\Validation\Rule;
+use App\Models\Validators\OfficeValidator;
+use App\Notifications\OfficePendingApproval;
+use Illuminate\Support\Facades\Notification;
+use App\Http\Pipelines\Orders\OrderByDistance;
 use Illuminate\Validation\ValidationException;
+use App\Http\Pipelines\Filtration\FilterByTags;
+use Illuminate\Http\Resources\Json\JsonResource;
+use App\Http\Pipelines\Filtration\FilterByUserId;
+use App\Http\Pipelines\Filtration\OfficeAvailable;
+use App\Http\Pipelines\Filtration\FilterByVisitorId;
+use App\Http\Pipelines\Relationships\ReturnWithTags;
+use App\Http\Pipelines\Relationships\ReturnWithUser;
+use App\Http\Pipelines\Relationships\ReturnWithImages;
+use App\Http\Pipelines\Relationships\ReturnWithReservationsCount;
 
 class OfficeController extends Controller
 {
     public function index(): JsonResource
     {
-        $offices = Office::query()
-            ->when(request('user_id') && auth()->user() && request('user_id') == auth()->id(),
-                fn($builder) => $builder,
-                fn($builder) => $builder->where('approval_status', Office::APPROVAL_APPROVED)->where('hidden', false)
-            )
-            ->when(request('user_id'), fn($builder) => $builder->whereUserId(request('user_id')))
-            ->when(request('visitor_id'),
-                fn($builder) => $builder->whereRelation('reservations', 'user_id', '=', request('visitor_id'))
-            )
-            ->when(
-                request('lat') && request('lng'),
-                fn($builder) => $builder->nearestTo(request('lat'), request('lng')),
-                fn($builder) => $builder->orderBy('id', 'ASC')
-            )
-            ->when(request('tags'),
-                fn($builder) => $builder->whereHas(
-                    'tags',
-                    fn ($builder) => $builder->whereIn('id', request('tags')),
-                    '=',
-                    count(request('tags'))
-                )
-            )
-            ->with(['images', 'tags', 'user'])
-            ->withCount(['reservations' => fn($builder) => $builder->whereStatus(Reservation::STATUS_ACTIVE)])
-            ->paginate(20);
+        $offices = app(Pipeline::class)
+                ->send(Office::query())
+                ->through([
+                    OfficeAvailable::class,
+                    FilterByUserId::class,
+                    FilterByVisitorId::class,
+                    OrderByDistance::class,
+                    FilterByTags::class,
+                    ReturnWithImages::class,
+                    ReturnWithTags::class,
+                    ReturnWithUser::class,
+                    ReturnWithReservationsCount::class,
+                ])
+                ->thenReturn()
+                ->paginate(request('per_page', 20));
 
         return OfficeResource::collection(
             $offices

app/Http/Pipelines/Filtration/FilterByHostId.php

@@ -0,0 +1,20 @@
+<?php
+
+namespace App\Http\Pipelines\Filtration;
+
+use Closure;
+use App\Http\Pipelines\Pipe;
+use Illuminate\Database\Eloquent\Builder;
+
+class FilterByHostId implements Pipe
+{
+    public function handle($request, Closure $next)
+    {
+        $builder = $next($request);
+
+        return $builder->when(request('host_id'),
+            fn(Builder $query) =>
+                $query->whereUserId(request('host_id')) 
+            );
+    }
+}

app/Http/Pipelines/Filtration/FilterByTags.php

@@ -0,0 +1,24 @@
+<?php
+
+namespace App\Http\Pipelines\Filtration;
+
+use Closure;
+use App\Http\Pipelines\Pipe;
+
+class FilterByTags implements Pipe
+{
+    public function handle($request, Closure $next)
+    {
+        $builder = $next($request);
+
+        return $builder
+            ->when(request('tags'),
+                fn($builder) => $builder->whereHas(
+                    'tags',
+                    fn ($builder) => $builder->whereIn('id', request('tags')),
+                    '=',
+                    count(request('tags'))
+                )
+            );
+    }
+}

app/Http/Pipelines/Filtration/FilterByUserId.php

@@ -0,0 +1,17 @@
+<?php
+
+namespace App\Http\Pipelines\Filtration;
+
+use Closure;
+use App\Http\Pipelines\Pipe;
+use Illuminate\Database\Eloquent\Builder;
+
+class FilterByUserId implements Pipe
+{
+    public function handle($request, Closure $next)
+    {
+        $builder = $next($request);
+
+        return $builder->when(request('user_id'), fn($builder) => $builder->whereUserId(request('user_id')));
+    }
+}

app/Http/Pipelines/Filtration/FilterByVisitorId.php

@@ -0,0 +1,20 @@
+<?php
+
+namespace App\Http\Pipelines\Filtration;
+
+use Closure;
+use App\Http\Pipelines\Pipe;
+use Illuminate\Database\Eloquent\Builder;
+
+class FilterByVisitorId implements Pipe
+{
+    public function handle($request, Closure $next)
+    {
+        $builder = $next($request);
+
+        return $builder->when(request('visitor_id'), 
+            fn (Builder $query) => 
+                $query->whereRelation('reservations', 'user_id', request('visitor_id'))
+            );
+    }
+}

app/Http/Pipelines/Filtration/IsApproved.php

@@ -0,0 +1,18 @@
+<?php
+
+namespace App\Http\Pipelines\Filtration;
+
+use App\Http\Pipelines\Pipe;
+use App\Models\Office;
+use Closure;
+
+class IsApproved implements Pipe
+{
+    public function handle($request, Closure $next)
+    {
+        $builder = $next($request);
+
+        return $builder
+            ->where('approval_status', Office::APPROVAL_APPROVED);
+    }
+}

app/Http/Pipelines/Filtration/IsNotHidden.php

@@ -0,0 +1,16 @@
+<?php
+
+namespace App\Http\Pipelines\Filtration;
+
+use Closure;
+use App\Http\Pipelines\Pipe;
+
+class IsNotHidden implements Pipe
+{
+    public function handle($request, Closure $next)
+    {
+        $builder = $next($request);
+
+        return $builder->where('hidden', false);
+    }
+}

app/Http/Pipelines/Filtration/OfficeAvailable.php

@@ -0,0 +1,22 @@
+<?php
+
+namespace App\Http\Pipelines\Filtration;
+
+use Closure;
+use App\Models\Office;
+use App\Http\Pipelines\Pipe;
+
+class OfficeAvailable implements Pipe
+{
+    public function handle($request, Closure $next)
+    {
+        $builder = $next($request);
+
+        return $builder
+            ->when(
+                request('user_id') && auth()->user() && request('user_id') == auth()->id(),
+                fn ($builder) => $builder,
+                fn ($builder) => $builder->where('approval_status', Office::APPROVAL_APPROVED)->where('hidden', false)
+            );
+    }
+}

app/Http/Pipelines/Orders/OrderByDistance.php

@@ -0,0 +1,21 @@
+<?php
+
+namespace App\Http\Pipelines\Orders;
+
+use Closure;
+use App\Http\Pipelines\Pipe;
+use Illuminate\Database\Eloquent\Builder;
+
+class OrderByDistance implements Pipe
+{
+    public function handle($request, Closure $next)
+    {
+        $builder = $next($request);
+        return $builder
+            ->when(
+                request('lat') && request('lng'),
+                fn (Builder $builder) => $builder->nearestTo(request('lat'), request('lng')),
+                fn (Builder $builder) => $builder->orderBy('id', 'ASC')
+            );
+    }
+}

app/Http/Pipelines/Pipe.php

@@ -0,0 +1,11 @@
+<?php
+
+namespace App\Http\Pipelines;
+
+use Closure;
+use Illuminate\Database\Eloquent\Builder;
+
+interface Pipe
+{
+    public function handle($request, Closure $next);
+}

app/Http/Pipelines/Relationships/ReturnWithImages.php

@@ -0,0 +1,15 @@
+<?php
+
+namespace App\Http\Pipelines\Relationships;
+
+use App\Http\Pipelines\Pipe;
+use Closure;
+
+class ReturnWithImages implements Pipe
+{
+    public function handle($request, Closure $next)
+    {
+        $builder = $next($request);
+        return $builder->with('images');
+    }
+}

app/Http/Pipelines/Relationships/ReturnWithReservationsCount.php

@@ -0,0 +1,21 @@
+<?php
+
+namespace App\Http\Pipelines\Relationships;
+
+use Closure;
+use App\Http\Pipelines\Pipe;
+use App\Models\Reservation;
+use Illuminate\Database\Eloquent\Builder;
+
+class ReturnWithReservationsCount implements Pipe
+{
+    public function handle($request, Closure $next)
+    {
+        $builder = $next($request);
+        return $builder->withCount([
+            'reservations' => 
+                fn(Builder $query) => 
+                    $query->whereStatus(Reservation::STATUS_ACTIVE)
+        ]);
+    }
+}

app/Http/Pipelines/Relationships/ReturnWithTags.php

@@ -0,0 +1,15 @@
+<?php
+
+namespace App\Http\Pipelines\Relationships;
+
+use App\Http\Pipelines\Pipe;
+use Closure;
+
+class ReturnWithTags implements Pipe
+{
+    public function handle($request, Closure $next)
+    {
+        $builder = $next($request);
+        return $builder->with('tags');
+    }
+}

app/Http/Pipelines/Relationships/ReturnWithUser.php

@@ -0,0 +1,15 @@
+<?php
+
+namespace App\Http\Pipelines\Relationships;
+
+use App\Http\Pipelines\Pipe;
+use Closure;
+
+class ReturnWithUser implements Pipe
+{
+    public function handle($request, Closure $next)
+    {
+        $builder = $next($request);
+        return $builder->with('user');
+    }
+}