Skip to content
This repository was archived by the owner on Mar 31, 2021. It is now read-only.

Commit 31dda2f

Browse files
committed
Move log() function to be in app.js
1 parent e40bfca commit 31dda2f

File tree

3 files changed

+33
-27
lines changed

3 files changed

+33
-27
lines changed

app.js

Lines changed: 30 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -7,6 +7,7 @@ var express = require('express');
77
var config = require('./config.json');
88
var servers = require('./server');
99
var request = require('request');
10+
var _ = require('underscore');
1011

1112
var app = module.exports = express.createServer();
1213

@@ -46,13 +47,38 @@ var createSender = function(port) {
4647
};
4748
}
4849

50+
// Pad a number with preceding zeroes
51+
var pad = function(number, length) {
52+
var str = '' + number;
53+
while (str.length < length) {
54+
str = '0' + str;
55+
}
56+
57+
return str;
58+
}
59+
60+
var logs = [];
4961
var peers = [];
50-
for(var i = 0; i < numServers; i++) {
51-
var port = startPort + i + 1;
62+
_.each(_.range(numServers), function(idx) {
63+
var port = startPort + idx + 1;
5264
senders[port] = createSender(port);
53-
servers.create(port);
65+
66+
// Create a log function that will generate sortable
67+
// log data
68+
var prefix = "[server:" + port + "]";
69+
var index = 0;
70+
var log = function() {
71+
var date = "[" + (new Date()).toISOString() + ":" + pad((++index), 6) + "]";
72+
var args = _.toArray(arguments);
73+
args.unshift(prefix + date + "[" + port + "]");
74+
console.log.apply(console, args);
75+
}
76+
5477
peers.push(port);
55-
}
78+
logs.push(log);
79+
80+
servers.create(port, log);
81+
});
5682

5783
var start = null;
5884

package.json

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,7 @@
88
"request": "2.5.8",
99
"underscore": "1.3.3",
1010
"request": "2.9.202",
11-
"async": "0.1.18"
11+
"async": "0.1.18",
12+
"socket.io": "0.9.6"
1213
}
1314
}

server.js

Lines changed: 1 addition & 22 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
module.exports.create = function(port) {
1+
module.exports.create = function(port, log) {
22
var express = require('express');
33
var _ = require('underscore');
44
var async = require('async');
@@ -31,27 +31,6 @@ module.exports.create = function(port) {
3131
});
3232

3333
/****** UTILITY FUNCTIONS ******/
34-
35-
// Pad a number with preceding zeroes
36-
var pad = function(number, length) {
37-
var str = '' + number;
38-
while (str.length < length) {
39-
str = '0' + str;
40-
}
41-
42-
return str;
43-
}
44-
45-
// Create a log function that will generate sortable
46-
// log data
47-
var prefix = "[server:" + port + "]";
48-
var index = 0;
49-
var log = function() {
50-
var date = "[" + (new Date()).toISOString() + ":" + pad((++index), 6) + "]";
51-
var args = _.toArray(arguments);
52-
args.unshift(prefix + date + "[" + port + "]");
53-
console.log.apply(console, args);
54-
}
5534

5635
// Whether or not we should drop a packet
5736
var shouldDrop = function() {

0 commit comments

Comments
 (0)