Shuo/lib/models/chan.js

var _ = require("lodash");
var config = require("../../config") || {};
var fs = require('fs');
var moment = require("moment");

module.exports = Chan;

function Chan(attr) {
	_.merge(this, _.extend({
		id: global.id = ++global.id || 1,
		name: "",
		type: "channel",
		network: "",
		count: 0,
		messages: [],
		users: [],
	}, attr));
};

Chan.prototype.addMsg = function(msg) {
	this.messages.push(msg);
	if (config.log != true || this.type == "lobby") {
		return;
	}
	
	var dir = "logs/";
	dir += this.network + "/";
	if (!fs.existsSync(dir)) {
		fs.mkdir(dir);
	}
	
	var line = "[" + msg.time + "] ";
	if (msg.type == "normal") {
		// Format:
		// [00:00] <Arnold> Put that cookie down.. Now!!
		line += "<" + msg.from + "> " + msg.text;
	} else {
		// Format:
		// [00:00] * Arnold quit
		line += "* " + msg.from + " " + msg.type;
		if (msg.text) {
			line += " " + msg.text;
		}
	}
	
	var file = dir + this.name + ".log";
	fs.appendFile(
		file,
		line + "\n"
	);
};

Chan.prototype.addUser = function(user) {
	this.users.push(user);
};

Chan.prototype.sortUsers = function() {
	this.users = _.sortBy(
		this.users,
		function(u) { return u.name.toLowerCase(); }
	);
	var modes = [
		"~",
		"%",
		"@",
		"+",
	].reverse();
	modes.forEach(function(mode) {
		this.users = _.remove(
			this.users,
			function(u) { return u.mode == mode; }
		).concat(this.users);
	}, this);
};

Chan.prototype.toJSON = function() {
	var clone = _.clone(this);
	clone.count = clone.messages.length;
	clone.messages = clone.messages.slice(-100);
	return clone;
};