var CensusQuery = require('dbgcensus').Query;
var request = require('request');
var query = new CensusQuery('outfit', 'ps2:v2', 'conchubair');
var mysql = require('mysql');
var j, i;
var results;

var connection = mysql.createConnection({
    host: 'localhost',
    user: 'root',
    password: 'cuck420',
    database: 'learning',
});

GatherData();

function GatherData() {
    connection.connect(function (err) {
        if (err) {
            console.error('error connecting: ' + err.stack);
            return;
        }

        console.log('connected as id ' + connection.threadId);
    });
    connection.query('SELECT DISTINCT item_id FROM learning.ac_items;', function (err, result) {
        if (!err) {
            console.log('SQL id finding query complete');
            //console.log(result[0].item_id);

            for (j = 0; j < result.length; j++) {
                //console.log(result[j].item_id);
                request('https://census.daybreakgames.com/s:conchubair/get/ps2/item/' + result[j].item_id + '', function (error, response, body) {
                    if (!error && response.statusCode == 200) {
                        var data = JSON.parse(body);
                        processItems(data);
                    }
                });//closes request
            }//closes for j
        }//closes if

        else {
            console.log('Error');
            console.log(err);

        };//closes commit
    });//closes select distinct
}//closes GatherData

function processItems(data) {
    var item = data.item_list[0];
    //console.log(data);
    if (!item|| !item.name) {
        return;
    }
    var values = [item.item_id, item.name.en, item.item_type_id, item.item_category_id, item.image_id, item.image_path];

    //console.log("item logged");
    console.log(item.item_id);
    connection.query('INSERT INTO item_reference (item_id, name_en, item_type_id, item_category_id, image_id, image_path) VALUES (?,?,?,?,?,?)', values, function (err, result) {
        if (!err) { //mysql.escape()
            //console.log('Query complete');
        }
        else {
            console.log('Error');
            console.log(err);

        };//closes commit
    });//closes connection query insert
}//closes process data