var admin = '76561198163331062';

var bot_id = "idbot";
var bot_nick = "acc";
var bot_passowrd = "pass";
var bot_secret = "secrtt";
var bot_identity = "identity";
var bot_webapikey = "webapi";

var sitename = "easy4skin.top";
var GameTime = 120;

var mysqlInfo;
mysqlInfo = {
  host     : '127.0.0.1',
  user     : 'acc',
  password : 'pass',
  database : 'database',
  charset  : 'utf8_general_ci'
};


var logOnOptions = {
    accountName: 'acc',
    password: 'pass'
};

var authCode = 'Steamguard Code';

var globalSessionID;

var Steam = require('steam');
var SteamTradeOffers = require('steam-tradeoffers');
var SteamUser = require('steam-user');
var mysql      = require('mysql');
var request = require("request");
var steamuserinfo = require('steam-userinfo');
var SteamConfirm = require('steamcommunity-mobile-confirmations');
var SteamTotp = require('steam-totp');
var setup = false;

var steamcommunityMobileConfirmations;

steamuserinfo.setup(bot_webapikey);


var mysqlConnection = mysql.createConnection(mysqlInfo);

var steam = new SteamUser()
var offers = new SteamTradeOffers();

var recheck = true;

logOnOptions["twoFactorCode"] = SteamTotp.generateAuthCode(bot_secret);

steam.logOn(logOnOptions);


function getUserName(steamid) {
    steamuserinfo.getUserInfo(steamid, function(error, data){
        if(error) throw error;
        var datadec = JSON.parse(JSON.stringify(data.response));
        return (datadec.players[0].personaname);
    });
}

function proceedWinners() {
    var url = 'http://'+sitename+'/getwinner34634f.php';
    request(url, function(error, response, body){});
}

var locked=false,proceeded;
var itemscopy;
var detected=false;
var detected2=false;
function CheckTimer() {
    if(locked == true) return;
    locked = true;
    if(recheck == true) {
        recheck = false;
        checkoffers(1000);
    }
    mysqlConnection.query('SELECT `value` FROM `info` WHERE `name`=\'current_game\'', function(err, rows, fields) {
        if(err) return;
        mysqlConnection.query('SELECT `starttime` FROM `games` WHERE `id`=\''+rows[0].value+'\'', function(errs, rowss, fieldss) {
            if(errs) return;
            var timeleft;
            if(rowss[0].starttime == 2147483647) timeleft = GameTime;
            else {
                var unixtime = Math.round(new Date().getTime()/1000.0);
                timeleft = rowss[0].starttime+GameTime-unixtime;
                if(timeleft < 0) timeleft = 0;
            }
            if(timeleft == 0) {
                if(proceeded == true) return;
                proceedWinners();
                proceeded = true;
            } else proceeded = false;
        });
    });
    detected2 = false;
    offers.loadMyInventory({
        appId: 730,
        contextId: 2
    }, function(err, itemx) {
        if(err) {
            steam.webLogOn(function(newCookie) {
                offers.setup({
                    sessionID: globalSessionID,
                    webCookie: newCookie
                }, function(err) {
                    if (err) {
                    }
                });
            });
            return;
        }
        if(detected2 == true) {
            return;
        }
        detected2 = true;
        itemscopy = itemx;
        detected = false;
        mysqlConnection.query('SELECT * FROM `queue` WHERE `status`=\'active\'', function(err, row, fields) {
            if(err) {
                return;
            }
            if(detected == true) {
                return;
            }
            detected = true;
            for(var i=0; i < row.length; i++) {
                var gameid = row[i].id;
                mysqlConnection.query('UPDATE `queue` SET `status`=\'sent\' WHERE `id`=\''+gameid+'\'', function(err, row, fields) {});
                var sendItems = (row[i].items).split('/');
                var item=[],num=0;
                for (var x = 0; x < itemscopy.length; x++) {
                    for(var j=0; j < sendItems.length; j++) {
                        if (itemscopy[x].tradable && (itemscopy[x].market_name).indexOf(sendItems[j]) == 0) {
                            sendItems[j] = "FASGASFHGASFHGFasdasdasd";
                            item[num] = {
                                appid: 730,
                                contextid: 2,
                                amount: itemscopy[x].amount,
                                assetid: itemscopy[x].id
                            }
                            num++;
                        }
                    }
                }
                if (num > 0) {
                    var gamenum = row[i].id;
                    offers.makeOffer ({
                        partnerSteamId: row[i].userid,
                        itemsFromMe: item,
                        accessToken: row[i].token,
                        itemsFromThem: [],
                        message: 'Ваш выигрыш на сайте '+sitename+' в игре #'+gamenum
                    }, function(err, response){
                        if (err) {
                            return;
                        }
                        console.log('Trade offer for queue '+gamenum+' sent!');
                    });
                }
            }
        });
    });
    setTimeout(function(){locked = false;},100000);
}

