@@ -17,15 +17,11 @@ |
||
| 17 | 17 | namespace IPub\WebSocketsSession\Users; |
| 18 | 18 | |
| 19 | 19 | use Nette; |
| 20 | -use Nette\Security as NS; |
|
| 21 | - |
|
| 22 | 20 | use IPub; |
| 23 | 21 | use IPub\WebSockets\Clients; |
| 24 | 22 | use IPub\WebSockets\Entities; |
| 25 | 23 | use IPub\WebSockets\Exceptions; |
| 26 | 24 | |
| 27 | -use IPub\WebSockets\Entities as WebSocketsEntities; |
|
| 28 | - |
|
| 29 | 25 | /** |
| 30 | 26 | * Connected users repository |
| 31 | 27 | * |
@@ -38,7 +38,7 @@ |
||
| 38 | 38 | |
| 39 | 39 | if (count($data)) { |
| 40 | 40 | foreach ($data as $bucket => $bucketData) { |
| 41 | - $preSerialized[] = $bucket . '|' . \serialize($bucketData); |
|
| 41 | + $preSerialized[] = $bucket.'|'.\serialize($bucketData); |
|
| 42 | 42 | } |
| 43 | 43 | |
| 44 | 44 | $serialized = implode('', $preSerialized); |
@@ -36,7 +36,7 @@ |
||
| 36 | 36 | */ |
| 37 | 37 | public static function create() : ISessionSerializer |
| 38 | 38 | { |
| 39 | - $serialClass = '\\IPub\\WebSocketsSession\\Serializers\\Session' . self::toClassCase(ini_get('session.serialize_handler')) . 'Serializer'; // awesome/terrible hack, eh? |
|
| 39 | + $serialClass = '\\IPub\\WebSocketsSession\\Serializers\\Session'.self::toClassCase(ini_get('session.serialize_handler')).'Serializer'; // awesome/terrible hack, eh? |
|
| 40 | 40 | |
| 41 | 41 | if (!class_exists($serialClass)) { |
| 42 | 42 | throw new Exceptions\RuntimeException('Unable to parse session serialize handler'); |
@@ -67,7 +67,7 @@ discard block |
||
| 67 | 67 | |
| 68 | 68 | $builder->addDefinition($this->prefix('serializer.session')) |
| 69 | 69 | ->setClass(Serializers\ISessionSerializer::class) |
| 70 | - ->setFactory(Serializers\SessionSerializerFactory::class . '::create'); |
|
| 70 | + ->setFactory(Serializers\SessionSerializerFactory::class.'::create'); |
|
| 71 | 71 | |
| 72 | 72 | /** |
| 73 | 73 | * USERS |
@@ -120,9 +120,9 @@ discard block |
||
| 120 | 120 | ->setArguments(['session' => $switchableSession]); |
| 121 | 121 | |
| 122 | 122 | $serverWrapper = $builder->getDefinitionByType(IPub\WebSockets\Server\Wrapper::class); |
| 123 | - $serverWrapper->addSetup('$service->onClientConnected[] = ?', ['@' . $this->prefix('events.onClientConnected')]); |
|
| 124 | - $serverWrapper->addSetup('$service->onClientDisconnected[] = ?', ['@' . $this->prefix('events.onClientDisconnected')]); |
|
| 125 | - $serverWrapper->addSetup('$service->onIncomingMessage[] = ?', ['@' . $this->prefix('events.onIncomingMessage')]); |
|
| 123 | + $serverWrapper->addSetup('$service->onClientConnected[] = ?', ['@'.$this->prefix('events.onClientConnected')]); |
|
| 124 | + $serverWrapper->addSetup('$service->onClientDisconnected[] = ?', ['@'.$this->prefix('events.onClientDisconnected')]); |
|
| 125 | + $serverWrapper->addSetup('$service->onIncomingMessage[] = ?', ['@'.$this->prefix('events.onIncomingMessage')]); |
|
| 126 | 126 | } |
| 127 | 127 | } |
| 128 | 128 | |