clean up endpoint

This commit is contained in:
freek 2018-12-04 09:08:25 +01:00
parent e1eecbc4e2
commit 016a6f4e4f
1 changed files with 25 additions and 9 deletions

View File

@ -2,6 +2,7 @@
namespace BeyondCode\LaravelWebSockets\Dashboard\Http\Controllers;
use BeyondCode\LaravelWebSockets\Statistics\Rules\AppId;
use Pusher\Pusher;
use Illuminate\Http\Request;
use Illuminate\Broadcasting\Broadcasters\PusherBroadcaster;
@ -9,19 +10,34 @@ use Illuminate\Broadcasting\Broadcasters\PusherBroadcaster;
class SendMessage
{
public function __invoke(Request $request)
{
$validated = $request->validate([
'appId' => ['required', new AppId()],
'key' => 'required',
'secret' => 'required',
'channel' => 'required',
'event' => 'required',
'data' => 'json',
]);
$this->getPusherBroadcaster($validated)->broadcast(
[$validated['channel']],
$validated['event'],
json_decode($validated['data'], true)
);
return 'ok';
}
protected function getPusherBroadcaster(array $validated): PusherBroadcaster
{
$pusher = new Pusher(
$request->key,
$request->secret,
$request->appId,
$validated['key'],
$validated['secret'],
$validated['appId'],
config('broadcasting.connections.pusher.options', [])
);
return (new PusherBroadcaster($pusher))
->broadcast(
[$request->channel],
$request->event,
json_decode($request->data, true)
);
return new PusherBroadcaster($pusher);
}
}