var WebSocket = require('ws'), superagent = require('superagent'), tskMD5 = require('./tsk_md5') const readline = require('readline');

const rl = readline.createInterface({    input: process.stdin,    output: process.stdout,    prompt: 'OHAI> ' });

var obj = {}, httpHeader = {}, baseUrl ='', pass = '', ip = '', websocketUrl = ''var keepWsAlive, readyState

function getReadline() { const lines = []; // 用于保存所有輸入信息。 console.log('Please input the range of extensions(eg: 1001,1010):/n') rl.on("line", function(line) {  if (line ==='') {   console.log('The input is empty, please input again:/n')  } else {   lines.push(line);   if (lines.length === 1) {    obj.extensionsArr = line.split(',');    console.log('Please input the password(eg:1234aa):/n')   } else if (lines.length === 2) {    obj.password = line;    pass = line;    console.log('Please input the ip(eg:192.168.124.125):/n')   } else if (lines.length === 3) {    websocketUrl = 'ws://' + line + ':8089/ws';    obj.websocketUrl = websocketUrl;    obj.ip = line;    ip = line;    console.log('Starting register.../n');    // 開始注冊事件    loopRegister(obj)    }  } });  // close事件監(jiān)聽 rl.on("close", function(){  // 結束程序  process.exit(0); }); }

function setHttpHeader(username) {  httpHeader = {   Accept:'application/json, text/javascript, */*; q=0.01',   'Accept-Encoding': 'gzip, deflate',   'Accept-Language': 'zh-CN,zh;q=0.9,en;q=0.8,pt;q=0.7',   'Cache-Control': 'no-cache',   Connection: 'keep-alive',   'Content-Type': 'application/x-www-form-urlencoded; charset=UTF-8',   Cookie: 'TRACKID='+trackid+'; session-identify=sid121076289-1520217430; username=admin; user_id=0',   Host: ip +':8089',   Origin: 'http://'+ip+':8089',   Pragma: 'no-cache',   Referer: 'http://'+ip+':8089/gswave/',   'User-Agent': 'Mozilla/5.0 (Windows NT 6.1; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/38.0.2125.122 Safari/537.36 SE 2.X MetaSr 1.0',   'X-Requested-With':'XMLHttpRequest'  }  var accountData = {   action:'challenge',   user:username  }  baseUrl = 'http://'+ip+':8089/webrtccgi?';  getChanllenge(accountData, username) // 用戶鑒權函數(shù) }

<!--賬號密碼 鑒權-->function getChanllenge(accountData, username) {  console.log('start getChangllenge')  var challenge = ''  //獲取challenge   superagent    .post(baseUrl)    .set(httpHeader)    .type('form')    .send(accountData)    .redirects(0)    .end(function(err, result) {     if (typeof(result) == 'undefined') {      console.error("get challenge is error, result is undefined");     } else {      var responce = result.body      if(responce && responce.status === 0) {       challenge = responce.response.challenge       getCookie(challenge, username)      } else {       console.error('get challenge is error, result.body.status is not 0')      }     }    }); } <!--cookie 鑒權-->  function getCookie(challenge, username) {  var md5key = tskMD5.MD5.hexdigest(challenge + pass) // MD5加密用戶登錄密碼  var subData={   token: md5key,   action: 'login',   user: username  }  // 開始請求進行用戶登錄密碼鑒權，類似ajax請求  superagent   .post(baseUrl)   .set(httpHeader)   .type('form')   .send(subData)   .redirects(0)   .end(function(err, res) {    if (typeof(res) == 'undefined') {     console.log("get cookie is error, result is undefined");    } else {     var responce = res.body     if(responce && responce.status === 0) {     // 登錄鑒權通過，開始執(zhí)行SIP注冊      var cookie = responce.response.cookie      // 注冊函數(shù)      startSocket(username)     } else {      console.log('get cookie is error, result.body.status is not 0')     }    }   }) }

var ws = new WebSocket(websocketUrl, "sip"); # 注意建立的是sip類型的websocket ws.on('open', function open() {  console.log('ws open message1' + message1)  readyState = WebSocket.OPEN  // 發(fā)送相關信息  ws.send(message);  });  ws.on('message', function incoming(data) {  a++;  var dataArr = data.split('/r/n')  if (dataArr[0].indexOf('401') > -1 && a === 1) {   // 發(fā)送注冊信令函數(shù)（其中發(fā)送信令信息，均參考瀏覽器的發(fā)送頭進行拼接）   startRegister(ws, dataArr, username)  } else if (dataArr[0].indexOf('200')) {   // ws.close()   // console.log('register sucess...')  } else {  } });