Add reregisterForMessages method and fix deleting from verbs once unr…

…egistered
drachtio · May 16, 2024 · f3e1945 · f3e1945
1 parent d8ce54a
commit f3e1945
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 15 deletions.
diff --git a/lib/drachtio-agent.js b/lib/drachtio-agent.js
@@ -470,25 +470,12 @@ class DrachtioAgent extends Emitter {
 
     this.mapServer.forEach((obj, socket) => {
       if (obj.authenticated) {
-        this.unrouteVerbs(socket) ;
+        this.wp.send(socket, 'remove_route|' + verb) ;
+        this.verbs.delete(verb) ;
       }
     });
   }
 
-  unrouteVerbs(socket) {
-    this.verbs.forEach((obj, verb) => {
-      if (obj.sent === false) {
-        return ;
-      }
-
-      obj = {
-        sent: false,
-        acknowledged: false,
-        rid: this.wp.send(socket, 'remove_route|' + verb)
-      } ;
-    });
-  }
-
   disconnect(socket) {
     const sock = socket || this._getDefaultSocket();
     debugSocket(`disconnect: removing socket ${sockPort(sock)}`);

diff --git a/lib/srf.js b/lib/srf.js
@@ -1229,6 +1229,10 @@ class Srf extends Emitter {
     this._app.client.removeRoute(sipVerb) ;
   }
 
+  reregisterForMessages(sipVerb) {
+    this._app.client.route(sipVerb) ;
+  }
+
   _b2bRequestWithinDialog(dlg, req, res, proxyRequestHeaders, proxyResponseHeaders, callback) {
     callback = callback || noop ;
     let headers = {} ;