@@ -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 |
@@ -17,7 +17,6 @@ |
||
17 | 17 | namespace IPub\WebSocketsSession\Users; |
18 | 18 | |
19 | 19 | use Nette; |
20 | - |
|
21 | 20 | use IPub; |
22 | 21 | use IPub\WebSockets\Clients as WebSocketsClients; |
23 | 22 | use IPub\WebSockets\Entities as WebSocketsEntities; |