passer par un alias pour les websockets

src/ninegate-1.0/app/config/config.yml

@@ -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:

src/ninegate-1.0/scripts/ninegate-websocket.sh

@@ -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

src/ninegate-1.0/src/Cadoles/PortalBundle/Resources/views/Page/pages.html.twig

@@ -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() {

src/ninegate-1.0/src/Cadoles/WebsocketBundle/Controller/ChatController.php

@@ -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();
+                }  
             }
 
 

src/ninegate-1.0/src/Cadoles/WebsocketBundle/Resources/views/Chat/client.html.twig

@@ -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) {