stackroute · Baskarant · Mar 18, 2016 · Mar 19, 2016 · Mar 19, 2016 · Mar 21, 2016
diff --git a/.gitignore b/.gitignore
@@ -0,0 +1 @@
+node_modules
diff --git a/angular.html b/angular.html
@@ -0,0 +1,31 @@
+<!DOCTYPE html>
+<html>
+<script src="http://ajax.googleapis.com/ajax/libs/angularjs/1.4.8/angular.min.js"></script>
+<body>
+
+<div ng-app="myApp" ng-controller="myCtrl">
+<input type="text" name="name" ng-model='username'>
+<button type="button" name="button" ng-click="greet(username)">button</button>
+current time {{time}}
+</div>
+
+<script>
+var app = angular.module('myApp', []);
+app.controller('myCtrl', function($scope, $window,$interval) {
+  $scope.greet=function (username) {
+    // console.log('hello');
+    $scope.username="abc"
+    $window.alert("hello "+ $scope.username);
+  }
+  $interval(function () {
+    var hour=new Date().getHours();
+    var min=(new Date().getMinutes())
+    var seconds=(+new Date().getSeconds())
+
+    $scope.time=hour +':'+ min+':'+seconds
+  },1000)
+  });
+</script>
+
+</body>
+</html>
diff --git a/app.js b/app.js
@@ -8,9 +8,42 @@ var formidable = require('formidable');
 var session = require('express-session');
 
 var routes = require('./routes/index');
+<<<<<<< Updated upstream
 var dimensionRouter = require('./routes/dimensions');
 var measuresRouter = require('./routes/measures');
 var namespaceRouter = require('./routes/logdata');
+=======
+
+var configRoute = require('./routes/config');
+var serviceConfigRoute = require('./routes/serviceConfig');
+var authenticate = require('./routes/authenticate')(passport);
+var userAgent = require('./routes/nginx/userAgent');
+var logListing = require('./routes/nginx/logListing');
+var trafficRate = require('./routes/nginx/trafficRate');
+
+//Wave 2 code
+var packageRoutes = require('./routes/aptCache/packageCount');
+var graphRoutes = require('./routes/aptCache/logRateData');
+var dataRateData = require('./routes/aptCache/dataRateData');
+var packageAnalytics = require('./routes/aptCache/packageAnalytics');
+var repRoutes = require('./routes/aptCache/repository');
+var getInfo = require('./routes/aptCache/getInfo');
+//end wave 2 code
+
+//wave 3 routes starts
+var getFilterData = require('./routes/gitLog/getFilterData');
+var newfilter = require('./routes/gitLog/newfilter');
+var plotTheGraph = require('./routes/gitLog/plot_the_graph');
+var getProfile = require('./routes/gitLog/getProfile');
+var getDashBoardJson = require('./routes/gitLog/getDashBoardJson');
+var onPageLoadDashBoard = require('./routes/gitLog/onPageLoadDashBoard');
+var gitDashboardConfigData  = require('./routes/gitLog/gitDashboardConfigData');
+//wave 3 routes ends
+
+//wave 4 starts
+var expressions=require('./routes/realTimeLogs/queryBuilder/expressions.js')
+//wave 4 ends
+>>>>>>> Stashed changes
 var app = express();
 
 // view engine setup
@@ -44,6 +77,11 @@ app.use('/dimensions', dimensionRouter);
 app.use('/measures', measuresRouter);
 app.use('/logdata', namespaceRouter);
 
