Merge branch 'master' into dist/envole/6/master
This commit is contained in:
@ -127,16 +127,16 @@ gos_web_socket:
|
||||
firewall: main
|
||||
shared_config: true
|
||||
server:
|
||||
port: %websocket_port% #The port the socket server will listen on
|
||||
host: %websocket_host% #The host ip to bind to
|
||||
port: 443 #The port the socket server will listen on
|
||||
host: %weburl%/wssninegate #The host ip to bind to
|
||||
|
||||
router:
|
||||
resources:
|
||||
- "@CadolesWebsocketBundle/Resources/config/topic.yml"
|
||||
pushers:
|
||||
wamp:
|
||||
host: %websocket_host%
|
||||
port: %websocket_portinterne%
|
||||
host: 0.0.0.0
|
||||
port: 5556
|
||||
|
||||
# ckeditor configuration
|
||||
ivory_ck_editor:
|
||||
|
@ -1,11 +1,9 @@
|
||||
#!/bin/bash
|
||||
websocket_url=$(CreoleGet adresse_ip_eth0 non)
|
||||
websocket_portinterne=$(CreoleGet ninegate_websocket_portinterne non)
|
||||
|
||||
# Server Websocket
|
||||
if [[ "$1" != "restartifdown" ]]; then
|
||||
echo WEBSOCKET = STOP
|
||||
pid="$(pgrep -a -f gos:websocket | grep $websocket_portinterne)"
|
||||
pid="$(pgrep -a -f gos:websocket | grep 5556)"
|
||||
if [ -n "${pid}" ]; then
|
||||
IFS=' ' read -r -a array <<< "$pid"
|
||||
kill -9 ${array[0]};
|
||||
@ -13,7 +11,7 @@ if [[ "$1" != "restartifdown" ]]; then
|
||||
fi
|
||||
|
||||
# Port LISTEN ?
|
||||
pid="$(pgrep -a -f gos:websocket | grep $websocket_portinterne)"
|
||||
pid="$(pgrep -a -f gos:websocket | grep 5556)"
|
||||
restart="yes"
|
||||
if [ "$1" == "restartifdown" ] && [ -n "${pid}" ] ; then
|
||||
restart="no"
|
||||
@ -22,5 +20,5 @@ fi
|
||||
if [ "$restart" == "yes" ] && [ "$1" != "stop" ] ; then
|
||||
echo WEBSOCKET = START
|
||||
cd /var/www/html/ninegate
|
||||
bin/console gos:websocket:server --port $websocket_portinterne -a $websocket_url --no-debug -n -q --env=prod & disown
|
||||
systemctl restart wssninegate
|
||||
fi
|
@ -318,49 +318,6 @@
|
||||
loadmsgCounter()
|
||||
}, {{(app.session.get("timerefreshnotif")*1000)}});
|
||||
{% endif %}
|
||||
|
||||
// Init socket de counter
|
||||
/* Désactiver car il semble préférable de faire un appel ajax régulier plutot qu'ouvrir un channel websocket
|
||||
{% if websocket_activate %}
|
||||
var _WS_URI = "wss://{{ gos_web_socket_server_host }}:{{ gos_web_socket_server_port }}";
|
||||
|
||||
var webSocket = WS.connect(_WS_URI);
|
||||
|
||||
webSocket.on("socket/connect", function (session) {
|
||||
// The callback function in "subscribe" is called everytime an event is published in that channel.
|
||||
session.subscribe("websocket/counter", function (uri, payload) {
|
||||
if(payload.log) {
|
||||
console.log("Received message", payload.log);
|
||||
}
|
||||
if(payload.alert) {
|
||||
alert(payload.alert);
|
||||
}
|
||||
{% if app.user %}
|
||||
if(payload.from!="{{app.user.id}}") {
|
||||
menu=$("a[data-group='"+payload.group+"']");
|
||||
if(menu.length) {
|
||||
if(payload.add) {
|
||||
console.log("Ajout counter pour group "+payload.group+" by "+payload.from);
|
||||
if(menu.children(".badge").length) {
|
||||
menu.children(".badge").html(+(menu.children(".badge").html())+1);
|
||||
}
|
||||
else menu.append("<span id='badge-"+payload.group+"' class='badge'>1</span");
|
||||
}
|
||||
}
|
||||
}
|
||||
{% endif %}
|
||||
});
|
||||
|
||||
$(document).on('click', '#refreshcounter', function(){
|
||||
{% if app.user %}
|
||||
event=$(this).data("event");
|
||||
event.userid={{app.user.id}}
|
||||
session.publish("websocket/counter", event);
|
||||
{% endif %}
|
||||
});
|
||||
});
|
||||
{% endif %}
|
||||
*/
|
||||
});
|
||||
|
||||
$(window).resize(function() {
|
||||
|
@ -51,12 +51,16 @@ class ChatController extends Controller
|
||||
if(!$group) die();
|
||||
|
||||
// Génération d'une clé temporaire d'accès au chat
|
||||
$key = Uuid::uuid4();
|
||||
$usergroup=$em->getRepository("CadolesCoreBundle:UserGroup")->findOneBy(["group"=>$group,"user"=>$user]);
|
||||
$key=null;
|
||||
if($usergroup) {
|
||||
$usergroup->setKeyvalue($key);
|
||||
$em->persist($usergroup);
|
||||
$em->flush();
|
||||
$key=$usergroup->getKeyvalue();
|
||||
if(is_null($key)) {
|
||||
$key = Uuid::uuid4();
|
||||
$usergroup->setKeyvalue($key);
|
||||
$em->persist($usergroup);
|
||||
$em->flush();
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
|
@ -362,7 +362,8 @@
|
||||
|
||||
function websocket()
|
||||
{
|
||||
var _WS_URI = "wss://{{ gos_web_socket_server_host }}:{{ gos_web_socket_server_port }}";
|
||||
var _WS_URI = "wss://{{ gos_web_socket_server_host }}";
|
||||
console.log(_WS_URI);
|
||||
webSocket = WS.connect(_WS_URI,{retryDelay: delayRetry});
|
||||
|
||||
webSocket.on("socket/connect", function (sess) {
|
||||
|
Reference in New Issue
Block a user