Add command for cart pruning

packages/core/config/cart.php

@@ -150,4 +150,26 @@
         'lines.purchasable.product',
         'lines.cart.currency',
     ],
+
+    /*
+    |--------------------------------------------------------------------------
+    | Prune carts
+    |--------------------------------------------------------------------------
+    |
+    | Should the cart models be pruned to prevent data build up and 
+    | some settings controlling how pruning should be determined
+    |
+    */
+    'prune_tables' => [
+
+        'enabled' => true,
+
+        'pipelines' => [
+            Lunar\Pipelines\CartPrune\PruneAfter::class,
+            Lunar\Pipelines\CartPrune\WithoutOrders::class,
+        ],
+
+        'prune_interval' => 90, // days
+
+    ],
 ];

packages/core/src/Console/Commands/PruneCarts.php

@@ -0,0 +1,52 @@
+<?php
+
+namespace Lunar\Console\Commands;
+
+use Illuminate\Console\Command;
+use Illuminate\Pipeline\Pipeline;
+use Lunar\Models\Cart;
+
+class PruneCarts extends Command
+{
+    /**
+     * The name and signature of the console command.
+     *
+     * @var string
+     */
+    protected $signature = 'lunar:prune:carts';
+
+    /**
+     * The console command description.
+     *
+     * @var string
+     */
+    protected $description = 'Prune the carts table';
+
+    /**
+     * Execute the console command.
+     *
+     * @return void
+     */
+    public function handle()
+    {        
+        $this->info('Beginning prune');
+
+        $query = Cart::query();
+
+        $carts = app(Pipeline::class)
+            ->send($query)
+            ->through(
+                config('lunar.cart.prune_tables.pipelines', [])
+            )->then(fn ($query) => $query->get());
+
+        $carts->each(function ($cart) {
+            Cart::where('merged_id', $cart->id)->update(['merged_id' => null]);
+
+            $cart->lines()->delete();
+            $cart->addresses()->delete();
+            $cart->delete();
+        });
+
+        $this->info('Prune complete');
+    }
+}

packages/core/src/LunarServiceProvider.php

@@ -5,6 +5,7 @@
 use Cartalyst\Converter\Laravel\Facades\Converter;
 use Illuminate\Auth\Events\Login;
 use Illuminate\Auth\Events\Logout;
+use Illuminate\Console\Scheduling\Schedule;
 use Illuminate\Database\Events\MigrationsEnded;
 use Illuminate\Database\Events\MigrationsStarted;
 use Illuminate\Database\Events\NoPendingMigrations;
@@ -39,6 +40,7 @@
 use Lunar\Console\Commands\Import\AddressData;
 use Lunar\Console\Commands\MigrateGetCandy;
 use Lunar\Console\Commands\Orders\SyncNewCustomerOrders;
+use Lunar\Console\Commands\PruneCarts;
 use Lunar\Console\Commands\ScoutIndexerCommand;
 use Lunar\Console\InstallLunar;
 use Lunar\Database\State\ConvertProductTypeAttributesToProducts;
@@ -203,7 +205,14 @@ public function boot(): void
                 ScoutIndexerCommand::class,
                 MigrateGetCandy::class,
                 SyncNewCustomerOrders::class,
+                PruneCarts::class,
             ]);
+
+            if (config('lunar.cart.prune_tables.enabled', false)) {
+                $this->callAfterResolving(Schedule::class, function (Schedule $schedule) {
+                    $schedule->command('lunar:prune:carts')->daily();
+                });
+            }
         }
 
         Arr::macro('permutate', [\Lunar\Utils\Arr::class, 'permutate']);

packages/core/src/Pipelines/CartPrune/PruneAfter.php

@@ -0,0 +1,21 @@
+<?php
+
+namespace Lunar\Pipelines\CartPrune;
+
+use Closure;
+use Illuminate\Database\Eloquent\Builder;
+
+final class PruneAfter
+{
+    public function handle(Builder $query, Closure $next)
+    {
+        $days = config('lunar.cart.prune_tables.prune_after', 90);
+
+        $query->where('updated_at', '<=', now()->subDays($days))
+            ->whereDoesntHave('lines', function ($query) use ($days) {
+                $query->where('updated_at', '>', now()->subDays($days));
+            });
+
+        return $next($query);
+    }
+}

packages/core/src/Pipelines/CartPrune/WithoutOrders.php

@@ -0,0 +1,16 @@
+<?php
+
+namespace Lunar\Pipelines\CartPrune;
+
+use Closure;
+use Illuminate\Database\Eloquent\Builder;
+
+final class WithoutOrders
+{
+    public function handle(Builder $query, Closure $next)
+    {
+        $query->whereDoesntHave('orders');
+
+        return $next($query);
+    }
+}