+//wave 4 code
+app.use('/exp',expressions);
+
+// wave 4 code ends
+
 // catch 404 and forward to error handler
 app.use(function(req, res, next) {
   var err = new Error('Not Found');

diff --git a/baskar/LogAggregator-4 b/baskar/LogAggregator-4
diff --git a/check.js b/check.js
@@ -0,0 +1,67 @@
+var sift = require('sift');
+var _=require('highland')
+
+// eval= {
+//   val1: '140',
+//   val2: <%= val1%>
+// }
+
+// console.log(eval.val2);
+// // i=eval.val2;
+// var fs = require('fs');
+// var output=fs.createWriteStream('output')
+// var calls=0;
+// var num=_(['1','2','3','4','5','6']).map(function(x) {
+//   ++calls;
+//   return x+1;
+// });
+// var nums=num.batch(2);
+// nums.pipe(output)
+// var output=_(['some','texe']).intersperse('n');
+// // _(output).pipe(process.stdout);
+
+// var output=_(['somme','texmme']).splitBy('mm');
+// _(output).pipe(process.stdout);
+// var output=_(['foo', 'bar']).invoke('toUpperCase', [])
+// _(output).pipe(process.stdout);
+// var output=_(['foo', 'bar']).map(toUpperCase);
+// _(output).pipe(process.stdout)
+
+// var output=_([1]).reduce1(function(a,b) {
+//   return a+b;
+// });
+// _(output).each(function(x) {
+//   console.log(x);
+// });
+var ar=[]
+
+for (var i = 1; i <= 100; i++) {
+  ar.push(i);
+
+}
+
+var output=_(ar).batch(10).reduce1(function (a,b) {
+  // console.log(x);
+  a=parseInt(a);
+  b=parseInt(b)
+  return a+b;
+});
+
+_(output).each(function(x) {
+  console.log(x);
+})
+// console.log(calls);
+// var sift = require('sift');
+//
+//
+// eval= {
+//   val1: 5,
+//   val2: 5
+// }
+//
+// var sifter = sift({$where: function() {
+//   return this.val1 >= this.val2;
+// }});
+//
+// eval.highlight=sifter(eval)
+// console.log(eval);
diff --git a/check.txt b/check.txt
diff --git a/demo.js b/demo.js
@@ -0,0 +1,7 @@
+var _ = require('highland');
+var sift = require('sift');
+
+
+var sifter=sift({index:{$gt:'0'}});
+
+console.log(sifter({index:'-9'}));
diff --git a/dest/routes/dimensions.js b/dest/routes/dimensions.js
@@ -0,0 +1,56 @@
+var express = require('express');
+var dimensionRouter = express.Router();
+var mongoose = require('mongoose');
+var Namespace = require('../model/db').namespaceModel;
+
+/* GET Dimensions */
+dimensionRouter.get('/', function(req, res) {
+  if(req.session.oid!==null){
+  Namespace.findNamespace(req.session.oid, function(err, namespace) {
+    if (namespace != null) {
+      res.send(namespace.dimensions);
+    }
+  });
+}
+});
+
+/* POST Dimension */
+
+dimensionRouter.post('/addDimension', function(req, res) {
+  if (req.session.oid !== null) {
+  Namespace.findNamespace(req.session.oid, function(err, namespace) {
+    if (namespace != null) {
+      namespace.dimensions.push({
+        displayName: req.body.displayname,
+        fieldName: req.body.fieldname
+      });
+
+      namespace.save(function(err, namespace) {
+        console.log('namespace saved:', namespace);
+      });
+    }
+  });
+}
+  res.redirect('/');
+});
+
+/*delete*/
+dimensionRouter.post('/:id', function(req, res) {
+  console.log("deleted value is", req.params.id);
+  // Namespace.findNamespace('test_namespace', function(err, namespace) {
+  //   if (namespace != null) {
+  //     var length = namespace.dimensions.length;
+  //     for(var i =0 ;i<length-1;i++)
+  //     {
+  //       if(namespace.dimensions[i].displayname===req.params.id)
+  //       {
+  //
+  //       }
+  //       break;
+  //     }
+  //   }
+  // });
+  res.redirect('/');
+});
+
+module.exports = dimensionRouter;
diff --git a/dest/routes/index.js b/dest/routes/index.js
@@ -0,0 +1,8 @@
+var express = require('express');
+var router = express.Router();
+
+/* GET home page. */
+router.get('/', function(req, res) {
+  res.render('index');
+});
+module.exports = router;
diff --git a/dest/routes/logdata.js b/dest/routes/logdata.js
@@ -0,0 +1,58 @@
+var express = require('express');
+var router = express.Router();
+var formidable = require('formidable');
+var mongoose = require('mongoose');
+var Namespace = require('../model/db').namespaceModel;
+var fs = require('fs');
+
+
+
+/* GET log data */
+router.get('/', function(req, res) {
+  if (req.session.oid !== null) {
+    Namespace.findNamespace(req.session.oid, function(err, namespace) {
+      if (namespace != null) {
+        fs.readFile(namespace.filePath, 'utf8', function(err, data) {
+          if (err) {
+            return console.log(err);
+          }
+          res.send(JSON.parse(data));
+        });
+      }
+    });
+  }
+});
+
+/* POST Namespace*/
+router.post('/', function(req, res) {
+  //creates a new incoming form.
+  var form = new formidable.IncomingForm();
+
+  // parse a file upload
+  form.parse(req, function(err, fields, files) {
+    var newPath;
+    fs.readFile(files.file.path, function(err, data) {
+      var filedata = data.toString();
+      fs.writeFile("public/upload/" + files.file.name, filedata, function(err) {
+        if (err) return console.log(err);
+        console.log("file written");
+      });
+    });
+
+    Namespace.create({
+      name: fields.namespace,
+      description: fields.desc,
+      createdOn: Date.now(),
+      filePath: "public/upload/" + files.file.name
+    }, function(err, namespace) {
+      if (err) {
+        console.log(err);
+      } else {
+        console.log("namespace created and saved", namespace);
+        req.session.oid = namespace._id;
+        res.redirect('/');
+      }
+    });
+  });
+});
+module.exports = router;
diff --git a/dest/routes/measures.js b/dest/routes/measures.js
@@ -0,0 +1,50 @@
+var express = require('express');
+var router = express.Router();
+var mongoose = require('mongoose');
+var Namespace = require('../model/db').namespaceModel;
+
+/* GET Measures */
+router.get('/', function(req, res) {
+  if (req.session.oid !== null) {
+    Namespace.findNamespace(req.session.oid, function(err, namespace) {
+      if (namespace != null) {
+        res.send(namespace.measures);
+      }
+    });
+  }
+});
+
+/* POST Measures */
+router.post('/addMeasure', function(req, res) {
+  if (req.session.oid !== null) {
+    Namespace.findNamespace(req.session.oid, function(err, namespace) {
+      if (namespace != null) {
+        if (req.body.measureEventSelector == "") {
+          var fieldEventValue = req.body.measureFieldSelector;
+        } else {
+          var fieldEventValue = req.body.measureEventSelector;
+        }
+        namespace.measures.push({
+          displayName: req.body.displaymeasurename,
+          aggrFunc: req.body.aggregator,
+          fieldEvent: fieldEventValue,
+          filterField: req.body.filterfield,
+          filterValue: req.body.filtervalue,
+        });
+        namespace.save(function(err, namespace) {
+          console.log('namespace saved:', namespace);
+        });
+      }
+    });
+  }
+  res.redirect('/');
+});
+
+/* Delete Measure */
+
+router.post('/:id', function(req, res) {
+  console.log("deleted value is", req.params.id);
+  res.redirect('/');
+});
+
+module.exports = router;
diff --git a/exam11.js b/exam11.js
@@ -0,0 +1,46 @@
+// custom element with data based on the data requested
+
+// You create directives with the Module.directive method
+// using the name of the directive and the factory function
+var app11 = angular.module('app11', []);
+
+app11.directive("player", function() {
+
+    // Create a directive object
+    var directive = {};
+
+    // Define that we are using an element directive instead of
+    // a A: attribute, C: class, or M: comment
+    // I covered how to apply as an attribute previously
+    // I normally only apply as elements or attributes because
+    // it is easy to figure out where the directive was applied.
+    directive.restrict = 'E';
+
+    // The template is filled with the data and replaces the element
+    directive.template = "{{player.name}} had a {{player.avg}} AVG with {{player.hr}} homeruns and a {{player.obp}} OBP";
+
+    // Scope defines what is unique about each element
+    directive.scope = { player: "=name" };
+
+    // compile is called during the initialization phase
+    directive.compile = function(element, attributes){
+
+      // The link function receives the scope, the element The
+      // directive is associated with and that elements
+      // attributes. Here we can handle events on that element
+      var linkFunc = function($scope, element, attributes){
+        element.bind('click', function() {
+          element.html('Barry disappeared');
+        });
+      }
+      return linkFunc;
+    }
+    return directive;
+});
+
+app11.controller("mainCtrl", function($scope,$window) {
+$scope.greet=function(username) {
+  $window.alert("hello "+username )
+}
+  });
+- See more at: http://www.newthinktank.com/2016/02/angularjs-tutorial-3/#sthash.0jrfTOEM.dpuf