wip

Author: xquanluu

lib/regbot.js

@@ -50,9 +50,8 @@ class Regbot {
     this.register(srf);
   }
 
-  stop() {
+  stop(srf) {
     const { deleteEphemeralGateway } = srf.locals.realtimeDbHelpers;
-    this.logger.info(`stopping regbot ${this.fromUser}@${this.sip_realm}`);
     clearTimeout(this.timer);
     this.timer = null;
     // remove any ephemeral gateways created for this regbot
@@ -147,7 +146,7 @@ class Regbot {
           if (REGISTER_RESPONSE_REMOVE.includes(res.status)) {
             const { updateCarrierBySid, lookupCarrierBySid } = srf.locals.dbHelpers;
             await updateCarrierBySid(this.voip_carrier_sid, {requires_register: false});
-            this.stop(); //Remove the retry timer
+            this.stop(srf); //Remove the retry timer
             const carrier = await lookupCarrierBySid(this.voip_carrier_sid);
             if (carrier) {
               // eslint-disable-next-line max-len

lib/sip-trunk-register.js

@@ -154,12 +154,12 @@ const checkStatus = async(logger, srf) => {
       }
       else if (token && token !== myToken) {
         logger.info('Someone else grabbed the role!  I need to stand down');
-        regbots.forEach((rb) => rb.stop());
+        regbots.forEach((rb) => rb.stop(srf));
         regbots.length = 0;
       }
       else {
         grabForTheWheel = true;
-        regbots.forEach((rb) => rb.stop());
+        regbots.forEach((rb) => rb.stop(srf));
         regbots.length = 0;
       }
     }
@@ -230,7 +230,7 @@ const updateCarrierRegbots = async(logger, srf) => {
       Array.prototype.push.apply(gateways, gws);
 
       // stop / kill existing regbots
-      regbots.forEach((rb) => rb.stop());
+      regbots.forEach((rb) => rb.stop(srf));
       regbots.length = 0;
 
       // start new regbots