astelm/telemt
1
0
Fork 0
mirror of https://github.com/telemt/telemt.git synced 2026-10-09 19:05:58 +03:00
Code Issues Packages Projects Releases Wiki Activity

Update tests.rs

Browse Source
This commit is contained in:
Alexey
2026-09-11 20:33:01 +03:00
parent 479899240a
commit 54197e848a
1 changed files with 20 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/web/bridge/tests.rs
+20 -15
View File
@@ -225,28 +225,33 @@ fn committed_websocket_lane_escalates_only_pre_upgrade_failure() {
assert!(page.body.contains( assert!(page.body.contains(
"if(settled)return;settled=true;if(openTimer)clearTimeout(openTimer);openTimer=null" "if(settled)return;settled=true;if(openTimer)clearTimeout(openTimer);openTimer=null"
)); ));
assert!(page assert!(
.body page.body
.contains("if(closed||lanes.get(lane.id)!==lane||lane.socket!==opened)return")); .contains("if(closed||lanes.get(lane.id)!==lane||lane.socket!==opened)return")
);
assert!(page.body.contains( assert!(page.body.contains(
"if(!upgraded){lane.socket=null;opened.close();recoveryController.recover(reason,null);return}" "if(!upgraded){lane.socket=null;opened.close();recoveryController.recover(reason,null);return}"
)); ));
assert!(page assert!(
.body page.body
.contains("recoveryController.recover(reason,null);return}finishLane(lane,true)")); .contains("recoveryController.recover(reason,null);return}finishLane(lane,true)")
assert!(page );
.body assert!(
.contains("openTimer=setTimeout(()=>finishSocket('timeout'),websocketOpenMs)")); page.body
.contains("openTimer=setTimeout(()=>finishSocket('timeout'),websocketOpenMs)")
);
assert!(page.body.contains( assert!(page.body.contains(
"if(closed||lanes.get(lane.id)!==lane||lane.socket!==opened){opened.close();return}" "if(closed||lanes.get(lane.id)!==lane||lane.socket!==opened){opened.close();return}"
)); ));
assert!(page.body.contains("upgraded=true;lane.ready=true")); assert!(page.body.contains("upgraded=true;lane.ready=true"));
assert!(page assert!(page.body.contains(
.body "lane.socket.onmessage=event=>{\n if(openTimer)clearTimeout(openTimer);openTimer=null;\n if(closed||lanes.get(lane.id)!==lane||lane.socket!==opened||!(event.data instanceof ArrayBuffer))"
.contains("lane.socket.onclose=()=>finishSocket(upgraded?'network':'upgrade')")); ));
assert!(page assert!(
.body page.body
.contains("port.postMessage({t:'status',state})")); .contains("lane.socket.onclose=()=>finishSocket(upgraded?'network':'upgrade')")
);
assert!(page.body.contains("port.postMessage({t:'status',state})"));
assert!(!page.body.contains("port.postMessage({t:'status',state,")); assert!(!page.body.contains("port.postMessage({t:'status',state,"));
} }