@@ -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 |
@@ -124,10 +124,10 @@ discard block |
||
124 | 124 | ->setArguments(['session' => $switchableSession]); |
125 | 125 | |
126 | 126 | $serverWrapper = $builder->getDefinitionByType(IPub\WebSockets\Server\Wrapper::class); |
127 | - $serverWrapper->addSetup('$service->onClientConnected[] = ?', ['@' . $this->prefix('events.onClientConnected')]); |
|
128 | - $serverWrapper->addSetup('$service->onClientDisconnected[] = ?', ['@' . $this->prefix('events.onClientDisconnected')]); |
|
129 | - $serverWrapper->addSetup('$service->onIncomingMessage[] = ?', ['@' . $this->prefix('events.onIncomingMessage')]); |
|
130 | - $serverWrapper->addSetup('$service->onAfterIncomingMessage[] = ?', ['@' . $this->prefix('events.onAfterIncomingMessage')]); |
|
127 | + $serverWrapper->addSetup('$service->onClientConnected[] = ?', ['@'.$this->prefix('events.onClientConnected')]); |
|
128 | + $serverWrapper->addSetup('$service->onClientDisconnected[] = ?', ['@'.$this->prefix('events.onClientDisconnected')]); |
|
129 | + $serverWrapper->addSetup('$service->onIncomingMessage[] = ?', ['@'.$this->prefix('events.onIncomingMessage')]); |
|
130 | + $serverWrapper->addSetup('$service->onAfterIncomingMessage[] = ?', ['@'.$this->prefix('events.onAfterIncomingMessage')]); |
|
131 | 131 | } |
132 | 132 | } |
133 | 133 |
@@ -17,7 +17,6 @@ |
||
17 | 17 | namespace IPub\WebSocketsSession\Session; |
18 | 18 | |
19 | 19 | use Nette\Http; |
20 | - |
|
21 | 20 | use IPub; |
22 | 21 | use IPub\WebSocketsSession\Exceptions; |
23 | 22 |
@@ -16,13 +16,10 @@ |
||
16 | 16 | |
17 | 17 | namespace IPub\WebSocketsSession\Session; |
18 | 18 | |
19 | -use Nette\Diagnostics\Debugger; |
|
20 | 19 | use Nette\Http; |
21 | - |
|
22 | 20 | use IPub; |
23 | 21 | use IPub\WebSocketsSession\Exceptions; |
24 | 22 | use IPub\WebSocketsSession\Serializers; |
25 | - |
|
26 | 23 | use IPub\WebSockets\Entities as WebSocketsEntities; |
27 | 24 | use IPub\WebSockets\Http as WebSocketsHttp; |
28 | 25 |