fix: when set DND, state must be BUSY (#17)

Author: edospadoni

lib/plugins_command_13/setState.js

@@ -0,0 +1,149 @@
+/**
+ * @submodule plugins_command_13
+ */
+var action = require('../action');
+
+/**
+ * The module identifier used by the logger.
+ *
+ * @property IDLOG
+ * @type string
+ * @private
+ * @final
+ * @readOnly
+ * @default [setState]
+ */
+var IDLOG = '[setState]';
+
+(function() {
+
+  /**
+   * The logger. It must have at least three methods: _info, warn and error._
+   *
+   * @property logger
+   * @type object
+   * @private
+   * @default console
+   */
+  var logger = console;
+
+  try {
+    /**
+     * Map associations between ActionID and callback to execute at the end
+     * of the command.
+     *
+     * @property map
+     * @type {object}
+     * @private
+     */
+    var map = {};
+
+    /**
+     * Command plugin to set the presence state of an extension. 
+     *
+     * Use it with _astproxy_ module as follow:
+     *
+     *     ast_proxy.doCmd({ command: 'setState', exten: '214', state: 'BUSY' }, function (res) {
+     *         // some code
+     *     });
+     *
+     *
+     * @class setState
+     * @static
+     */
+    var setState = {
+
+      /**
+       * Execute asterisk action to set the presence state.
+       *
+       * @method execute
+       * @param {object} am Asterisk manager used to send the action
+       * @param {object} args The object containing optional parameters
+       * @param {function} cb The callback function
+       * @static
+       */
+      execute: function(am, args, cb) {
+        try {
+            var act;
+            // action for asterisk
+            act = {
+              Action: 'Command',
+              Command: 'devstate change Custom:DND' + args.exten + ' ' + args.state
+            };
+
+          // set the action identifier
+          act.ActionID = action.getActionId('setState');
+
+          // add association ActionID-callback
+          map[act.ActionID] = cb;
+
+          // send action to asterisk
+          am.send(act);
+
+        } catch (err) {
+          logger.error(IDLOG, err.stack);
+        }
+      },
+
+      /**
+       * It's called from _astproxy_ component for each data received
+       * from asterisk and relative to this command.
+       *
+       * @method data
+       * @param {object} data The asterisk data for the current command
+       * @static
+       */
+      data: function(data) {
+        try {
+          // check callback
+          if (map[data.actionid]) {
+            map[data.actionid](null);
+            delete map[data.actionid]; // remove association ActionID-callback
+          } else {
+            map[data.actionid](new Error('error'));
+            delete map[data.actionid]; // remove association ActionID-callback
+          }
+
+        } catch (err) {
+          logger.error(IDLOG, err.stack);
+          if (map[data.actionid]) {
+            map[data.actionid](err);
+            delete map[data.actionid];
+          }
+        }
+      },
+
+      /**
+       * Set the logger to be used.
+       *
+       * @method setLogger
+       * @param {object} log The logger object. It must have at least
+       * three methods: _info, warn and error_
+       * @static
+       */
+      setLogger: function(log) {
+        try {
+          if (typeof log === 'object' &&
+            typeof log.info === 'function' &&
+            typeof log.warn === 'function' &&
+            typeof log.error === 'function') {
+
+            logger = log;
+          } else {
+            throw new Error('wrong logger object');
+          }
+        } catch (err) {
+          logger.error(IDLOG, err.stack);
+        }
+      }
+    };
+
+    // public interface
+    exports.data = setState.data;
+    exports.execute = setState.execute;
+    exports.setLogger = setState.setLogger;
+
+  } catch (err) {
+    logger.error(IDLOG, err.stack);
+  }
+})();

lib/proxy_logic_13/proxy_logic_13.js

@@ -9937,7 +9937,41 @@ function setAsteriskPresence(extension, presenceState, cb) {
       exten: extension,
       state: presenceState
     }, function (error) {
-      cb(error);
+      if (error) {
+        logger.error(IDLOG, 'setPresenceState to "'+ presenceState +'" for "' + extension + ' failed');
+        cb(error);
+      }
+
+      // if presence is DND, set also state to BUSY
+      if(presenceState === 'DND') {
+        astProxy.doCmd({
+          command: 'setState',
+          exten: extension,
+          state: 'BUSY'
+        }, function (error) {
+          if (error) {
+            logger.error(IDLOG, 'setState to "BUSY" for "' + extension + ' failed');
+            cb(error);
+          }
+        });
+      }
+
+      // if presence is AVAILABLE, set also state to NOT_INUSE
+      if(presenceState === 'AVAILABLE') {
+        astProxy.doCmd({
+          command: 'setState',
+          exten: extension,
+          state: 'NOT_INUSE'
+        }, function (error) {
+          if (error) {
+            logger.error(IDLOG, 'setState to "NOT_INUSE" for "' + extension + ' failed');
+            cb(error);
+          }
+        });
+      }
+
+      // return callback
+      cb();
     });
   } catch (e) {
     logger.error(IDLOG, e.stack);