Merge branch 'master' of github.com:beyondcode/laravel-websockets
This commit is contained in:
commit
085b80542c
|
|
@ -8,7 +8,7 @@ use BeyondCode\LaravelWebSockets\Events\ChannelVacated;
|
|||
use BeyondCode\LaravelWebSockets\Events\ClientMessageSent;
|
||||
use BeyondCode\LaravelWebSockets\Events\ConnectionEstablished;
|
||||
use BeyondCode\LaravelWebSockets\Events\SubscribedToChannel;
|
||||
use BeyondCode\LaravelWebSockets\WebSocketServer\Pusher\DashboardLogger;
|
||||
use BeyondCode\LaravelWebSockets\WebSocket\Pusher\DashboardLogger;
|
||||
use Illuminate\Events\Dispatcher;
|
||||
|
||||
class EventSubscriber
|
||||
|
|
|
|||
|
|
@ -4,11 +4,11 @@ namespace BeyondCode\LaravelWebSockets\Server;
|
|||
|
||||
use BeyondCode\LaravelWebSockets\LaravelEcho;
|
||||
use BeyondCode\LaravelWebSockets\Server\Logger\MessageLogger;
|
||||
use BeyondCode\LaravelWebSockets\WebSocketServer\Controllers\FetchChannel;
|
||||
use BeyondCode\LaravelWebSockets\WebSocketServer\Controllers\FetchChannels;
|
||||
use BeyondCode\LaravelWebSockets\WebSocketServer\Controllers\FetchUsers;
|
||||
use BeyondCode\LaravelWebSockets\WebSocketServer\Controllers\TriggerEvent;
|
||||
use BeyondCode\LaravelWebSockets\WebSocketServer\Pusher\PusherController;
|
||||
use BeyondCode\LaravelWebSockets\WebSocket\Controllers\FetchChannel;
|
||||
use BeyondCode\LaravelWebSockets\WebSocket\Controllers\FetchChannels;
|
||||
use BeyondCode\LaravelWebSockets\WebSocket\Controllers\FetchUsers;
|
||||
use BeyondCode\LaravelWebSockets\WebSocket\Controllers\TriggerEvent;
|
||||
use BeyondCode\LaravelWebSockets\WebSocket\Pusher\PusherController;
|
||||
use Ratchet\WebSocket\WsServer;
|
||||
use Symfony\Component\Routing\Route;
|
||||
use Ratchet\Http\HttpServerInterface;
|
||||
|
|
|
|||
|
|
@ -1,6 +1,6 @@
|
|||
<?php
|
||||
|
||||
namespace BeyondCode\LaravelWebSockets\WebSocketServer\Controllers;
|
||||
namespace BeyondCode\LaravelWebSockets\WebSocket\Controllers;
|
||||
|
||||
use BeyondCode\LaravelWebSockets\ClientProviders\Client;
|
||||
use BeyondCode\LaravelWebSockets\Events\ExceptionThrown;
|
||||
|
|
@ -15,11 +15,11 @@ use Ratchet\Http\HttpServerInterface;
|
|||
use Psr\Http\Message\RequestInterface;
|
||||
use Symfony\Component\HttpKernel\Exception\HttpException;
|
||||
use Symfony\Bridge\PsrHttpMessage\Factory\HttpFoundationFactory;
|
||||
use BeyondCode\LaravelWebSockets\WebSocketServer\Pusher\Channels\ChannelManager;
|
||||
use BeyondCode\LaravelWebSockets\WebSocket\Pusher\Channels\ChannelManager;
|
||||
|
||||
abstract class Controller implements HttpServerInterface
|
||||
{
|
||||
/** @var \BeyondCode\LaravelWebSockets\WebSocketServer\Pusher\Channels\ChannelManager */
|
||||
/** @var \BeyondCode\LaravelWebSockets\WebSocket\Pusher\Channels\ChannelManager */
|
||||
protected $channelManager;
|
||||
|
||||
public function __construct(ChannelManager $channelManager)
|
||||
|
|
@ -1,6 +1,6 @@
|
|||
<?php
|
||||
|
||||
namespace BeyondCode\LaravelWebSockets\WebSocketServer\Controllers;
|
||||
namespace BeyondCode\LaravelWebSockets\WebSocket\Controllers;
|
||||
|
||||
use Illuminate\Http\Request;
|
||||
use Symfony\Component\HttpKernel\Exception\HttpException;
|
||||
|
|
@ -1,10 +1,10 @@
|
|||
<?php
|
||||
|
||||
namespace BeyondCode\LaravelWebSockets\WebSocketServer\Controllers;
|
||||
namespace BeyondCode\LaravelWebSockets\WebSocket\Controllers;
|
||||
|
||||
use Illuminate\Http\Request;
|
||||
use Illuminate\Support\Collection;
|
||||
use BeyondCode\LaravelWebSockets\WebSocketServer\Pusher\Channels\PresenceChannel;
|
||||
use BeyondCode\LaravelWebSockets\WebSocket\Pusher\Channels\PresenceChannel;
|
||||
|
||||
class FetchChannels extends Controller
|
||||
{
|
||||
|
|
@ -1,11 +1,11 @@
|
|||
<?php
|
||||
|
||||
namespace BeyondCode\LaravelWebSockets\WebSocketServer\Controllers;
|
||||
namespace BeyondCode\LaravelWebSockets\WebSocket\Controllers;
|
||||
|
||||
use Illuminate\Http\Request;
|
||||
use Illuminate\Support\Collection;
|
||||
use Symfony\Component\HttpKernel\Exception\HttpException;
|
||||
use BeyondCode\LaravelWebSockets\WebSocketServer\Pusher\Channels\PresenceChannel;
|
||||
use BeyondCode\LaravelWebSockets\WebSocket\Pusher\Channels\PresenceChannel;
|
||||
|
||||
class FetchUsers extends Controller
|
||||
{
|
||||
|
|
@ -1,6 +1,6 @@
|
|||
<?php
|
||||
|
||||
namespace BeyondCode\LaravelWebSockets\WebSocketServer\Controllers;
|
||||
namespace BeyondCode\LaravelWebSockets\WebSocket\Controllers;
|
||||
|
||||
use BeyondCode\LaravelWebSockets\Events\ApiMessageSent;
|
||||
use Illuminate\Http\Request;
|
||||
|
|
@ -1,9 +1,9 @@
|
|||
<?php
|
||||
|
||||
namespace BeyondCode\LaravelWebSockets\WebSocketServer\Messages;
|
||||
namespace BeyondCode\LaravelWebSockets\WebSocket\Messages;
|
||||
|
||||
use BeyondCode\LaravelWebSockets\Events\ClientMessageSent;
|
||||
use BeyondCode\LaravelWebSockets\WebSocketServer\Pusher\Channels\ChannelManager;
|
||||
use BeyondCode\LaravelWebSockets\WebSocket\Pusher\Channels\ChannelManager;
|
||||
use Ratchet\ConnectionInterface;
|
||||
use stdClass;
|
||||
|
||||
|
|
@ -15,7 +15,7 @@ class Message implements RespondableMessage
|
|||
/** @var \Ratchet\ConnectionInterface */
|
||||
protected $connection;
|
||||
|
||||
/** @var \BeyondCode\LaravelWebSockets\WebSocketServer\Pusher\Channels\ChannelManager */
|
||||
/** @var \BeyondCode\LaravelWebSockets\WebSocket\Pusher\Channels\ChannelManager */
|
||||
protected $channelManager;
|
||||
|
||||
public function __construct(stdClass $payload, ConnectionInterface $connection, ChannelManager $channelManager)
|
||||
|
|
@ -1,5 +1,5 @@
|
|||
<?php
|
||||
namespace BeyondCode\LaravelWebSockets\WebSocketServer\Messages;
|
||||
namespace BeyondCode\LaravelWebSockets\WebSocket\Messages;
|
||||
|
||||
interface RespondableMessage
|
||||
{
|
||||
|
|
@ -1,9 +1,9 @@
|
|||
<?php
|
||||
|
||||
namespace BeyondCode\LaravelWebSockets\WebSocketServer\Messages;
|
||||
namespace BeyondCode\LaravelWebSockets\WebSocket\Messages;
|
||||
|
||||
use BeyondCode\LaravelWebSockets\WebSocketServer\Pusher\Channels\ChannelManager;
|
||||
use BeyondCode\LaravelWebSockets\WebSocketServer\Pusher\PusherMessage;
|
||||
use BeyondCode\LaravelWebSockets\WebSocket\Pusher\Channels\ChannelManager;
|
||||
use BeyondCode\LaravelWebSockets\WebSocket\Pusher\PusherMessage;
|
||||
use Ratchet\ConnectionInterface;
|
||||
use Ratchet\RFC6455\Messaging\MessageInterface;
|
||||
|
||||
|
|
@ -1,11 +1,11 @@
|
|||
<?php
|
||||
|
||||
namespace BeyondCode\LaravelWebSockets\WebSocketServer\Pusher\Channels;
|
||||
namespace BeyondCode\LaravelWebSockets\WebSocket\Pusher\Channels;
|
||||
|
||||
use BeyondCode\LaravelWebSockets\Events\ChannelOccupied;
|
||||
use BeyondCode\LaravelWebSockets\Events\ChannelVacated;
|
||||
use BeyondCode\LaravelWebSockets\Events\SubscribedToChannel;
|
||||
use BeyondCode\LaravelWebSockets\WebSocketServer\Pusher\Exceptions\InvalidSignature;
|
||||
use BeyondCode\LaravelWebSockets\WebSocket\Pusher\Exceptions\InvalidSignature;
|
||||
use Illuminate\Support\Collection;
|
||||
use Ratchet\ConnectionInterface;
|
||||
use stdClass;
|
||||
|
|
@ -1,6 +1,6 @@
|
|||
<?php
|
||||
|
||||
namespace BeyondCode\LaravelWebSockets\WebSocketServer\Pusher\Channels;
|
||||
namespace BeyondCode\LaravelWebSockets\WebSocket\Pusher\Channels;
|
||||
|
||||
use ReflectionClass;
|
||||
use Ratchet\ConnectionInterface;
|
||||
|
|
@ -1,6 +1,6 @@
|
|||
<?php
|
||||
|
||||
namespace BeyondCode\LaravelWebSockets\WebSocketServer\Pusher\Channels;
|
||||
namespace BeyondCode\LaravelWebSockets\WebSocket\Pusher\Channels;
|
||||
|
||||
use Ratchet\ConnectionInterface;
|
||||
use stdClass;
|
||||
|
|
@ -1,6 +1,6 @@
|
|||
<?php
|
||||
|
||||
namespace BeyondCode\LaravelWebSockets\WebSocketServer\Pusher\Channels;
|
||||
namespace BeyondCode\LaravelWebSockets\WebSocket\Pusher\Channels;
|
||||
|
||||
use Ratchet\ConnectionInterface;
|
||||
use stdClass;
|
||||
|
|
@ -1,9 +1,9 @@
|
|||
<?php
|
||||
|
||||
namespace BeyondCode\LaravelWebSockets\WebSocketServer\Pusher;
|
||||
namespace BeyondCode\LaravelWebSockets\WebSocket\Pusher;
|
||||
|
||||
use Ratchet\ConnectionInterface;
|
||||
use BeyondCode\LaravelWebSockets\WebSocketServer\Pusher\Channels\ChannelManager;
|
||||
use BeyondCode\LaravelWebSockets\WebSocket\Pusher\Channels\ChannelManager;
|
||||
use stdClass;
|
||||
|
||||
class DashboardLogger
|
||||
|
|
@ -1,6 +1,6 @@
|
|||
<?php
|
||||
|
||||
namespace BeyondCode\LaravelWebSockets\WebSocketServer\Pusher\Exceptions;
|
||||
namespace BeyondCode\LaravelWebSockets\WebSocket\Pusher\Exceptions;
|
||||
|
||||
class InvalidConnection extends PusherException
|
||||
{
|
||||
|
|
@ -1,6 +1,6 @@
|
|||
<?php
|
||||
|
||||
namespace BeyondCode\LaravelWebSockets\WebSocketServer\Pusher\Exceptions;
|
||||
namespace BeyondCode\LaravelWebSockets\WebSocket\Pusher\Exceptions;
|
||||
|
||||
class InvalidSignature extends PusherException
|
||||
{
|
||||
|
|
@ -1,6 +1,6 @@
|
|||
<?php
|
||||
|
||||
namespace BeyondCode\LaravelWebSockets\WebSocketServer\Pusher\Exceptions;
|
||||
namespace BeyondCode\LaravelWebSockets\WebSocket\Pusher\Exceptions;
|
||||
|
||||
use Exception;
|
||||
|
||||
|
|
@ -1,6 +1,6 @@
|
|||
<?php
|
||||
|
||||
namespace BeyondCode\LaravelWebSockets\WebSocketServer\Pusher\Exceptions;
|
||||
namespace BeyondCode\LaravelWebSockets\WebSocket\Pusher\Exceptions;
|
||||
|
||||
class UnknownAppKey extends PusherException
|
||||
{
|
||||
|
|
@ -1,22 +1,22 @@
|
|||
<?php
|
||||
|
||||
namespace BeyondCode\LaravelWebSockets\WebSocketServer\Pusher;
|
||||
namespace BeyondCode\LaravelWebSockets\WebSocket\Pusher;
|
||||
|
||||
use BeyondCode\LaravelWebSockets\Events\ConnectionEstablished;
|
||||
use BeyondCode\LaravelWebSockets\WebSocketServer\Messages\RespondableMessageFactory;
|
||||
use BeyondCode\LaravelWebSockets\WebSocket\Messages\RespondableMessageFactory;
|
||||
use BeyondCode\LaravelWebSockets\QueryParameters;
|
||||
use Exception;
|
||||
use Ratchet\ConnectionInterface;
|
||||
use Ratchet\RFC6455\Messaging\MessageInterface;
|
||||
use BeyondCode\LaravelWebSockets\Server\WebSocketController;
|
||||
use BeyondCode\LaravelWebSockets\ClientProviders\Client;
|
||||
use BeyondCode\LaravelWebSockets\WebSocketServer\Pusher\Channels\ChannelManager;
|
||||
use BeyondCode\LaravelWebSockets\WebSocketServer\Pusher\Exceptions\PusherException;
|
||||
use BeyondCode\LaravelWebSockets\WebSocketServer\Pusher\Exceptions\UnknownAppKey;
|
||||
use BeyondCode\LaravelWebSockets\WebSocket\Pusher\Channels\ChannelManager;
|
||||
use BeyondCode\LaravelWebSockets\WebSocket\Pusher\Exceptions\PusherException;
|
||||
use BeyondCode\LaravelWebSockets\WebSocket\Pusher\Exceptions\UnknownAppKey;
|
||||
|
||||
class PusherController extends WebSocketController
|
||||
{
|
||||
/** @var \BeyondCode\LaravelWebSockets\WebSocketServer\Pusher\Channels\ChannelManager */
|
||||
/** @var \BeyondCode\LaravelWebSockets\WebSocket\Pusher\Channels\ChannelManager */
|
||||
protected $channelManager;
|
||||
|
||||
public function __construct(ChannelManager $channelManager)
|
||||
|
|
@ -1,21 +1,21 @@
|
|||
<?php
|
||||
|
||||
namespace BeyondCode\LaravelWebSockets\WebSocketServer\Pusher;
|
||||
namespace BeyondCode\LaravelWebSockets\WebSocket\Pusher;
|
||||
|
||||
use BeyondCode\LaravelWebSockets\WebSocketServer\Pusher\Channels\ChannelManager;
|
||||
use BeyondCode\LaravelWebSockets\WebSocketServer\Messages\RespondableMessage;
|
||||
use BeyondCode\LaravelWebSockets\WebSocket\Pusher\Channels\ChannelManager;
|
||||
use BeyondCode\LaravelWebSockets\WebSocket\Messages\RespondableMessage;
|
||||
use Ratchet\ConnectionInterface;
|
||||
use stdClass;
|
||||
|
||||
class PusherMessage implements RespondableMessage
|
||||
{
|
||||
/** @var \BeyondCode\LaravelWebSockets\WebSocketServer\Pusher\stdClass */
|
||||
/** @var \BeyondCode\LaravelWebSockets\WebSocket\Pusher\stdClass */
|
||||
protected $payload;
|
||||
|
||||
/** @var \React\Socket\ConnectionInterface */
|
||||
protected $connection;
|
||||
|
||||
/** @var \BeyondCode\LaravelWebSockets\WebSocketServer\Pusher\Channels\ChannelManager */
|
||||
/** @var \BeyondCode\LaravelWebSockets\WebSocket\Pusher\Channels\ChannelManager */
|
||||
protected $channelManager;
|
||||
|
||||
public function __construct(stdClass $payload, ConnectionInterface $connection, ChannelManager $channelManager)
|
||||
|
|
@ -13,7 +13,7 @@ use Illuminate\Support\Facades\Gate;
|
|||
use Illuminate\Support\Facades\Route;
|
||||
use BeyondCode\LaravelWebSockets\ClientProviders\ClientProvider;
|
||||
use Illuminate\Support\ServiceProvider;
|
||||
use BeyondCode\LaravelWebSockets\WebSocketServer\Pusher\Channels\ChannelManager;
|
||||
use BeyondCode\LaravelWebSockets\WebSocket\Pusher\Channels\ChannelManager;
|
||||
|
||||
class WebSocketsServiceProvider extends ServiceProvider
|
||||
{
|
||||
|
|
|
|||
|
|
@ -3,14 +3,14 @@
|
|||
namespace BeyondCode\LaravelWebSockets\Tests;
|
||||
|
||||
use BeyondCode\LaravelWebSockets\ClientProviders\Client;
|
||||
use BeyondCode\LaravelWebSockets\WebSocketServer\Pusher\Exceptions\InvalidSignature;
|
||||
use BeyondCode\LaravelWebSockets\WebSocketServer\Pusher\Exceptions\UnknownAppKey;
|
||||
use BeyondCode\LaravelWebSockets\WebSocketServer\Pusher\PusherController;
|
||||
use BeyondCode\LaravelWebSockets\WebSocket\Pusher\Exceptions\InvalidSignature;
|
||||
use BeyondCode\LaravelWebSockets\WebSocket\Pusher\Exceptions\UnknownAppKey;
|
||||
use BeyondCode\LaravelWebSockets\WebSocket\Pusher\PusherController;
|
||||
use BeyondCode\LaravelWebSockets\Tests\Mocks\Message;
|
||||
|
||||
class ConnectionTest extends TestCase
|
||||
{
|
||||
/** @var \BeyondCode\LaravelWebSockets\WebSocketServer\Pusher\PusherController */
|
||||
/** @var \BeyondCode\LaravelWebSockets\WebSocket\Pusher\PusherController */
|
||||
protected $pusherServer;
|
||||
|
||||
public function setUp()
|
||||
|
|
|
|||
Loading…
Reference in New Issue