added shp -> mongodb importer

.gitignore

@@ -1,3 +1,4 @@
 .DS_Store
 *.o
 /mongodb.input
+node_modules

README.md

@@ -25,17 +25,20 @@ In another terminal:
     cd db
     mongod --dbpath .
 
-3) Import a shapefile
+3) Prepare test environment
+
+    cd test/
+    npm install mongodb mapnik
+
+4) Import a shapefile
 
 In another terminal:
 
-    cd test/
-    python import.py
+    node import.js
 
-4) Run test.py
+5) Run test.js
 
-    cd test/
-    python test.py
+    node test.js
 
 
 # Trouble

test/import.js

@@ -0,0 +1,55 @@
+"use strict";
+
+var path = require("path"), fs = require("fs");
+var mapnik = require("mapnik"), mongodb = require("mongodb");
+
+var server = new mongodb.Server("localhost", 27017),
+    connector = new mongodb.Db("gis", server, { w: 1 });
+
+var nReady = 0;
+
+connector.open(function(err, db) {
+    if (err)
+        return console.log("mongodb connect error:", err.message);
+
+    [ "points", "linestrings", "polygons" ].forEach(function(name) {
+        db.collection(name, function(err, collection) {
+            if (err) {
+                connector.close();
+                return console.log("collection selecting error:", err.message);
+            }
+
+            collection.ensureIndex({ loc: "2dsphere" }, function(err) {
+                if (err) {
+                    connector.close();
+                    return console.log("collection selecting error:", err.message);
+                }
+
+                importShp(name, collection);
+            });
+        });
+    });
+});
+
+function importShp(name, collection) {
+    var dataSource = new mapnik.Datasource({
+            type: "shape",
+            file: path.join("shp", name)
+        }),
+        featureSet = dataSource.featureset(), feature;
+
+    (function next(feature) {
+        if (!feature) {
+            if (++nReady === 3) {
+                console.log("done...");
+                connector.close();
+            }
+
+            return;
+        }
+
+        var json = JSON.parse(feature.toJSON()), doc = json.properties;
+        doc.loc = json.geometry;
+        collection.insert(doc, function(err) { next(featureSet.next()); });
+    })(featureSet.next());
+}

test/shp/linestrings.prj

@@ -0,0 +1 @@
+GEOGCS["GCS_WGS_1984",DATUM["D_WGS_1984",SPHEROID["WGS_1984",6378137,298.257223563]],PRIMEM["Greenwich",0],UNIT["Degree",0.017453292519943295]]

test/shp/linestrings.qpj

@@ -0,0 +1 @@
+GEOGCS["WGS 84",DATUM["WGS_1984",SPHEROID["WGS 84",6378137,298.257223563,AUTHORITY["EPSG","7030"]],AUTHORITY["EPSG","6326"]],PRIMEM["Greenwich",0,AUTHORITY["EPSG","8901"]],UNIT["degree",0.0174532925199433,AUTHORITY["EPSG","9122"]],AUTHORITY["EPSG","4326"]]

test/shp/points.prj

@@ -0,0 +1 @@
+GEOGCS["GCS_WGS_1984",DATUM["D_WGS_1984",SPHEROID["WGS_1984",6378137,298.257223563]],PRIMEM["Greenwich",0],UNIT["Degree",0.017453292519943295]]

test/shp/points.qpj

@@ -0,0 +1 @@
+GEOGCS["WGS 84",DATUM["WGS_1984",SPHEROID["WGS 84",6378137,298.257223563,AUTHORITY["EPSG","7030"]],AUTHORITY["EPSG","6326"]],PRIMEM["Greenwich",0,AUTHORITY["EPSG","8901"]],UNIT["degree",0.0174532925199433,AUTHORITY["EPSG","9122"]],AUTHORITY["EPSG","4326"]]

test/shp/polygons.prj

@@ -0,0 +1 @@
+GEOGCS["GCS_WGS_1984",DATUM["D_WGS_1984",SPHEROID["WGS_1984",6378137,298.257223563]],PRIMEM["Greenwich",0],UNIT["Degree",0.017453292519943295]]

test/shp/polygons.qpj

@@ -0,0 +1 @@
+GEOGCS["WGS 84",DATUM["WGS_1984",SPHEROID["WGS 84",6378137,298.257223563,AUTHORITY["EPSG","7030"]],AUTHORITY["EPSG","6326"]],PRIMEM["Greenwich",0,AUTHORITY["EPSG","8901"]],UNIT["degree",0.0174532925199433,AUTHORITY["EPSG","9122"]],AUTHORITY["EPSG","4326"]]