@@ -203,14 +203,14 @@ |
||
203 | 203 | * @throws ShareTokenNotFoundException |
204 | 204 | */ |
205 | 205 | public function importFromDatabase(array $data, string $prefix = ''): IQueryRow { |
206 | - if ($this->get($prefix . 'token', $data) === '') { |
|
206 | + if ($this->get($prefix.'token', $data) === '') { |
|
207 | 207 | throw new ShareTokenNotFoundException(); |
208 | 208 | } |
209 | 209 | |
210 | - $this->setSingleId($this->get($prefix . 'single_id', $data)); |
|
211 | - $this->setUpdateType($this->get($prefix . 'update_type', $data)); |
|
212 | - $this->setUpdateTypeId($this->get($prefix . 'update_type_id', $data)); |
|
213 | - $this->setTime($this->getInt($prefix . 'time', $data)); |
|
210 | + $this->setSingleId($this->get($prefix.'single_id', $data)); |
|
211 | + $this->setUpdateType($this->get($prefix.'update_type', $data)); |
|
212 | + $this->setUpdateTypeId($this->get($prefix.'update_type_id', $data)); |
|
213 | + $this->setTime($this->getInt($prefix.'time', $data)); |
|
214 | 214 | |
215 | 215 | return $this; |
216 | 216 | } |
@@ -132,7 +132,7 @@ |
||
132 | 132 | $syncedItem |
133 | 133 | ); |
134 | 134 | |
135 | - echo 'reached !? ' . json_encode($data) . "\n"; |
|
135 | + echo 'reached !? '.json_encode($data)."\n"; |
|
136 | 136 | } |
137 | 137 | |
138 | 138 | } |
@@ -260,18 +260,18 @@ |
||
260 | 260 | * @throws SyncedItemNotFoundException |
261 | 261 | */ |
262 | 262 | public function importFromDatabase(array $data, string $prefix = ''): IQueryRow { |
263 | - if ($this->get($prefix . 'single_id', $data) === '') { |
|
263 | + if ($this->get($prefix.'single_id', $data) === '') { |
|
264 | 264 | throw new SyncedItemNotFoundException(); |
265 | 265 | } |
266 | 266 | |
267 | - $this->setSingleId($this->get($prefix . 'single_id', $data)); |
|
268 | - $this->setInstance($this->get($prefix . 'instance', $data)); |
|
269 | - $this->setInstance($this->get($prefix . 'instance', $data)); |
|
270 | - $this->setAppId($this->get($prefix . 'app_id', $data)); |
|
271 | - $this->setItemType($this->get($prefix . 'item_type', $data)); |
|
272 | - $this->setItemId($this->get($prefix . 'item_id', $data)); |
|
273 | - $this->setChecksum($this->get($prefix . 'checksum', $data)); |
|
274 | - $this->setDeleted($this->getBool($prefix . 'deleted', $data)); |
|
267 | + $this->setSingleId($this->get($prefix.'single_id', $data)); |
|
268 | + $this->setInstance($this->get($prefix.'instance', $data)); |
|
269 | + $this->setInstance($this->get($prefix.'instance', $data)); |
|
270 | + $this->setAppId($this->get($prefix.'app_id', $data)); |
|
271 | + $this->setItemType($this->get($prefix.'item_type', $data)); |
|
272 | + $this->setItemId($this->get($prefix.'item_id', $data)); |
|
273 | + $this->setChecksum($this->get($prefix.'checksum', $data)); |
|
274 | + $this->setDeleted($this->getBool($prefix.'deleted', $data)); |
|
275 | 275 | |
276 | 276 | if ($this->getInstance() === '') { |
277 | 277 | $this->setInstance($this->getManager()->getLocalInstance()); |
@@ -133,12 +133,12 @@ |
||
133 | 133 | * @throws SyncedShareNotFoundException |
134 | 134 | */ |
135 | 135 | public function importFromDatabase(array $data, string $prefix = ''): IQueryRow { |
136 | - if ($this->get($prefix . 'single_id', $data) === '') { |
|
136 | + if ($this->get($prefix.'single_id', $data) === '') { |
|
137 | 137 | throw new SyncedShareNotFoundException(); |
138 | 138 | } |
139 | 139 | |
140 | - $this->setCircleId($this->get($prefix . 'circle_id', $data)); |
|
141 | - $this->setSingleId($this->get($prefix . 'single_id', $data)); |
|
140 | + $this->setCircleId($this->get($prefix.'circle_id', $data)); |
|
141 | + $this->setSingleId($this->get($prefix.'single_id', $data)); |
|
142 | 142 | |
143 | 143 | return $this; |
144 | 144 | } |
@@ -234,7 +234,7 @@ discard block |
||
234 | 234 | try { |
235 | 235 | $reflection = new ReflectionClass($class); |
236 | 236 | } catch (ReflectionException $e) { |
237 | - throw new InvalidItemException('reflection issue with ' . $class); |
|
237 | + throw new InvalidItemException('reflection issue with '.$class); |
|
238 | 238 | } |
239 | 239 | |
240 | 240 | if (!$reflection->implementsInterface(IDeserializable::class)) { |
@@ -354,7 +354,7 @@ discard block |
||
354 | 354 | * @return string |
355 | 355 | */ |
356 | 356 | private function getRef(string $key, string $ref): string { |
357 | - return $this->get($key . '.' . $ref, $this->ref); |
|
357 | + return $this->get($key.'.'.$ref, $this->ref); |
|
358 | 358 | } |
359 | 359 | |
360 | 360 | /** |
@@ -242,16 +242,16 @@ |
||
242 | 242 | * @throws InvalidItemException |
243 | 243 | */ |
244 | 244 | public function importFromDatabase(array $data, string $prefix = ''): IQueryRow { |
245 | - if (empty($this->getArray($prefix . 'debug', $data))) { |
|
245 | + if (empty($this->getArray($prefix.'debug', $data))) { |
|
246 | 246 | throw new InvalidItemException(); |
247 | 247 | } |
248 | 248 | |
249 | - $this->setId($this->getInt($prefix . 'id', $data)); |
|
250 | - $this->setThread($this->get($prefix . 'thread', $data)); |
|
251 | - $this->setType($this->get($prefix . 'type', $data)); |
|
252 | - $this->setCircleId($this->get($prefix . 'circle_id', $data)); |
|
253 | - $this->setInstance($this->get($prefix . 'instance', $data)); |
|
254 | - $this->setTime($this->getInt($prefix . 'time', $data)); |
|
249 | + $this->setId($this->getInt($prefix.'id', $data)); |
|
250 | + $this->setThread($this->get($prefix.'thread', $data)); |
|
251 | + $this->setType($this->get($prefix.'type', $data)); |
|
252 | + $this->setCircleId($this->get($prefix.'circle_id', $data)); |
|
253 | + $this->setInstance($this->get($prefix.'instance', $data)); |
|
254 | + $this->setTime($this->getInt($prefix.'time', $data)); |
|
255 | 255 | |
256 | 256 | /** @var ReferencedDataStore $store */ |
257 | 257 | $store = $this->deserialize($this->getArray('debug', $data), ReferencedDataStore::class); |
@@ -145,7 +145,7 @@ |
||
145 | 145 | |
146 | 146 | $msg = $e->getMessage(); |
147 | 147 | $store = new ReferencedDataStore(); |
148 | - $store->s(self::ACTION, '{?' . self::E_CLASS . '}' . (($msg !== '') ? ' (' . $msg . ')' : '')); |
|
148 | + $store->s(self::ACTION, '{?'.self::E_CLASS.'}'.(($msg !== '') ? ' ('.$msg.')' : '')); |
|
149 | 149 | $store->s(self::E_CLASS, get_class($e)); |
150 | 150 | $store->s(self::EXCEPTION, $e->getMessage()); |
151 | 151 | $store->sArray(self::E_TRACE, debug_backtrace()); |
@@ -134,7 +134,7 @@ |
||
134 | 134 | */ |
135 | 135 | public function extractObjectFromRequest( |
136 | 136 | string $class, |
137 | - ?NCSignedRequest &$signed = null |
|
137 | + ?NCSignedRequest & $signed = null |
|
138 | 138 | ): IDeserializable { |
139 | 139 | $signed = $this->remoteStreamService->incomingSignedRequest(); |
140 | 140 | $this->confirmRemoteInstance($signed); |
@@ -285,7 +285,7 @@ discard block |
||
285 | 285 | public function confirmRemoteInstanceAccess(string $syncedId, string $instance): void { |
286 | 286 | $circleIds = array_values( |
287 | 287 | array_map( |
288 | - function (SyncedShare $share): string { |
|
288 | + function(SyncedShare $share): string { |
|
289 | 289 | return $share->getCircleId(); |
290 | 290 | }, |
291 | 291 | $this->syncedShareRequest->getShares($syncedId) |
@@ -297,7 +297,7 @@ discard block |
||
297 | 297 | // federated circles only works as root, so sub-circles cannot spread on multiple instances. |
298 | 298 | $links = $this->memberRequest->getLinksWithInstance($instance, $circleIds); |
299 | 299 | $this->debugService->info( |
300 | - 'SyncedItem {singleId} is shared to ' . count($circleIds) . ' circles', '', |
|
300 | + 'SyncedItem {singleId} is shared to '.count($circleIds).' circles', '', |
|
301 | 301 | [ |
302 | 302 | 'syncedId' => $syncedId, |
303 | 303 | 'circleIds' => $circleIds, |