JavaScriptIOT
diff --git a/Collapse file
‎package.json‎
Copy file name to clipboardExpand all lines: package.json
+12-12Lines changed: 12 additions & 12 deletions b/Collapse file
‎package.json‎
Copy file name to clipboardExpand all lines: package.json
+12-12Lines changed: 12 additions & 12 deletions
diff --git a/Collapse file
‎server.js‎
Copy file name to clipboardExpand all lines: server.js
+15-4Lines changed: 15 additions & 4 deletions b/Collapse file
‎server.js‎
Copy file name to clipboardExpand all lines: server.js
+15-4Lines changed: 15 additions & 4 deletions
@@ -18,22 +18,28 @@
   "dependencies": {
     "assert": "*",
     "bluebird": "*",
+    "optimist": "*",
+    "express": "~4.0.0",
+    "express-session": "*",
+    "express-http-proxy": "*",
+    "passport": ">= 0.0.0",
+    "socket.io": "*",
+    "deasync": "*",
+    "data.io": "*",
+    "tingodb": "0.3.5",
+    "pouchdb": "3.1.0",
+    "swagger-tools": "*",
     "body-parser": "*",
     "chai": "*",
     "coap": "0.17.0",
     "collections": "*",
     "cron": "*",
-    "data.io": "*",
-    "deasync": "*",
     "deep-equal": "^1.0.1",
-    "diffsync": "*",
-    "express": "~4.0.0",
-    "express-http-proxy": "*",
-    "express-session": "*",
     "ffi": "*",
     "figlet": "*",
     "gun": "^0.9.93",
     "helmet": "^3.6.0",
+    "node-zookeeper-client": "*",
     "kafka-rest": "*",
     "localtunnel": "*",
     "log4js": "*",
@@ -44,17 +50,11 @@
     "mqtt": "^1.14.1",
     "multer": "0.1.6",
     "node-uuid": "*",
-    "node-zookeeper-client": "*",
     "numeric": "*",
-    "optimist": "*",
-    "passport": ">= 0.0.0",
     "plotly": "0.2.13",
     "request": "*",
     "shelljs": "*",
-    "socket.io": "*",
-    "swagger-tools": "*",
     "tcp-port-used": "*",
-    "tingodb": "0.3.5",
     "tingyun": "*",
     "tty.js": "*"
   },
 
@@ -37,7 +37,8 @@ var loadDir = require('./loaddir');
 var module = loadDir(config.app_path);
 var multer = require('multer');
 var sockectio = require('socket.io');
-var diffsync = require('diffsync');
+var PouchDB = require('pouchdb');
+var pouchdb = new PouchDB('dbname');
 var tingodb = require('tingodb')();
 var Gun = require('gun');
 var optimist = require('optimist');
@@ -107,8 +108,6 @@ function parser_parameter(fun_str) {
 var port = argv.port || process.env.PORT || config.port; // set our port
 var server = http.createServer(app);
 var io = sockectio.listen(server);
-var dataAdapter = new diffsync.InMemoryDataAdapter();
-var diffSyncServer = new diffsync.Server(dataAdapter, io);
 var data = require('data.io')(io);
 var messages = data.resource('messages');
 var request = require('request').defaults({
@@ -158,7 +157,19 @@ function dynamicloadmodule(filename) {
 
 event.addListener('load', dynamicloadmodule);
 
-//console.log(numeric.add([1,2],[3,4],[5,6],[7,8]))
+pouchdb.put({
+  _id: 'dave@gmail.com',
+  name: 'David',
+  age: 69
+});
+
+pouchdb.changes().on('change', function() {
+  logger.info('Ch-Ch-Changes');
+});
+
+
+// pouchdb.replicate.to('http://example.com/mydb');
+// console.log(numeric.add([1,2],[3,4],[5,6],[7,8]))
 
 server.listen(port);
 logger.info("Restful API server run on port", port)