53 lines
1.3 KiB
PHP
53 lines
1.3 KiB
PHP
<?php
|
|
|
|
namespace BeyondCode\LaravelWebSockets\Console;
|
|
|
|
use Carbon\Carbon;
|
|
use Illuminate\Console\Command;
|
|
use Illuminate\Database\Eloquent\Builder;
|
|
|
|
class CleanStatistics extends Command
|
|
{
|
|
/**
|
|
* The name and signature of the console command.
|
|
*
|
|
* @var string
|
|
*/
|
|
protected $signature = 'websockets:clean
|
|
{appId? : (optional) The app id that will be cleaned.}
|
|
';
|
|
|
|
/**
|
|
* The console command description.
|
|
*
|
|
* @var string|null
|
|
*/
|
|
protected $description = 'Clean up old statistics from the websocket log.';
|
|
|
|
/**
|
|
* Run the command.
|
|
*
|
|
* @return void
|
|
*/
|
|
public function handle()
|
|
{
|
|
$this->comment('Cleaning WebSocket Statistics...');
|
|
|
|
$appId = $this->argument('appId');
|
|
|
|
$maxAgeInDays = config('websockets.statistics.delete_statistics_older_than_days');
|
|
|
|
$cutOffDate = Carbon::now()->subDay($maxAgeInDays)->format('Y-m-d H:i:s');
|
|
|
|
$class = config('websockets.statistics.model');
|
|
|
|
$amountDeleted = $class::where('created_at', '<', $cutOffDate)
|
|
->when(! is_null($appId), function (Builder $query) use ($appId) {
|
|
$query->where('app_id', $appId);
|
|
})
|
|
->delete();
|
|
|
|
$this->info("Deleted {$amountDeleted} record(s) from the WebSocket statistics.");
|
|
}
|
|
}
|