Skip to content

Commit 84ca237

Browse files
rahildarrahildar
committed
Master Branch Migration Commit
1 parent e4713c0 commit 84ca237

25 files changed

Lines changed: 115728 additions & 87 deletions

‎baskar/LogAggregator-4‎

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
Subproject commit afa321b8c1cd9a10a8fb8413fc85f74a53ed72ca

‎check.js‎

Lines changed: 67 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,67 @@
1+
var sift = require('sift');
2+
var _=require('highland')
3+
4+
// eval= {
5+
// val1: '140',
6+
// val2: <%= val1%>
7+
// }
8+
9+
// console.log(eval.val2);
10+
// // i=eval.val2;
11+
// var fs = require('fs');
12+
// var output=fs.createWriteStream('output')
13+
// var calls=0;
14+
// var num=_(['1','2','3','4','5','6']).map(function(x) {
15+
// ++calls;
16+
// return x+1;
17+
// });
18+
// var nums=num.batch(2);
19+
// nums.pipe(output)
20+
// var output=_(['some','texe']).intersperse('n');
21+
// // _(output).pipe(process.stdout);
22+
23+
// var output=_(['somme','texmme']).splitBy('mm');
24+
// _(output).pipe(process.stdout);
25+
// var output=_(['foo', 'bar']).invoke('toUpperCase', [])
26+
// _(output).pipe(process.stdout);
27+
// var output=_(['foo', 'bar']).map(toUpperCase);
28+
// _(output).pipe(process.stdout)
29+
30+
// var output=_([1]).reduce1(function(a,b) {
31+
// return a+b;
32+
// });
33+
// _(output).each(function(x) {
34+
// console.log(x);
35+
// });
36+
var ar=[]
37+
38+
for (var i = 1; i <= 100; i++) {
39+
ar.push(i);
40+
41+
}
42+
43+
var output=_(ar).batch(10).reduce1(function (a,b) {
44+
// console.log(x);
45+
a=parseInt(a);
46+
b=parseInt(b)
47+
return a+b;
48+
});
49+
50+
_(output).each(function(x) {
51+
console.log(x);
52+
})
53+
// console.log(calls);
54+
// var sift = require('sift');
55+
//
56+
//
57+
// eval= {
58+
// val1: 5,
59+
// val2: 5
60+
// }
61+
//
62+
// var sifter = sift({$where: function() {
63+
// return this.val1 >= this.val2;
64+
// }});
65+
//
66+
// eval.highlight=sifter(eval)
67+
// console.log(eval);

‎check.txt‎

Whitespace-only changes.

‎demo.js‎

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,7 @@
1+
var _ = require('highland');
2+
var sift = require('sift');
3+
4+
5+
var sifter=sift({index:{$gt:'0'}});
6+
7+
console.log(sifter({index:'-9'}));

‎dest/routes/dimensions.js‎

Lines changed: 56 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,56 @@
1+
var express = require('express');
2+
var dimensionRouter = express.Router();
3+
var mongoose = require('mongoose');
4+
var Namespace = require('../model/db').namespaceModel;
5+
6+
/* GET Dimensions */
7+
dimensionRouter.get('/', function(req, res) {
8+
if(req.session.oid!==null){
9+
Namespace.findNamespace(req.session.oid, function(err, namespace) {
10+
if (namespace != null) {
11+
res.send(namespace.dimensions);
12+
}
13+
});
14+
}
15+
});
16+
17+
/* POST Dimension */
18+
19+
dimensionRouter.post('/addDimension', function(req, res) {
20+
if (req.session.oid !== null) {
21+
Namespace.findNamespace(req.session.oid, function(err, namespace) {
22+
if (namespace != null) {
23+
namespace.dimensions.push({
24+
displayName: req.body.displayname,
25+
fieldName: req.body.fieldname
26+
});
27+
28+
namespace.save(function(err, namespace) {
29+
console.log('namespace saved:', namespace);
30+
});
31+
}
32+
});
33+
}
34+
res.redirect('/');
35+
});
36+
37+
/*delete*/
38+
dimensionRouter.post('/:id', function(req, res) {
39+
console.log("deleted value is", req.params.id);
40+
// Namespace.findNamespace('test_namespace', function(err, namespace) {
41+
// if (namespace != null) {
42+
// var length = namespace.dimensions.length;
43+
// for(var i =0 ;i<length-1;i++)
44+
// {
45+
// if(namespace.dimensions[i].displayname===req.params.id)
46+
// {
47+
//
48+
// }
49+
// break;
50+
// }
51+
// }
52+
// });
53+
res.redirect('/');
54+
});
55+
56+
module.exports = dimensionRouter;

‎dest/routes/index.js‎

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,8 @@
1+
var express = require('express');
2+
var router = express.Router();
3+
4+
/* GET home page. */
5+
router.get('/', function(req, res) {
6+
res.render('index');
7+
});
8+
module.exports = router;

‎dest/routes/logdata.js‎

