trade

var Winston           	= require('winston');
var express             = require('express');
var fs                	= require('fs');
var app                 = require('http').createServer(handler);
var io                  = require('socket.io')(app);
var steamUserInventory  = require('steam-user-inventory');
var mysql 				= require('mysql');
var request             = require('request');


app.listen(8090);

var pool  = mysql.createPool({
    connectionLimit : 10,
    database: 'trade',
    host: 'localhost',
    user: 'root',
    password: 'fncjpfncjpdu86'
});
var response = [];

function handler (req, res) {
    fs.readFile(__dirname + '/index.html',
        function (err, data) {
            if (err) {
                res.writeHead(500);
                return res.end('Error loading index.html');
            }

            res.writeHead(200);
            res.end(data);
        });
}



var app = express();


var items;
var h1z1;
var test;
var table = [];

fs.readdir("items/", function(err, filenames) {
    if (err) {
        onError(err);
        return;
    }
    filenames.forEach(function(filename) {
        fs.readFile("items/" + filename, 'utf-8', function(err, content) {
            if (err) {
                onError(err);
                return;
            }

            var items = JSON.parse(content);
            for (var i = 0; i < items.length; ++i) {
                table.push(items[i]);
            }
        });
    });
});


var h1z1prices;
fs.readFile("price/H1Z1-price.json", 'utf-8', function (err, content) {
    if (err) {
        return console.log(err);
    }
    h1z1prices = JSON.parse(content);
});


function getUserInventory(steamID, game, context) {
    var url = "http://steamcommunity.com/inventory/"+steamID+"/"+game+"/"+context+"?l=english&count=5000";
    request(url , function (error, res, body) {
        if (!error && res.statusCode === 200) {
            // console.log(body) // Print the json response
            var data = JSON.parse(body);
            // console.log(data.descriptions);
            var desc = data.descriptions;
            var assets = data.assets;


            Object.keys(assets).forEach(key => {
                var temp = assets[key];
                var i;
                Object.keys(desc).forEach(key => {
                    var temp2 = desc[key];
                    if (temp.classid == temp2.classid){
                        i = key;
                    }
                });

                let item = desc[i];
                // console.log(temp);
                // console.log(desc);
                let data = {
                    id: temp.assetid,
                    amount: temp.amount,
                    pos: temp.pos,
                    name: item.name,
                    appid: item.appid,
                    classid: item.classid,
                    instanceid: item.instanceid,
                    tradable: item.tradable,
                    marketable: item.marketable,
                    marketTradableRestriction: item.market_tradable_restriction,
                    link: item.actions ? item.actions[0].link : null,
                    image: `http://steamcommunity-a.akamaihd.net/economy/image/${item.icon_url_large || item.icon_url}`,
                    category: null,
                    type: null,
                    exterior: null,
                    quality: null,
                    raw: item,
                };

                item.tags.forEach(tag => {
                    if (tag.category === 'Type') {
                        data.type = tag.internal_name;
                    }
                    if (tag.category === 'Weapon') {
                        data.weapon = tag.internal_name;
                    }
                    if (tag.category === 'Quality') {
                        data.category = tag.internal_name;
                    }
                    if (tag.category === 'Exterior') {
                        data.exterior = tag.internal_name;
                    }
                });

                response.push(data);
            });
            return response;
            // socket.emit('inv user', {inv: response})
        }
    });
}