steam.on('loggedOn', function(result) {
    console.log('Logged in!');
    steam.setPersona(SteamUser.Steam.EPersonaState.LookingToTrade);
    steam.addFriend("76561198163331062");
    steam.chatMessage(admin,"[SERVER] BOT logged on");
});

steam.on('webSessionID', function(sessionID) {
    globalSessionID = sessionID;
    steam.webLogOn(function(newCookie) {
        offers.setup({
            sessionID: sessionID,
            webCookie: newCookie,
            APIKey: bot_webapikey
        }, function(err) {
            if (err) {
                throw err;
            }

             steamcommunityMobileConfirmations = new SteamConfirm(
            {
                steamid:         bot_id,
                identity_secret: bot_identity,
                device_id:       bot_deviceid,
                webCookie:       globalSessionID
            });
            if(!setup){
                setInterval(CheckTimer,1000);
                checkoffers(4);
                setInterval(handleConfirmation,5000);
                setup = true;
            }
        });
    });
});


function handleConfirmation() {
	this.steamcommunityMobileConfirmations.FetchConfirmations(function (err, confirmations)
        {
            if (err)
            {
                console.log(err);
                return;
            }
            console.log('steamcommunityMobileConfirmations.FetchConfirmations received ' + confirmations.length + ' confirmations');
            if ( ! confirmations.length)
            {
                return;
            }
            steamcommunityMobileConfirmations.AcceptConfirmation(confirmations[0], (function (err, result)
            {
                if (err)
                {
                    console.log(err);
                    return;
                }
            console.log('steamcommunityMobileConfirmations.AcceptConfirmation result: ' + result);
        }).bind(this));
    }.bind(this));
}

steam.on('friendMsg', function(steamID, message, type) {
    if(type != Steam.EChatEntryType.ChatMsg) return;
    if(steamID == admin) {
        if(message.indexOf("/sendallitems") == 0) {
            offers.loadMyInventory({
                appId: 730,
                contextId: 2
            }, function(err, items) {
                if(err) {
                    steam.sendMessage(steamID, 'Не могу загрузить свой инвентарь, попробуй ещё раз');
                    steam.webLogOn(function(newCookie) {
                        offers.setup({
                            sessionID: globalSessionID,
                            webCookie: newCookie
                        }, function(err) {
                            if (err) {
                            }
                        });
                    });
                    return;
                }
                var item=[],num=0;
                for (var i = 0; i < items.length; i++) {
                    if (items[i].tradable) {
                        item[num] = {
                            appid: 730,
                            contextid: 2,
                            amount: items[i].amount,
                            assetid: items[i].id
                        }
                        num++;
                    }
                }
                if (num > 0) {
                    offers.makeOffer ({
                        partnerSteamId: steamID,
                        itemsFromMe: item,
                        itemsFromThem: [],
                        message: ''
                    }, function(err, response){
                        if (err) {
                            throw err;
                        }
                        steam.sendMessage(steamID, 'Обмен отправлен!');
                    });
                }
            });
        } else if(message.indexOf("/send") == 0) {
            var params = message.split(' ');
            if(params.length == 1) return steam.sendMessage(steamID, 'Формат: /send [название предмета]');
            offers.loadMyInventory({
                appId: 730,
                contextId: 2
            }, function(err, items) {
                if(err) {
                    steam.sendMessage(steamID, 'Не могу загрузить свой инвентарь, попробуй ещё раз');
                    steam.webLogOn(function(newCookie) {
                        offers.setup({
                            sessionID: globalSessionID,
                            webCookie: newCookie
                        }, function(err) {
                            if (err) {
                            }
                        });
                    });
                    return;
                }
                var item=0;
                for (var i = 0; i < items.length; i++) {
                        if((items[i].market_name).indexOf(params[1]) != -1) {
                            item = items[i].id;
                            break;
                        }
                    }
                if (item != 0) {
                    offers.makeOffer ({
                        partnerSteamId: steamID,
                        itemsFromMe: [
                        {
                            appid: 730,
                            contextid: 2,
                            amount: 1,
                            assetid: item
                        }
                        ],
                        itemsFromThem: [],
                        message: ''
                    }, function(err, response){
                        if (err) {
                            throw err;
                        }
                        steam.sendMessage(steamID, 'Обмен отправлен!');
                    });
                }
            });
        } else if(message.indexOf("/show") == 0) {
            var params = message.split(' ');
            offers.loadMyInventory({
                appId: 730,
                contextId: 2
            }, function(err, items) {
                if(err) {
                    steam.sendMessage(steamID, 'Не могу загрузить свой инвентарь, попробуй ещё раз');
                    steam.webLogOn(function(newCookie) {
                        offers.setup({
                            sessionID: globalSessionID,
                            webCookie: newCookie
                        }, function(err) {
                            if (err) {
                            }
                        });
                    });
                    return;
                }
                steam.sendMessage(steamID,'Смотри: ');
                for (var i = 0; i < items.length; i++) {
                    steam.sendMessage(steamID,'http://steamcommunity.com/id/kukovicata/inventory/#'+items[i].appid+'_'+items[i].contextid+'_'+items[i].id);
                }
            });
        }
    }
    steamuserinfo.getUserInfo(steamID, function(error, data){
        if(error) throw error;
        var datadec = JSON.parse(JSON.stringify(data.response));
        var name = datadec.players[0].personaname;
        console.log(name + ': ' + message); // Log it
    });
    //steam.sendMessage(steamID, 'I\'m a bot that accepts all your unwanted items.  If you would like to grab a few crates from me, please request a trade.');
});

