flat-file-parser
Advanced tools
Comparing version 0.5.0 to 0.6.0
@@ -1,1 +0,1 @@ | ||
"use strict";const fs=require("fs"),readline=require("readline"),{once}=require("events"),{LineParser}=require("./lineParser"),{sanityInt}=require("./helper"),FlatFileParser=function(){let e={},r=null,t=!1,n=!1,l=0,s=0,o=[];const _ensureOpened=()=>{if(!t||null==r)throw"No file has been opened for parsing. Please use open() before using it"};e.open=n=>(r=fs.createReadStream(n),t=!0,e);const _next=(r,t,i,a=!1)=>(_ensureOpened(),n?o.splice(++s+l,0,LineParser(r,t,i,a)):o.push(LineParser(r,t,i,a)),e);return e.next=(e,r,t)=>_next(e,r,t),e.loop=(e,r)=>_next((()=>null),r,e,!0),e.skip=(e,r)=>{if(sanityInt(e)<=0)throw"Must set the noOfLines to skip. It should be a positive integer";return _next((e=>e),e,r)},e.process=async()=>{_ensureOpened(),n=!0;try{let t=0;const n=readline.createInterface({input:r}),_processLine=r=>{if(o.length>l){const n=o[l];let i={data:null,completed:!1};const a=n.isLoop();a||(i=n.process(r,e,l,t));n.callback(i.data,r,e,l,t);if(a){let r=n.loopCount();1!=r&&e.loop(n.reLoop(),r-1),i.completed=!0}i.completed&&(s=0,l++),a&&_processLine(r)}else n.close()};n.on("line",(e=>{_processLine(e),t++})).on("close",(()=>{e.done(),n.removeAllListeners()})),await once(n,"close")}catch(e){console.error(e)}return e},e.done=()=>(null!=r&&r.destroy(),r=null,t=!1,o.splice(0),l=0,s=0,n=!1,e),e[Symbol.toStringTag]="FlatFileParser",e};module.exports={FlatFileParser,flatFileParser:FlatFileParser()}; | ||
"use strict";const fs=require("fs"),readline=require("readline"),{once}=require("events"),{LineParser}=require("./lineParser"),{sanityInt}=require("./helper"),FlatFileParser=function(){let e={},r=null,t=!1,l=!1,n=0,s=0,o=[];const _ensureOpened=()=>{if(!t||null==r)throw"No file has been opened for parsing. Please use open() before using it"};e.open=l=>(r=fs.createReadStream(l),t=!0,e);const _next=(r,t,i,a=!1)=>(_ensureOpened(),l?o.splice(++s+n,0,LineParser(r,t,i,a)):o.push(LineParser(r,t,i,a)),e);return e.next=(e,r,t)=>_next(e,r,t),e.loop=(e,r)=>_next((()=>null),r,e,!0),e.skip=(e,r)=>{if(sanityInt(e)<=0)throw"Must set the noOfLines to skip. It should be a positive integer";return _next((e=>e),e,r)},e.process=async({signal:t})=>{_ensureOpened(),l=!0;try{let l=0;const i=readline.createInterface({input:r}),_processLine=r=>{if(o.length>n){const t=o[n];let i={data:null,completed:!1};const a=t.isLoop();a||(i=t.process(r,e,n,l));t.callback(i.data,r,e,n,l);if(a){let r=t.loopCount();1!=r&&e.loop(t.reLoop(),r-1),i.completed=!0}i.completed&&(s=0,n++),a&&_processLine(r)}else i.close()};i.on("line",(e=>{!0===(t?{}:t).aborted&&i.close(),_processLine(e),l++})).on("close",(()=>{e.done(),i.removeAllListeners()})),await once(i,"close")}catch(e){console.error(e)}return e},e.done=()=>(null!=r&&r.destroy(),r=null,t=!1,o.splice(0),n=0,s=0,l=!1,e),e[Symbol.toStringTag]="FlatFileParser",e};module.exports={FlatFileParser,flatFileParser:FlatFileParser()}; |
{ | ||
"name": "flat-file-parser", | ||
"version": "0.5.0", | ||
"version": "0.6.0", | ||
"description": "some Flat File Parser", | ||
"main": "index.js", | ||
"scripts": { | ||
"bdd-test": "cd tests && mocha ./**.spec.js --timeout 10000", | ||
"unit-test": "mocha ./lib/**.spec.js --timeout 10000", | ||
"build": "gulp preBuild", | ||
"bdd-test": "cd tests && mocha ./**/**.spec.js --timeout 10000", | ||
"unit-test": "cd lib && mocha ./**/**.spec.js --timeout 10000", | ||
"test": "npm run bdd-test" | ||
@@ -10,0 +11,0 @@ }, |
Empty package
Supply chain riskPackage does not contain any code. It may be removed, is name squatting, or the result of a faulty package publish.
Found 1 instance in 1 package
6054
11
74
0