67 lines
		
	
	
		
			2.2 KiB
		
	
	
	
		
			PHP
		
	
	
	
	
	
			
		
		
	
	
			67 lines
		
	
	
		
			2.2 KiB
		
	
	
	
		
			PHP
		
	
	
	
	
	
| <?php
 | |
| 
 | |
| namespace App\Jobs;
 | |
| 
 | |
| use App\Models\Server;
 | |
| use App\Notifications\Server\HighDiskUsage;
 | |
| use Illuminate\Bus\Queueable;
 | |
| use Illuminate\Contracts\Queue\ShouldBeEncrypted;
 | |
| use Illuminate\Contracts\Queue\ShouldQueue;
 | |
| use Illuminate\Foundation\Bus\Dispatchable;
 | |
| use Illuminate\Queue\InteractsWithQueue;
 | |
| use Illuminate\Queue\SerializesModels;
 | |
| use Illuminate\Support\Facades\RateLimiter;
 | |
| use Laravel\Horizon\Contracts\Silenced;
 | |
| 
 | |
| class ServerStorageCheckJob implements ShouldBeEncrypted, ShouldQueue, Silenced
 | |
| {
 | |
|     use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
 | |
| 
 | |
|     public $tries = 1;
 | |
| 
 | |
|     public $timeout = 60;
 | |
| 
 | |
|     public function backoff(): int
 | |
|     {
 | |
|         return isDev() ? 1 : 3;
 | |
|     }
 | |
| 
 | |
|     public function __construct(public Server $server, public int|string|null $percentage = null) {}
 | |
| 
 | |
|     public function handle()
 | |
|     {
 | |
|         try {
 | |
|             if ($this->server->isFunctional() === false) {
 | |
|                 return 'Server is not functional.';
 | |
|             }
 | |
|             $team = data_get($this->server, 'team');
 | |
|             $serverDiskUsageNotificationThreshold = data_get($this->server, 'settings.server_disk_usage_notification_threshold');
 | |
| 
 | |
|             if (is_null($this->percentage)) {
 | |
|                 $this->percentage = $this->server->storageCheck();
 | |
|             }
 | |
|             if (! $this->percentage) {
 | |
|                 return 'No percentage could be retrieved.';
 | |
|             }
 | |
|             if ($this->percentage > $serverDiskUsageNotificationThreshold) {
 | |
|                 $executed = RateLimiter::attempt(
 | |
|                     'high-disk-usage:'.$this->server->id,
 | |
|                     $maxAttempts = 0,
 | |
|                     function () use ($team, $serverDiskUsageNotificationThreshold) {
 | |
|                         $team->notify(new HighDiskUsage($this->server, $this->percentage, $serverDiskUsageNotificationThreshold));
 | |
|                     },
 | |
|                     $decaySeconds = 3600,
 | |
|                 );
 | |
| 
 | |
|                 if (! $executed) {
 | |
|                     return 'Too many messages sent!';
 | |
|                 }
 | |
|             } else {
 | |
|                 RateLimiter::hit('high-disk-usage:'.$this->server->id, 600);
 | |
|             }
 | |
|         } catch (\Throwable $e) {
 | |
|             return handleError($e);
 | |
|         }
 | |
|     }
 | |
| }
 | 
