const io = require('socket.io')(6565);
const mysql = require('mysql');
const SqlString = require('sqlstring');

//const setTZ = require('set-tz');

//setTZ('CET');

var isRun  = false;
var state  = 0;

const db = mysql.createConnection({
  host: '127.0.0.1',
  user: 'root',
  port: 3306,
  password: '6buWWMz24b7f6Ji8IF'
});



const dbList = ['deimos', 'pandora', 'telawel', 'hutena'];

const worldsRegexp = 'deimos|pandora|telawel|hutena|tarhuna|katahha';

check_fake_world = function (string) {
       var regexp = new RegExp('(\\b)(' + worldsRegexp + ')(\\b)','ig');

       return regexp.test(string);
}


get_user_info = function (type, server, user_id, callback) {
  console.log(`${type} ${server} ${user_id}`);

   if(type == 'games') {
      db.query(`USE ${server}`, (err, res) => {
          if(!err) {
            db.query('SELECT ABS(SUM(`change`)) AS `sum`, COUNT(*) AS `ile` FROM transactions WHERE `change` < 0 AND `round_id` > 0 AND `user` = ?', [user_id], (err, res, fields) => {
                if(!err) {
                 callback(res);
                }
            });
          }

          else {
            console.log(err);
          }
      });
   }

   else if(type == 'match') {
     db.query(`USE ${server}`, (err1, res) => {
        if(!err1) {
          db.query('SELECT COUNT(user) as ammount FROM transactions WHERE user = ? AND reason = ?', [user_id, 'Wpłata'], (err2, res2) => {
                if(!err2) {
                   callback(err2, res2[0].ammount);
                }
          });
        }

        else {
          console.log(err);
        }
     });
   }
}

set_status_db = function (c) {
  if(c == 'online') {
     for(let i in dbList) {
       db.query(`UPDATE ${dbList[i]}.CI_Settings SET withdraw_state = 1`);
       db.query(`UPDATE ${dbList[i]}.CI_Settings SET deposit_state = 1`);
     }
  }

  else {
     for(let i in dbList) {
       db.query(`UPDATE ${dbList[i]}.CI_Settings SET withdraw_state = 0`);
       db.query(`UPDATE ${dbList[i]}.CI_Settings SET deposit_state' = 0`);
     }
  }
}

/*
addValute = function (server, id, val) {
   db.query(`USE ${server}`, (err, res) => {
       if(!err) {
          db.query(`UPDATE CI_User SET coins = coins + ${val} WHERE id = ? LIMIT 1`, [id], (err, res, fields) => {
            if(!err) {
               console.log('Dodaje logi.');
               add_logs(server, 'wplata', val, id);
             }
         });
       }

       else {
        console.log(err);
       }
   });
}
*/

add_logs = function (server, type, ammount, user_id) {
   db.query(`USE ${server}`, (err, res) => {
       if(!err) {

          if(type == 'wplata') {
            db.query('INSERT INTO `transactions` (`user`, `change`, `reason`) VALUES(?, ?, ?)', [user_id, ammount, 'Wpłata'], (err2, res2) => {
                 if(!err2) {
                     console.log(res);
                 }

                 else {
                  console.log(err2);
                 }
            });
          }

          else if(type == 'wyplata') {
           db.query('INSERT INTO `transactions` (`user`, `change`, `reason`) VALUES(?, -1 * ABS(?), ?)', [user_id, ammount, 'Wypłata'], (err2, res2) => {
                 if(!err2) {
                     console.log(res);
                 }

                 else {
                  console.log(err2);
                 }
            });
          }

       }
   });
}

/*
MinusUserValute = function (server, val, user_id) {
   db.query(`USE ${server}`, (err, res) => {
      if(!err) {
         db.query(`UPDATE CI_User SET coins = coins - ${val} WHERE id = ?`, [user_id], (err, res, fields) => {
             add_logs(server, 'wyplata', val, user_id);
         });
      }

      else {
        console.log(err);
      }
   });
} */

exchange = function (server, pin, val, id, nick, socket) {
  db.query(`USE ${server}`, (err, res) => {
      if(!err) {
        db.query(`SELECT id, coins FROM CI_User WHERE mypin = ? AND id = ?`, [pin, id], (err, res, fields) => {
          if(!err) {
           if(res.length > 0) {
             if(res[0].coins >= val) {
              //  MinusUserValute(server, val, id);
              add_logs(server, 'wyplata', val, id);

           socket.emit('exchange', {
                  nick: nick,
                  val: val
              });

           }
         }
      }
  });
      }
  })
}

io.sockets.on('connection', (socket) => {

	   socket.emit('bot status', isRun);

     socket.on('add valute', (data) => {

     if(typeof data.server != 'undefined' && typeof data.id != 'undefined' && data.val != 'undefined' && typeof data.val == 'number' && check_fake_world(data.server)) {
                 db.query(`USE ${data.server}`, (err, res) => {
                     if(!err) {
                       if(data.val >= 1000000 && data.val <= 1000000000) {
                         add_logs(data.server, 'wplata', data.val, data.id);
                       }

                       else {
                        console.log('Gracz chcę za mało wpłacić!');
                       }
                     }
                 });
             }
       });

       socket.on('exchange', (data) => {
        get_user_info('games', data.server, data.user_id, (res) => {
               if(res[0].ile >= 8) {

                   get_user_info('match', data.server, data.user_id, (err2, ammount) => {
                        if(ammount >= 1) {

                          if(typeof data.server != 'undefined' && typeof data.val != 'undefined' && data.pin != 'undefined' && data.user_id != 'undefined' && typeof data.server != 'undefined'  && check_fake_world(data.server)) {
                               exchange(data.server, data.pin, data.val, data.user_id, data.nick, socket);
                           }
                       }

                       else {
                        console.log('Za mało wpłat.');
                       }

                   });
               }

               else {
                 console.log('Za mało rozegrał meczy!');
               }
          });
       });

       socket.on('update bot state', (res) => {
       	   state = res;
       });

       socket.on('get bot state', (res) => {
             socket.emit('bot state', state);
       });


       socket.on('set bot status', (res) => {
       	   if(res == 'online') {
                isRun = true;
               // set_status_db('online');
                socket.emit('message', 'Bot uruchomiony.');
       	   }

       	   else if(res == 'offline') {
                isRun = false;
                state = 0;
                //set_status_db('offline');
                socket.emit('message', 'Bot Wyłączony.');
       	   }
       });
});