Lines changed: 58 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,58 @@
1+
var express = require('express');
2+
var router = express.Router();
3+
var formidable = require('formidable');
4+
var mongoose = require('mongoose');
5+
var Namespace = require('../model/db').namespaceModel;
6+
var fs = require('fs');
7+
8+
9+
10+
/* GET log data */
11+
router.get('/', function(req, res) {
12+
if (req.session.oid !== null) {
13+
Namespace.findNamespace(req.session.oid, function(err, namespace) {
14+
if (namespace != null) {
15+
fs.readFile(namespace.filePath, 'utf8', function(err, data) {
16+
if (err) {
17+
return console.log(err);
18+
}
19+
res.send(JSON.parse(data));
20+
});
21+
}
22+
});
23+
}
24+
});
25+
26+
/* POST Namespace*/
27+
router.post('/', function(req, res) {
28+
//creates a new incoming form.
29+
var form = new formidable.IncomingForm();
30+
31+
// parse a file upload
32+
form.parse(req, function(err, fields, files) {
33+
var newPath;
34+
fs.readFile(files.file.path, function(err, data) {
35+
var filedata = data.toString();
36+
fs.writeFile("public/upload/" + files.file.name, filedata, function(err) {
37+
if (err) return console.log(err);
38+
console.log("file written");
39+
});
40+
});
41+
42+
Namespace.create({
43+
name: fields.namespace,
44+
description: fields.desc,
45+
createdOn: Date.now(),
46+
filePath: "public/upload/" + files.file.name
47+
}, function(err, namespace) {
48+
if (err) {
49+
console.log(err);
50+
} else {
51+
console.log("namespace created and saved", namespace);
52+
req.session.oid = namespace._id;
53+
res.redirect('/');
54+
}
55+
});
56+
});
57+
});
58+
module.exports = router;

‎dest/routes/measures.js‎

Lines changed: 50 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,50 @@
1+
var express = require('express');
2+
var router = express.Router();
3+
var mongoose = require('mongoose');
4+
var Namespace = require('../model/db').namespaceModel;
5+
6+
/* GET Measures */
7+
router.get('/', function(req, res) {
8+
if (req.session.oid !== null) {
9+
Namespace.findNamespace(req.session.oid, function(err, namespace) {
10+
if (namespace != null) {
11+
res.send(namespace.measures);
12+
}
13+
});
14+
}
15+
});
16+
17+
/* POST Measures */
18+
router.post('/addMeasure', function(req, res) {
19+
if (req.session.oid !== null) {
20+
Namespace.findNamespace(req.session.oid, function(err, namespace) {
21+
if (namespace != null) {
22+
if (req.body.measureEventSelector == "") {
23+
var fieldEventValue = req.body.measureFieldSelector;
24+
} else {
25+
var fieldEventValue = req.body.measureEventSelector;
26+
}
27+
namespace.measures.push({
28+
displayName: req.body.displaymeasurename,
29+
aggrFunc: req.body.aggregator,
30+
fieldEvent: fieldEventValue,
31+
filterField: req.body.filterfield,
32+
filterValue: req.body.filtervalue,
33+
});
34+
namespace.save(function(err, namespace) {
35+
console.log('namespace saved:', namespace);
36+
});
37+
}
38+
});
39+
}
40+
res.redirect('/');
41+
});
42+
43+
/* Delete Measure */
44+
45+
router.post('/:id', function(req, res) {
46+
console.log("deleted value is", req.params.id);
47+
res.redirect('/');
48+
});
49+
50+
module.exports = router;

‎example.js‎

Lines changed: 70 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,70 @@
1+
// 17/3/16 mongo client
2+
3+
// #2
4+
var _ = require('highland');
5+
var fs = require('fs')
6+
// var uri = 'mongodb://localhost:27017/slog4'
7+
var WebSocketClient = require('websocket').client;
8+
var WebSocket = new WebSocketClient();
9+
10+
11+
var dest =fs.createWriteStream('eout.json',{defaultEncoding:'utf8'});
12+
13+
WebSocket.on('connect',function(connection) {
14+
console.log("Connected..Waiting for some message");
15+
16+
_('message',connection).map(function(msg){
17+
console.log('msg1:' + JSON.stringify(msg));
18+
}).done(function(){
19+
console.log('Done');
20+
});
21+
22+
/*connection.on('message',function(message) {
23+
24+
// var docs =_([message]);
25+
// var docs=message;
26+
// var output=fs.createWriteStream('output.txt');
27+
// _(docs).pipe(output);
28+
29+
// es.through([
30+
// fs.createReadStream('message'),
31+
// ]).pipe(fs.createWriteStream('output.json'));
32+
//
33+
34+
// console.log(message);
35+
// var outputFile='output.json'
36+
var data =_([message]);
37+
console.log("******");
38+
console.log(data);
39+
var dest =fs.createWriteStream('eout.json');
40+
data.pipe(dest);
41+
data.pipe(through).pipe(dest);
42+
// es.through(function write(data){
43+
// this.emit('data', data);
44+
// })
45+
console.log(data);
46+
47+
// data.pipe();
48+
//console.log(message);
49+
50+
// data.toArray(function(s){
51+
// console.log("bhaskar",s);
52+
// fs.writeFile(outputFile,JSON.stringify(s),function(err){
53+
// console.log(err);
54+
// });
55+
//
56+
// });
57+
58+
// data
59+
// .flatMap(_.wrapCallback(fs.writeFile.bind(fs,outputFile)))
60+
// .stopOnError(function(err){
61+
// console.log(err);
62+
// });
63+
64+
console.log(message);
65+
});*/
66+
});
67+
WebSocket.connect('ws://172.23.238.253:7070');
68+
69+
// function msg
70+
/* ending of program*/

0 commit comments

Comments
 (0)