index.js

var mysql = require('mysql');
var WebSocketServer = require('websocket').server;
//var http = require('http');

'use strict'
const https = require('https');
const fs = require('fs');
const ws = require('ws');

const options = {
  key: fs.readFileSync('wildcard_bkpm_go_id_2018.key'),
  cert: fs.readFileSync('star_bkpm_go_id.crt')
};



var websocketList = [];

var server = https.createServer(options, (req, res) => {
  // process HTTP request. Since we're writing just WebSockets
  // server we don't have to implement anything.
});
server.listen(1337, function() {
    console.log("Web socket start...");
});


var connection_mysql = mysql.createConnection({
  host     : 'localhost',
  user     : 'super_root',
  password : 'qwerty147',
  database : 'antrian_bkpm'
});

connection_mysql.connect();

// create the server
wsServer = new WebSocketServer({
  httpServer: server
});

// WebSocket server
wsServer.on('request', function(request) {

  var connection = request.accept(null, request.origin);

  // This is the most important callback for us, we'll handle
  // all messages from users here.
  connection.on('message', function(message) {

    websocketList.forEach(ws => {
        ws.send(data);
    });

    // Terima pesan dari CLIENT
    if (message.type === 'utf8') {
      var msgClient = message.utf8Data;

      if(msgClient == "plasma_pop_up") {
            connection_mysql.query('select * from temp_panggilan  where  status='0' and ID_TEMP_PANGGILAN like '".date('ymd')."%' order by ID_TEMP_PANGGILAN ASC', function (error, results, fields) {
              if (error) throw error;
             var mydata = "no_data";
             if(results[0].PANGILAN){
                // kirim balik ke client
                console.log('The solution is: ', results[0].PANGILAN);
                var str_pg  = results[0].PANGILAN.split(";");
                var panggil =  $str_pg[0]."%%$$%%".$str_pg[1]."%%$$%%".$data->ID_TEMP_PANGGILAN;
                connection.send(results[0].PANGILAN);
             }
             else {

             }
              c
            });
      }

    }
  });

  connection.on('close', function(connection) {
    // close user connection
  });
});