VaporDevelopmentEvent.php

<?php

namespace App\Events;

use Illuminate\Broadcasting\Channel;
use Illuminate\Broadcasting\InteractsWithSockets;
use Illuminate\Broadcasting\PresenceChannel;
use Illuminate\Broadcasting\PrivateChannel;
use Illuminate\Contracts\Broadcasting\ShouldBroadcast;
use Illuminate\Foundation\Events\Dispatchable;
use Illuminate\Queue\SerializesModels;

class VaporDevelopmentEvent implements ShouldBroadcast
{
  use Dispatchable, InteractsWithSockets, SerializesModels;

  public $message;

  public function __construct($message)
  {
      $this->message = $message;
  }

  public function broadcastOn()
  {
    return new Channel('aws.channel');
  }

  public function broadcastAs()
  {
      return 'aws.event';
  }
}

web.php

<?php

use Illuminate\Support\Facades\Route;
use App\Domain\Utility\Events\VaporDevelopmentEvent;
use Illuminate\Support\Facades\Artisan;

Route::any('/webhooks/aws/events', function () {
    if (config('app.env') !== 'staging' || !env('PUSHER_APP_ID')) {
        abort(404);
        return;
    }
    $payload = base64_encode(json_encode(request()->all()));
    event(new VaporDevelopmentEvent($payload));
    return 'ok';
});
Route::any('/webhooks/aws/payload', function () {
    if (config('app.env') !== 'local' || !env('PUSHER_APP_ID')) {
        abort(404);
        return;
    }
    $payload = request()->get('payload');
    Artisan::call('vapor:handle '. $payload);
    return 'ok';
});
?>