function checkoffers(number) {
    if (number > 0) {
        offers.getOffers({
            get_received_offers: 1,
            active_only: 1,
            get_sent_offers: 0,
            get_descriptions: 1,
            language: "en_us"
        }, function(error, body) {
            if(error) return;
            if(body.response.trade_offers_received){
                body.response.trade_offers_received.forEach(function(offer) {
                    if (offer.trade_offer_state == 2){
                        if(offer.items_to_give) {
                            offers.declineOffer({tradeOfferId: offer.tradeofferid});
                            return;
                        }
                        mysqlConnection.query('SELECT `value` FROM `info` WHERE `name`=\'maxitems\'', function(err, row, fields) {
                            if(offer.items_to_receive.length > row[0].value) {
                                offers.declineOffer({tradeOfferId: offer.tradeofferid});
                                offer.items_to_receive = [];
                                mysqlConnection.query('INSERT INTO `messages` (`userid`,`msg`,`from`) VALUES (\''+offer.steamid_other+'\',\'toomuch\',\'System\')', function(err, row, fields) {});
                                return;
                            }
                        });
                        offers.loadPartnerInventory({partnerSteamId: offer.steamid_other, appId: 730, contextId: 2, tradeOfferId: offer.tradeofferid, language: "en"}, function(err, hitems) {
                            if(err) {
                                steam.webLogOn(function(newCookie) {
                                    offers.setup({
                                        sessionID: globalSessionID,
                                        webCookie: newCookie
                                    }, function(err) {
                                        if (err) {
                                        }
                                    });
                                });
                                recheck = true;
                                return;
                            }
                            var items = offer.items_to_receive;
                            var wgg=[],num=0;
                            for (var i = 0; i < items.length; i++) {
                                for(var j=0; j < hitems.length; j++) {
                                    if(items[i].assetid == hitems[j].id) {
                                        wgg[num] = hitems[j];
                                        num++;
                                        break;
                                    }
                                }
                            }
                            var price=[];
                            for(var i=0; i < num; i++) {
                                if(wgg[i].appid != 730) {
                                    offers.declineOffer({tradeOfferId: offer.tradeofferid});
                                    mysqlConnection.query('INSERT INTO `messages` (`userid`,`msg`,`from`) VALUES (\''+offer.steamid_other+'\',\'onlycsgo\',\'System\')', function(err, row, fields) {});
                                    return;
                                }
                                if(wgg[i].market_name.indexOf("Souvenir") != -1) {
                                    offers.declineOffer({tradeOfferId: offer.tradeofferid});
                                    mysqlConnection.query('INSERT INTO `messages` (`userid`,`msg`,`from`) VALUES (\''+offer.steamid_other+'\',\'souvenir\',\'System\')', function(err, row, fields) {});
                                    return;
                                }
                                var itemname = wgg[i].market_name;
                                var url = 'http://'+sitename+'/cost.php?item='+encodeURIComponent(itemname);
                                (function(someshit) {
                                request(url, function(error, response, body){
                                    if(!error && response.statusCode === 200){
                                        if(body == "notfound") { offers.declineOffer({tradeOfferId: offer.tradeofferid}); mysqlConnection.query('INSERT INTO `messages` (`userid`,`msg`,`from`) VALUES (\''+offer.steamid_other+'\',\'notavailable\',\'System\')', function(err, row, fields) {}); }
                                        else {
                                            wgg[someshit].cost = parseFloat(body);
                                        }
                                    } else offers.declineOffer({tradeOfferId: offer.tradeofferid});
                                });})(i)
                            }
                            setTimeout(function() {
                                var sum=0;
                                for(var i=0; i < num; i++) {
                                    sum += wgg[i].cost;
                                }
                                mysqlConnection.query('SELECT `value` FROM `info` WHERE `name`=\'minbet\'', function(err, row, fields) {
                                    if(sum < row[0].value) {
                                        num = 0;
                                        offers.declineOffer({tradeOfferId: offer.tradeofferid});
                                        mysqlConnection.query('INSERT INTO `messages` (`userid`,`msg`,`from`) VALUES (\''+offer.steamid_other+'\',\'toosmall!\',\'System\')', function(err, row, fields) {});
                                        return;
                                    }
                                });
                                                steamuserinfo.getUserInfo(offer.steamid_other, function(error, data){
                                                    if(error) throw error;
                                                    var datadec = JSON.parse(JSON.stringify(data.response));
                                                    var name = datadec.players[0].personaname;
                                                    var avatar = datadec.players[0].avatarfull;

                                                    if(num == 0) return;

                                                    mysqlConnection.query('SELECT `value` FROM `info` WHERE `name`=\'current_game\'', function(err, row, fields) {
                                                        var current_game = (row[0].value);
                                                        mysqlConnection.query('SELECT `cost`,`itemsnum` FROM `games` WHERE `id`=\''+current_game+'\'', function(err, row, fields) {
                                                            var current_bank = parseFloat(row[0].cost);
                                                            var itemsnum = row[0].itemsnum;

                                                        if(item.length > 0)     {
                                                                 mysqlConnection.query('UPDATE `games` SET `starttime`=UNIX_TIMESTAMP() WHERE `id` = \'' + current_game + '\'', function(err, row, fields) {});
                                                            }

                                                            for(var j=0; j < num; j++) {
                                                                mysqlConnection.query('INSERT INTO `game' + current_game + '` (`userid`,`username`,`item`,`color`,`value`,`avatar`,`image`,`from`,`to`) VALUES (\'' + offer.steamid_other + '\',\'' + name + '\',\'' + wgg[j].market_name + '\',\'' + wgg[j].name_color + '\',\'' + wgg[j].cost + '\',\'' + avatar + '\',\'' + wgg[j].icon_url + '\',\''+current_bank+'\'+\'0\',\''+current_bank+'\'+\''+wgg[j].cost+'\')', function(err, row, fields) {});
                                                                mysqlConnection.query('UPDATE `games` SET `itemsnum`=`itemsnum`+1, `cost`=`cost`+\''+wgg[j].cost+'\' WHERE `id` = \'' + current_game + '\'', function(err, row, fields) {});
                                                                current_bank = parseFloat(current_bank + wgg[j].cost);
                                                                itemsnum++;
                                                            }


                                                            if(itemsnum > 50) {
                                                                proceedWinners();
                                                            }
                                                            offers.acceptOffer({tradeOfferId: offer.tradeofferid});
                                                            console.log('Accepted trade offer #'+offer.tradeofferid+' by '+name+' ('+offer.steamid_other+')');
                                                        });
                                                    });
                                                });
                                },3000);
                        });
                    }
                });
            }
        });
    }
}

var pew;
steam.on('tradeOffers', checkoffers);

steam.on('sentry', function(data) {
    require('fs').writeFileSync('sentry_'+logOnOptions['accountName']+'.hash', data);
});