Spaces:
Build error
Build error
| /* | |
| * Copyright (c) 2024 lax1dude. All Rights Reserved. | |
| * | |
| * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND | |
| * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED | |
| * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. | |
| * IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, | |
| * INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT | |
| * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR | |
| * PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, | |
| * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) | |
| * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE | |
| * POSSIBILITY OF SUCH DAMAGE. | |
| * | |
| */ | |
| const platfNetworkingName = "platformNetworking"; | |
| (function() { | |
| const WS_CLOSED = 0; | |
| const WS_CONNECTING = 1; | |
| const WS_CONNECTED = 2; | |
| const WS_FAILED = 3; | |
| function closeSocketImpl() { | |
| this["_socket"].close(); | |
| } | |
| /** | |
| * @param {string} str | |
| */ | |
| function sendStringFrameImpl(str) { | |
| this["_socket"].send(str); | |
| } | |
| /** | |
| * @param {Uint8Array} bin | |
| */ | |
| function sendBinaryFrameImpl(bin) { | |
| this["_socket"].send(bin); | |
| } | |
| /** | |
| * @return {number} | |
| */ | |
| function availableFramesImpl() { | |
| return this["_frameCountStr"] + this["_frameCountBin"]; | |
| } | |
| /** | |
| * @return {Object} | |
| */ | |
| function getNextFrameImpl() { | |
| const f = this["_queue"]; | |
| if(f) { | |
| if(f["_next"] === f && f["_prev"] === f) { | |
| this["_queue"] = null; | |
| }else { | |
| this["_queue"] = f["_next"]; | |
| f["_prev"]["_next"] = f["_next"]; | |
| f["_next"]["_prev"] = f["_prev"]; | |
| } | |
| f["_next"] = null; | |
| f["_prev"] = null; | |
| if(f["type"] === 0) { | |
| --this["_frameCountStr"]; | |
| }else { | |
| --this["_frameCountBin"]; | |
| } | |
| return f; | |
| }else { | |
| return null; | |
| } | |
| } | |
| /** | |
| * @return {Array} | |
| */ | |
| function getAllFramesImpl() { | |
| const len = this["_frameCountStr"] + this["_frameCountBin"]; | |
| if(len === 0) { | |
| return null; | |
| } | |
| const ret = new Array(len); | |
| var idx = 0; | |
| var f = this["_queue"]; | |
| var g; | |
| const ff = f; | |
| do { | |
| ret[idx++] = f; | |
| g = f["_next"]; | |
| f["_next"] = null; | |
| f["_prev"] = null; | |
| f = g; | |
| }while(f !== ff); | |
| this["_queue"] = null; | |
| this["_frameCountStr"] = 0; | |
| this["_frameCountBin"] = 0; | |
| return ret; | |
| } | |
| function clearFramesImpl() { | |
| this["_queue"] = null; | |
| this["_frameCountStr"] = 0; | |
| this["_frameCountBin"] = 0; | |
| } | |
| /** | |
| * @param {Object} thisObj | |
| * @param {number} type | |
| * @return {Object} | |
| */ | |
| function getNextTypedFrameImpl(thisObj, type) { | |
| var f = thisObj["_queue"]; | |
| if(!f) { | |
| return null; | |
| } | |
| var g, h; | |
| const ff = f; | |
| do { | |
| g = f["_next"]; | |
| if(f["type"] === type) { | |
| h = f["_prev"]; | |
| if(g === f && h === f) { | |
| thisObj["_queue"] = null; | |
| }else { | |
| if(f === ff) { | |
| thisObj["_queue"] = g; | |
| } | |
| h["_next"] = g; | |
| g["_prev"] = h; | |
| } | |
| f["_next"] = null; | |
| f["_prev"] = null; | |
| return f; | |
| } | |
| f = g; | |
| }while(f !== ff); | |
| return null; | |
| } | |
| /** | |
| * @param {Object} thisObj | |
| * @param {number} type | |
| * @param {Array} ret | |
| */ | |
| function getAllTypedFrameImpl(thisObj, type, ret) { | |
| var idx = 0; | |
| var f = thisObj["_queue"]; | |
| var g, h; | |
| const ff = f; | |
| do { | |
| g = f["_next"]; | |
| if(f["type"] === type) { | |
| ret[idx++] = f; | |
| } | |
| f = g; | |
| }while(f !== ff); | |
| ret.length = idx; | |
| for(var i = 0; i < idx; ++i) { | |
| f = ret[i]; | |
| g = f["_next"]; | |
| h = f["_prev"]; | |
| if(g === f && h === f) { | |
| thisObj["_queue"] = null; | |
| }else { | |
| if(f === thisObj["_queue"]) { | |
| thisObj["_queue"] = g; | |
| } | |
| h["_next"] = g; | |
| g["_prev"] = h; | |
| } | |
| } | |
| } | |
| /** | |
| * @return {number} | |
| */ | |
| function availableStringFramesImpl() { | |
| return this["_frameCountStr"]; | |
| } | |
| /** | |
| * @return {Object} | |
| */ | |
| function getNextStringFrameImpl() { | |
| const len = this["_frameCountStr"]; | |
| if(len === 0) { | |
| return null; | |
| } | |
| const ret = getNextTypedFrameImpl(this, 0); | |
| if(!ret) { | |
| this["_frameCountStr"] = 0; | |
| }else { | |
| --this["_frameCountStr"]; | |
| } | |
| return ret; | |
| } | |
| /** | |
| * @return {Array} | |
| */ | |
| function getAllStringFramesImpl() { | |
| const len = this["_frameCountStr"]; | |
| if(len === 0) { | |
| return null; | |
| } | |
| const ret = new Array(len); | |
| getAllTypedFrameImpl(this, 0, ret); | |
| this["_frameCountStr"] = 0; | |
| return ret; | |
| } | |
| function clearStringFramesImpl() { | |
| const len = this["_frameCountStr"]; | |
| if(len === 0) { | |
| return null; | |
| } | |
| const ret = new Array(len); | |
| getAllTypedFrameImpl(this, 0, ret); | |
| this["_frameCountStr"] = 0; | |
| } | |
| /** | |
| * @return {number} | |
| */ | |
| function availableBinaryFramesImpl() { | |
| return this["_frameCountBin"]; | |
| } | |
| /** | |
| * @return {Object} | |
| */ | |
| function getNextBinaryFrameImpl() { | |
| const len = this["_frameCountBin"]; | |
| if(len === 0) { | |
| return null; | |
| } | |
| const ret = getNextTypedFrameImpl(this, 1); | |
| if(!ret) { | |
| this["_frameCountBin"] = 0; | |
| }else { | |
| --this["_frameCountBin"]; | |
| } | |
| return ret; | |
| } | |
| /** | |
| * @return {Array} | |
| */ | |
| function getAllBinaryFramesImpl() { | |
| const len = this["_frameCountBin"]; | |
| if(len === 0) { | |
| return null; | |
| } | |
| const ret = new Array(len); | |
| getAllTypedFrameImpl(this, 1, ret); | |
| this["_frameCountBin"] = 0; | |
| return ret; | |
| } | |
| function clearBinaryFramesImpl() { | |
| const len = this["_frameCountBin"]; | |
| if(len === 0) { | |
| return null; | |
| } | |
| const ret = new Array(len); | |
| getAllTypedFrameImpl(this, 1, ret); | |
| this["_frameCountBin"] = 0; | |
| } | |
| /** | |
| * @param {boolean} enable | |
| */ | |
| function setEnableStringFramesImpl(enable) { | |
| this["_enableStringFrames"] = enable; | |
| } | |
| /** | |
| * @param {boolean} enable | |
| */ | |
| function setEnableBinaryFramesImpl(enable) { | |
| this["_enableBinaryFrames"] = enable; | |
| } | |
| function addRecievedFrameImpl(dat) { | |
| const isStr = (typeof dat === "string"); | |
| if(isStr) { | |
| if(!this["_enableStringFrames"]) | |
| return; | |
| }else { | |
| if(!this["_enableBinaryFrames"]) | |
| return; | |
| } | |
| const itm = { | |
| "type": (isStr ? 0 : 1), | |
| "data": dat, | |
| "timestamp": performance.now(), | |
| "_next": null, | |
| "_prev": null | |
| }; | |
| const first = this["_queue"]; | |
| if(!first) { | |
| this["_queue"] = itm; | |
| itm["_next"] = itm; | |
| itm["_prev"] = itm; | |
| }else { | |
| const last = first["_prev"]; | |
| last["_next"] = itm; | |
| itm["_prev"] = last; | |
| itm["_next"] = first; | |
| first["_prev"] = itm; | |
| } | |
| if(isStr) { | |
| ++this["_frameCountStr"]; | |
| }else { | |
| ++this["_frameCountBin"]; | |
| } | |
| } | |
| /** | |
| * @param {string} socketURI | |
| * @return {Object} | |
| */ | |
| eagruntimeImpl.platformNetworking["createWebSocketHandle"] = function(socketURI) { | |
| let sock; | |
| try { | |
| sock = new WebSocket(socketURI); | |
| }catch(ex) { | |
| eagError("Failed to create WebSocket: {}", socketURI); | |
| eagStackTrace(ERROR, "Exception Caught", ex); | |
| return null; | |
| } | |
| sock.binaryType = "arraybuffer"; | |
| const ret = { | |
| "state": WS_CONNECTING, | |
| "_socket": sock, | |
| "_queue": null, | |
| "_frameCountStr": 0, | |
| "_frameCountBin": 0, | |
| "_addRecievedFrame": addRecievedFrameImpl, | |
| "_enableStringFrames": true, | |
| "_enableBinaryFrames": true, | |
| "closeSocket": closeSocketImpl, | |
| "sendStringFrame": sendStringFrameImpl, | |
| "sendBinaryFrame": sendBinaryFrameImpl, | |
| "availableFrames": availableFramesImpl, | |
| "getNextFrame": getNextFrameImpl, | |
| "getAllFrames": getAllFramesImpl, | |
| "clearFrames": clearFramesImpl, | |
| "availableStringFrames": availableStringFramesImpl, | |
| "getNextStringFrame": getNextStringFrameImpl, | |
| "getAllStringFrames": getAllStringFramesImpl, | |
| "clearStringFrames": clearStringFramesImpl, | |
| "availableBinaryFrames": availableBinaryFramesImpl, | |
| "getNextBinaryFrame": getNextBinaryFrameImpl, | |
| "getAllBinaryFrames": getAllBinaryFramesImpl, | |
| "clearBinaryFrames": clearBinaryFramesImpl, | |
| "setEnableStringFrames": setEnableStringFramesImpl, | |
| "setEnableBinaryFrames": setEnableBinaryFramesImpl | |
| }; | |
| sock.addEventListener("open", function(evt) { | |
| ret["state"] = WS_CONNECTED; | |
| }); | |
| sock.addEventListener("message", function(evt) { | |
| ret["_addRecievedFrame"](evt.data); | |
| }); | |
| sock.addEventListener("close", function(evt) { | |
| if(ret["state"] !== WS_FAILED) { | |
| ret["state"] = WS_CLOSED; | |
| } | |
| }); | |
| sock.addEventListener("error", function(evt) { | |
| if(ret["state"] === WS_CONNECTING) { | |
| ret["state"] = WS_FAILED; | |
| } | |
| }); | |
| return ret; | |
| }; | |
| })(); | |