Reload97 / store-dompul-stock

Browse Code »

Commit 1a631d48d6aa1ac4f1515a148284ad95f0e29191

Authored by Adhidarma Hadiwinoto 10 years ago

1 parent 408d15fe30

Exists in master

fix format

Showing 2 changed files with 33 additions and 4 deletions Inline Diff

httpserver.js
package.json

httpserver.js

Diff comments View file @ 1a631d4

1	var name = require('path').basename(__filename);	1	var name = require('path').basename(__filename);
2		2
3	var redis = require('redis');	3	var redis = require('redis');
4	var redisClient;	4	var redisClient;
5		5
6	var http = require('http');	6	var http = require('http');
7	var nsr = require('node-simple-router');	7	var nsr = require('node-simple-router');
8	var router = nsr();	8	var router = nsr();
9		9
10	var js2xmlparser = require('js2xmlparser');	10	var js2xmlparser = require('js2xmlparser');
11		11
12	var httpServer;	12	var httpServer;
13	var config;	13	var config;
14	var logger;	14	var logger;
15		15
16	function formatData(data, format) {	16
17	if (format == 'xml') {	17	function toArrayOfObject(obj) {
18	return js2xmlparser('stock', data);	18	var arr = [];
		19
		20	var chips = Object.getOwnPropertyNames(obj);
		21	var chipsCount = chips.length;
		22
		23	for (var i = 0; i < chipsCount; i++) {
		24	data = {
		25	'name': chips[i],
		26	'stock': obj[chips[i]],
		27	}
		28
		29	arr.push(data);
19	}	30	}
		31	return arr;
		32	}
		33
		34	function formatDataAsHtml(data) {
20	return JSON.stringify(data);	35	return JSON.stringify(data);
21	}	36	}
22		37
		38	function formatData(_data, format) {
		39	data = toArrayOfObject(_data);
		40	if (format == 'xml') {
		41	return js2xmlparser('chips', {chip: data});
		42	}
		43	else if (format == 'json') {
		44	return JSON.stringify(data);
		45	}
		46
		47	return formatDataAsHtml(data);
		48	}
		49
23	function getStockKeyForDenom(denom) {	50	function getStockKeyForDenom(denom) {
24	return 'stock.dompul.by-denom.' + denom;	51	return 'stock.dompul.by-denom.' + denom;
25	}	52	}
26		53
27	function onHttpGetByDenom(request, response) {	54	function onHttpGetByDenom(request, response) {
28	var key = getStockKeyForDenom(request.params.denom);	55	var key = getStockKeyForDenom(request.params.denom);
29		56
30	redisClient.hgetall(key, function(err, obj) {	57	redisClient.hgetall(key, function(err, obj) {
31		58
32	if (err) {	59	if (err) {
33	response.end('Error: ' + err);	60	response.end('Error: ' + err);
34	return;	61	return;
35	}	62	}
36		63
37	response.end(formatData(obj, request.params.format));	64	response.end(formatData(obj, request.params.format));
38	});	65	});
39	}	66	}
40		67
41	function onHttpGetTotalByDenom(request, response) {	68	function onHttpGetTotalByDenom(request, response) {
42	var key = getStockKeyForDenom(request.params.denom);	69	var key = getStockKeyForDenom(request.params.denom);
43		70
44	redisClient.hgetall(key, function(err, obj) {	71	redisClient.hgetall(key, function(err, obj) {
45		72
46	if (err) {	73	if (err) {
47	response.end('Error: ' + err);	74	response.end('Error: ' + err);
48	return;	75	return;
49	}	76	}
50		77
51	var chips = Object.getOwnPropertyNames(obj);	78	var chips = Object.getOwnPropertyNames(obj);
52	var chipsCount = chips.length;	79	var chipsCount = chips.length;
53	var total = 0;	80	var total = 0;
54		81
55	for (var i = 0; i < chipsCount; i++) {	82	for (var i = 0; i < chipsCount; i++) {
56	total = total + parseInt(obj[chips[i]]);	83	total = total + parseInt(obj[chips[i]]);
57	}	84	}
58	response.end(total.toString());	85	response.end(total.toString());
59	});	86	});
60	}	87	}
61		88
62		89
63	function createServer() {	90	function createServer() {
64	router.get('/realtime-report/stock/:denom/index', onHttpGetByDenom);	91	router.get('/realtime-report/stock/:denom/index', onHttpGetByDenom);
65	router.get('/realtime-report/stock/:denom/index/:format', onHttpGetByDenom);	92	router.get('/realtime-report/stock/:denom/index/:format', onHttpGetByDenom);
66	router.get('/realtime-report/stock/:denom/total', onHttpGetTotalByDenom);	93	router.get('/realtime-report/stock/:denom/total', onHttpGetTotalByDenom);
67		94
68	httpServer = http.createServer(router).listen(config.httpserver.listen_port);	95	httpServer = http.createServer(router).listen(config.httpserver.listen_port);
69	console.log('HTTP server listens on port ' + config.httpserver.listen_port);	96	console.log('HTTP server listens on port ' + config.httpserver.listen_port);
70	}	97	}
71		98
72	function start(_config, _logger) {	99	function start(_config, _logger) {
73	config = _config;	100	config = _config;
74	logger = _logger;	101	logger = _logger;
75		102
76	redisClient = redis.createClient(config.globals.redis_port, config.globals.redis_host);	103	redisClient = redis.createClient(config.globals.redis_port, config.globals.redis_host);
77		104
78	redisClient.on("error", function (err) {	105	redisClient.on("error", function (err) {
79	logger.error(name + "- redis client error: " + err);	106	logger.error(name + "- redis client error: " + err);
80	});	107	});
81		108
82		109
83	logger.info('Starting http server');	110	logger.info('Starting http server');
84		111
85	createServer();	112	createServer();
86	}	113	}
87		114
88	exports.start = start;	115	exports.start = start;
89		116

package.json

Diff comments View file @ 1a631d4

 {
   "name": "store-dompul-stock",
   "version": "0.0.1",
   "description": "Store DOMPUL stock in Redis",
   "main": "index.js",
   "scripts": {
     "start": "node index.js",
     "test": "mocha"
   },
   "repository": {
     "type": "git",
     "url": "git@gitlab.kodesumber.com:reload97/store-dompul-stock.git"
   },
   "keywords": [
     "Reload97",
     "ST24",
     "PPOB",
     "Server",
     "Pulsa"
   ],
   "author": "Adhidarma Hadiwinoto",
   "license": "BSD",
   "dependencies": {
     "redis": "~0.12.1",
     "hiredis": "~0.3.0",
     "iniparser": "~1.0.5",
     "winston": "~1.0.0",
     "node-simple-router": "~0.9.4-2",
-    "js2xmlparser": "~0.1.9"
+    "js2xmlparser": "~0.1.9",
+    "xml": "~1.0.0",
+    "xmlbuilder": "~2.6.2"
   }
 }