yetangitu/Oinktube
1
0
Fork 0
mirror of https://github.com/DanielnetoDotCom/YouPHPTube synced 2025-10-03 01:39:24 +02:00
Code Issues Releases Wiki Activity

update socket

Browse source
This commit is contained in:
Daniel Neto 2023-03-06 15:36:54 -03:00
parent 93b0e11e30
commit e1bf080979
12 changed files with 250 additions and 69 deletions
Download patch file Download diff file Expand all files Collapse all files

35
plugin/YPTSocket/MessageSQLite.php
View file

@ -6,6 +6,7 @@ use React\EventLoop\Loop;
use Ratchet\MessageComponentInterface;
use Ratchet\ConnectionInterface;
use Amp\Loop as AMPLoop;
use User;
require_once dirname(__FILE__) . '/../../videos/configuration.php';
require_once $global['systemRootPath'] . 'plugin/YPTSocket/functions.php';
@ -33,6 +34,7 @@ class Message implements MessageComponentInterface {
}
public function onOpen(ConnectionInterface $conn) {
global $global;
$start = microtime(true);
$query = $conn->httpRequest->getUri()->getQuery();
parse_str($query, $wsocketGetVars);
@ -56,6 +58,8 @@ class Message implements MessageComponentInterface {
$live_key['live_servers_id'] = 0;
$live_key['liveLink'] = '';
}
//var_dump($live_key);
$client = array();
$client['resourceId'] = intval($conn->resourceId);
@ -68,6 +72,7 @@ class Message implements MessageComponentInterface {
$client['live_key'] = $live_key['key'];
$client['live_servers_id'] = intval($live_key['live_servers_id']);
$client['user_name'] = $json->user_name;
$client['identification'] = User::getNameIdentificationById($client['users_id']);
$client['browser'] = $json->browser;
$client['yptDeviceId'] = $json->yptDeviceId;
$client['client'] = deviceIdToObject($json->yptDeviceId);
@ -91,7 +96,23 @@ class Message implements MessageComponentInterface {
$client['browser'] = $client['client']->browser;
$client['os'] = $client['client']->os;
$client['data'] = $json;
if(empty($client['room_users_id'])){
$queryString = parse_url($client['selfURI'], PHP_URL_QUERY);
parse_str($queryString, $params);
if(!empty($params['room_users_id'])){
$client['room_users_id'] = intval($params['room_users_id']);
}
}
$client['chat_is_banned'] = 0;
if(!empty($client['room_users_id']) && !empty($client['users_id'])){
require_once $global['systemRootPath'] . 'plugin/Chat2/Objects/ChatBan.php';
if(\ChatBan::isUserBanned($client['room_users_id'], $client['users_id'])){
$client['chat_is_banned'] = 1;
}
}
//var_dump($client['liveLink'], $live_key);
$this->setClient($conn, $client);
@ -102,7 +123,19 @@ class Message implements MessageComponentInterface {
$this->msgToResourceId($json, $conn->resourceId, \SocketMessageType::TESTING);
} else if ($this->shouldPropagateInfo($client)) {
//_log_message("shouldPropagateInfo {$json->yptDeviceId}");
$this->msgToAll($conn, array('users_id' => $client['users_id'], 'user_name' => $client['user_name'], 'yptDeviceId' => $client['yptDeviceId']), \SocketMessageType::NEW_CONNECTION, true);
$this->msgToAll(
$conn,
array(
'users_id' => $client['users_id'],
'yptDeviceId' => $client['yptDeviceId'],
'live_key_servers_id' => $client['live_key_servers_id'],
'identification' => $client['identification'],
'videos_id' => $client['videos_id'],
'room_users_id' => $client['room_users_id'],
'chat_is_banned' => $client['chat_is_banned'],
'resourceId' => $client['resourceId']),
\SocketMessageType::NEW_CONNECTION,
true);
} else {
//_log_message("NOT shouldPropagateInfo ");
}