126 lines
3.9 KiB
JavaScript
Executable File
126 lines
3.9 KiB
JavaScript
Executable File
#!/usr/bin/env node
|
|
|
|
var fs = require("fs"),
|
|
path = require("path"),
|
|
readline = require("readline"),
|
|
commander = require("commander"),
|
|
topojson = require("../");
|
|
|
|
commander
|
|
.version(require("../package.json").version)
|
|
.usage("[options] <[name=]file>…")
|
|
.description("Converts GeoJSON features to TopoJSON objects.")
|
|
.option("-o, --out <file>", "output file name; defaults to “-” for stdout", "-")
|
|
.option("-n, --newline-delimited", "accept newline-delimited JSON")
|
|
.option("-q, --quantization <count>", "pre-quantization parameter; 0 disables quantization", 0)
|
|
.parse(process.argv);
|
|
|
|
if (commander.args.length < 1) commander.args[0] = "-";
|
|
|
|
var nullType = {},
|
|
nullObject = {type: nullType},
|
|
objects = {},
|
|
out = (commander.out === "-" ? process.stdout : fs.createWriteStream(commander.out)).on("error", handleEpipe);
|
|
|
|
Promise.all(commander.args.map(read)).then(write).catch(abort);
|
|
|
|
function read(specifier) {
|
|
var i = specifier.indexOf("="),
|
|
file = i >= 0 ? specifier.slice(i + 1) : specifier,
|
|
name = i >= 0 ? specifier.slice(0, i) : path.basename(specifier, path.extname(specifier));
|
|
if (name in objects) {
|
|
console.error();
|
|
console.error(" error: object “" + name + "” is not unique");
|
|
console.error();
|
|
process.exit(1);
|
|
}
|
|
objects[name] = undefined;
|
|
return (commander.newlineDelimited ? readNewlineDelimitedObject : readObject)(file === "-"
|
|
? process.stdin : fs.createReadStream(file))
|
|
.then(function(object) { objects[name] = object; });
|
|
}
|
|
|
|
function readNewlineDelimitedObject(stream) {
|
|
return new Promise(function(resolve, reject) {
|
|
var collection;
|
|
readline.createInterface({
|
|
input: stream,
|
|
output: null
|
|
}).on("line", function(line) {
|
|
var object = JSON.parse(line);
|
|
if (object == null) object = nullObject;
|
|
switch (object.type) {
|
|
case "Feature": {
|
|
if (collection) {
|
|
if (collection.type !== "FeatureCollection") {
|
|
console.error();
|
|
console.error(" error: expected geometry, not Feature");
|
|
console.error();
|
|
process.exit(1);
|
|
}
|
|
collection.features.push(object);
|
|
} else {
|
|
collection = {type: "FeatureCollection", features: [object]};
|
|
}
|
|
break;
|
|
}
|
|
case nullType:
|
|
case "GeometryCollection":
|
|
case "MultiLineString":
|
|
case "LineString":
|
|
case "Polygon":
|
|
case "MultiPolygon":
|
|
case "Point":
|
|
case "MultiPoint": {
|
|
if (collection) {
|
|
if (collection.type !== "GeometryCollection") {
|
|
console.error();
|
|
console.error(" error: expected Feature, not " + object.type);
|
|
console.error();
|
|
process.exit(1);
|
|
}
|
|
collection.geometries.push(object);
|
|
} else {
|
|
collection = {type: "GeometryCollection", geometries: [object]};
|
|
}
|
|
break;
|
|
}
|
|
default: {
|
|
console.error();
|
|
console.error(" error: expected Feature or geometry, not " + object.type);
|
|
console.error();
|
|
process.exit(1);
|
|
break;
|
|
}
|
|
}
|
|
}).on("close", function() {
|
|
resolve(collection || {type: "FeatureCollection", features: []});
|
|
}).on("error", reject);
|
|
});
|
|
}
|
|
|
|
function readObject(stream) {
|
|
return new Promise(function(resolve, reject) {
|
|
var data = [];
|
|
stream
|
|
.on("data", function(d) { data.push(d); })
|
|
.on("end", function() { resolve(JSON.parse(Buffer.concat(data))); })
|
|
.on("error", reject);
|
|
});
|
|
}
|
|
|
|
function write() {
|
|
out.write(JSON.stringify(topojson.topology(objects, +commander.quantization)));
|
|
out[out === process.stdout ? "write" : "end"]("\n");
|
|
}
|
|
|
|
function handleEpipe(error) {
|
|
if (error.code === "EPIPE" || error.errno === "EPIPE") {
|
|
process.exit(0);
|
|
}
|
|
}
|
|
|
|
function abort(error) {
|
|
console.error(error.stack);
|
|
}
|