Create CSV reader scaffolding

src/csv/decoder.ts

@@ -0,0 +1,12 @@
+import { decode } from "windows-1250";
+import { Transform } from 'stream';
+
+export default new Transform({
+  transform(chunk, encoding, callback) {    
+    try {
+      callback(null, decode(chunk));
+    } catch(error: any) {
+      callback(error);
+    }
+  },
+});

src/csv/index.ts

@@ -0,0 +1 @@
+export { default  as openCsv } from "./pipeline";

src/csv/pipeline.ts

@@ -0,0 +1,9 @@
+import Papa from "papaparse";
+import fs from "fs";
+import decoder from "./decoder";
+
+export default function(file: string, config?: Papa.ParseConfig) {
+  return fs.createReadStream(file)
+    .pipe(decoder)
+    .pipe(Papa.parse(Papa.NODE_STREAM_INPUT, config))
+}