adding unix pipe capability.

Ex $ cat example-osm/way.osm | ./mongosm -update
sammerry · Jul 21, 2013 · ae0bf7b · ae0bf7b
1 parent b23c7c1
commit ae0bf7b
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 3 deletions.
diff --git a/lib/mongosm.js b/lib/mongosm.js
@@ -95,8 +95,15 @@ mongoose.connection.on('open', function () {
 
   saxStream.on("opentag", parse);
   saxStream.on("closetag", closetag);
-  fs.createReadStream(options.filename)
-    .pipe(saxStream);
+
+  if (options.filename) {
+    fs.createReadStream(options.filename)
+      .pipe(saxStream);
+  } else {
+    process.stdin.resume();
+    process.stdin.setEncoding('utf8');
+    process.stdin.pipe(saxStream);
+  }
 
   saxStream.on("end", function() {
     eof = true;

diff --git a/lib/options.js b/lib/options.js
@@ -3,7 +3,7 @@ module.exports = {
     uri: ""
   },
   verbose: false,
-  filename: "example-osm/way.osm",
+  //filename: "example-osm/way.osm",
   host: "localhost",
   port: "27017",
   database: "test",