parseStream and parseFile yield different results. about node-sqlite3 HOT 3 CLOSED

//Function for handling xml characters
function xmlValue(nodeName, chars) {
    if (chars.replace(/(^\s+|\s+$)/g, '') !== '') {
        sessionInfo[dir + nodeName] = chars.replace(/(^\s+|\s+$)/g, '');
    }
}

xmlNode.onStartDocument(function () {
    db.run("CREATE TABLE sessions(  session_id int primary key, \
                                    policy text, \
                                    srcAddr text, \
                                    srcPort int, \
                                    srcPkts int, \
                                    srcBytes int, \
                                    srcInterface, \
                                    dstAddr text, \
                                    dstPort int, \
                                    dstPkts int, \
                                    dstBytes int, \
                                    dstInterface, \
                                    protocol)");
});

xmlNode.onStartElementNS(function (elem) {
    nodeName = elem;
});
xmlNode.onEndElementNS(function (elem) {
    if (elem === 'flow-session') {
        console.log(sessionInfo);
        db.run("INSERT into sessions values ($id, \
                                            $policy, \
                                            $srcAddr, \
                                            $srcPort, \
                                            $srcPkts, \
                                            $srcBytes, \
                                            $srcInterface, \
                                            $dstAddr, \
                                            $dstPort, \
                                            $dstPkts, \
                                            $dstBytes, \
                                            $dstInterface, \
                                            $protocol)",
                                            {$id:sessionInfo['session-identifier'],
                                            $policy:sessionInfo['policy'],
                                            $srcAddr:sessionInfo['in-source-address'],
                                            $srcPort:sessionInfo['in-source-port'],
                                            $srcPkts:sessionInfo['in-pkt-cnt'],
                                            $srcBytes:sessionInfo['in-byte-cnt'],
                                            $srcInterface:sessionInfo['in-interface-name'],
                                            $dstAddr:sessionInfo['out-source-address'],
                                            $dstPort:sessionInfo['out-source-port'],
                                            $dstPkts:sessionInfo['out-pkt-cnt'],
                                            $dstBytes:sessionInfo['out-byte-cnt'],
                                            $dstInterface:sessionInfo['out-interface-name'],
                                            $protocol:sessionInfo['in-protocol']});
        dir = '';
        sessionInfo = {};
    } else if (elem === 'displayed-session-count') {
        console.log(sessionInfo);
    }
});
xmlNode.onCharacters(function (chars) {
    if (nodeName === 'direction') {
        if (chars.match('In')) {
            dir = 'in-';
        } else if (chars.match('Out')) {
            dir = 'out-';
        }
    } else {
        xmlValue(nodeName, chars);
    }
});
xmlNode.onError(function (msg) {
    console.log('<ERROR>' + JSON.stringify(msg) + "</ERROR>");
});

netconf.stdout.on('data', function (data) {
    if (re.test(data)) {
        switch (count) {
            case 1:
                count ++;
                netconf.stdin.write(rpcSession);
                break;
            case 2:
                count ++;
                netconf.stdin.write(rpcClose);
                break;
        }
    }

    if (rpcReply.test(data)) {
        log = true;
    }

    if (count === 2 && log) {
        if (stream) {
            stream.write(data);
        } else {
            parser.parseString(data);
        }
    }
});

netconf.stderr.on('data', function (data) {
    console.log('stderr: ' + data);
});

netconf.on('exit', function (code) {
    console.log('netconf exited with code ' + code);
    if (stream) {
        stream.end();
        console.log("stream closed");
        parser.parseFile(process.argv[3] + '.xml');
    }
});