mirrors/bun.sh
1
0
Fork 0
mirror of https://github.com/oven-sh/bun synced 2026-02-09 10:28:47 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix WebSocket server sending invalid data at the end

Browse Source
This commit is contained in:
Jarred Sumner
2022-10-16 00:13:51 -07:00
parent abf3a13433
commit 2852520d90
1 changed files with 10 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
src/deps/libuwsockets.cpp
View File

@@ -488,15 +488,17 @@ uws_sendstatus_t uws_ws_send_with_options(int ssl, uws_websocket_t *ws,
if (ssl) {
uWS::WebSocket<true, true, void *> *uws =
(uWS::WebSocket<true, true, void *> *)ws;
return (uws_sendstatus_t)uws->send(std::string_view(message),
return (uws_sendstatus_t)uws->send(std::string_view(message, length),
(uWS::OpCode)(unsigned char)opcode,
compress, fin);
} else {
uWS::WebSocket<false, true, void *> *uws =
(uWS::WebSocket<false, true, void *> *)ws;
return (uws_sendstatus_t)uws->send(std::string_view(message, length),
(uWS::OpCode)(unsigned char)opcode,
compress, fin);
}
uWS::WebSocket<false, true, void *> *uws =
(uWS::WebSocket<false, true, void *> *)ws;
return (uws_sendstatus_t)uws->send(std::string_view(message),
(uWS::OpCode)(unsigned char)opcode,
compress, fin);
}
uws_sendstatus_t uws_ws_send_fragment(int ssl, uws_websocket_t *ws,
@@ -520,12 +522,12 @@ uws_sendstatus_t uws_ws_send_first_fragment(int ssl, uws_websocket_t *ws,
uWS::WebSocket<true, true, void *> *uws =
(uWS::WebSocket<true, true, void *> *)ws;
return (uws_sendstatus_t)uws->sendFirstFragment(
std::string_view(message), uWS::OpCode::BINARY, compress);
std::string_view(message, length), uWS::OpCode::BINARY, compress);
}
uWS::WebSocket<false, true, void *> *uws =
(uWS::WebSocket<false, true, void *> *)ws;
return (uws_sendstatus_t)uws->sendFirstFragment(
std::string_view(message), uWS::OpCode::BINARY, compress);
std::string_view(message, length), uWS::OpCode::BINARY, compress);
}
uws_sendstatus_t
uws_ws_send_first_fragment_with_opcode(int ssl, uws_websocket_t *ws,