First version of server

2015-02-08 19:35:51 +01:00
parent e529bb5f02
commit 915f7cbbec
2 changed files with 145 additions and 0 deletions
@@ -0,0 +1,110 @@
+/**
+ * Handle incomming SMPP traffic
+ *
+ * Error codes: http://www.activexperts.com/activsms/sms/smpperrorcodes/
+ */
+'use strict';
+
+var log   = require('winston'),
+    merge = require('utils-merge'),
+    smpp  = require('smpp');
+
+/**
+ * Set up SMPP server
+ *
+ * The option "checkUserAndPass" should be a function, taking three parameters: username, password and callback(err)
+ *
+ * @param obj options port, checkUserAndPass-function
+ */
+exports.server = function(options) {
+	options = merge({
+		'port': 2775,
+		'checkUserAndPass': false
+	}, options);
+
+	smpp.createServer(function(smppSession) {
+		var loggedIn = false;
+
+		log.debug('larvitsmpp: server() - server session started');
+
+		/**
+		 * Set logged in to true
+		 */
+		function login(pdu) {
+			loggedIn = true;
+
+			smppSession.send(pdu.response({
+				'command_status': smpp.ESME_ROK
+			}));
+
+			smppSession.resume();
+		}
+
+		/**
+		 * General bind function for bind_receiver, bind_transmitter and bind_transceiver
+		 *
+		 * @param obj pdu
+		 */
+		function bindGeneral(pdu) {
+			if (options.checkUserAndPass instanceof Function) {
+				// We pause the smppSession to prevent further incoming pdu events,
+				// Untill we authorize the smppSession with some async operation.
+				smppSession.pause();
+				log.debug('larvitsmpp: server() - Checking username and password');
+
+				options.checkUserAndPass(pdu.system_id, pdu.password, function(err) {
+					if (err) {
+						log.warn('larvitsmpp: server() - Wrong username or password. Username: "' + pdu.system_id + '"');
+
+						smppSession.send(pdu.response({
+							'command_status': smpp.ESME_RBINDFAIL
+						}));
+						smppSession.close();
+						loggedIn = false;
+						return;
+					}
+
+					log.debug('larvitsmpp: server() - Username and password is ok');
+					login(pdu);
+					smppSession.resume();
+				});
+			} else {
+				login(pdu);
+			}
+		}
+
+		smppSession.on('error', function() {
+			log.error('larvitsmpp: server() - smppSession error!', arguments);
+			console.log(arguments);
+		});
+
+		smppSession.on('pdu', function(pdu) {
+			log.debug('larvitsmpp: server() - Received command "' + pdu.command + '"');
+
+			if (pdu.command === 'bind_receiver' || pdu.command === 'bind_transmitter' || pdu.command === 'bind_transceiver') {
+				bindGeneral(pdu);
+			} else if (pdu.command !== 'enquire_link') {
+				if (loggedIn) {
+					log.error('larvitsmpp: server() - Unkown command!', pdu);
+
+					console.log('PDU!!!!');
+					console.log(arguments);
+				} else {
+					log.warn('larvitsmpp: server() - Not logged in but trying to send non-bind command');
+
+					smppSession.send(pdu.response({
+						'command_status': smpp.ESME_RSERTYPUNAUTH
+					}));
+				}
+			}
+		});
+
+		smppSession.on('enquire_link', function(pdu) {
+			log.silly('larvitsmpp: server() - Enquire_link - client heart beat.');
+
+			smppSession.send(pdu.response({
+				'command_status': smpp.ESME_ROK
+			}));
+		});
+	}).listen(options.port);
+};