function loadUserInventory (hash, socket){
    query('SELECT steamID, update_time FROM users WHERE hash = "' + hash +'";', function (err, res) {
        if(err) {
            console.log(err);
        } else {
            var time = res[0].update_time;
            var after = Date.now();
            var verif = after - time;
            var steamID = res[0].steamID;
            if(verif > 120000){
                query('UPDATE users SET update_time = "' + Date.now() + '" WHERE hash = "' + hash +'";', function (err, res1) {
                    if (err) {
                        console.log(err)
                    } else {
                        console.log(steamID);
                        getUserInventory(steamID, '433850', '1');
                        // console.log(getUserInventory(steamID, '433850', '1'));
                        var intervalEmit = setInterval(function () {
                            if (response.length != 0) {
                                query('DELETE FROM users_items WHERE id_user = "' + steamID + '";', function (err, re) {
                                    if (err) {
                                        console.log(err)
                                    } else {
                                        for (var j in response) {
                                            query('INSERT INTO users_items (`appid`, `category`, `classid`, `exterior`, `id`, `image`, `instanceid`, `link`, `marketTradableRestriction`, `marketable`, `name`, `pos`, `commodity`, `description`, `icon_url`, `icon_url_large`, `market_hash_name`, `market_name`, `tag`, `tradable`, `type`, `id_user`) VALUES (' + response[j].appid + ', "' + response[j].category + '", ' + response[j].classid + ', "' + response[j].exterior + '", ' + response[j].id + ', "' + response[j].image + '", ' + response[j].instanceid + ', "' + response[j].link + '", "' + response[j].marketTradableRestriction + '", ' + response[j].marketable + ', "' + response[j].name + '", "' + response[j].pos + '", "' + response[j].commodity + '", "' + response[j].description + '", "' + response[j].icon_url + '", "' + response[j].icon_url_large + '", "' + response[j].market_hash_name + '", "' + response[j].market_name + '", "' + response[j].tag + '", ' + response[j].tradable + ', "' + response[j].type + '", "' + steamID + '" );', function (err, resultat) {
                                                if (err) {
                                                    console.log(err)
                                                }
                                            });
                                        }
                                    }
                                });
                                socket.emit('inv user', {inv: response})
                                clearInterval(intervalEmit);
                            }
                        }, 1000);
                        if (response.length != 0) {
                            query('DELETE FROM users_items WHERE id_user = "' + steamID + '";', function (err, re) {
                                if (err) {
                                    console.log(err)
                                } else {
                                    for (var j in response) {
                                        query('INSERT INTO users_items (`appid`, `category`, `classid`, `exterior`, `id`, `image`, `instanceid`, `link`, `marketTradableRestriction`, `marketable`, `name`, `pos`, `commodity`, `description`, `icon_url`, `icon_url_large`, `market_hash_name`, `market_name`, `tag`, `tradable`, `type`, `id_user`) VALUES (' + response[j].appid + ', "' + response[j].category + '", ' + response[j].classid + ', "' + response[j].exterior + '", ' + response[j].id + ', "' + response[j].image + '", ' + response[j].instanceid + ', "' + response[j].link + '", "' + response[j].marketTradableRestriction + '", ' + response[j].marketable + ', "' + response[j].name + '", "' + response[j].pos + '", "' + response[j].commodity + '", "' + response[j].description + '", "' + response[j].icon_url + '", "' + response[j].icon_url_large + '", "' + response[j].market_hash_name + '", "' + response[j].market_name + '", "' + response[j].tag + '", ' + response[j].tradable + ', "' + response[j].type + '", "' + steamID + '" );', function (err, resultat) {
                                            if (err) {
                                                console.log(err)
                                            }
                                        });
                                    }
                                }
                            });
                            socket.emit('inv user', {inv: response})
                        }
                    }
                });
            } else {
                socket.emit('inv user', {inv: "Stop Refresh ! Just wait 2 minutes !!"})
            }
        }
    });
}



io.on('connection', function (socket) {
    console.log("New connection !!");
    socket.emit('inventory', {result: table});
    socket.emit('h1z1json', { prices: h1z1prices });


    socket.on('load user', function (data) {
        console.log(data.client);
        loadUserInventory(data.client, socket)



    });
});


function query(sql, callback) {
    if (typeof callback === 'undefined') {
        callback = function() {};
    }
    pool.getConnection(function(err, connection) {
        if(err) return callback(err);
        // console.log('DB connection ID: '+connection.threadId);
        connection.query(sql, function(err, rows) {
            if(err) return callback(err);
            connection.release();
            return callback(null, rows);
        });
    });
}