Method start

Source/Http/HttpServer.cpp:270–332

	}

	bool start(int port) {
		try {
			_server.WebSocket(".*", [this](const httplib::Request& req, httplib::ws::WebSocket& ws) {
				auto resource = req.target.empty() ? req.path : req.target;
				if (_owner && _owner->_authRequired && !_owner->isWebSocketAuthorized(resource)) {
					ws.close(httplib::ws::CloseStatus::PolicyViolation, "unauthorized"s);
					return;
				}
				auto connection = std::make_shared<Connection>(&ws);
				{
					std::lock_guard<std::mutex> guard(_connectionLock);
					_connections.insert(connection);
				}
				SharedApplication.invokeInLogic([]() {
					Event::send("AppWS"sv, makeAppWSMessage("Open"_slice));
				});
				std::string msg;
				httplib::ws::ReadResult ret;
				while ((ret = ws.read(msg))) {
					if (ret == httplib::ws::Binary) {
						auto message = std::make_shared<std::string>(std::move(msg));
						SharedApplication.invokeInLogic([message = std::move(message)]() {
							Event::send("AppWS"sv, makeAppWSMessage("Receive"_slice, std::move(*message)));
						});
					}
				}
				{
					std::lock_guard<std::mutex> guard(connection->lock);
					connection->webSocket = nullptr;
				}
				{
					std::lock_guard<std::mutex> guard(_connectionLock);
					_connections.erase(connection);
				}
				SharedApplication.invokeInLogic([]() {
					Event::send("AppWS"sv, makeAppWSMessage("Close"_slice));
				});
			});
			if (!_server.bind_to_port("0.0.0.0", port)) {
				Error("failed to bind websocket server port {}!", port);
				return false;
			}
			{
				std::lock_guard<std::mutex> guard(_shutdownLock);
				_stopped = false;
			}
			_thread->run([this]() {
				if (!_server.listen_after_bind()) {
					Error("websocket server failed to start");
				}
				{
					std::lock_guard<std::mutex> guard(_shutdownLock);
					_stopped = true;
				}
				_waitForShutdown.notify_all();
			});
			LogHandler += std::make_pair(this, &WebSocketServer::sendLog);
			return true;