Modularized MLLP server to be used in DRE

Author: kachok

README.md

@@ -6,4 +6,18 @@
 
 * http://www.hl7standards.com/blog/2007/05/02/hl7-mlp-minimum-layer-protocol-defined/
 * http://www.hl7standards.com/blog/2007/02/01/ack-message-original-mode-acknowledgement/
-    
+    
+
+== Usage ==
+
+see example.js
+
+```javascript
+var mllp=require('./index.js');
+
+var server = new mllp.MLLPServer();
+
+server.on('hl7', function(data){
+	console.log("just an example", data);
+});
+```

example.js

@@ -0,0 +1,7 @@
+var mllp=require('./index.js');
+
+var server = new mllp.MLLPServer();
+
+server.on('hl7', function(data){
+	console.log("just an example", data);
+});

index.js

@@ -1,61 +1,78 @@
 var net = require('net');
 var hl7 = require('../hl7/index.js');
-
-var HOST = '127.0.0.1';
-var PORT = 6969;
-
+var util = require('util');
+var EventEmitter = require('events').EventEmitter;
 
 //The header is a vertical tab character <VT> its hex value is 0x0b.
 //The trailer is a field separator character <FS> (hex 0x1c) immediately followed by a carriage return <CR> (hex 0x0d)
 
-var VT=String.fromCharCode(0x0b);
-var FS=String.fromCharCode(0x1c);
-var CR=String.fromCharCode(0x0d);
+var VT = String.fromCharCode(0x0b);
+var FS = String.fromCharCode(0x1c);
+var CR = String.fromCharCode(0x0d);
 
 
-function ackn(data, ack_type){
-    //get message ID
-    var msg_id = data[0][10];
 
-    var header = [data[0]];
-    
-    //switch around sender/receiver names
-    header[0][3]=data[0][5];
-    header[0][4]=data[0][6];
-    header[0][5]=data[0][3];
-    header[0][6]=data[0][4];
 
-    var result=hl7.serializeJSON(header);
-    result=result+"\r"+"MSA|"+ack_type+"|"+msg_id;
-    
-    return result;
-}
+function MLLPServer(host, port) {
 
-net.createServer(function(sock) {
-    
-    console.log('CONNECTED: ' + sock.remoteAddress +':'+ sock.remotePort);
-    
-    sock.on('data', function(data) {
-        data=data.toString();
-        //strip separators
-        data=data.substring(1,data.length-3);
-        var data2=hl7.parseString(data);
-
-        var ack = ackn(data2, "AA");
-
-        console.log("DATA:\nfrom "  + sock.remoteAddress + ':\n' + data.split("\r").join("\n"));
-        console.log();
-
-        sock.write(VT+ack+FS+CR);
-        console.log("ACK:\n"+ ack.split("\r").join("\n"));
-        console.log();
-        
-    });
+    var self = this;
+
+    var HOST = host || '127.0.0.1';
+    var PORT = port || 6969;
+
+    var Server = net.createServer(function(sock) {
+
+        console.log('CONNECTED: ' + sock.remoteAddress + ':' + sock.remotePort);
+
+
+        function ackn(data, ack_type) {
+            //get message ID
+            var msg_id = data[0][10];
+
+            var header = [data[0]];
+
+            //switch around sender/receiver names
+            header[0][3] = data[0][5];
+            header[0][4] = data[0][6];
+            header[0][5] = data[0][3];
+            header[0][6] = data[0][4];
+
+            var result = hl7.serializeJSON(header);
+            result = result + "\r" + "MSA|" + ack_type + "|" + msg_id;
+
+            return result;
+        }
+
+        sock.on('data', function(data) {
+            data = data.toString();
+            //strip separators
+            data = data.substring(1, data.length - 3);
+            var data2 = hl7.parseString(data);
+
+            self.emit('hl7', data2);
+
+            var ack = ackn(data2, "AA");
+
+            console.log("DATA:\nfrom " + sock.remoteAddress + ':\n' + data.split("\r").join("\n"));
+            console.log();
+
+            sock.write(VT + ack + FS + CR);
+            console.log("ACK:\n" + ack.split("\r").join("\n"));
+            console.log();
+
+        });
+
+        sock.on('close', function(data) {
+            console.log('CLOSED: ' + sock.remoteAddress + ' ' + sock.remotePort);
+        });
 
-    sock.on('close', function(data) {
-        console.log('CLOSED: ' + sock.remoteAddress +' '+ sock.remotePort);
     });
-    
-}).listen(PORT, HOST);
 
-console.log('Server listening on ' + HOST +':'+ PORT);
+
+    Server.listen(PORT, HOST);
+
+}
+
+util.inherits(MLLPServer, EventEmitter);
+
+exports.MLLPServer = MLLPServer;

package.json

@@ -1,6 +1,6 @@
 {
-  "name": "mllp",
-  "version": "0.0.0",
+  "name": "mllp-node",
+  "version": "0.0.1",
   "description": "MLLP (HL7) implementation in Node.js",
   "main": "index.js",
   "scripts": {