aboutsummaryrefslogtreecommitdiff
path: root/src/base/QXmppSocks.cpp
diff options
context:
space:
mode:
authorLinus Jahn <lnj@kaidan.im>2020-02-02 18:14:27 +0100
committerLNJ <lnj@kaidan.im>2020-02-03 00:11:55 +0100
commit57f1b775197aed1d32e98b0299c0999339a7d5f6 (patch)
treece5702781e15f3a5c438ab153edf06f51a501b29 /src/base/QXmppSocks.cpp
parent99b850a3008bbb03d3449d683adb87839f7d5c4b (diff)
downloadqxmpp-57f1b775197aed1d32e98b0299c0999339a7d5f6.tar.gz
Run clang-format also on all cpp files
Diffstat (limited to 'src/base/QXmppSocks.cpp')
-rw-r--r--src/base/QXmppSocks.cpp48
1 files changed, 18 insertions, 30 deletions
diff --git a/src/base/QXmppSocks.cpp b/src/base/QXmppSocks.cpp
index 43a36bf1..cf07a740 100644
--- a/src/base/QXmppSocks.cpp
+++ b/src/base/QXmppSocks.cpp
@@ -100,9 +100,9 @@ static bool parseHostAndPort(QDataStream &stream, quint8 &type, QByteArray &host
QXmppSocksClient::QXmppSocksClient(const QString &proxyHost, quint16 proxyPort, QObject *parent)
: QTcpSocket(parent),
- m_proxyHost(proxyHost),
- m_proxyPort(proxyPort),
- m_step(ConnectState)
+ m_proxyHost(proxyHost),
+ m_proxyPort(proxyPort),
+ m_step(ConnectState)
{
connect(this, &QAbstractSocket::connected, this, &QXmppSocksClient::slotConnected);
connect(this, &QIODevice::readyRead, this, &QXmppSocksClient::slotReadyRead);
@@ -126,19 +126,17 @@ void QXmppSocksClient::slotConnected()
QByteArray buffer;
buffer.resize(3);
buffer[0] = SocksVersion;
- buffer[1] = 0x01; // number of methods
+ buffer[1] = 0x01; // number of methods
buffer[2] = NoAuthentication;
write(buffer);
}
void QXmppSocksClient::slotReadyRead()
{
- if (m_step == ConnectState)
- {
+ if (m_step == ConnectState) {
// receive connect to server response
QByteArray buffer = readAll();
- if (buffer.size() != 2 || buffer.at(0) != SocksVersion || buffer.at(1) != NoAuthentication)
- {
+ if (buffer.size() != 2 || buffer.at(0) != SocksVersion || buffer.at(1) != NoAuthentication) {
qWarning("QXmppSocksClient received an invalid response during handshake");
close();
return;
@@ -151,7 +149,7 @@ void QXmppSocksClient::slotReadyRead()
buffer.resize(3);
buffer[0] = SocksVersion;
buffer[1] = ConnectCommand;
- buffer[2] = 0x00; // reserved
+ buffer[2] = 0x00; // reserved
buffer.append(encodeHostAndPort(
DomainName,
m_hostName.toLatin1(),
@@ -167,8 +165,7 @@ void QXmppSocksClient::slotReadyRead()
if (buffer.size() != 3 ||
buffer.at(0) != SocksVersion ||
buffer.at(1) != Succeeded ||
- buffer.at(2) != 0)
- {
+ buffer.at(2) != 0) {
qWarning("QXmppSocksClient received an invalid response to CONNECT command");
close();
return;
@@ -179,8 +176,7 @@ void QXmppSocksClient::slotReadyRead()
QByteArray hostName;
quint16 hostPort;
QDataStream stream(this);
- if (!parseHostAndPort(stream, hostType, hostName, hostPort))
- {
+ if (!parseHostAndPort(stream, hostType, hostName, hostPort)) {
qWarning("QXmppSocksClient could not parse type/host/port");
close();
return;
@@ -226,7 +222,7 @@ quint16 QXmppSocksServer::serverPort() const
void QXmppSocksServer::slotNewConnection()
{
- auto *server = qobject_cast<QTcpServer*>(sender());
+ auto *server = qobject_cast<QTcpServer *>(sender());
if (!server)
return;
@@ -241,18 +237,16 @@ void QXmppSocksServer::slotNewConnection()
void QXmppSocksServer::slotReadyRead()
{
- auto *socket = qobject_cast<QTcpSocket*>(sender());
+ auto *socket = qobject_cast<QTcpSocket *>(sender());
if (!socket || !m_states.contains(socket))
return;
- if (m_states.value(socket) == ConnectState)
- {
+ if (m_states.value(socket) == ConnectState) {
// receive connect to server request
QByteArray buffer = socket->readAll();
if (buffer.size() < 3 ||
buffer.at(0) != SocksVersion ||
- buffer.at(1) + 2 != buffer.size())
- {
+ buffer.at(1) + 2 != buffer.size()) {
qWarning("QXmppSocksServer received invalid handshake");
socket->close();
return;
@@ -260,16 +254,13 @@ void QXmppSocksServer::slotReadyRead()
// check authentication method
bool foundMethod = false;
- for (int i = 2; i < buffer.size(); i++)
- {
- if (buffer.at(i) == NoAuthentication)
- {
+ for (int i = 2; i < buffer.size(); i++) {
+ if (buffer.at(i) == NoAuthentication) {
foundMethod = true;
break;
}
}
- if (!foundMethod)
- {
+ if (!foundMethod) {
qWarning("QXmppSocksServer received bad authentication method");
buffer.resize(2);
@@ -299,8 +290,7 @@ void QXmppSocksServer::slotReadyRead()
if (buffer.size() != 3 ||
buffer.at(0) != SocksVersion ||
buffer.at(1) != ConnectCommand ||
- buffer.at(2) != 0x00)
- {
+ buffer.at(2) != 0x00) {
qWarning("QXmppSocksServer received an invalid command");
socket->close();
return;
@@ -311,8 +301,7 @@ void QXmppSocksServer::slotReadyRead()
QByteArray hostName;
quint16 hostPort;
QDataStream stream(socket);
- if (!parseHostAndPort(stream, hostType, hostName, hostPort))
- {
+ if (!parseHostAndPort(stream, hostType, hostName, hostPort)) {
qWarning("QXmppSocksServer could not parse type/host/port");
socket->close();
return;
@@ -334,4 +323,3 @@ void QXmppSocksServer::slotReadyRead()
socket->write(buffer);
}
}
-