mirror of
https://github.com/telegramdesktop/tdesktop
synced 2025-01-25 16:54:25 +00:00
08167a6a91
Currently the build without implicitly included precompiled header is not supported anyway (because Qt MOC source files do not include stdafx.h, they include plain headers). So when we decide to support building without implicitly included precompiled headers we'll have to fix all the headers anyway.
89 lines
3.2 KiB
C++
89 lines
3.2 KiB
C++
/*
|
|
This file is part of Telegram Desktop,
|
|
the official desktop version of Telegram messaging app, see https://telegram.org
|
|
|
|
Telegram Desktop is free software: you can redistribute it and/or modify
|
|
it under the terms of the GNU General Public License as published by
|
|
the Free Software Foundation, either version 3 of the License, or
|
|
(at your option) any later version.
|
|
|
|
It is distributed in the hope that it will be useful,
|
|
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
GNU General Public License for more details.
|
|
|
|
In addition, as a special exception, the copyright holders give permission
|
|
to link the code of portions of this program with the OpenSSL library.
|
|
|
|
Full license: https://github.com/telegramdesktop/tdesktop/blob/master/LICENSE
|
|
Copyright (c) 2014-2017 John Preston, https://desktop.telegram.org
|
|
*/
|
|
#include "mtproto/connection_abstract.h"
|
|
|
|
#include "mtproto/connection_tcp.h"
|
|
#include "mtproto/connection_http.h"
|
|
#include "mtproto/connection_auto.h"
|
|
|
|
namespace MTP {
|
|
namespace internal {
|
|
|
|
AbstractConnection::~AbstractConnection() {
|
|
}
|
|
|
|
mtpBuffer AbstractConnection::preparePQFake(const MTPint128 &nonce) {
|
|
MTPReq_pq req_pq(nonce);
|
|
mtpBuffer buffer;
|
|
uint32 requestSize = req_pq.innerLength() >> 2;
|
|
|
|
buffer.resize(0);
|
|
buffer.reserve(8 + requestSize);
|
|
buffer.push_back(0); // tcp packet len
|
|
buffer.push_back(0); // tcp packet num
|
|
buffer.push_back(0);
|
|
buffer.push_back(0);
|
|
buffer.push_back(0);
|
|
buffer.push_back(unixtime());
|
|
buffer.push_back(requestSize * 4);
|
|
req_pq.write(buffer);
|
|
buffer.push_back(0); // tcp crc32 hash
|
|
|
|
return buffer;
|
|
}
|
|
|
|
MTPResPQ AbstractConnection::readPQFakeReply(const mtpBuffer &buffer) {
|
|
const mtpPrime *answer(buffer.constData());
|
|
uint32 len = buffer.size();
|
|
if (len < 5) {
|
|
LOG(("Fake PQ Error: bad request answer, len = %1").arg(len * sizeof(mtpPrime)));
|
|
DEBUG_LOG(("Fake PQ Error: answer bytes %1").arg(Logs::mb(answer, len * sizeof(mtpPrime)).str()));
|
|
throw Exception("bad pq reply");
|
|
}
|
|
if (answer[0] != 0 || answer[1] != 0 || (((uint32)answer[2]) & 0x03) != 1/* || (unixtime() - answer[3] > 300) || (answer[3] - unixtime() > 60)*/) { // didnt sync time yet
|
|
LOG(("Fake PQ Error: bad request answer start (%1 %2 %3)").arg(answer[0]).arg(answer[1]).arg(answer[2]));
|
|
DEBUG_LOG(("Fake PQ Error: answer bytes %1").arg(Logs::mb(answer, len * sizeof(mtpPrime)).str()));
|
|
throw Exception("bad pq reply");
|
|
}
|
|
uint32 answerLen = (uint32)answer[4];
|
|
if (answerLen != (len - 5) * sizeof(mtpPrime)) {
|
|
LOG(("Fake PQ Error: bad request answer %1 <> %2").arg(answerLen).arg((len - 5) * sizeof(mtpPrime)));
|
|
DEBUG_LOG(("Fake PQ Error: answer bytes %1").arg(Logs::mb(answer, len * sizeof(mtpPrime)).str()));
|
|
throw Exception("bad pq reply");
|
|
}
|
|
const mtpPrime *from(answer + 5), *end(from + len - 5);
|
|
MTPResPQ response;
|
|
response.read(from, end);
|
|
return response;
|
|
}
|
|
|
|
AbstractConnection *AbstractConnection::create(QThread *thread) {
|
|
if (Global::ConnectionType() == dbictHttpProxy) {
|
|
return new HTTPConnection(thread);
|
|
} else if (Global::ConnectionType() == dbictTcpProxy) {
|
|
return new TCPConnection(thread);
|
|
}
|
|
return new AutoConnection(thread);
|
|
}
|
|
|
|
} // namespace internal
|
|
} // namespace MTP
|