Method ProcessHttp

include/brynet/net/http/HttpService.hpp:348–381

    }

    static size_t ProcessHttp(const char* buffer,
                              size_t len,
                              const HTTPParser::Ptr& httpParser,
                              const HttpSession::Ptr& httpSession)
    {
        size_t retlen = len;
        if (!httpParser->isCompleted())
        {
            retlen = httpParser->tryParse(buffer, len);
            if (!httpParser->isCompleted())
            {
                return retlen;
            }
        }

        if (httpParser->isWebSocket())
        {
            if (httpParser->hasKey("Sec-WebSocket-Key"))
            {
                auto response = WebSocketFormat::wsHandshake(
                        httpParser->getValue("Sec-WebSocket-Key"));
                httpSession->send(response.c_str(),
                                  response.size());
            }

            const auto& wsConnectedCallback = httpSession->getWSConnectedCallback();
            if (wsConnectedCallback != nullptr)
            {
                wsConnectedCallback(httpSession, *httpParser);
            }
        }

        return retlen;
    }
};

}}}// namespace brynet::net::http