mirror of https://github.com/procxx/kepka.git
94 lines
3.3 KiB
C++
94 lines
3.3 KiB
C++
//
|
|
// This file is part of Kepka,
|
|
// an unofficial desktop version of Telegram messaging app,
|
|
// see https://github.com/procxx/kepka
|
|
//
|
|
// Kepka 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/procxx/kepka/blob/master/LICENSE
|
|
// Copyright (c) 2014-2017 John Preston, https://desktop.telegram.org
|
|
// Copyright (c) 2017- Kepka Contributors, https://github.com/procxx
|
|
//
|
|
#include "mtproto/connection_abstract.h"
|
|
|
|
#include "mtproto/connection_auto.h"
|
|
#include "mtproto/connection_http.h"
|
|
#include "mtproto/connection_tcp.h"
|
|
|
|
#include "facades.h"
|
|
|
|
namespace MTP {
|
|
namespace internal {
|
|
|
|
AbstractConnection::~AbstractConnection() {}
|
|
|
|
mtpBuffer AbstractConnection::preparePQFake(const MTPint128 &nonce) {
|
|
MTPReq_pq req_pq(nonce);
|
|
mtpBuffer buffer;
|
|
quint32 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());
|
|
quint32 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 ||
|
|
(((quint32)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");
|
|
}
|
|
quint32 answerLen = (quint32)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(DcType type, QThread *thread) {
|
|
if ((type == DcType::Temporary) || (Global::ConnectionType() == dbictTcpProxy)) {
|
|
return new TCPConnection(thread);
|
|
} else if (Global::ConnectionType() == dbictHttpProxy) {
|
|
return new HTTPConnection(thread);
|
|
}
|
|
return new AutoConnection(thread);
|
|
}
|
|
|
|
} // namespace internal
|
|
} // namespace MTP
|