Zaid Abdulla
41fb97adef
Keep session data in process for as long as the TCP connectoin is open. Use redis if connection closes before the session is over.
88 lines
2.4 KiB
CoffeeScript
88 lines
2.4 KiB
CoffeeScript
###
|
|
# Copyright 2013, 2014 Zaid Abdulla
|
|
#
|
|
# GenieACS is free software: you can redistribute it and/or modify
|
|
# it under the terms of the GNU Affero General Public License as
|
|
# published by the Free Software Foundation, either version 3 of the
|
|
# License, or (at your option) any later version.
|
|
#
|
|
# GenieACS is distributed in the hope that it will be useful,
|
|
# but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
# GNU Affero General Public License for more details.
|
|
#
|
|
# You should have received a copy of the GNU Affero General Public License
|
|
# along with GenieACS. If not, see <http://www.gnu.org/licenses/>.
|
|
###
|
|
|
|
domain = require 'domain'
|
|
util = require 'util'
|
|
cluster = require 'cluster'
|
|
config = require './config'
|
|
db = require './db'
|
|
|
|
service = config.argv[0]
|
|
if not service?
|
|
throw new Error('Missing argument cwmp, fs, or nbi')
|
|
|
|
networkInterface = config.get("#{service.toUpperCase()}_INTERFACE")
|
|
port = config.get("#{service.toUpperCase()}_PORT")
|
|
useHttps = config.get("#{service.toUpperCase()}_SSL")
|
|
|
|
serviceListener = require("./#{service}").listener
|
|
onConnection = require("./#{service}").onConnection
|
|
|
|
server = null
|
|
|
|
listener = (httpRequest, httpResponse) ->
|
|
d = domain.create()
|
|
|
|
d.on('error', (err) ->
|
|
util.error("#{new Date().toISOString()} - #{err.stack}\n")
|
|
try
|
|
killTimer = setTimeout(() ->
|
|
process.exit(1)
|
|
, 30000)
|
|
|
|
killTimer.unref()
|
|
|
|
cluster.worker?.disconnect()
|
|
server.close(() ->
|
|
db.disconnect()
|
|
)
|
|
|
|
httpResponse.writeHead(500, {'Connection' : 'close'})
|
|
httpResponse.end("#{err.name}: #{err.message}")
|
|
catch err2
|
|
util.error("#{new Date().toISOString()} - #{err2.stack}\n")
|
|
)
|
|
|
|
d.add(httpRequest)
|
|
d.add(httpResponse)
|
|
|
|
d.run(() ->
|
|
serviceListener(httpRequest, httpResponse)
|
|
)
|
|
|
|
|
|
if useHttps
|
|
path = require 'path'
|
|
fs = require 'fs'
|
|
httpsKey = path.resolve(config.get('CONFIG_DIR'), "#{service}.key")
|
|
httpsCert = path.resolve(config.get('CONFIG_DIR'), "#{service}.crt")
|
|
options = {
|
|
key: fs.readFileSync(httpsKey),
|
|
cert: fs.readFileSync(httpsCert)
|
|
}
|
|
server = require('https').createServer(options, listener)
|
|
else
|
|
server = require('http').createServer(listener)
|
|
|
|
if onConnection?
|
|
server.on('connection', onConnection)
|
|
|
|
db.connect((err) ->
|
|
throw err if err
|
|
server.listen(port, networkInterface)
|
|
)
|