Skip to content

Commit 96557f1

Browse files
committed
FIX: moved file locations, server instantiation.
1 parent 97e4bf0 commit 96557f1

File tree

5 files changed

+12
-12
lines changed

5 files changed

+12
-12
lines changed

server.js

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -3,10 +3,10 @@ const EventEmitter = require('events')
33
const series = require('run-series')
44
const string2compact = require('string2compact')
55

6-
const attachHttpServer = require("./server/attachHttpServer");
7-
const attachUdpServer = require('./server/attachUdpServer')
8-
const attachWSServer = require('./server/attachWSServer')
9-
const setupStatsRoute = require('./server/setupStatsRoute')
6+
const attachHttpServer = require('./services/attachHttp')
7+
const attachUdpServer = require('./services/attachUdp')
8+
const attachWSServer = require('./services/attachWS')
9+
const setupStatsRoute = require('./services/statsRoute')
1010
const common = require('./lib/common')
1111
const Swarm = require('./lib/server/swarm')
1212

@@ -333,4 +333,4 @@ function toNumber (x) {
333333

334334
function noop () {}
335335

336-
module.exports = new Server()
336+
module.exports = Server

services/attachHttp/parseHttpRequest.js

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
module.exports = parseHttpRequest
22

3-
var common = require('../common')
3+
const common = require('../../lib/common')
44

55
function parseHttpRequest (req, opts) {
66
if (!opts) opts = {}

services/attachUdp/parseUdpRequest.js

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,12 +1,12 @@
11
module.exports = parseUdpRequest
22

3-
var ipLib = require('ip')
4-
var common = require('../common')
3+
const ipLib = require('ip')
4+
const common = require('../../lib/common')
55

66
function parseUdpRequest (msg, rinfo) {
77
if (msg.length < 16) throw new Error('received packet is too short')
88

9-
var params = {
9+
const params = {
1010
connectionId: msg.slice(0, 8), // 64-bit
1111
action: msg.readUInt32BE(8),
1212
transactionId: msg.readUInt32BE(12),
@@ -29,7 +29,7 @@ function parseUdpRequest (msg, rinfo) {
2929
params.event = common.EVENT_IDS[msg.readUInt32BE(80)]
3030
if (!params.event) throw new Error('invalid event') // early return
3131

32-
var ip = msg.readUInt32BE(84) // optional
32+
const ip = msg.readUInt32BE(84) // optional
3333
params.ip = ip
3434
? ipLib.toString(ip)
3535
: rinfo.address

services/attachWS/index.js

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
const WebSocketServer = require("ws").Server
22
const parseWebSocketRequest = require("./parseWebsocketRequest")
3-
const attachHttpServer = require("../attachHttpServer")
3+
const attachHttpServer = require("../attachHttp")
44

55
function setupHttpService(server) {
66
if (server.http) return server.http

services/attachWS/parseWebsocketRequest.js

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
module.exports = parseWebSocketRequest
22

3-
var common = require('../common')
3+
const common = require('../../lib/common')
44

55
function parseWebSocketRequest (socket, opts, params) {
66
if (!opts) opts = {}

0 commit comments

Comments
 (0)