Apply fixes from StyleCI (#518)
This commit is contained in:
parent
6f32b89459
commit
341eb9604f
|
|
@ -2,8 +2,9 @@
|
||||||
|
|
||||||
namespace BeyondCode\LaravelWebSockets\API;
|
namespace BeyondCode\LaravelWebSockets\API;
|
||||||
|
|
||||||
|
use BeyondCode\LaravelWebSockets\Apps\App;
|
||||||
|
use BeyondCode\LaravelWebSockets\Contracts\ChannelManager;
|
||||||
use BeyondCode\LaravelWebSockets\Server\QueryParameters;
|
use BeyondCode\LaravelWebSockets\Server\QueryParameters;
|
||||||
use Ratchet\Http\HttpServerInterface;
|
|
||||||
use Exception;
|
use Exception;
|
||||||
use GuzzleHttp\Psr7\Response;
|
use GuzzleHttp\Psr7\Response;
|
||||||
use GuzzleHttp\Psr7\ServerRequest;
|
use GuzzleHttp\Psr7\ServerRequest;
|
||||||
|
|
@ -14,11 +15,10 @@ use Illuminate\Support\Collection;
|
||||||
use Psr\Http\Message\RequestInterface;
|
use Psr\Http\Message\RequestInterface;
|
||||||
use Pusher\Pusher;
|
use Pusher\Pusher;
|
||||||
use Ratchet\ConnectionInterface;
|
use Ratchet\ConnectionInterface;
|
||||||
|
use Ratchet\Http\HttpServerInterface;
|
||||||
use React\Promise\PromiseInterface;
|
use React\Promise\PromiseInterface;
|
||||||
use Symfony\Bridge\PsrHttpMessage\Factory\HttpFoundationFactory;
|
use Symfony\Bridge\PsrHttpMessage\Factory\HttpFoundationFactory;
|
||||||
use Symfony\Component\HttpKernel\Exception\HttpException;
|
use Symfony\Component\HttpKernel\Exception\HttpException;
|
||||||
use BeyondCode\LaravelWebSockets\Contracts\ChannelManager;
|
|
||||||
use BeyondCode\LaravelWebSockets\Apps\App;
|
|
||||||
|
|
||||||
abstract class Controller implements HttpServerInterface
|
abstract class Controller implements HttpServerInterface
|
||||||
{
|
{
|
||||||
|
|
|
||||||
|
|
@ -2,8 +2,8 @@
|
||||||
|
|
||||||
namespace BeyondCode\LaravelWebSockets\API;
|
namespace BeyondCode\LaravelWebSockets\API;
|
||||||
|
|
||||||
use Illuminate\Support\Str;
|
|
||||||
use Illuminate\Http\Request;
|
use Illuminate\Http\Request;
|
||||||
|
use Illuminate\Support\Str;
|
||||||
use Symfony\Component\HttpKernel\Exception\HttpException;
|
use Symfony\Component\HttpKernel\Exception\HttpException;
|
||||||
|
|
||||||
class FetchChannel extends Controller
|
class FetchChannel extends Controller
|
||||||
|
|
|
||||||
|
|
@ -4,7 +4,6 @@ namespace BeyondCode\LaravelWebSockets\API;
|
||||||
|
|
||||||
use BeyondCode\LaravelWebSockets\Channels\Channel;
|
use BeyondCode\LaravelWebSockets\Channels\Channel;
|
||||||
use Illuminate\Http\Request;
|
use Illuminate\Http\Request;
|
||||||
use Illuminate\Support\Collection;
|
|
||||||
use Illuminate\Support\Str;
|
use Illuminate\Support\Str;
|
||||||
use stdClass;
|
use stdClass;
|
||||||
use Symfony\Component\HttpKernel\Exception\HttpException;
|
use Symfony\Component\HttpKernel\Exception\HttpException;
|
||||||
|
|
|
||||||
|
|
@ -2,10 +2,8 @@
|
||||||
|
|
||||||
namespace BeyondCode\LaravelWebSockets\API;
|
namespace BeyondCode\LaravelWebSockets\API;
|
||||||
|
|
||||||
use BeyondCode\LaravelWebSockets\WebSockets\Channels\PresenceChannel;
|
|
||||||
use Illuminate\Http\Request;
|
use Illuminate\Http\Request;
|
||||||
use Illuminate\Support\Str;
|
use Illuminate\Support\Str;
|
||||||
use Illuminate\Support\Collection;
|
|
||||||
use Symfony\Component\HttpKernel\Exception\HttpException;
|
use Symfony\Component\HttpKernel\Exception\HttpException;
|
||||||
|
|
||||||
class FetchUsers extends Controller
|
class FetchUsers extends Controller
|
||||||
|
|
|
||||||
|
|
@ -3,12 +3,8 @@
|
||||||
namespace BeyondCode\LaravelWebSockets\API;
|
namespace BeyondCode\LaravelWebSockets\API;
|
||||||
|
|
||||||
use BeyondCode\LaravelWebSockets\DashboardLogger;
|
use BeyondCode\LaravelWebSockets\DashboardLogger;
|
||||||
use BeyondCode\LaravelWebSockets\WebSockets\Channels\PresenceChannel;
|
|
||||||
use Illuminate\Http\Request;
|
|
||||||
use Illuminate\Support\Str;
|
|
||||||
use Illuminate\Support\Collection;
|
|
||||||
use Symfony\Component\HttpKernel\Exception\HttpException;
|
|
||||||
use BeyondCode\LaravelWebSockets\Facades\StatisticsCollector;
|
use BeyondCode\LaravelWebSockets\Facades\StatisticsCollector;
|
||||||
|
use Illuminate\Http\Request;
|
||||||
|
|
||||||
class TriggerEvent extends Controller
|
class TriggerEvent extends Controller
|
||||||
{
|
{
|
||||||
|
|
|
||||||
|
|
@ -2,16 +2,16 @@
|
||||||
|
|
||||||
namespace BeyondCode\LaravelWebSockets\ChannelManagers;
|
namespace BeyondCode\LaravelWebSockets\ChannelManagers;
|
||||||
|
|
||||||
use BeyondCode\LaravelWebSockets\Contracts\ChannelManager;
|
|
||||||
use Illuminate\Support\Str;
|
|
||||||
use BeyondCode\LaravelWebSockets\Channels\Channel;
|
use BeyondCode\LaravelWebSockets\Channels\Channel;
|
||||||
use BeyondCode\LaravelWebSockets\Channels\PresenceChannel;
|
use BeyondCode\LaravelWebSockets\Channels\PresenceChannel;
|
||||||
use BeyondCode\LaravelWebSockets\Channels\PrivateChannel;
|
use BeyondCode\LaravelWebSockets\Channels\PrivateChannel;
|
||||||
|
use BeyondCode\LaravelWebSockets\Contracts\ChannelManager;
|
||||||
|
use Illuminate\Support\Str;
|
||||||
|
use Ratchet\ConnectionInterface;
|
||||||
|
use React\EventLoop\LoopInterface;
|
||||||
use React\Promise\FulfilledPromise;
|
use React\Promise\FulfilledPromise;
|
||||||
use React\Promise\PromiseInterface;
|
use React\Promise\PromiseInterface;
|
||||||
use stdClass;
|
use stdClass;
|
||||||
use Ratchet\ConnectionInterface;
|
|
||||||
use React\EventLoop\LoopInterface;
|
|
||||||
|
|
||||||
class LocalChannelManager implements ChannelManager
|
class LocalChannelManager implements ChannelManager
|
||||||
{
|
{
|
||||||
|
|
|
||||||
|
|
@ -2,18 +2,14 @@
|
||||||
|
|
||||||
namespace BeyondCode\LaravelWebSockets\ChannelManagers;
|
namespace BeyondCode\LaravelWebSockets\ChannelManagers;
|
||||||
|
|
||||||
use BeyondCode\LaravelWebSockets\Contracts\ChannelManager;
|
|
||||||
use Illuminate\Support\Str;
|
|
||||||
use BeyondCode\LaravelWebSockets\Channels\Channel;
|
use BeyondCode\LaravelWebSockets\Channels\Channel;
|
||||||
use BeyondCode\LaravelWebSockets\Channels\PresenceChannel;
|
|
||||||
use BeyondCode\LaravelWebSockets\Channels\PrivateChannel;
|
|
||||||
use React\Promise\FulfilledPromise;
|
|
||||||
use React\Promise\PromiseInterface;
|
|
||||||
use Clue\React\Redis\Client;
|
use Clue\React\Redis\Client;
|
||||||
use Clue\React\Redis\Factory;
|
use Clue\React\Redis\Factory;
|
||||||
use stdClass;
|
use Illuminate\Support\Str;
|
||||||
use Ratchet\ConnectionInterface;
|
use Ratchet\ConnectionInterface;
|
||||||
use React\EventLoop\LoopInterface;
|
use React\EventLoop\LoopInterface;
|
||||||
|
use React\Promise\PromiseInterface;
|
||||||
|
use stdClass;
|
||||||
|
|
||||||
class RedisChannelManager extends LocalChannelManager
|
class RedisChannelManager extends LocalChannelManager
|
||||||
{
|
{
|
||||||
|
|
|
||||||
|
|
@ -2,12 +2,12 @@
|
||||||
|
|
||||||
namespace BeyondCode\LaravelWebSockets\Channels;
|
namespace BeyondCode\LaravelWebSockets\Channels;
|
||||||
|
|
||||||
|
use BeyondCode\LaravelWebSockets\Contracts\ChannelManager;
|
||||||
use BeyondCode\LaravelWebSockets\DashboardLogger;
|
use BeyondCode\LaravelWebSockets\DashboardLogger;
|
||||||
|
use BeyondCode\LaravelWebSockets\Server\Exceptions\InvalidSignature;
|
||||||
|
use Illuminate\Support\Str;
|
||||||
use Ratchet\ConnectionInterface;
|
use Ratchet\ConnectionInterface;
|
||||||
use stdClass;
|
use stdClass;
|
||||||
use BeyondCode\LaravelWebSockets\Contracts\ChannelManager;
|
|
||||||
use Illuminate\Support\Str;
|
|
||||||
use BeyondCode\LaravelWebSockets\Server\Exceptions\InvalidSignature;
|
|
||||||
|
|
||||||
class Channel
|
class Channel
|
||||||
{
|
{
|
||||||
|
|
|
||||||
|
|
@ -2,17 +2,17 @@
|
||||||
|
|
||||||
namespace BeyondCode\LaravelWebSockets\Console\Commands;
|
namespace BeyondCode\LaravelWebSockets\Console\Commands;
|
||||||
|
|
||||||
|
use BeyondCode\LaravelWebSockets\Contracts\ChannelManager;
|
||||||
|
use BeyondCode\LaravelWebSockets\Contracts\StatisticsCollector;
|
||||||
|
use BeyondCode\LaravelWebSockets\Facades\StatisticsCollector as StatisticsCollectorFacade;
|
||||||
|
use BeyondCode\LaravelWebSockets\Facades\WebSocketsRouter;
|
||||||
use BeyondCode\LaravelWebSockets\Server\Loggers\ConnectionLogger;
|
use BeyondCode\LaravelWebSockets\Server\Loggers\ConnectionLogger;
|
||||||
use BeyondCode\LaravelWebSockets\Server\Loggers\HttpLogger;
|
use BeyondCode\LaravelWebSockets\Server\Loggers\HttpLogger;
|
||||||
use BeyondCode\LaravelWebSockets\Server\Loggers\WebSocketsLogger;
|
use BeyondCode\LaravelWebSockets\Server\Loggers\WebSocketsLogger;
|
||||||
use BeyondCode\LaravelWebSockets\ServerFactory;
|
use BeyondCode\LaravelWebSockets\ServerFactory;
|
||||||
use Illuminate\Console\Command;
|
use Illuminate\Console\Command;
|
||||||
use BeyondCode\LaravelWebSockets\Facades\WebSocketsRouter;
|
|
||||||
use BeyondCode\LaravelWebSockets\Facades\StatisticsCollector as StatisticsCollectorFacade;
|
|
||||||
use BeyondCode\LaravelWebSockets\Contracts\ChannelManager;
|
|
||||||
use BeyondCode\LaravelWebSockets\Contracts\StatisticsCollector;
|
|
||||||
use React\EventLoop\Factory as LoopFactory;
|
|
||||||
use Illuminate\Support\Facades\Cache;
|
use Illuminate\Support\Facades\Cache;
|
||||||
|
use React\EventLoop\Factory as LoopFactory;
|
||||||
|
|
||||||
class StartServer extends Command
|
class StartServer extends Command
|
||||||
{
|
{
|
||||||
|
|
|
||||||
|
|
@ -3,9 +3,9 @@
|
||||||
namespace BeyondCode\LaravelWebSockets\Contracts;
|
namespace BeyondCode\LaravelWebSockets\Contracts;
|
||||||
|
|
||||||
use Ratchet\ConnectionInterface;
|
use Ratchet\ConnectionInterface;
|
||||||
|
use React\EventLoop\LoopInterface;
|
||||||
use React\Promise\PromiseInterface;
|
use React\Promise\PromiseInterface;
|
||||||
use stdClass;
|
use stdClass;
|
||||||
use React\EventLoop\LoopInterface;
|
|
||||||
|
|
||||||
interface ChannelManager
|
interface ChannelManager
|
||||||
{
|
{
|
||||||
|
|
|
||||||
|
|
@ -2,7 +2,6 @@
|
||||||
|
|
||||||
namespace BeyondCode\LaravelWebSockets\Contracts;
|
namespace BeyondCode\LaravelWebSockets\Contracts;
|
||||||
|
|
||||||
use React\Promise\FulfilledPromise;
|
|
||||||
use React\Promise\PromiseInterface;
|
use React\Promise\PromiseInterface;
|
||||||
|
|
||||||
interface StatisticsCollector
|
interface StatisticsCollector
|
||||||
|
|
|
||||||
|
|
@ -4,7 +4,6 @@ namespace BeyondCode\LaravelWebSockets\Dashboard\Http\Controllers;
|
||||||
|
|
||||||
use BeyondCode\LaravelWebSockets\Contracts\ChannelManager;
|
use BeyondCode\LaravelWebSockets\Contracts\ChannelManager;
|
||||||
use BeyondCode\LaravelWebSockets\Rules\AppId;
|
use BeyondCode\LaravelWebSockets\Rules\AppId;
|
||||||
use Exception;
|
|
||||||
use Illuminate\Http\Request;
|
use Illuminate\Http\Request;
|
||||||
|
|
||||||
class SendMessage
|
class SendMessage
|
||||||
|
|
|
||||||
|
|
@ -12,7 +12,6 @@ class DashboardLogger
|
||||||
|
|
||||||
const TYPE_CONNECTED = 'connected';
|
const TYPE_CONNECTED = 'connected';
|
||||||
|
|
||||||
|
|
||||||
const TYPE_OCCUPIED = 'occupied';
|
const TYPE_OCCUPIED = 'occupied';
|
||||||
|
|
||||||
const TYPE_SUBSCRIBED = 'subscribed';
|
const TYPE_SUBSCRIBED = 'subscribed';
|
||||||
|
|
|
||||||
|
|
@ -2,8 +2,8 @@
|
||||||
|
|
||||||
namespace BeyondCode\LaravelWebSockets\Facades;
|
namespace BeyondCode\LaravelWebSockets\Facades;
|
||||||
|
|
||||||
use Illuminate\Support\Facades\Facade;
|
|
||||||
use BeyondCode\LaravelWebSockets\Contracts\StatisticsCollector as StatisticsCollectorInterface;
|
use BeyondCode\LaravelWebSockets\Contracts\StatisticsCollector as StatisticsCollectorInterface;
|
||||||
|
use Illuminate\Support\Facades\Facade;
|
||||||
|
|
||||||
class StatisticsCollector extends Facade
|
class StatisticsCollector extends Facade
|
||||||
{
|
{
|
||||||
|
|
|
||||||
|
|
@ -2,8 +2,8 @@
|
||||||
|
|
||||||
namespace BeyondCode\LaravelWebSockets\Facades;
|
namespace BeyondCode\LaravelWebSockets\Facades;
|
||||||
|
|
||||||
use Illuminate\Support\Facades\Facade;
|
|
||||||
use BeyondCode\LaravelWebSockets\Contracts\StatisticsStore as StatisticsStoreInterface;
|
use BeyondCode\LaravelWebSockets\Contracts\StatisticsStore as StatisticsStoreInterface;
|
||||||
|
use Illuminate\Support\Facades\Facade;
|
||||||
|
|
||||||
class StatisticsStore extends Facade
|
class StatisticsStore extends Facade
|
||||||
{
|
{
|
||||||
|
|
|
||||||
|
|
@ -12,6 +12,6 @@ class ConnectionsOverCapacity extends WebSocketException
|
||||||
*/
|
*/
|
||||||
public function __construct()
|
public function __construct()
|
||||||
{
|
{
|
||||||
$this->trigger("Over capacity", 4100);
|
$this->trigger('Over capacity', 4100);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -12,6 +12,6 @@ class InvalidSignature extends WebSocketException
|
||||||
*/
|
*/
|
||||||
public function __construct()
|
public function __construct()
|
||||||
{
|
{
|
||||||
$this->trigger("Invalid Signature", 4009);
|
$this->trigger('Invalid Signature', 4009);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -2,8 +2,8 @@
|
||||||
|
|
||||||
namespace BeyondCode\LaravelWebSockets\Server;
|
namespace BeyondCode\LaravelWebSockets\Server;
|
||||||
|
|
||||||
use Ratchet\Http\HttpServerInterface;
|
|
||||||
use Ratchet\Http\HttpServer as BaseHttpServer;
|
use Ratchet\Http\HttpServer as BaseHttpServer;
|
||||||
|
use Ratchet\Http\HttpServerInterface;
|
||||||
|
|
||||||
class HttpServer extends BaseHttpServer
|
class HttpServer extends BaseHttpServer
|
||||||
{
|
{
|
||||||
|
|
|
||||||
|
|
@ -2,11 +2,9 @@
|
||||||
|
|
||||||
namespace BeyondCode\LaravelWebSockets\Server\Messages;
|
namespace BeyondCode\LaravelWebSockets\Server\Messages;
|
||||||
|
|
||||||
use BeyondCode\LaravelWebSockets\Contracts\ChannelManager;
|
|
||||||
use Illuminate\Support\Str;
|
use Illuminate\Support\Str;
|
||||||
use Ratchet\ConnectionInterface;
|
use Ratchet\ConnectionInterface;
|
||||||
use stdClass;
|
use stdClass;
|
||||||
use BeyondCode\LaravelWebSockets\Contracts\PusherMessage;
|
|
||||||
|
|
||||||
class PusherChannelProtocolMessage extends PusherClientMessage
|
class PusherChannelProtocolMessage extends PusherClientMessage
|
||||||
{
|
{
|
||||||
|
|
|
||||||
|
|
@ -2,12 +2,12 @@
|
||||||
|
|
||||||
namespace BeyondCode\LaravelWebSockets\Server\Messages;
|
namespace BeyondCode\LaravelWebSockets\Server\Messages;
|
||||||
|
|
||||||
use BeyondCode\LaravelWebSockets\DashboardLogger;
|
|
||||||
use BeyondCode\LaravelWebSockets\Contracts\ChannelManager;
|
use BeyondCode\LaravelWebSockets\Contracts\ChannelManager;
|
||||||
|
use BeyondCode\LaravelWebSockets\Contracts\PusherMessage;
|
||||||
|
use BeyondCode\LaravelWebSockets\DashboardLogger;
|
||||||
use Illuminate\Support\Str;
|
use Illuminate\Support\Str;
|
||||||
use Ratchet\ConnectionInterface;
|
use Ratchet\ConnectionInterface;
|
||||||
use stdClass;
|
use stdClass;
|
||||||
use BeyondCode\LaravelWebSockets\Contracts\PusherMessage;
|
|
||||||
|
|
||||||
class PusherClientMessage implements PusherMessage
|
class PusherClientMessage implements PusherMessage
|
||||||
{
|
{
|
||||||
|
|
@ -75,6 +75,5 @@ class PusherClientMessage implements PusherMessage
|
||||||
'event' => $this->payload->event,
|
'event' => $this->payload->event,
|
||||||
'data' => $this->payload,
|
'data' => $this->payload,
|
||||||
]);
|
]);
|
||||||
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -2,11 +2,11 @@
|
||||||
|
|
||||||
namespace BeyondCode\LaravelWebSockets\Server\Messages;
|
namespace BeyondCode\LaravelWebSockets\Server\Messages;
|
||||||
|
|
||||||
|
use BeyondCode\LaravelWebSockets\Contracts\ChannelManager;
|
||||||
|
use BeyondCode\LaravelWebSockets\Contracts\PusherMessage;
|
||||||
use Illuminate\Support\Str;
|
use Illuminate\Support\Str;
|
||||||
use Ratchet\ConnectionInterface;
|
use Ratchet\ConnectionInterface;
|
||||||
use Ratchet\RFC6455\Messaging\MessageInterface;
|
use Ratchet\RFC6455\Messaging\MessageInterface;
|
||||||
use BeyondCode\LaravelWebSockets\Contracts\ChannelManager;
|
|
||||||
use BeyondCode\LaravelWebSockets\Contracts\PusherMessage;
|
|
||||||
|
|
||||||
class PusherMessageFactory
|
class PusherMessageFactory
|
||||||
{
|
{
|
||||||
|
|
|
||||||
|
|
@ -3,7 +3,6 @@
|
||||||
namespace BeyondCode\LaravelWebSockets\Server;
|
namespace BeyondCode\LaravelWebSockets\Server;
|
||||||
|
|
||||||
use BeyondCode\LaravelWebSockets\Server\Loggers\WebSocketsLogger;
|
use BeyondCode\LaravelWebSockets\Server\Loggers\WebSocketsLogger;
|
||||||
use Illuminate\Support\Collection;
|
|
||||||
use Ratchet\WebSocket\MessageComponentInterface;
|
use Ratchet\WebSocket\MessageComponentInterface;
|
||||||
use Ratchet\WebSocket\WsServer;
|
use Ratchet\WebSocket\WsServer;
|
||||||
use Symfony\Component\Routing\Route;
|
use Symfony\Component\Routing\Route;
|
||||||
|
|
@ -15,7 +14,7 @@ class Router
|
||||||
* The implemented routes.
|
* The implemented routes.
|
||||||
*
|
*
|
||||||
* @var \Symfony\Component\Routing\RouteCollection
|
* @var \Symfony\Component\Routing\RouteCollection
|
||||||
*/
|
*/
|
||||||
protected $routes;
|
protected $routes;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|
|
||||||
|
|
@ -2,14 +2,14 @@
|
||||||
|
|
||||||
namespace BeyondCode\LaravelWebSockets\Server;
|
namespace BeyondCode\LaravelWebSockets\Server;
|
||||||
|
|
||||||
use BeyondCode\LaravelWebSockets\DashboardLogger;
|
|
||||||
use BeyondCode\LaravelWebSockets\Apps\App;
|
use BeyondCode\LaravelWebSockets\Apps\App;
|
||||||
|
use BeyondCode\LaravelWebSockets\Contracts\ChannelManager;
|
||||||
|
use BeyondCode\LaravelWebSockets\DashboardLogger;
|
||||||
|
use BeyondCode\LaravelWebSockets\Facades\StatisticsCollector;
|
||||||
use Exception;
|
use Exception;
|
||||||
use Ratchet\WebSocket\MessageComponentInterface;
|
|
||||||
use Ratchet\ConnectionInterface;
|
use Ratchet\ConnectionInterface;
|
||||||
use Ratchet\RFC6455\Messaging\MessageInterface;
|
use Ratchet\RFC6455\Messaging\MessageInterface;
|
||||||
use BeyondCode\LaravelWebSockets\Contracts\ChannelManager;
|
use Ratchet\WebSocket\MessageComponentInterface;
|
||||||
use BeyondCode\LaravelWebSockets\Facades\StatisticsCollector;
|
|
||||||
|
|
||||||
class WebSocketHandler implements MessageComponentInterface
|
class WebSocketHandler implements MessageComponentInterface
|
||||||
{
|
{
|
||||||
|
|
|
||||||
|
|
@ -2,6 +2,8 @@
|
||||||
|
|
||||||
namespace BeyondCode\LaravelWebSockets;
|
namespace BeyondCode\LaravelWebSockets;
|
||||||
|
|
||||||
|
use BeyondCode\LaravelWebSockets\Server\HttpServer;
|
||||||
|
use BeyondCode\LaravelWebSockets\Server\Loggers\HttpLogger;
|
||||||
use Ratchet\Http\Router;
|
use Ratchet\Http\Router;
|
||||||
use Ratchet\Server\IoServer;
|
use Ratchet\Server\IoServer;
|
||||||
use React\EventLoop\Factory as LoopFactory;
|
use React\EventLoop\Factory as LoopFactory;
|
||||||
|
|
@ -12,8 +14,6 @@ use Symfony\Component\Console\Output\OutputInterface;
|
||||||
use Symfony\Component\Routing\Matcher\UrlMatcher;
|
use Symfony\Component\Routing\Matcher\UrlMatcher;
|
||||||
use Symfony\Component\Routing\RequestContext;
|
use Symfony\Component\Routing\RequestContext;
|
||||||
use Symfony\Component\Routing\RouteCollection;
|
use Symfony\Component\Routing\RouteCollection;
|
||||||
use BeyondCode\LaravelWebSockets\Server\HttpServer;
|
|
||||||
use BeyondCode\LaravelWebSockets\Server\Loggers\HttpLogger;
|
|
||||||
|
|
||||||
class ServerFactory
|
class ServerFactory
|
||||||
{
|
{
|
||||||
|
|
|
||||||
|
|
@ -2,12 +2,12 @@
|
||||||
|
|
||||||
namespace BeyondCode\LaravelWebSockets\Statistics\Collectors;
|
namespace BeyondCode\LaravelWebSockets\Statistics\Collectors;
|
||||||
|
|
||||||
use React\Promise\FulfilledPromise;
|
use BeyondCode\LaravelWebSockets\Contracts\ChannelManager;
|
||||||
use React\Promise\PromiseInterface;
|
use BeyondCode\LaravelWebSockets\Contracts\StatisticsCollector;
|
||||||
use BeyondCode\LaravelWebSockets\Facades\StatisticsStore;
|
use BeyondCode\LaravelWebSockets\Facades\StatisticsStore;
|
||||||
use BeyondCode\LaravelWebSockets\Statistics\Statistic;
|
use BeyondCode\LaravelWebSockets\Statistics\Statistic;
|
||||||
use BeyondCode\LaravelWebSockets\Contracts\StatisticsCollector;
|
use React\Promise\FulfilledPromise;
|
||||||
use BeyondCode\LaravelWebSockets\Contracts\ChannelManager;
|
use React\Promise\PromiseInterface;
|
||||||
|
|
||||||
class MemoryCollector implements StatisticsCollector
|
class MemoryCollector implements StatisticsCollector
|
||||||
{
|
{
|
||||||
|
|
|
||||||
|
|
@ -2,14 +2,10 @@
|
||||||
|
|
||||||
namespace BeyondCode\LaravelWebSockets\Statistics\Collectors;
|
namespace BeyondCode\LaravelWebSockets\Statistics\Collectors;
|
||||||
|
|
||||||
use React\Promise\FulfilledPromise;
|
|
||||||
use React\Promise\PromiseInterface;
|
|
||||||
use BeyondCode\LaravelWebSockets\Facades\StatisticsStore;
|
|
||||||
use BeyondCode\LaravelWebSockets\Statistics\Statistic;
|
use BeyondCode\LaravelWebSockets\Statistics\Statistic;
|
||||||
use BeyondCode\LaravelWebSockets\Contracts\StatisticsCollector;
|
|
||||||
use BeyondCode\LaravelWebSockets\Contracts\ChannelManager;
|
|
||||||
use Illuminate\Cache\RedisLock;
|
use Illuminate\Cache\RedisLock;
|
||||||
use Illuminate\Support\Facades\Redis;
|
use Illuminate\Support\Facades\Redis;
|
||||||
|
use React\Promise\PromiseInterface;
|
||||||
|
|
||||||
class RedisCollector extends MemoryCollector
|
class RedisCollector extends MemoryCollector
|
||||||
{
|
{
|
||||||
|
|
@ -117,7 +113,7 @@ class RedisCollector extends MemoryCollector
|
||||||
'peak_connections_count', $peakConnectionsCount
|
'peak_connections_count', $peakConnectionsCount
|
||||||
);
|
);
|
||||||
});
|
});
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|
@ -157,7 +153,7 @@ class RedisCollector extends MemoryCollector
|
||||||
'peak_connections_count', $peakConnectionsCount
|
'peak_connections_count', $peakConnectionsCount
|
||||||
);
|
);
|
||||||
});
|
});
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|
|
||||||
|
|
@ -2,15 +2,15 @@
|
||||||
|
|
||||||
namespace BeyondCode\LaravelWebSockets;
|
namespace BeyondCode\LaravelWebSockets;
|
||||||
|
|
||||||
use Illuminate\Support\ServiceProvider;
|
|
||||||
use BeyondCode\LaravelWebSockets\Server\Router;
|
|
||||||
use BeyondCode\LaravelWebSockets\Dashboard\Http\Middleware\Authorize as AuthorizeDashboard;
|
|
||||||
use BeyondCode\LaravelWebSockets\Dashboard\Http\Controllers\AuthenticateDashboard;
|
use BeyondCode\LaravelWebSockets\Dashboard\Http\Controllers\AuthenticateDashboard;
|
||||||
use BeyondCode\LaravelWebSockets\Dashboard\Http\Controllers\SendMessage;
|
use BeyondCode\LaravelWebSockets\Dashboard\Http\Controllers\SendMessage;
|
||||||
use BeyondCode\LaravelWebSockets\Dashboard\Http\Controllers\ShowDashboard;
|
use BeyondCode\LaravelWebSockets\Dashboard\Http\Controllers\ShowDashboard;
|
||||||
use BeyondCode\LaravelWebSockets\Dashboard\Http\Controllers\ShowStatistics;
|
use BeyondCode\LaravelWebSockets\Dashboard\Http\Controllers\ShowStatistics;
|
||||||
|
use BeyondCode\LaravelWebSockets\Dashboard\Http\Middleware\Authorize as AuthorizeDashboard;
|
||||||
|
use BeyondCode\LaravelWebSockets\Server\Router;
|
||||||
use Illuminate\Support\Facades\Gate;
|
use Illuminate\Support\Facades\Gate;
|
||||||
use Illuminate\Support\Facades\Route;
|
use Illuminate\Support\Facades\Route;
|
||||||
|
use Illuminate\Support\ServiceProvider;
|
||||||
|
|
||||||
class WebSocketsServiceProvider extends ServiceProvider
|
class WebSocketsServiceProvider extends ServiceProvider
|
||||||
{
|
{
|
||||||
|
|
|
||||||
|
|
@ -2,8 +2,6 @@
|
||||||
|
|
||||||
namespace BeyondCode\LaravelWebSockets\Test;
|
namespace BeyondCode\LaravelWebSockets\Test;
|
||||||
|
|
||||||
use BeyondCode\LaravelWebSockets\Test\TestCase;
|
|
||||||
|
|
||||||
class StatisticsCleanTest extends TestCase
|
class StatisticsCleanTest extends TestCase
|
||||||
{
|
{
|
||||||
public function test_clean_statistics_for_app_id()
|
public function test_clean_statistics_for_app_id()
|
||||||
|
|
@ -17,7 +15,7 @@ class StatisticsCleanTest extends TestCase
|
||||||
|
|
||||||
foreach ($this->statisticsStore->getRawRecords() as $record) {
|
foreach ($this->statisticsStore->getRawRecords() as $record) {
|
||||||
$record->update(['created_at' => now()->subDays(10)]);
|
$record->update(['created_at' => now()->subDays(10)]);
|
||||||
};
|
}
|
||||||
|
|
||||||
$this->artisan('websockets:clean', [
|
$this->artisan('websockets:clean', [
|
||||||
'appId' => '12345',
|
'appId' => '12345',
|
||||||
|
|
@ -38,7 +36,7 @@ class StatisticsCleanTest extends TestCase
|
||||||
|
|
||||||
foreach ($this->statisticsStore->getRawRecords() as $record) {
|
foreach ($this->statisticsStore->getRawRecords() as $record) {
|
||||||
$record->update(['created_at' => now()->subDays(10)]);
|
$record->update(['created_at' => now()->subDays(10)]);
|
||||||
};
|
}
|
||||||
|
|
||||||
$this->artisan('websockets:clean', ['--days' => 1]);
|
$this->artisan('websockets:clean', ['--days' => 1]);
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -2,7 +2,8 @@
|
||||||
|
|
||||||
namespace BeyondCode\LaravelWebSockets\Test;
|
namespace BeyondCode\LaravelWebSockets\Test;
|
||||||
|
|
||||||
use BeyondCode\LaravelWebSockets\Server\Exceptions\{ OriginNotAllowed, UnknownAppKey, ConnectionsOverCapacity };
|
use BeyondCode\LaravelWebSockets\Server\Exceptions\OriginNotAllowed;
|
||||||
|
use BeyondCode\LaravelWebSockets\Server\Exceptions\UnknownAppKey;
|
||||||
|
|
||||||
class ConnectionTest extends TestCase
|
class ConnectionTest extends TestCase
|
||||||
{
|
{
|
||||||
|
|
|
||||||
|
|
@ -2,7 +2,6 @@
|
||||||
|
|
||||||
namespace BeyondCode\LaravelWebSockets\Test\Dashboard;
|
namespace BeyondCode\LaravelWebSockets\Test\Dashboard;
|
||||||
|
|
||||||
use BeyondCode\LaravelWebSockets\Statistics\Logger\MemoryStatisticsLogger;
|
|
||||||
use BeyondCode\LaravelWebSockets\Test\Models\User;
|
use BeyondCode\LaravelWebSockets\Test\Models\User;
|
||||||
use BeyondCode\LaravelWebSockets\Test\TestCase;
|
use BeyondCode\LaravelWebSockets\Test\TestCase;
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -3,8 +3,8 @@
|
||||||
namespace BeyondCode\LaravelWebSockets\Test\Mocks;
|
namespace BeyondCode\LaravelWebSockets\Test\Mocks;
|
||||||
|
|
||||||
use Clue\React\Block;
|
use Clue\React\Block;
|
||||||
use React\Promise\PromiseInterface;
|
|
||||||
use React\Promise\FulfilledPromise;
|
use React\Promise\FulfilledPromise;
|
||||||
|
use React\Promise\PromiseInterface;
|
||||||
|
|
||||||
class PromiseResolver implements PromiseInterface
|
class PromiseResolver implements PromiseInterface
|
||||||
{
|
{
|
||||||
|
|
|
||||||
|
|
@ -2,13 +2,13 @@
|
||||||
|
|
||||||
namespace BeyondCode\LaravelWebSockets\Test;
|
namespace BeyondCode\LaravelWebSockets\Test;
|
||||||
|
|
||||||
use Orchestra\Testbench\BrowserKit\TestCase as Orchestra;
|
|
||||||
use React\EventLoop\Factory as LoopFactory;
|
|
||||||
use GuzzleHttp\Psr7\Request;
|
|
||||||
use BeyondCode\LaravelWebSockets\Contracts\ChannelManager;
|
use BeyondCode\LaravelWebSockets\Contracts\ChannelManager;
|
||||||
use BeyondCode\LaravelWebSockets\Contracts\StatisticsCollector;
|
use BeyondCode\LaravelWebSockets\Contracts\StatisticsCollector;
|
||||||
use BeyondCode\LaravelWebSockets\Contracts\StatisticsStore;
|
use BeyondCode\LaravelWebSockets\Contracts\StatisticsStore;
|
||||||
|
use GuzzleHttp\Psr7\Request;
|
||||||
use Illuminate\Support\Facades\Redis;
|
use Illuminate\Support\Facades\Redis;
|
||||||
|
use Orchestra\Testbench\BrowserKit\TestCase as Orchestra;
|
||||||
|
use React\EventLoop\Factory as LoopFactory;
|
||||||
|
|
||||||
abstract class TestCase extends Orchestra
|
abstract class TestCase extends Orchestra
|
||||||
{
|
{
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue