Advertisement
Guest User

Untitled

a guest
Sep 1st, 2016
80
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 16.91 KB | None | 0 0
  1. var mysql = require('mysql');
  2. var log4js = require('log4js');
  3. var io = require('socket.io')(8000);
  4. var request = require('request');
  5. var fs = require('fs');
  6. var md5 = require('md5');
  7. var sha256 = require('sha256');
  8. var math = require('mathjs');
  9.  
  10. log4js.configure({
  11. appenders: [
  12. { type: 'console' },
  13. { type: 'file', filename: 'logs/site.log' }
  14. ]
  15. });
  16. var logger = log4js.getLogger();
  17.  
  18. var pool = mysql.createPool({
  19. connectionLimit : 10,
  20. database: 'csgo',
  21. host: 'localhost',
  22. user: 'root',
  23. password: 'jenn19960709'
  24. });
  25.  
  26. process.on('uncaughtException', function (err) {
  27. logger.trace('Strange error');
  28. logger.debug(err);
  29. });
  30.  
  31. /* */
  32. var accept = 30;
  33. var wait = 10;
  34. var br = 3;
  35. var chat = 2;
  36. var chatb = 2000000;
  37. var maxbet = 5000000;
  38. var minbet = 1;
  39. var q1 = 2;
  40. var q2 = 14;
  41. var timer = -1;
  42. var users = {};
  43. var roll = 0;
  44. var currentBets = [];
  45. var historyRolls = [];
  46. var usersBr = {};
  47. var usersAmount = {};
  48. var currentSums = {
  49. '0-0': 0,
  50. '1-7': 0,
  51. '8-14': 0
  52. };
  53. var currentRollid = 0;
  54. var pause = false;
  55. var hash = '';
  56. var last_message = {};
  57. /* */
  58.  
  59. load();
  60.  
  61. var prices;
  62. request('http://backpack.tf/api/IGetMarketPrices/v1/?key=56fce4a5c4404545131c8fcf&compress=1&appid=730', function(error, response, body) {
  63. prices = JSON.parse(body);
  64. if(prices.response.success == 0) {
  65. logger.warn('Loaded fresh prices');
  66. if(fs.existsSync(__dirname + '/prices.txt')){
  67. prices = JSON.parse(fs.readFileSync(__dirname + '/prices.txt'));
  68. logger.warn('Prices loaded from cache');
  69. } else {
  70. logger.error('No prices in cache');
  71. process.exit(0);
  72. }
  73. } else {
  74. fs.writeFileSync('prices.txt', body);
  75. logger.trace('New prices loaded');
  76. }
  77. });
  78.  
  79. updateHash();
  80. function updateHash() {
  81. query('SELECT * FROM `hash` ORDER BY `id` DESC LIMIT 1', function(err, row) {
  82. if(err) {
  83. logger.error('Cant get the hash, stopping');
  84. logger.debug(err);
  85. process.exit(0);
  86. return;
  87. }
  88. if(row.length == 0) {
  89. logger.error('Wrong hash found, stopping');
  90. process.exit(0);
  91. } else {
  92. if(hash != row[0].hash) logger.warn('Loaded hash'+row[0].hash);
  93. hash = row[0].hash;
  94. }
  95. });
  96. }
  97.  
  98. io.on('connection', function(socket) {
  99. var user = false;
  100. socket.on('hash', function(hash) {
  101. query('SELECT * FROM `users` WHERE `hash` = '+pool.escape(hash), function(err, row) {
  102. if((err) || (!row.length)) return socket.disconnect();
  103. user = row[0];
  104. users[user.steamid] = {
  105. socket: socket.id,
  106. balance: parseInt(row[0].balance)
  107. }
  108. socket.emit('message', {
  109. accept: accept,
  110. balance: row[0].balance,
  111. br: br,
  112. chat: chat,
  113. chatb: chatb,
  114. count: timer-wait,
  115. icon: row[0].avatar,
  116. maxbet: maxbet,
  117. minbet: minbet,
  118. name: row[0].name,
  119. rank: row[0].rank,
  120. rolls: historyRolls,
  121. type: 'hello',
  122. user: row[0].steamid
  123. });
  124. socket.emit('message', {
  125. type: 'logins',
  126. count: Object.size(io.sockets.connected)
  127. });
  128. currentBets.forEach(function(itm) {
  129. socket.emit('message', {
  130. type: 'bet',
  131. bet: {
  132. amount: itm.amount,
  133. betid: itm.betid,
  134. icon: itm.icon,
  135. lower: itm.lower,
  136. name: itm.name,
  137. rollid: itm.rollid,
  138. upper: itm.upper,
  139. user: itm.user,
  140. won: null
  141. },
  142. sums: {
  143. 0: currentSums['0-0'],
  144. 1: currentSums['1-7'],
  145. 2: currentSums['8-14'],
  146. }
  147. });
  148. });
  149. });
  150. });
  151. socket.on('mes', function(m) {
  152. if(!user) return;
  153. logger.debug(m);
  154. if(m.type == "bet") return setBet(m, user, socket);
  155. if(m.type == "balance") return getBalance(user, socket);
  156. if(m.type == "chat") return ch(m, user, socket);
  157. if(m.type == "plus") return plus(user, socket);
  158. });
  159. socket.on('disconnect', function() {
  160. io.sockets.emit('message', {
  161. type: 'logins',
  162. count: Object.size(io.sockets.connected)
  163. });
  164. delete users[user.steamid];
  165. })
  166. });
  167.  
  168. function plus(user, socket) {
  169. query('SELECT * FROM `users` WHERE `steamid` = '+pool.escape(user.steamid), function(err, row) {
  170. if(err) return;
  171. if(time() > row[0].plus) {
  172. query('UPDATE `users` SET `plus` = '+pool.escape(time()+10*60)+', `balance` = `balance` + 1 WHERE `steamid` = '+user.steamid);
  173. socket.emit('message', {
  174. type: 'alert',
  175. alert: 'Confirmed'
  176. });
  177. getBalance(user, socket);
  178. } else {
  179. socket.emit('message', {
  180. type: 'alert',
  181. alert: 'You have '+(row[0].plus-time())+' to accept'
  182. });
  183. }
  184. });
  185. }
  186.  
  187. function ch(m, user, socket) {
  188. if(m.msg) {
  189. if(last_message[user.steamid]+1 >= time()) {
  190. console.log('Too fast');
  191. return;
  192. } else {
  193. last_message[user.steamid] = time();
  194. }
  195. var res = null;
  196. if (res = /^\/send ([0-9]*) ([0-9]*)/.exec(m.msg)) {
  197. logger.trace('We need to send coins from '+res[2]+' to '+res[1]);
  198. query('SELECT `balance` FROM `users` WHERE `steamid` = '+pool.escape(user.steamid), function(err, row) {
  199. if((err) || (!row.length)) {
  200. logger.error('Failed to get the person in the database');
  201. logger.debug(err);
  202. socket.emit('message', {
  203. type: 'error',
  204. enable: false,
  205. error: 'Error: User not in DB.'
  206. });
  207. return;
  208. }
  209. if(row[0].balance < res[2]) {
  210. socket.emit('message', {
  211. type: 'error',
  212. enable: false,
  213. error: 'Error: Insufficient funds.'
  214. });
  215. } else if(res[2] <= 0) {
  216. socket.emit('message', {
  217. type: 'error',
  218. enable: false,
  219. error: 'Error: Amount must be greater than 0.'
  220. });
  221. } else {
  222. query('SELECT `name` FROM `users` WHERE `steamid` = '+pool.escape(res[1]), function(err2, row2) {
  223. if((err) || (!row.length)) {
  224. logger.error('Failed to get the STEAMID');
  225. logger.debug(err);
  226. socket.emit('message', {
  227. type: 'error',
  228. enable: false,
  229. error: 'Error: Unknown receiver.'
  230. });
  231. return;
  232. }
  233. query('UPDATE `users` SET `balance` = `balance` - '+res[2]+' WHERE `steamid` = '+pool.escape(user.steamid));
  234. query('UPDATE `users` SET `balance` = `balance` + '+res[2]+' WHERE `steamid` = '+pool.escape(res[1]));
  235. query('INSERT INTO `transfers` SET `from1` = '+pool.escape(user.steamid)+', `to1` = '+pool.escape(res[1])+', `amount` = '+pool.escape(res[2])+', `time` = '+pool.escape(time()));
  236. socket.emit('message', {
  237. type: 'alert',
  238. alert: 'You sent '+res[2]+' coins to '+row2[0].name+'.'
  239. });
  240. getBalance(user, socket);
  241. });
  242. }
  243. });
  244. } else if (res = /^\/mute ([0-9]*) ([0-9]*)/.exec(m.msg)) {
  245. if(user.rank > 0) {
  246. var t = time();
  247. query('UPDATE `users` SET `mute` = '+pool.escape(parseInt(t)+parseInt(res[2]))+' WHERE `steamid` = '+pool.escape(res[1]));
  248. socket.emit('message', {
  249. type: 'alert',
  250. alert: 'You mute '+res[1]+' to '+res[2]
  251. });
  252. }
  253. } else {
  254.  
  255. query('SELECT `mute` FROM `users` WHERE `steamid` = '+pool.escape(user.steamid), function(err, row) {
  256. if(err) return;
  257. if(row[0].mute > time()) {
  258. socket.emit('message', {
  259. type: 'alert',
  260. alert: 'You are muted '+(row[0].mute-time())
  261. });
  262. return;
  263. }
  264. io.sockets.emit('message', {
  265. type: 'chat',
  266. msg: safe_tags_replace(m.msg),
  267. name: user.name,
  268. icon: user.avatar,
  269. user: user.steamid,
  270. rank: user.rank,
  271. lang: m.lang,
  272. hide: m.hide
  273. });
  274. });
  275. }
  276. }
  277. }
  278.  
  279. function getBalance(user, socket) {
  280. query('SELECT `balance` FROM `users` WHERE `steamid` = '+pool.escape(user.steamid), function(err, row) {
  281. if((err) || (!row.length)) {
  282. logger.error('Failed to load your balance');
  283. logger.debug(err);
  284. socket.emit('message', {
  285. type: 'error',
  286. enable: true,
  287. error: 'Error: You are not DB.'
  288. });
  289. return;
  290. }
  291. socket.emit('message', {
  292. type: 'balance',
  293. balance: row[0].balance
  294. });
  295. if(user.steamid) users[user.steamid].balance = parseInt(row[0].balance);
  296. })
  297. }
  298.  
  299. function setBet(m, user, socket) {
  300. if((usersBr[user.steamid] !== undefined) && (usersBr[user.steamid] == br)) {
  301. socket.emit('message', {
  302. type: 'error',
  303. enable: true,
  304. error: 'You\'ve already placed '+usersBr[user.steamid]+'/'+br+' bets this roll.'
  305. });
  306. return;
  307. }
  308. if((m.amount < minbet) || (m.amount > maxbet)) {
  309. socket.emit('message', {
  310. type: 'error',
  311. enable: true,
  312. error: 'Invalid bet amount.'
  313.  
  314. });
  315. return;
  316. }
  317. if(pause) {
  318. socket.emit('message', {
  319. type: 'error',
  320. enable: false,
  321. error: 'Betting for this round is closed.'
  322. });
  323. return;
  324. }
  325. if(m.upper - m.lower > 6){
  326. logger.warn("User tried to place an invalid bid!! (Might be hacking)");
  327. return;
  328. } else {
  329. if(m.lower != 0 && m.lower != 1 && m.lower != 8){
  330. logger.warn("User is trying some weird offset!! (Might be hacking)");
  331. return;
  332. }
  333. if(m.lower == 0){
  334. m.upper = 0;
  335. } else {
  336. m.upper = m.lower + 6;
  337. }
  338. }
  339. var start_time = new Date();
  340. query('SELECT `balance` FROM `users` WHERE `steamid` = '+pool.escape(user.steamid), function(err, row) {
  341. if((err) || (!row.length)) {
  342. logger.error('Failed to find DB');
  343. logger.debug(err);
  344. socket.emit('message', {
  345. type: 'error',
  346. enable: true,
  347. error: 'You are not DB'
  348. });
  349. return;
  350. }
  351. if(row[0].balance >= m.amount) {
  352. query('UPDATE `users` SET `balance` = `balance` - '+parseInt(m.amount)+' WHERE `steamid` = '+pool.escape(user.steamid), function(err2, row2) {
  353. if(err2) {
  354. logger.error('Error in withdraw');
  355. logger.debug(err);
  356. socket.emit('message', {
  357. type: 'error',
  358. enable: true,
  359. error: 'You dont have enough points'
  360. });
  361. return;
  362. }
  363. query('INSERT INTO `bets` SET `user` = '+pool.escape(user.steamid)+', `amount` = '+pool.escape(m.amount)+', `lower` = '+pool.escape(m.lower)+', `upper` = '+pool.escape(m.upper), function(err3, row3) {
  364. if(err3) {
  365. logger.error('Error in DB');
  366. logger.debug(err);
  367. return;
  368. }
  369. var end = new Date();
  370. if(usersBr[user.steamid] === undefined) {
  371. usersBr[user.steamid] = 1;
  372. } else {
  373. usersBr[user.steamid]++;
  374. }
  375. if(usersAmount[user.steamid] === undefined) {
  376. usersAmount[user.steamid] = {
  377. '0-0': 0,
  378. '1-7': 0,
  379. '8-14': 0
  380. };
  381. }
  382. usersAmount[user.steamid][m.lower+'-'+m.upper] += parseInt(m.amount);
  383. currentSums[m.lower+'-'+m.upper] += m.amount;
  384. socket.emit('message', {
  385. type: 'betconfirm',
  386. bet: {
  387. betid: row3.insertId,
  388. lower: m.lower,
  389. upper: m.upper,
  390. amount: usersAmount[user.steamid][m.lower+'-'+m.upper]
  391. },
  392. balance: row[0].balance-m.amount,
  393. mybr: usersBr[user.steamid],
  394. br: br,
  395. exec: (end.getTime()-start_time.getTime()).toFixed(3)
  396. });
  397. users[user.steamid].balance = row[0].balance-m.amount;
  398. io.sockets.emit('message', {
  399. type: 'bet',
  400. bet: {
  401. amount: usersAmount[user.steamid][m.lower+'-'+m.upper],
  402. betid: row3.insertId,
  403. icon: user.avatar,
  404. lower: m.lower,
  405. name: user.name,
  406. rollid: currentRollid,
  407. upper: m.upper,
  408. user: user.steamid,
  409. won: null
  410. },
  411. sums: {
  412. 0: currentSums['0-0'],
  413. 1: currentSums['1-7'],
  414. 2: currentSums['8-14'],
  415. }
  416. });
  417. currentBets.push({
  418. amount: m.amount,
  419. betid: row3.insertId,
  420. icon: user.avatar,
  421. lower: m.lower,
  422. name: user.name,
  423. rollid: currentRollid,
  424. upper: m.upper,
  425. user: user.steamid,
  426. });
  427. logger.debug('Bet #'+row3.insertId+' Ammount: '+m.amount);
  428. checkTimer();
  429. })
  430. });
  431. } else {
  432. socket.emit('message', {
  433. type: 'error',
  434. enable: true,
  435. error: 'You dont have any money'
  436. });
  437. }
  438. });
  439. }
  440.  
  441. function checkTimer() {
  442. if((currentBets.length > 0) && (timer == -1) && (!pause)) {
  443. logger.trace('Timer starting');
  444. timer = accept+wait;
  445. timerID = setInterval(function() {
  446. logger.trace('Timer: '+timer+' Site timer: '+(timer-wait));
  447. if (timer == wait) {
  448. pause = true;
  449. logger.trace('Pause included');
  450. var inprog = getRandomInt(0, (currentBets.length/4).toFixed(0));
  451. io.sockets.emit('message', {
  452. type: 'preroll',
  453. totalbets: currentBets.length-inprog,
  454. inprog: inprog,
  455. sums: {
  456. 0: currentSums['0-0'],
  457. 1: currentSums['1-7'],
  458. 2: currentSums['8-14'],
  459. }
  460. });
  461. }
  462. if (timer == wait-2) {
  463. logger.trace('Timer: ');
  464. toWin(); // Выбираем победителя
  465. }
  466. if(timer == 0) {
  467. logger.trace('Reset');
  468. timer = accept+wait;
  469. currentBets = [];
  470. historyRolls.push({id: currentRollid, roll: roll});
  471. if(historyRolls.length > 10) historyRolls.slice(1);
  472. usersBr = {}; // сколько пользователи внесли
  473. usersAmount = {}; // сколько пользователи внесли монеток
  474. currentSums = {
  475. '0-0': 0,
  476. '1-7': 0,
  477. '8-14': 0
  478. };
  479. currentRollid = currentRollid+1;
  480. pause = false;
  481. }
  482. timer--;
  483. }, 1000);
  484. }
  485. }
  486.  
  487. function toWin() {
  488. var sh = sha256(hash+'-'+currentRollid);
  489. roll = sh.substr(0, 8);
  490. roll = parseInt(roll, 16);
  491. roll = math.abs(roll) % 15;
  492. logger.trace('Rolled '+roll);
  493. var r = '';
  494. var s = q1;
  495. var wins = {
  496. '0-0': 0,
  497. '1-7': 0,
  498. '8-14': 0
  499. }
  500. if(roll == 0) { r = '0-0'; s = q2; wins['0-0'] = currentSums['0-0']*s; }
  501. if((roll > 0) && (roll < 8)) { r = '1-7'; wins['1-7'] = currentSums['1-7']*s; }
  502. if((roll > 7) && (roll < 15)) { r = '8-14'; wins['8-14'] = currentSums['8-14']*s; }
  503. logger.debug(currentBets);
  504. logger.debug(usersBr);
  505. logger.debug(usersAmount);
  506. logger.debug(currentSums);
  507. for(key in users) {
  508. if(usersAmount[key] === undefined) {
  509. var balance = null;
  510. var won = 0;
  511. } else {
  512. var balance = parseInt(users[key].balance)+usersAmount[key][r]*s;
  513. var won = usersAmount[key][r]*s;
  514. }
  515. if (io.sockets.connected[users[key].socket]) io.sockets.connected[users[key].socket].emit('message', {
  516. balance: balance,
  517. count: accept,
  518. nets: [{
  519. lower: 0,
  520. samount: currentSums['0-0'],
  521. swon: wins['0-0'],
  522. upper: 0
  523. }, {
  524. lower: 1,
  525. samount: currentSums['1-7'],
  526. swon: wins['1-7'],
  527. upper: 7
  528. }, {
  529. lower: 8,
  530. samount: currentSums['8-14'],
  531. swon: wins['8-14'],
  532. upper: 14
  533. }
  534. ],
  535. roll: roll,
  536. rollid: currentRollid+1,
  537. type: "roll",
  538. wait: wait-2,
  539. wobble: getRandomArbitary(0, 1),
  540. won: won
  541. });
  542. }
  543. currentBets.forEach(function(itm) {
  544. if((roll >= itm.lower) && (roll <= itm.upper)) {
  545. logger.debug('Rate #'+itm.betid+' sum '+itm.amount+' win '+(itm.amount*s));
  546. query('UPDATE `users` SET `balance` = `balance` + '+itm.amount*s+' WHERE `steamid` = '+pool.escape(itm.user));
  547. }
  548. });
  549. query('UPDATE `rolls` SET `roll` = '+pool.escape(roll)+', `hash` = '+pool.escape(hash)+', `time` = '+pool.escape(time())+' WHERE `id` = '+pool.escape(currentRollid));
  550. query('INSERT INTO `rolls` SET `roll` = -1');
  551. updateHash();
  552. }
  553.  
  554.  
  555.  
  556.  
  557.  
  558.  
  559.  
  560.  
  561.  
  562. /* */
  563. var tagsToReplace = {
  564. '&': '&amp;',
  565. '<': '&lt;',
  566. '>': '&gt;'
  567. };
  568.  
  569. function replaceTag(tag) {
  570. return tagsToReplace[tag] || tag;
  571. }
  572.  
  573. function safe_tags_replace(str) {
  574. return str.replace(/[&<>]/g, replaceTag);
  575. }
  576. Object.size = function(obj) {
  577. var size = 0,
  578. key;
  579. for (key in obj) {
  580. if (obj.hasOwnProperty(key)) size++;
  581. }
  582. return size;
  583. };
  584. function getRandomInt(min, max) {
  585. return Math.floor(Math.random() * (max - min + 1)) + min;
  586. }
  587. function getRandomArbitary(min, max) {
  588. return Math.random() * (max - min) + min;
  589. }
  590.  
  591. function query(sql, callback) {
  592. if (typeof callback === 'undefined') {
  593. callback = function() {};
  594. }
  595. pool.getConnection(function(err, connection) {
  596. if(err) return callback(err);
  597. logger.info('DB Connection ID: '+connection.threadId);
  598. connection.query(sql, function(err, rows) {
  599. if(err) return callback(err);
  600. connection.release();
  601. return callback(null, rows);
  602. });
  603. });
  604. }
  605. function load() {
  606. query('SET NAMES utf8');
  607. query('SELECT `id` FROM `rolls` ORDER BY `id` DESC LIMIT 1', function(err, row) {
  608. if((err) || (!row.length)) {
  609. logger.error('Cant get number from the last game');
  610. logger.debug(err);
  611. process.exit(0);
  612. return;
  613. }
  614. currentRollid = row[0].id;
  615. logger.trace('Roll '+currentRollid);
  616. });
  617. loadHistory();
  618. setTimeout(function() { io.listen(8080); }, 3000);
  619. }
  620. function loadHistory() {
  621. query('SELECT * FROM `rolls` ORDER BY `id` LIMIT 10', function(err, row) {
  622. if(err) {
  623. logger.error('Cant load betting history');
  624. logger.debug(err);
  625. process.exit(0);
  626. }
  627. logger.trace('Sucesfully updated history');
  628. row.forEach(function(itm) {
  629. if(itm.roll != -1) historyRolls.push(itm);
  630. });
  631. });
  632. }
  633.  
  634. function time() {
  635. return parseInt(new Date().getTime()/1000)
  636. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement