Advertisement
GarryLaly

server.js

Jun 26th, 2014
233
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
  1. var express = require("express"),
  2.     mysql = require("mysql"),
  3.     fs = require("fs"),
  4.     io = require("socket.io"),
  5.     app = express(),
  6.     http = require("http"),
  7.     server = http.createServer(app);
  8.    
  9. //get data from config.json
  10. var config = JSON.parse(fs.readFileSync(__dirname + "/config.json")),
  11.     host = process.env.OPENSHIFT_NODEJS_IP || config.host,
  12.     port = process.env.OPENSHIFT_NODEJS_PORT || config.port,
  13.     DB_HOST = config.DB_HOST,
  14.     DB_USER = config.DB_USER,
  15.     DB_PASS = config.DB_PASS,
  16.     DB_NAME = config.DB_NAME;
  17.    
  18. //declar connection mysql
  19. var connection = mysql.createConnection(
  20.     {
  21.         host: DB_HOST,
  22.         user: DB_USER,
  23.         password: DB_PASS,
  24.         database: DB_NAME
  25.     }
  26. );
  27.  
  28. connection.connect();
  29.  
  30. //create listen url
  31. server.listen(port, host, function(){
  32.     console.log("Listen on " + host + ":" + port);
  33. });
  34.  
  35. var client = io.listen(server).sockets;
  36.  
  37. client.on("connection", function(socket){
  38.     connection.query("SELECT * FROM users", function(err, row, fields){
  39.         if (err) throw err;
  40.         socket.emit("list", row);
  41.     });
  42.    
  43.     socket.on("insert", function(data){
  44.         connection.query("INSERT INTO users VALUES('','" + data + "', '')", function(err, row, fields){
  45.             connection.query("SELECT * FROM users", function(err, row, fields){
  46.                 if (err) throw err;
  47.                 client.emit("list", row);
  48.             });
  49.         });
  50.     });
  51. });
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement