<VirtualHost *:80>
    ServerAdmin moi@mon_orange.fr
    ServerName monsupersite.fr
    ServerAlias www.monsupersite.fr
    redirect    / https://monsupersite.fr
    RewriteEngine On
    DocumentRoot /var/www/vhosts/monsupersite.fr/public
</VirtualHost>

<IfModule mod_ssl.c>
    <VirtualHost *:443>
        ServerName              monsupersite.fr
        ServerAlias             www.monsupersite.fr
        DocumentRoot            /var/www/vhosts/monsupersite.fr/public

        # Optimisation du proxy WebSocket
        ProxyRequests Off
        SSLProxyEngine On

        ProxyPass "/chat1" "ws://localhost:8443/"
        ProxyPassReverse "/chat1" "ws://localhost:8443/"

        ProxyPass "/chat2" "ws://localhost:8453/"
        ProxyPassReverse "/chat2" "ws://localhost:8453/"

        ProxyPass "/chat3" "ws://localhost:8463/"
        ProxyPassReverse "/chat3" "ws://localhost:8463/"


        # Configuration du répertoire
        <Directory "/var/www/vhosts/monsupersite.fr">
            Options -Indexes +FollowSymLinks +ExecCGI
            AllowOverride All
            Require all granted
        </Directory>

        # Configuration SSL
        SSLEngine on
        SSLCertificateFile      /etc/letsencrypt/live/monsupersite.fr/cert.pem
        SSLCertificateKeyFile   /etc/letsencrypt/live/monsupersite.fr/privkey.pem
        SSLCertificateChainFile   /etc/letsencrypt/live/monsupersite.fr/chain.pem


        # SSL : désactiver les protocoles obsolètes et sécuriser les suites de chiffrement
        SSLProtocol all -SSLv2 -SSLv3 -TLSv1 -TLSv1.1
        SSLCipherSuite HIGH:!aNULL:!MD5:!3DES
        SSLHonorCipherOrder on
        SSLCompression off
        SSLOptions +StrictRequire

        ErrorLog ${APACHE_LOG_DIR}/error.log
        CustomLog ${APACHE_LOG_DIR}/access.log combined

    </VirtualHost>
</IfModule>

<?php 
require dirname( __FILE__ ) . '/vendor/autoload.php';
use Ratchet\Server\IoServer; 
use Ratchet\Http\HttpServer;
use Ratchet\WebSocket\WsServer;
use Ratchet\MessageComponentInterface;
use Ratchet\ConnectionInterface;

class MySocket implements MessageComponentInterface {
    protected $sockets;

    public function __construct() {
        $this->sockets = new \SplObjectStorage;
        date_default_timezone_set('Europe/Paris');
    }

    public function onOpen(ConnectionInterface $conn) {
        $this->sockets->attach($conn);
        error_log("Connection opened: {$conn->resourceId}");
    }

    public function onMessage(ConnectionInterface $conn, $msg) {
        $decodedMsg = json_decode($msg, true);
        if ($decodedMsg === null) {
            error_log("Invalid JSON message received from {$conn->resourceId}");
            return;
        }
        
        foreach ($this->sockets as $client) {
            if ($client !== $conn) { // Eviter d'envoyer le message à l'expéditeur
                $client->send(json_encode($decodedMsg));
            }
        }
        error_log("Message from {$conn->resourceId}: " . json_encode($decodedMsg));
    }

    public function onClose(ConnectionInterface $conn) {
        $this->sockets->detach($conn);
        error_log("Connection closed: {$conn->resourceId}");
        }

    public function onError(ConnectionInterface $conn, \Exception $e) {
        error_log("An error occurred with connection {$conn->resourceId}: {$e->getMessage()}");
        $conn->close();        
    }

    public static function startServer() {
        error_log("Starting WebSocket server...");
        $server = IoServer::factory(
            new HttpServer(
                new WsServer(
                    new MySocket()
                )
            ),
            8443
        );
        $server->run();
    }
}
MySocket::startServer();  

const MySocket=(function(){
  "use strict";
  let socket=null;
  let msg={
    header:{
      host:window.location.host,
      pathname:window.location.pathname,
      user:'nomuser'
      },      
    chat:{
      channel :"all",
      message :null
    }
  };
  const init=()=>{ 
    try {
      socket=new WebSocket(`wss://monsupersite.fr/chat1?token=${conf.session.compte}`);
      if (socket) {
        socket.onopen=(e)=>{
            msg.object='onopen';
            socket.send(JSON.stringify(msg));
            socket.onmessage=(e)=>{
              const result=JSON.parse(e.data);
              console.log(result)
          }
        };
      }
      socket.addEventListener("error", (event) => {
        event.preventDefault();
      });
    } catch (error) {

    }
  }
  const sendChat=(message)=>{ 
    msg.chat.message=message;
    socket.send(JSON.stringify(msg));
  }

  return {
    init:init,
  };
})();

document.addEventListener('DOMContentLoaded', ()=>MySocket.init());