diff --git a/swarmlab-app/src/run/app.js b/swarmlab-app/src/run/app.js
index c64fc09..94258eb 100755
--- a/swarmlab-app/src/run/app.js
+++ b/swarmlab-app/src/run/app.js
@@ -253,6 +253,37 @@ app.get('/run', [
 cors(corsOptions),  (req, res, next) => {
 
   (async() => { 
+
+var mongourl = "mongodb://playgrounduser:efvvnuioervefSDFSGYGHRDFVsdfergvssppiiedifhwincvinviw_dbfjbsifbsdkjfswuunscfudfgbbfvibqefwrvnine@ondemand_playground_mongo1:27017,ondemand_playground_mongo2:27017,ondemand_playground_mongo3:27017,ondemand_playground_mongo4:27017,ondemand_playground_mongo5:27017,ondemand_playground_mongo6:27017,ondemand_playground_mongo7:27017/fluent?replicaSet=rs1"
+const OPTS = { 
+  useNewUrlParser: true, 
+  useUnifiedTopology: true
+};
+MongoClient.connect(mongourl, OPTS, function(err, client){
+    if(err){
+        console.log(err);
+    } else {
+    const db = client.db('fluent');
+    //db.collection('log', onCollection);
+      var stream = db.collection('log').find({}, {
+    tailable: true,
+    awaitdata: true
+    /* other options */
+}).stream();
+
+stream.on('data', function (doc) {
+        console.log(JSON.stringify(doc)) 
+    //socket.write(JSON.stringify({'action': 'log','param': doc.log}));
+});
+      /*
+        db.collection(function(err, collections) {
+            collections.forEach(function(coll) {
+                console.log(coll.s.name);
+            });
+        });
+        */
+    }
+});
       var RES = new Object();
       RES.code    = req.query["filter"]
       RES.token    = req.query["filter"]