laravel-websockets/src/LaravelEcho/Http/Controllers/EventController.php

43 lines
1.3 KiB
PHP
Raw Normal View History

2018-11-21 11:13:40 +00:00
<?php
namespace BeyondCode\LaravelWebSockets\LaravelEcho\Http\Controllers;
2018-11-21 14:42:04 +00:00
use BeyondCode\LaravelWebSockets\LaravelEcho\Pusher\Channels\ChannelManager;
2018-11-21 11:13:40 +00:00
use Illuminate\Http\Request;
class EventController extends EchoController
{
2018-11-21 23:12:23 +00:00
/** @var \BeyondCode\LaravelWebSockets\LaravelEcho\Pusher\Channels\ChannelManager */
2018-11-21 21:11:44 +00:00
protected $channelManager;
2018-11-21 14:42:04 +00:00
public function __construct(ChannelManager $channelManager)
{
$this->channelManager = $channelManager;
}
2018-11-21 11:13:40 +00:00
public function __invoke(Request $request)
{
2018-11-21 21:11:44 +00:00
//TODO: verify the incoming request
/*
* array:6 [
"appId" => "test"
"auth_key" => ""
"auth_signature" => "51e7ab9c1411aacf9a4c28001ffc3e7f5fe71db130ce08ac071ab49d737bcf52"
"auth_timestamp" => "1542833998"
"auth_version" => "1.0"
"body_md5" => "816e28da10f4aedf0821865eddf55e7f"
]
*/
2018-11-21 14:42:04 +00:00
foreach ($request->json()->get('channels', []) as $channelId) {
2018-11-21 21:11:44 +00:00
$channel = $this->channelManager->find($request->appId, $channelId);
2018-11-21 14:42:04 +00:00
2018-11-21 23:12:23 +00:00
optional($channel)->broadcast([
2018-11-21 14:42:04 +00:00
'channel' => $channelId,
'event' => $request->json()->get('name'),
'data' => $request->json()->get('data'),
]);
}
2018-11-21 23:12:23 +00:00
2018-11-21 11:13:40 +00:00
return $request->json()->all();
}
}