TwitchChat Logger

logger.js

"use strict";
var irc 	= require("tmi.js");
var mysql 	= require('mysql');

var database_options = {
  host     : 'localhost',
  user     : 'root',
  password : 'password',
  database : 'irc_logger'
};

var connection = mysql.createConnection(database_options);

function logChat(channel, user, message){
	connection.beginTransaction(function(err) {
		if (err) { throw err; }
		
		connection.query(
			'INSERT INTO messages (channel, user, text, emotes, fullInfo) VALUES (?,?,?,?,?)', 
			[channel, user.username, message, JSON.stringify(user.emotes), JSON.stringify(user)], 
			function(err, result) {
				if(!err){
					
				}else{
					return connection.rollback(function() {throw err; });
				}
			}
		);
		connection.commit(function(err) {
			if (err) {
				return connection.rollback(function() {
					throw err;
				});
			}
			console.log("Logged: ["+channel+"]["+user.username+"] " + message );
		});
	});
}

var IRCLogger = function(games){
	this.client = new irc.client({
		options: {
			debug: false
		},
		connection: {
			random: "chat",
			reconnect: true
		},
		identity: {
			username: "username",
			password: "xxxxxxxxxxxxxxxxxxxxxxxxxxxx"
		}
	});
	this.client.games = games;
	
	this.client.on("connected", function (address, port) {
		var now = new Date();
		console.log("[" + now.toUTCString() + "] Connected");
		for(var i = 0; i < this.games.length; i++){
			
			//Gets the 10 top streams for the game and add them to the log list
			var game = this.games[i].replace(' ', '+');
			var _this = this;
			this.api({
				url: "https://api.twitch.tv/kraken/streams?game="+game+"&limit=10",
				method: "GET",
				headers: {"Accept": "application/vnd.twitchtv.v3+json"}
			},
			function(err, res, body) {
				if(!err){
					var response = JSON.parse(body);
					for(var key in response.streams){
						if (response.streams.hasOwnProperty(key)) {
							console.log(response.streams[key].channel.name);
							_this.join('#'+response.streams[key].channel.name);
						}
					}
				}
			});
		}
	});
	this.client.on("connecting", function (address, port) {
		var now = new Date();
		console.log("[" + now.toUTCString() + "] Connecting to " + address + ":" + port);
	});
	this.client.on("disconnected", function (reason) {
		var now = new Date();
		console.log("[" + now.toUTCString() + "] Disconnected");
	});
	this.client.on("chat", function (channel, user, message, self) {
		logChat(channel, user, message);
	});
	this.client.on("join", function (channel, username) {
		var now = new Date();
		console.log("[" + now.toUTCString() + "] Joining " + channel);
	});
};
IRCLogger.prototype.start = function() {
  this.client.connect();
};
IRCLogger.prototype.restart = function() {
  this.client.disconnect();
  this.client.connect();
};
var logger = new IRCLogger(["Dota 2"]);
logger.start();