Method onClientDataReceived

sources/webserver/QtHttpClientWrapper.cpp:80–282

}

void QtHttpClientWrapper::onClientDataReceived(void)
{
	if (m_sockClient != Q_NULLPTR)
	{
		while (m_sockClient->bytesAvailable())
		{
			QByteArray line = m_sockClient->readLine();

			switch (m_parsingStatus) // handle parsing steps
			{
			case AwaitingRequest: // "command url version" × 1
			{
				QString str = QString::fromUtf8(line).trimmed();
				QStringList parts = str.split(SPACE, Qt::SkipEmptyParts);
				if (parts.size() == 3)
				{
					QString command = parts.at(0);
					QString url = parts.at(1);
					QString version = parts.at(2);

					if (version == QtHttpServer::HTTP_VERSION)
					{
						m_currentRequest = new QtHttpRequest(this, m_serverHandle);
						m_currentRequest->setClientInfo(m_sockClient->localAddress(), m_sockClient->peerAddress());
						m_currentRequest->setUrl(QUrl(url));
						m_currentRequest->setCommand(command);
						m_parsingStatus = AwaitingHeaders;
					}
					else
					{
						m_parsingStatus = ParsingError;
						//qWarning () << "Error : unhandled HTTP version :" << version;
					}
				}
				else
				{
					m_parsingStatus = ParsingError;
					//qWarning () << "Error : incorrect HTTP command line :" << line;
				}

				break;
			}
			case AwaitingHeaders: // "header: value" × N (until empty line)
			{
				QByteArray raw = line.trimmed();

				if (!raw.isEmpty()) // parse headers
				{
					int pos = raw.indexOf(COLON);

					if (pos > 0)
					{
						QByteArray header = raw.left(pos).trimmed();
						QByteArray value = raw.mid(pos + 1).trimmed();
						m_currentRequest->addHeader(header, value);
						if (header == QtHttpHeader::ContentLength)
						{
							bool ok = false;