export all last features

Author: dimik

remote-object-manager-server/README.md

@@ -1,3 +1,7 @@
-The OpenShift `nodejs` cartridge documentation can be found at:
+HOSTING DOCUMENTATION
 
 http://openshift.github.io/documentation/oo_cartridge_guide.html#nodejs
+
+TESTS
+
+https://github.com/dimik/ymaps/blob/master/remote-object-manager-server/test/express.spec.js

remote-object-manager-server/app-worker.js

@@ -8,9 +8,9 @@ var bodyParser = require('body-parser');
 var app = express();
 var api = require('./routes/api');
 
-app.use(bodyParser.json());
+app.use(bodyParser.json({ limit: 100000000 }));
 app.use(uncaughtExceptionHandler);
-app.use('/api', api);
+app.use('/api/v1', api);
 app.use(errorHandler);
 
 var host = config.get('server:hostname');
@@ -22,9 +22,8 @@ var server = app.listen(port, host, function () {
 // Expressjs middleware for handling errors.
 function errorHandler(err, req, res, next) {
   console.error('Express error', err);
-  res.status(500).json({
-    "error": err.message,
-    "stack": err.stack
+  res.status(400).json({
+    "error": err
   });
   // next(err);
 }
@@ -52,8 +51,7 @@ function uncaughtExceptionHandler(req, res, next) {
     // Try to send an error to the request that triggered the problem.
     try {
       res.status(500).json({
-        "error": err.message,
-        "stack": err.stack
+        "error": err
       });
     }
     catch (err) {

remote-object-manager-server/routes/api/features.js

@@ -0,0 +1,134 @@
+'use strict';
+
+var StorageFacade = require('../../lib/storage/facade');
+var storage = new StorageFacade();
+
+/**
+ * Find features.
+ */
+exports['get'] = function (req, res) {
+  storage.findFeatures()
+    .then(function (data) {
+      _send(res, {
+        "error": null,
+        "data": data.getData()
+      });
+    })
+    .fail(function (err) {
+      res.status(400);
+      _send(res, {
+        "error": err
+      });
+    });
+};
+
+/**
+ * Add feautures.
+ */
+exports['put'] = function (req, res) {
+  var inspector = require('schema-inspector');
+  var schema = require('../../schema/geojson.js');
+  var FeatureIds = require('../../lib/serializer/feature-ids');
+  var fIds = new FeatureIds();
+  var result = inspector.validate(schema['FeatureCollection'], req.body);
+
+  if(result.valid) {
+    storage.addFeatures(req.body.features)
+      .then(function (data) {
+        var ids = data.serialize(fIds).getData();
+
+        _send(res, {
+          "error": null,
+          "data": {
+            "total": ids.length,
+            "ids": ids
+          }
+        });
+      })
+      .fail(function (err) {
+        res.status(400);
+        _send(res, {
+          "error": err
+        });
+      });
+  }
+  else {
+    res.status(400);
+    _send(res, {
+      "error": new Error(result.format())
+    });
+  }
+};
+
+/**
+ * TODO
+ * Update features.
+ */
+exports['post'] = function (req, res) {
+};
+
+/**
+ * TODO
+ * Remove features.
+ */
+exports['delete'] = function (req, res) {
+};
+
+/**
+ * Find features inside bbox.
+ */
+exports['get-within-bbox'] = function (req, res) {
+  var FeatureClusterer = require('../../lib/serializer/feature-clusterer');
+  var fc = new FeatureClusterer();
+  var YMapsCluster = require('../../lib/serializer/ymaps-cluster');
+  var yc = new YMapsCluster();
+
+  var zoom = +req.param('zoom');
+  var bbox = req.param('bbox').split(',').map(Number);
+
+  storage.findFeaturesInBounds([ bbox.slice(0, 2), bbox.slice(2, 4) ])
+    .then(function (data) {
+      return req.param('clusterize')?
+        data.serialize(fc, { zoom: zoom }).serialize(yc) : data;
+    })
+    .then(function (data) {
+      _send(res, {
+        "error": null,
+        "data": data.getData()
+      });
+    })
+    .fail(function (err) {
+      res.status(400);
+      _send(res, {
+        "error": err
+      });
+    });
+};
+
+/**
+ * TODO
+ * Find features inside polygon.
+ */
+exports['get-within-polygon'] = function (req, res) {
+};
+
+/**
+ * TODO
+ * Find features near coordinates.
+ */
+exports['get-near'] = function (req, res) {
+};
+
+function _send(res, data) {
+  res.format({
+    "application/jsonp": function () {
+      res.jsonp(data);
+    },
+    "application/json": function () {
+      res.json(data);
+    },
+    "default": function () {
+      res.status(406).send('Not Acceptable');
+    }
+  });
+}

remote-object-manager-server/routes/api/get-features.js

@@ -2,9 +2,21 @@
 
 var express = require('express');
 var router = express.Router();
+var features = require('./features');
 
 module.exports = router;
 
-router.route('/v1/features')
-  .get(require('./get-features'))
-  .put(require('./put-features'));
+router.route('/features')
+  .get(features['get'])
+  .put(features['put'])
+  .post(features['post'])
+  .delete(features['delete']);
+
+router.route('/features/within/bbox/:bbox')
+  .get(features['get-within-bbox'])
+
+router.route('/features/within/polygon/:coordinates')
+  .get(features['get-within-polygon'])
+
+router.route('/features/near/:coordinates')
+  .get(features['get-near'])