Change config system

This commit is contained in:
calzoneman 2013-07-28 11:49:29 -04:00
parent 3932014ed0
commit 2fb28f4d43
6 changed files with 123 additions and 76 deletions

22
api.js
View File

@ -12,22 +12,22 @@ THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLI
var Auth = require("./auth"); var Auth = require("./auth");
var Logger = require("./logger"); var Logger = require("./logger");
var apilog = new Logger.Logger("api.log"); var apilog = new Logger.Logger("api.log");
var Config = require("./config");
var ActionLog = require("./actionlog"); var ActionLog = require("./actionlog");
var fs = require("fs"); var fs = require("fs");
function getIP(req) {
module.exports = function (Server) {
function getIP(req) {
var raw = req.connection.remoteAddress; var raw = req.connection.remoteAddress;
var forward = req.header("x-forwarded-for"); var forward = req.header("x-forwarded-for");
if(Config.REVERSE_PROXY && forward) { if(Server.cfg["trust-x-forward"] && forward) {
var ip = forward.split(",")[0]; var ip = forward.split(",")[0];
Logger.syslog.log("REVPROXY " + raw + " => " + ip); Logger.syslog.log("REVPROXY " + raw + " => " + ip);
return ip; return ip;
} }
return raw; return raw;
} }
module.exports = function (Server) {
var API = function () { var API = function () {
} }
@ -251,7 +251,7 @@ module.exports = function (Server) {
return; return;
} }
if(!Config.MAIL) { if(!Server.cfg["enable-mail"]) {
this.sendJSON(res, { this.sendJSON(res, {
success: false, success: false,
error: "This server does not have email enabled. Contact an administrator" error: "This server does not have email enabled. Contact an administrator"
@ -269,24 +269,24 @@ module.exports = function (Server) {
"A password reset request was issued for your account `", "A password reset request was issued for your account `",
name, name,
"` on ", "` on ",
Config.DOMAIN, Server.cfg["domain"],
". This request is valid for 24 hours. ", ". This request is valid for 24 hours. ",
"If you did not initiate this, there is no need to take action. ", "If you did not initiate this, there is no need to take action. ",
"To reset your password, copy and paste the following link into ", "To reset your password, copy and paste the following link into ",
"your browser: ", "your browser: ",
Config.DOMAIN, Server.cfg["domain"],
"/reset.html?", "/reset.html?",
hash hash
].join(""); ].join("");
var mail = { var mail = {
from: "CyTube Services <" + Config.MAIL_FROM + ">", from: "CyTube Services <" + Server.cfg["mail-from"] + ">",
to: email, to: email,
subject: "Password reset request", subject: "Password reset request",
text: msg text: msg
}; };
var api = this; var api = this;
Config.MAIL.sendMail(mail, function(err, response) { cfg["nodemailer"].sendMail(mail, function(err, response) {
if(err) { if(err) {
Logger.errlog.log("Mail fail: " + err); Logger.errlog.log("Mail fail: " + err);
api.sendJSON(res, { api.sendJSON(res, {
@ -299,7 +299,7 @@ module.exports = function (Server) {
success: true success: true
}); });
if(Config.DEBUG) { if(Server.cfg["debug"]) {
Logger.syslog.log(response); Logger.syslog.log(response);
} }
} }

View File

@ -11,7 +11,6 @@ THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLI
var mysql = require("mysql-libmysqlclient"); var mysql = require("mysql-libmysqlclient");
var Database = require("./database.js"); var Database = require("./database.js");
var Config = require("./config.js");
var bcrypt = require("bcrypt"); var bcrypt = require("bcrypt");
var hashlib = require("node_hash"); var hashlib = require("node_hash");
var Logger = require("./logger.js"); var Logger = require("./logger.js");

111
config.js
View File

@ -9,38 +9,83 @@ The above copyright notice and this permission notice shall be included in all c
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
*/ */
exports.MYSQL_SERVER = ""; var fs = require("fs");
exports.MYSQL_DB = ""; var Logger = require("./logger");
exports.MYSQL_USER = "";
exports.MYSQL_PASSWORD = "";
exports.IO_PORT = 1337; // Socket.IO port, DO NOT USE PORT 80.
exports.WEBSERVER_PORT = 8080; // Webserver port. Binding port 80 requires root permissions
exports.MAX_PER_IP = 10;
exports.GUEST_LOGIN_DELAY = 60; // Seconds
/*
Set to true if your IO_URL and WEB_URL are behind a reverse proxy
(e.g. Cloudflare) so that client IPs are passed through correctly.
If you are not behind a reverse proxy, leave it as false, otherwise
clients can fake their IP address in the x-forwarded-for header
*/
exports.REVERSE_PROXY = false;
var nodemailer = require("nodemailer"); var nodemailer = require("nodemailer");
exports.MAIL = false;
/* Example for setting up email:
exports.MAIL = nodemailer.createTransport("SMTP", {
service: "Gmail",
auth: {
user: "some.user@gmail.com",
pass: "supersecretpassword"
}
});
See https://github.com/andris9/Nodemailer var defaults = {
*/ "mysql-server" : "localhost",
exports.MAIL_FROM = "some.user@gmail.com"; "mysql-db" : "cytube",
// Domain for password reset link "mysql-user" : "cytube",
// Email sent goes to exports.DOMAIN/reset.html?resethash "mysql-pw" : "supersecretpass",
exports.DOMAIN = "http://localhost"; "express-host" : "0.0.0.0",
"asset-cache-ttl" : 0,
"web-port" : 8080,
"io-port" : 1337,
"ip-connection-limit" : 10,
"guest-login-delay" : 60,
"trust-x-forward" : false,
"enable-mail" : false,
"mail-transport" : "SMTP",
"mail-config" : {
"service" : "Gmail",
"auth" : {
"user" : "some.user@gmail.com",
"pass" : "supersecretpassword"
}
},
"mail-from" : "some.user@gmail.com",
"domain" : "http://localhost"
}
function save(cfg, file) {
fs.writeFile(file, JSON.stringify(cfg, null, 4), function (err) {
if(err) {
Logger.errlog.log("Failed to save config");
Logger.errlog.log(err);
}
});
}
exports.load = function (Server, file, callback) {
var cfg = {};
for(var k in defaults)
cfg[k] = defaults[k];
fs.readFile(file, function (err, data) {
if(err) {
if(err.code == "ENOENT") {
Logger.syslog.log("Config file not found, generating default");
Logger.syslog.log("Edit cfg.json to configure");
data = "{}";
}
else {
Logger.errlog.log("Config load failed");
Logger.errlog.log(err);
return;
}
}
try {
data = JSON.parse(data + "");
} catch(e) {
Logger.errlog.log("Config JSON is invalid: ");
Logger.errlog.log(e);
return;
}
for(var k in data)
cfg[k] = data[k];
if(cfg["enable-mail"]) {
cfg["nodemailer"] = nodemailer.createTransport(
cfg["mail-transport"],
cfg["mail-config"]
);
}
save(cfg, file);
Server.cfg = cfg;
callback();
});
}

View File

@ -24,10 +24,10 @@ var CONFIG = {};
var global_bans = {}; var global_bans = {};
function setup(cfg) { function setup(cfg) {
SERVER = cfg.MYSQL_SERVER; SERVER = cfg["mysql-server"];
USER = cfg.MYSQL_USER; USER = cfg["mysql-user"];
DATABASE = cfg.MYSQL_DB; DATABASE = cfg["mysql-db"];
PASSWORD = cfg.MYSQL_PASSWORD; PASSWORD = cfg["mysql-pw"];
CONFIG = cfg; CONFIG = cfg;
} }
@ -41,7 +41,7 @@ function getConnection() {
Logger.errlog.log("DB connection failed"); Logger.errlog.log("DB connection failed");
return false; return false;
} }
if(CONFIG.DEBUG) { if(CONFIG["debug"]) {
db._querySync = db.querySync; db._querySync = db.querySync;
db.querySync = function(q) { db.querySync = function(q) {
Logger.syslog.log("DEBUG: " + q); Logger.syslog.log("DEBUG: " + q);

View File

@ -10,7 +10,7 @@ const VERSION = "2.1.2";
function getIP(req) { function getIP(req) {
var raw = req.connection.remoteAddress; var raw = req.connection.remoteAddress;
var forward = req.header("x-forwarded-for"); var forward = req.header("x-forwarded-for");
if(Config.REVERSE_PROXY && forward) { if(Server.cfg["trust-x-forward"] && forward) {
var ip = forward.split(",")[0]; var ip = forward.split(",")[0];
Logger.syslog.log("REVPROXY " + raw + " => " + ip); Logger.syslog.log("REVPROXY " + raw + " => " + ip);
return ip; return ip;
@ -20,7 +20,7 @@ function getIP(req) {
function getSocketIP(socket) { function getSocketIP(socket) {
var raw = socket.handshake.address.address; var raw = socket.handshake.address.address;
if(Config.REVERSE_PROXY) { if(Server.cfg["trust-x-forward"]) {
if(typeof socket.handshake.headers["x-forwarded-for"] == "string") { if(typeof socket.handshake.headers["x-forwarded-for"] == "string") {
var ip = socket.handshake.headers["x-forwarded-for"] var ip = socket.handshake.headers["x-forwarded-for"]
.split(",")[0]; .split(",")[0];
@ -126,8 +126,10 @@ var Server = {
}); });
// bind servers // bind servers
this.httpserv = this.app.listen(Config.WEBSERVER_PORT); this.httpserv = this.app.listen(Server.cfg["web-port"],
this.ioserv = express().listen(Config.IO_PORT); Server.cfg["express-host"]);
this.ioserv = express().listen(Server.cfg["io-port"],
Server.cfg["express-host"]);
// init socket.io // init socket.io
this.io = require("socket.io").listen(this.ioserv); this.io = require("socket.io").listen(this.ioserv);
@ -152,7 +154,7 @@ var Server = {
this.ips[ip] = 0; this.ips[ip] = 0;
this.ips[ip]++; this.ips[ip]++;
if(this.ips[ip] > Config.MAX_PER_IP) { if(this.ips[ip] > Server.cfg["ip-connection-limit"]) {
socket.emit("kick", { socket.emit("kick", {
reason: "Too many connections from your IP address" reason: "Too many connections from your IP address"
}); });
@ -167,7 +169,7 @@ var Server = {
// init database // init database
this.db = require("./database"); this.db = require("./database");
this.db.setup(Config); this.db.setup(Server.cfg);
this.db.init(); this.db.init();
// init ACP // init ACP
@ -190,9 +192,9 @@ var Server = {
}; };
Logger.syslog.log("Starting CyTube v" + VERSION); Logger.syslog.log("Starting CyTube v" + VERSION);
Server.init(); Config.load(Server, "cfg.json", function () {
Server.init();
if(!Config.DEBUG) { if(!Server.cfg["debug"]) {
process.on("uncaughtException", function (err) { process.on("uncaughtException", function (err) {
Logger.errlog.log("[SEVERE] Uncaught Exception: " + err); Logger.errlog.log("[SEVERE] Uncaught Exception: " + err);
Logger.errlog.log(err.stack); Logger.errlog.log(err.stack);
@ -201,4 +203,5 @@ if(!Config.DEBUG) {
process.on("SIGINT", function () { process.on("SIGINT", function () {
Server.shutdown(); Server.shutdown();
}); });
} }
});

View File

@ -14,7 +14,6 @@ var Auth = require("./auth.js");
var Channel = require("./channel.js").Channel; var Channel = require("./channel.js").Channel;
var formatTime = require("./media.js").formatTime; var formatTime = require("./media.js").formatTime;
var Logger = require("./logger.js"); var Logger = require("./logger.js");
var Config = require("./config.js");
var ActionLog = require("./actionlog"); var ActionLog = require("./actionlog");
// Represents a client connected via socket.io // Represents a client connected via socket.io
@ -506,11 +505,12 @@ User.prototype.login = function(name, pw, session) {
if(pw == "" && session == "") { if(pw == "" && session == "") {
if(this.ip in lastguestlogin) { if(this.ip in lastguestlogin) {
var diff = (Date.now() - lastguestlogin[this.ip])/1000; var diff = (Date.now() - lastguestlogin[this.ip])/1000;
if(diff < Config.GUEST_LOGIN_DELAY) { if(diff < this.server.cfg["guest-login-delay"]) {
this.socket.emit("login", { this.socket.emit("login", {
success: false, success: false,
error: ["Guest logins are restricted to one per ", error: ["Guest logins are restricted to one per ",
Config.GUEST_LOGIN_DELAY + " seconds per IP. ", this.server.cfg["guest-login-delay"]
+ " seconds per IP. ",
"This restriction does not apply to registered users." "This restriction does not apply to registered users."
].join("") ].join("")
}); });