From 830e4cd9fc6be74540d85ea82505f604130d2a54 Mon Sep 17 00:00:00 2001 From: lazedo Date: Tue, 21 Jul 2020 18:04:39 +0000 Subject: [PATCH] add extension points for websockets role --- kamailio/websockets-role.cfg | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/kamailio/websockets-role.cfg b/kamailio/websockets-role.cfg index 0b98ba3..4555878 100644 --- a/kamailio/websockets-role.cfg +++ b/kamailio/websockets-role.cfg @@ -118,6 +118,8 @@ event_route[xhttp:request] exit; } + route_if_exists("WS_ON_BEFORE_HANSHAKE"); + if (ws_handle_handshake()) { $var(count) = $shtinc(websockets=>$var(ws_orig_ip)::count); $sht(websockets=>$ws_conid::ws_orig_ip) = $var(ws_orig_ip); @@ -127,6 +129,7 @@ event_route[xhttp:request] } else { xlog("L_INFO", "websocket|log|opened websocket $ws_conid from $var(ws_orig_ip):$sp\n"); } + route_if_exists("WS_ON_SUCCESSFULL_HANSHAKE"); exit; } @@ -138,7 +141,7 @@ event_route[websocket:closed] { $var(ws_orig_ip) = $sht(websockets=>$ws_conid::ws_orig_ip); $sht(websockets=>$ws_conid::ws_orig_ip) = $null; - + $var(count) = $shtdec(websockets=>$si::count); if($var(ws_orig_ip) != $null && $si != $var(ws_orig_ip)) { $var(countip) = $shtdec(websockets=>$var(ws_orig_ip)::count); @@ -148,4 +151,5 @@ event_route[websocket:closed] xlog("L_INFO", "websocket|log|closed websocket $ws_conid from $var(ws_orig_ip):$sp\n"); } if ($var(count) < 1) $sht(websockets=>$si::count) = $null; + route_if_exists("WS_ON_CLOSE"); }