diff --git a/lib/mongosm.js b/lib/mongosm.js index 4823a20..7d02d81 100644 --- 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 index dd44c6a..03a4229 100644 --- 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",