Added debug logging

Author: jscottsf

dist/LDMPClient.js

@@ -16,6 +16,8 @@ var _parsers = require('./parsers');
 
 function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
 
+// import {FrameParser} from './parsers'
+
 const ACK = Buffer.from('\r');
 
 const DEFAULT_PORT = 1024;
@@ -70,17 +72,34 @@ class LDMPClient extends _events.EventEmitter {
       const sock = this.socket = new _net2.default.Socket();
 
       sock.once('connect', () => {
+        console.log('LDMPClient connect!');
+
         sock.removeAllListeners();
+
+        sock.pipe(new _parsers.FrameParser({
+          matchChar: Buffer.from('\0'),
+          matchEncoding: 'ascii'
+        })).pipe(new _parsers.XMLRecordParser()).on('data', data => {
+          this.emit('record', data);
+        });
+
+        // sock.pipe(new FrameParser({
+        //   matchChar: Buffer.from('\0'),
+        //   matchEncoding: 'ascii'
+        // })).on('data', data => {
+        //   this.emit('record', data.frame.toString())
+        // })
+
         resolve(sock);
       });
       sock.once('error', reject);
 
-      sock.pipe(new _parsers.FrameParser({
-        matchChar: Buffer.from('\0'),
-        matchEncoding: 'ascii'
-      })).pipe(new _parsers.XMLRecordParser()).on('data', data => {
-        this.emit('record', data);
-      });
+      // sock.pipe(new FrameParser({
+      //   matchChar: Buffer.from('\0'),
+      //   matchEncoding: 'ascii'
+      // })).pipe(new XMLRecordParser()).on('data', data => {
+      //   this.emit('record', data)
+      // })
 
       sock.connect(this.options.port, this.options.host);
     });
@@ -106,11 +125,20 @@ class LDMPClient extends _events.EventEmitter {
    */
   ack() {
     return new Promise((resolve, reject) => {
+      if (!this.isConnected) console.log('LDMPClient ack not connected');
       if (!this.isConnected) return reject(new Error('Not connected'));
 
-      this.socket.write(ACK);
+      try {
+        this.socket.write(ACK);
+
+        console.log('LDMPClient ack sent');
 
-      resolve();
+        resolve();
+      } catch (err) {
+        console.log('LDMPClient ack error', err);
+
+        reject(err);
+      }
     });
   }
 
@@ -152,6 +180,8 @@ class LDMPClient extends _events.EventEmitter {
         tables
       });
 
+      console.log('LDMPClient specify', `${spec}`);
+
       this.socket.write(spec);
 
       resolve(spec.toString());

dist/parsers.js

@@ -27,6 +27,8 @@ class FrameParser extends _stream.Transform {
     let i;
     let s = 0;
 
+    // console.log('FrameParser._transform chunk', chunk)
+
     try {
       this._buf = this._buf ? Buffer.concat([this._buf, chunk], this._buf.length + chunk.length) : chunk;
 
@@ -69,6 +71,8 @@ class XMLRecordParser extends _stream.Transform {
     const errors = [];
     const obj = {};
 
+    // console.log('XMLRecordParser._transform chunk', chunk)
+
     try {
       const xmlDoc = new _xmldom.DOMParser({
         errorHandler: {

src/LDMPClient.js

@@ -2,6 +2,7 @@ import net from 'net'
 import {EventEmitter} from 'events'
 import {ClientSpecFormatter} from './formatters'
 import {FrameParser, XMLRecordParser} from './parsers'
+// import {FrameParser} from './parsers'
 
 const ACK = Buffer.from('\r')
 
@@ -57,17 +58,34 @@ export default class LDMPClient extends EventEmitter {
       const sock = this.socket = new net.Socket()
 
       sock.once('connect', () => {
+        console.log('LDMPClient connect!')
+
         sock.removeAllListeners()
+
+        sock.pipe(new FrameParser({
+          matchChar: Buffer.from('\0'),
+          matchEncoding: 'ascii'
+        })).pipe(new XMLRecordParser()).on('data', data => {
+          this.emit('record', data)
+        })
+
+        // sock.pipe(new FrameParser({
+        //   matchChar: Buffer.from('\0'),
+        //   matchEncoding: 'ascii'
+        // })).on('data', data => {
+        //   this.emit('record', data.frame.toString())
+        // })
+
         resolve(sock)
       })
       sock.once('error', reject)
 
-      sock.pipe(new FrameParser({
-        matchChar: Buffer.from('\0'),
-        matchEncoding: 'ascii'
-      })).pipe(new XMLRecordParser()).on('data', data => {
-        this.emit('record', data)
-      })
+      // sock.pipe(new FrameParser({
+      //   matchChar: Buffer.from('\0'),
+      //   matchEncoding: 'ascii'
+      // })).pipe(new XMLRecordParser()).on('data', data => {
+      //   this.emit('record', data)
+      // })
 
       sock.connect(this.options.port, this.options.host)
     })
@@ -96,11 +114,20 @@ export default class LDMPClient extends EventEmitter {
    */
   ack () {
     return new Promise((resolve, reject) => {
+      if (!this.isConnected) console.log('LDMPClient ack not connected')
       if (!this.isConnected) return reject(new Error('Not connected'))
 
-      this.socket.write(ACK)
+      try {
+        this.socket.write(ACK)
+
+        console.log('LDMPClient ack sent')
 
-      resolve()
+        resolve()
+      } catch (err) {
+        console.log('LDMPClient ack error', err)
+
+        reject(err)
+      }
     })
   }
 
@@ -145,6 +172,8 @@ export default class LDMPClient extends EventEmitter {
         tables
       })
 
+      console.log('LDMPClient specify', `${spec}`)
+
       this.socket.write(spec)
 
       resolve(spec.toString())

src/parsers.js

@@ -19,6 +19,8 @@ export class FrameParser extends Transform {
     let i
     let s = 0
 
+    // console.log('FrameParser._transform chunk', chunk)
+
     try {
       this._buf = this._buf ? Buffer.concat([this._buf, chunk], this._buf.length + chunk.length) : chunk
 
@@ -61,6 +63,8 @@ export class XMLRecordParser extends Transform {
     const errors = []
     const obj = {}
 
+    // console.log('XMLRecordParser._transform chunk', chunk)
+
     try {
       const xmlDoc = new DOMParser({
         errorHandler: {

test/01/long-run.spec.js

@@ -2,7 +2,7 @@
  * Main tests
  */
 
-describe('Module', function () {
+describe.skip('Module', function () {
   this.timeout(60000)
 
   const tables = [{