Jaussoin Timothée
11 years ago
5 changed files with 9 additions and 193 deletions
-
2app/views/contact.tpl
-
4app/widgets/Contact/_contact_header.tpl
-
6app/widgets/Roster/roster.tpl
-
6linker.php
-
184src/Movim/Daemon/Behaviour.php
@ -1,184 +0,0 @@ |
|||
<?php |
|||
namespace Movim\Daemon; |
|||
|
|||
use Ratchet\MessageComponentInterface; |
|||
use Ratchet\ConnectionInterface; |
|||
|
|||
class Behaviour implements MessageComponentInterface { |
|||
protected $sessions = array(); // Store the sessions
|
|||
protected $baseuri; |
|||
|
|||
public function __construct($baseuri, $port) { |
|||
echo colorize("Movim daemon launched\n", 'green'); |
|||
echo colorize("Base URI :", 'green')." {$baseuri}\n"; |
|||
echo colorize("WebSocket URL :", 'green')." http(s)://[your host adress]:{$port}\n"; |
|||
$this->baseuri = $baseuri; |
|||
} |
|||
|
|||
public function onOpen(ConnectionInterface $conn) { |
|||
$cookies = $conn->WebSocket->request->getCookies(); |
|||
|
|||
if(array_key_exists('MOVIM_SESSION_ID', $cookies)) { |
|||
$sid = $cookies['MOVIM_SESSION_ID']; |
|||
$this->sessions[$sid][$conn->resourceId] = $conn; |
|||
|
|||
// If a linker doesn't exist for the current session
|
|||
if(!array_key_exists('linker', $this->sessions[$sid])) { |
|||
$loop = \React\EventLoop\Factory::create(); |
|||
$this->sessions[$sid]['process'] = new \React\ChildProcess\Process( |
|||
'php linker.php', |
|||
null, |
|||
array( |
|||
'sid' => $sid, |
|||
'baseuri' => $this->baseuri |
|||
) |
|||
); |
|||
$this->sessions[$sid]['process']->start($loop); |
|||
} |
|||
|
|||
echo colorize($cookies['MOVIM_SESSION_ID'], 'yellow'). " : ".colorize($conn->resourceId." connected\n", 'green'); |
|||
} |
|||
} |
|||
|
|||
public function onMessage(ConnectionInterface $from, $msg) { |
|||
$msg = json_decode($msg); |
|||
|
|||
$sid = $this->getSid($from); |
|||
|
|||
if(!isset($msg->func)) { |
|||
return; |
|||
} |
|||
|
|||
switch ($msg->func) { |
|||
// The browser ask for a new session
|
|||
case 'unregister': |
|||
if(array_key_exists('linker', $this->sessions[$sid])) { |
|||
$this->sessions[$sid]['linker']->close(); |
|||
} |
|||
break; |
|||
|
|||
// A linker ask to be linked to a session
|
|||
case 'register_linker': |
|||
if(array_key_exists($msg->sid, $this->sessions) && |
|||
!array_key_exists('linker', $this->sessions[$msg->sid])) { |
|||
$from->sid = $msg->sid; |
|||
$this->sessions[$from->sid]['linker'] = $from; |
|||
} |
|||
|
|||
$obj = new \StdClass; |
|||
$obj->func = 'registered'; |
|||
|
|||
foreach($this->sessions[$from->sid] as $key => $client) { |
|||
if($from !== $client && $key != 'process') { |
|||
$this->send($client, json_encode($obj)); |
|||
} |
|||
} |
|||
|
|||
$session_size = count($this->sessions[$from->sid]); |
|||
echo colorize($from->sid, 'yellow')." : ".colorize($from->resourceId.' linker registered', 'green')." - session size {$session_size}\n"; |
|||
break; |
|||
|
|||
// A message is received !
|
|||
case 'message': |
|||
// Forbid any incoming messages if the session is not linked to XMPP
|
|||
if(!array_key_exists('linker', $this->sessions[$sid])) { |
|||
//$from->send(json_encode('linker not connected'));
|
|||
return; |
|||
} |
|||
|
|||
$msg->body = (string)json_encode($msg->body); |
|||
|
|||
// A message from the linker to the clients
|
|||
if($from === $this->sessions[$sid]['linker']) { |
|||
//echo "{$from->sid} : {$msg->body} got from the linker\n";
|
|||
foreach($this->sessions[$sid] as $key => $client) { |
|||
if($from !== $client && $key != 'process') { |
|||
//The sender is not the receiver, send to each client connected
|
|||
if(isset($msg->body)) { |
|||
$this->send($client, $msg->body); |
|||
} |
|||
} |
|||
} |
|||
// A message from the browser to the linker
|
|||
} else { |
|||
//echo "{$from->sid} : {$msg->body} sent to the linker\n";
|
|||
$this->sessions[$sid]['linker']->send((string)$msg->body); |
|||
} |
|||
break; |
|||
case 'admin': |
|||
$cd = new \Modl\ConfigDAO(); |
|||
$config = $cd->get(); |
|||
|
|||
if(!isset($msg->key) && $config->password != $msg->key) { |
|||
return; |
|||
} |
|||
|
|||
$obj = new \StdClass; |
|||
$obj->func = 'Statistics.daemonSessions'; |
|||
$obj->params = array(array_keys($this->sessions)); |
|||
|
|||
$out = $obj; |
|||
|
|||
$this->send($from, json_encode(array($out))); |
|||
break; |
|||
default: |
|||
$this->send($from, 'no function specified'); |
|||
break; |
|||
} |
|||
} |
|||
|
|||
public function onClose(ConnectionInterface $conn) { |
|||
if(count($this->sessions) > 0) { |
|||
$sid = $this->getSid($conn); |
|||
|
|||
if(array_key_exists($sid, $this->sessions)) { |
|||
$session_size = count($this->sessions[$sid]); |
|||
|
|||
// The connection is closed, remove it, as we can no longer send it messages
|
|||
if(array_key_exists('linker', $this->sessions[$sid]) |
|||
&& $conn->resourceId == $this->sessions[$sid]['linker']->resourceId) { |
|||
$obj = new \StdClass; |
|||
$obj->func = 'disconnected'; |
|||
|
|||
foreach($this->sessions[$conn->sid] as $key => $client) { |
|||
if($key != 'process') { |
|||
$this->send($client, json_encode($obj)); |
|||
echo "{$client->resourceId} disconnected to login\n"; |
|||
} |
|||
} |
|||
echo colorize($sid, 'yellow')." : ". |
|||
colorize($conn->resourceId.' linker disconnected', 'red')." - session size {$session_size}\n"; |
|||
unset($this->sessions[$sid]); |
|||
} else { |
|||
echo colorize($sid, 'yellow')." : ". |
|||
colorize($conn->resourceId.' disconnected', 'red')." - session size {$session_size}\n"; |
|||
unset($this->sessions[$sid][$conn->resourceId]); |
|||
} |
|||
} |
|||
} |
|||
} |
|||
|
|||
public function onError(ConnectionInterface $conn, \Exception $e) { |
|||
echo "An error has occurred: {$e->getMessage()}\n"; |
|||
|
|||
$conn->close(); |
|||
} |
|||
|
|||
private function send($client, $message) { |
|||
$client->send(base64_encode(gzcompress($message, 9))); |
|||
} |
|||
|
|||
private function getSid(ConnectionInterface $conn) { |
|||
$cookies = $conn->WebSocket->request->getCookies(); |
|||
|
|||
if(array_key_exists('MOVIM_SESSION_ID', $cookies)) { |
|||
$sid = $cookies['MOVIM_SESSION_ID']; |
|||
} elseif(isset($conn->sid)) { |
|||
$sid = $conn->sid; |
|||
} else { |
|||
$sid = null; |
|||
} |
|||
|
|||
return $sid; |
|||
} |
|||
} |
|||
Write
Preview
Loading…
Cancel
Save
Reference in new issue