console.log("Loading function");
var AWS = require("aws-sdk");
http = require("http");
var mysql = require('mysql');
var fbResponse;

exports.handler = function(event, context) {
    var eventText = JSON.stringify(event, null, 2);

    var banneduid = [];
    console.log("Received event:", eventText);
    var sns = new AWS.SNS();
    var url = 'http://api.steampowered.com/ISteamUser/GetPlayerBans/v1/?key=092D2362C44E25B35B2E992CDDA4777F&steamids=76561198105892308,76561198240571108,76561198354010197,76561198057545696,76561198202811851,76561198276526903,76561198363897112, 76561197973366643';

http.get(url, function(res){
    var body = '';

    res.on('data', function(chunk){
        body += chunk;
    });

    res.on('end', function(){
        var fbResponse = JSON.parse(body);
        //console.log("Got a response: ", fbResponse.players);
        var lol = "";
        var bans = [];
        for(var attributename in fbResponse.players){
        console.log(fbResponse.players[attributename].SteamId);
        if(fbResponse.players[attributename].CommunityBanned|| fbResponse.players[attributename].NumberOfVACBans > 0 || fbResponse.players[attributename].NumberOfGameBans > 0){

            bans.push(fbResponse.players[attributename].SteamId);
        }
        }

        if (bans.length > 0){

 var connection = mysql.createConnection({
        host     : 'defiancedb.cztab1l9swup.us-west-2.rds.amazonaws.com',
         user     : 'root',
         password : 'LifeDBpass1!',
         database : 'Banned',
         supportBigNumbers : true,
         stringifyObjects : false
        });
        connection.connect(function(err) {
        if (err) {
            console.error('error connecting: ' + err.stack);
        }

  console.log('connected as id ' + connection.threadId);
connection.query('SELECT * FROM `Banned`', function (error, results, fields) {

    for (var RowDataPacket in results){
    banneduid.push(results[RowDataPacket].BannedUid);
  }
    console.log(results);
    console.log(banneduid);
});
});
        var bans1 = [];
        http.get("http://api.steampowered.com/ISteamUser/GetPlayerSummaries/v0002/?key=092D2362C44E25B35B2E992CDDA4777F&steamids=76561198105892308,76561198240571108,76561198354010197,76561198057545696,76561198202811851,76561198276526903,76561198363897112, 76561197973366643", function(res){
        var body = '';

        res.on('data', function(chunk){
        body += chunk;
        });

        res.on('end', function(){
        var fbResponse1 = JSON.parse(body);
        //console.log("Got a response: ", fbResponse1.response);
        for(var attributename in fbResponse1.response.players){
            console.log("jew");
         if(inArray(fbResponse1.response.players[attributename].steamid, bans) != -1 && inArray(fbResponse1.response.players[attributename].steamid, banneduid) === -1){
            connection.query('INSERT INTO `Banned` (BannedUid) VALUES (' + fbResponse1.response.players[attributename].steamid +')' , function (error, results, fields) {});
            bans.splice(inArray(fbResponse1.response.players[attributename].steamid , bans), 0, fbResponse1.response.players[attributename].personaname);
            bans1.push([fbResponse1.response.players[attributename].steamid , fbResponse1.response.players[attributename].personaname]);
         }
        }
        connection.end();
        if (bans1.length !== 0) {
        var smstext = "The following account(s) have been banned";
        console.log(bans1);
        for(var accout in bans1){
            console.log(bans1[accout]);
            smstext += " " + bans1[accout][1];
        }
        /*
        sns.publish({
        Message: smstext,
        Subject: "Test SNS From Lambda",
        TopicArn: "arn:aws:sns:us-west-2:693326762126:aws-iot-button-sns-topic"

        }, context.done);
        */
        console.log(smstext);
        }
        }).on('error', function(e){
        console.log("Got an error: ", e);
        });
        });

                console.log(bans);
        } else {
            connection.end();
        }

}).on('error', function(e){
      console.log("Got an error: ", e);
});
function inArray(needle, haystack) {
    var length = haystack.length;
    for(var i = 0; i < length; i++) {
        if(haystack[i] == needle)
            return i + 1;
    }
    return -1;
}

});
};