var Steam = require('steam');
var SteamTradeOffers = require('steam-tradeoffers');
var SteamWebLogOn = require('steam-weblogon');
var mysql = require('mysql');
const readline = require('readline');

/**
 *
 *
 * CONFIG
 *
 *
 */

var connection = mysql.createConnection({ // MySql details that should be the same as the lua server.
  host     : '{Removed}',
  user     : '{Removed}',
  password : '{Removed}',
  database : '{Removed}'
});
var username = '{Removed}'; // The username of the account
var _password = '{Removed}'; // The password of the account
var _seconds = 60 // How often the bot checks for new trade offers to accept.

/**
 *
 *
 * END OF CONFIG
 *
 *
 */



var offers = new SteamTradeOffers();
var steamClient = new Steam.SteamClient();
var steamUser = new Steam.SteamUser(steamClient);
var steamWebLogOn = new SteamWebLogOn(steamClient, steamUser);

var authCode;
var loggedon = false;
const rl = readline.createInterface({
  input: process.stdin,
  output: process.stdout
});

console.log("Connecting to steam... (Might take a while)")
steamClient.connect();
steamClient.on('connected', function() {
    console.log("Connected.")
    rl.question('Mobile Auth Code: ', (authCode) => {
        steamUser.logOn({
          account_name: username,
          password: _password,
          two_factor_code: authCode
        });
      rl.close();
    });
});

steamClient.on('logOnResponse', function(logonResp) {
  if (logonResp.eresult == Steam.EResult.OK) {
    console.log('Logged in!');
    steamWebLogOn.webLogOn(function(webSessionID, cookies){
        offers.setup({
            sessionID: webSessionID,
            webCookie: cookies,
            APIKey: ""
        });
        loggedon = true;
    });
  }
});
setInterval(function(){
    if (!loggedon) { return };
    connection.query("UPDATE vsb_ping SET ping = '" + Math.floor(new Date() / 1000) + "';")
    console.log("Checking for trades to accept..");
    connection.query("SELECT * FROM vsb_trades WHERE status = '0';",function (error, results, fields) {
        if (error) throw error;
        for (i=0;i < results.length;i++) {
            console.log("Accepting offer " + results[i].offerid + "...");
            offers.acceptOffer({
              tradeOfferId: results[i].offerid
            });
            connection.query("UPDATE vsb_trades SET status ='1' WHERE offerid = '" + results[i].offerid +"';")
        }
    });
},1000 * _seconds);
setInterval(function () { // Keepalive
    connection.query('SELECT 1');
}, 5000);