dave/pathfinder-websocket
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

- removed requirement for ZMQ PHP extension and replaced the Socket stuff with native PHP code

Browse Source
This commit is contained in:
Mark Friedrich
2019-05-01 02:00:31 +02:00
parent 40c1cc5f7b
commit c77e3dd484
6 changed files with 625 additions and 46 deletions
Download Patch File Download Diff File Expand all files Collapse all files

33
app/Main/MapUpdate.php
View File

@@ -485,43 +485,44 @@ class MapUpdate implements MessageComponentInterface {
/**
* receive data from TCP socket (main App)
* -> send response back
* @param $data
* @param string $task
* @param null $load
* @return bool|float|int|null
*/
public function receiveData($data){
$data = (array)json_decode($data, true);
$load = $data['load'];
$task = $data['task'];
$response = false;
public function receiveData(string $task, $load = null){
$responseLoad = null;
switch($task){
case 'healthCheck':
$this->healthCheckToken = (float)$load;
$responseLoad = $this->healthCheckToken;
break;
case 'characterUpdate':
$response = $this->updateCharacterData($load);
$this->updateCharacterData($load);
$mapIds = $this->getMapIdsByCharacterId((int)$load['id']);
$this->broadcastMapSubscriptions('mapSubscriptions', $mapIds);
break;
case 'characterLogout':
$response = $this->unSubscribeCharacterIds($load);
$responseLoad = $this->unSubscribeCharacterIds($load);
break;
case 'mapConnectionAccess':
$response = $this->setConnectionAccess($load);
$responseLoad = $this->setConnectionAccess($load);
break;
case 'mapAccess':
$response = $this->setAccess($task, $load);
$responseLoad = $this->setAccess($task, $load);
break;
case 'mapUpdate':
$response = $this->broadcastMapUpdate($task, $load);
$responseLoad = $this->broadcastMapUpdate($task, $load);
break;
case 'mapDeleted':
$response = $this->deleteMapId($task, $load);
break;
case 'healthCheck':
$this->healthCheckToken = (float)$load;
$response = 'OK';
$responseLoad = $this->deleteMapId($task, $load);
break;
case 'logData':
$this->handleLogData((array)$load['meta'], (array)$load['log']);
break;
}
return $responseLoad;
}
private function setCharacterData(array $characterData){