1 line
9.0 KiB
JavaScript
1 line
9.0 KiB
JavaScript
|
!function(e){var t={};function s(r){if(t[r])return t[r].exports;var i=t[r]={i:r,l:!1,exports:{}};return e[r].call(i.exports,i,i.exports,s),i.l=!0,i.exports}s.m=e,s.c=t,s.d=function(e,t,r){s.o(e,t)||Object.defineProperty(e,t,{enumerable:!0,get:r})},s.r=function(e){"undefined"!=typeof Symbol&&Symbol.toStringTag&&Object.defineProperty(e,Symbol.toStringTag,{value:"Module"}),Object.defineProperty(e,"__esModule",{value:!0})},s.t=function(e,t){if(1&t&&(e=s(e)),8&t)return e;if(4&t&&"object"==typeof e&&e&&e.__esModule)return e;var r=Object.create(null);if(s.r(r),Object.defineProperty(r,"default",{enumerable:!0,value:e}),2&t&&"string"!=typeof e)for(var i in e)s.d(r,i,function(t){return e[t]}.bind(null,i));return r},s.n=function(e){var t=e&&e.__esModule?function(){return e.default}:function(){return e};return s.d(t,"a",t),t},s.o=function(e,t){return Object.prototype.hasOwnProperty.call(e,t)},s.p="",s(s.s=0)}([function(e,t,s){let r=s(1);new class extends r{constructor(e){super("192.168.2.209",28e3),this.ping()}Pong(e,t){console.log("Pong!!"),this.ping()}ping(){console.log("sending ping"),this.send("Ping",{},(e,t)=>{console.log("ping callback",e,t)})}}},function(e,t,s){let{StreamParser:r}=s(2);e.exports=class{constructor(e,t){this._status="CLOSED",this._sendQueue=[],this._callbacks={},this._messageCount=0,this._buffer="",this._url=`ws://${e}:${t}`,this._connect()}_connect(){this._socket=new WebSocket(this._url),this._socket.onopen=this._opened.bind(this),this._socket.onclose=this._closed.bind(this),this._socket.onerror=this._error.bind(this),this._socket.onmessage=this._message.bind(this),this._parser=new r({write:{writable:!0,on:(e,t)=>{this._closedListener=t},write:this._socket.send.bind(this._socket)}}),this._parser.on("reply",({err:e,cmd:t})=>{let s=t.Passport.Pid;this._callbacks[s](e,t)}),this._parser.on("query",e=>{this._dispatch(e)})}_message(e){this._parser.data(e.data.toString())}_dispatch(e){e.Cmd in this&&this[e.Cmd](e,(e,t)=>{this._parser.reply(e,t)})}_error(e){console.log(e)}_closed(e){this._status="CLOSED",this._closedListener(e),console.log("setTimeout"),setTimeout(this._connect.bind(this),0)}_opened(e){this._status="OPEN";for(let e in this._sendQueue){let[t,s]=this._sendQueue[e];this._send(t,s)}this._sendQueue=[]}async send(e,t,s){let r=++this._messageCount,i=Object.assign(t,{Cmd:e,Passport:{Query:!0,Pid:""+r}}),n=s?"query":"ping";if(this._send(n,i),!s)return await new Promise(e=>{this._callbacks[r]=((t,s)=>{delete this._callbacks[r],e(t?[t,s]:s)})});this._callbacks[r]=((e,t)=>{delete this._callbacks[r],s(e,t)})}_send(e,t){"CLOSED"!==this._status?this._parser[e](t):this._sendQueue[t.Passport.Pid]=[e,t]}}},function(e,t,s){"undefined"!=typeof self&&self,e.exports=function(e){var t={};function s(r){if(t[r])return t[r].exports;var i=t[r]={i:r,l:!1,exports:{}};return e[r].call(i.exports,i,i.exports,s),i.l=!0,i.exports}return s.m=e,s.c=t,s.d=function(e,t,r){s.o(e,t)||Object.defineProperty(e,t,{enumerable:!0,get:r})},s.r=function(e){"undefined"!=typeof Symbol&&Symbol.toStringTag&&Object.defineProperty(e,Symbol.toStringTag,{value:"Module"}),Object.defineProperty(e,"__esModule",{value:!0})},s.t=function(e,t){if(1&t&&(e=s(e)),8&t)return e;if(4&t&&"object"==typeof e&&e&&e.__esModule)return e;var r=Object.create(null);if(s.r(r),Object.defineProperty(r,"default",{enumerable:!0,value:e}),2&t&&"string"!=typeof e)for(var i in e)s.d(r,i,function(t){return e[t]}.bind(null,i));return r},s.n=function(e){var t=e&&e.__esModule?function(){return e.default}:function(){return e};return s.d(t,"a",t),t},s.o=function(e,t){return Object.prototype.hasOwnProperty.call(e,t)},s.p="",s(s.s=0)}([function(e,t,s){const r=s(1).EventEmitter;e.exports.StreamParser=class extends r{constructor(e){super(),this.buffer="",this._STATE="CLOSED","read"in e&&e.read.readable&&(e.read.on("data",this.data.bind(this)),e.read.on("close",this.close.bind(this)),this._STATE="OPEN"),"write"in e&&e.write.writable&&(this._writeStream=e.write,e.write.on("close",this.close.bind(this)),this._STATE="OPEN")}error(e){this.emit("error",e)}close(e){"CLOSED"!==this._STATE&&(this._STAT
|