89 lines
		
	
	
		
			2.4 KiB
		
	
	
	
		
			PHP
		
	
	
	
	
	
			
		
		
	
	
			89 lines
		
	
	
		
			2.4 KiB
		
	
	
	
		
			PHP
		
	
	
	
	
	
<?php
 | 
						|
 | 
						|
namespace App\Notifications\Server;
 | 
						|
 | 
						|
use App\Actions\Docker\GetContainersStatus;
 | 
						|
use App\Jobs\ContainerStatusJob;
 | 
						|
use App\Models\Server;
 | 
						|
use App\Notifications\Channels\DiscordChannel;
 | 
						|
use App\Notifications\Channels\EmailChannel;
 | 
						|
use App\Notifications\Channels\TelegramChannel;
 | 
						|
use Illuminate\Bus\Queueable;
 | 
						|
use Illuminate\Contracts\Queue\ShouldQueue;
 | 
						|
use Illuminate\Notifications\Messages\MailMessage;
 | 
						|
use Illuminate\Notifications\Notification;
 | 
						|
use Illuminate\Support\Facades\RateLimiter;
 | 
						|
 | 
						|
class Revived extends Notification implements ShouldQueue
 | 
						|
{
 | 
						|
    use Queueable;
 | 
						|
 | 
						|
    public $tries = 1;
 | 
						|
 | 
						|
    public function __construct(public Server $server)
 | 
						|
    {
 | 
						|
        if ($this->server->unreachable_notification_sent === false) {
 | 
						|
            return;
 | 
						|
        }
 | 
						|
        GetContainersStatus::dispatch($server)->onQueue('high');
 | 
						|
        // dispatch(new ContainerStatusJob($server));
 | 
						|
    }
 | 
						|
 | 
						|
    public function via(object $notifiable): array
 | 
						|
    {
 | 
						|
        $channels = [];
 | 
						|
        $isEmailEnabled = isEmailEnabled($notifiable);
 | 
						|
        $isDiscordEnabled = data_get($notifiable, 'discord_enabled');
 | 
						|
        $isTelegramEnabled = data_get($notifiable, 'telegram_enabled');
 | 
						|
 | 
						|
        if ($isDiscordEnabled) {
 | 
						|
            $channels[] = DiscordChannel::class;
 | 
						|
        }
 | 
						|
        if ($isEmailEnabled) {
 | 
						|
            $channels[] = EmailChannel::class;
 | 
						|
        }
 | 
						|
        if ($isTelegramEnabled) {
 | 
						|
            $channels[] = TelegramChannel::class;
 | 
						|
        }
 | 
						|
        $executed = RateLimiter::attempt(
 | 
						|
            'notification-server-revived-'.$this->server->uuid,
 | 
						|
            1,
 | 
						|
            function () use ($channels) {
 | 
						|
                return $channels;
 | 
						|
            },
 | 
						|
            7200,
 | 
						|
        );
 | 
						|
 | 
						|
        if (! $executed) {
 | 
						|
            return [];
 | 
						|
        }
 | 
						|
 | 
						|
        return $executed;
 | 
						|
    }
 | 
						|
 | 
						|
    public function toMail(): MailMessage
 | 
						|
    {
 | 
						|
        $mail = new MailMessage;
 | 
						|
        $mail->subject("Coolify: Server ({$this->server->name}) revived.");
 | 
						|
        $mail->view('emails.server-revived', [
 | 
						|
            'name' => $this->server->name,
 | 
						|
        ]);
 | 
						|
 | 
						|
        return $mail;
 | 
						|
    }
 | 
						|
 | 
						|
    public function toDiscord(): string
 | 
						|
    {
 | 
						|
        $message = "Coolify: Server '{$this->server->name}' revived. All automations & integrations are turned on again!";
 | 
						|
 | 
						|
        return $message;
 | 
						|
    }
 | 
						|
 | 
						|
    public function toTelegram(): array
 | 
						|
    {
 | 
						|
        return [
 | 
						|
            'message' => "Coolify: Server '{$this->server->name}' revived. All automations & integrations are turned on again!",
 | 
						|
        ];
 | 
						|
    }
 | 
						|
}
 |