diff --git a/src/WebSocketWrapper.h b/src/WebSocketWrapper.h index ac33acc..562e236 100644 --- a/src/WebSocketWrapper.h +++ b/src/WebSocketWrapper.h @@ -75,7 +75,14 @@ struct WebSocketWrapper { auto *ws = getWebSocket(args); if (ws) { NativeString topic(isolate, args[0]); + if (topic.isInvalid(args)) { + return; + } NativeString message(isolate, args[1]); + if (message.isInvalid(args)) { + return; + } + ws->publish(topic.getString(), message.getString(), BooleanValue(isolate, args[2]) ? uWS::OpCode::BINARY : uWS::OpCode::TEXT, BooleanValue(isolate, args[3])); } }