major refactor and improvements

1 files changed, 68 insertions, 0 deletions

diff --git a/bin/vicmap2osm.js b/bin/vicmap2osm.js
new file mode 100755
index 0000000..b252f24
--- /dev/null
+++ b/bin/vicmap2osm.js
@@ -0,0 +1,68 @@
+#!/usr/bin/env node
+
+const fs = require('fs')
+const { Transform, pipeline } = require('readable-stream')
+const ndjson = require('ndjson')
+const toOSM = require('./toOSM.js')
+const filterOSM = require('./filterOSM.js')
+
+const argv = require('yargs/yargs')(process.argv.slice(2))
+  .option('debug', {
+    type: 'boolean',
+    description: 'Dumps full debug logs'
+  })
+  .option('tracing', {
+    type: 'boolean',
+    description: 'Includes _pfi tags to aid debugging'
+  })
+  .argv
+
+if (argv._.length < 2) {
+  console.error("Usage: ./vicmap2osm.js input.geojson output.geojson")
+  process.exit(1)
+}
+
+const inputFile = argv._[0]
+const outputFile = argv._[1]
+
+if (!fs.existsSync(inputFile)) {
+  console.error(`${inputFile} not found`)
+  process.exit(1)
+}
+
+const transform = new Transform({
+  readableObjectMode: true,
+  writableObjectMode: true,
+  transform(feature, encoding, callback) {
+    // convert source Feature into a Feature per the OSM schema
+    const osm = toOSM(feature, {
+      tracing: argv.tracing
+    })
+
+    // some addresses we skip importing into OSM, see README.md#omitted-addresses
+    if (filterOSM(osm, {
+      debug: argv.debug
+    })) {
+      this.push(osm)
+    }
+
+    callback()
+  }
+})
+
+// stream in source ndjson, transfom and stream out
+pipeline(
+  fs.createReadStream(inputFile),
+  ndjson.parse(),
+  transform,
+  ndjson.stringify(),
+  fs.createWriteStream(outputFile),
+  (err) => {
+    if (err) {
+      console.log(err)
+      process.exit(1)
+    } else {
+      process.exit(0)
+    }
+  }
+)