Advertisement
Guest User

Untitled

a guest
May 5th, 2015
437
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
  1. function handler(req,res)
  2. {
  3. res.statusCode = 200;
  4. res.connection.setTimeout(0);
  5. res.end();
  6. }
  7. app.listen(port,ip);
  8.  
  9. var pollingLoop = function(){  
  10. mysql.getConnection(function(err,connection){
  11. if (err) {
  12.   connection.release();
  13.   console.log({"code" : 100, "status" : "Error in connection database"});
  14.   return;
  15. }  
  16. console.log('connected as id ' + connection.threadId);
  17.  
  18. var selection = "SELECT * FROM auctions";  
  19. var streamArray = [], lg = '';                      
  20.  
  21. var query = connection.query(selection, function(err, results, fields, rows){
  22. lg += ('id: '+results[0].id+' ('+results[0].duration+') ');        
  23.  
  24. if (conditions)
  25. {
  26. var query_update = mysql.query('UPDATE `auctions` SET `price` = ? WHERE `id` = ?',[price, auction.id]);
  27. console.log(time()+'UPDATED id '+auction.id+': price ('+price+'€)');    
  28. }                  
  29. streamArray.push(results);        
  30. });    
  31. console.log(time()+lg+' C: '+mysqlArray.length);
  32. pollingTimer = setTimeout(pollingLoop, 1000);
  33. updateSockets({ streamArray: streamArray });    
  34. console.log("auctions pushed: "+streamArray);  
  35.  
  36. connection.on('error', function(err) {      
  37.       console.log({"code" : 100, "status" : "Error in connection database"});
  38.       return;    
  39. });
  40. });
  41. }
  42.  
  43. io.sockets.on('connection', function(socket) {  
  44. pollingLoop();
  45.  
  46. socket.on('disconnect', function() {
  47. clearTimeout(pollingTimer);
  48. var socketIndex = mysqlArray.indexOf(socket);
  49. console.log(time()+'SOCKET-ID = %s DISCONNECTED', socketIndex);
  50. if (~socketIndex) { mysqlArray.splice(socketIndex, 1); }
  51. });  
  52. console.log(time()+'NEW SOCKET CONNECTED!');
  53. mysqlArray.push(socket);
  54. });
  55.  
  56. var updateSockets = function(data) {
  57. mysqlArray.forEach(function(tmpSocket) { tmpSocket.volatile.emit('stream', data); });
  58. };
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement