summaryrefslogtreecommitdiff
path: root/plugins/CryptoPP/src/cpp_rsam.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'plugins/CryptoPP/src/cpp_rsam.cpp')
-rw-r--r--plugins/CryptoPP/src/cpp_rsam.cpp138
1 files changed, 69 insertions, 69 deletions
diff --git a/plugins/CryptoPP/src/cpp_rsam.cpp b/plugins/CryptoPP/src/cpp_rsam.cpp
index c2eddf6cc8..1ff82b508d 100644
--- a/plugins/CryptoPP/src/cpp_rsam.cpp
+++ b/plugins/CryptoPP/src/cpp_rsam.cpp
@@ -281,7 +281,7 @@ int __cdecl rsa_disconnect(HANDLE context)
Sent_NetLog("rsa_disconnect: %08x", context);
#endif
pCNTX ptr = get_context_on_id(context); if (!ptr) return 0;
- rsa_free(ptr); // удалим трэд и очередь сообщений
+ rsa_free(ptr); // удалим трэд и очередь сообщений
pRSADATA p = (pRSADATA)cpp_alloc_pdata(ptr);
if (!p->state) return 1;
@@ -291,7 +291,7 @@ int __cdecl rsa_disconnect(HANDLE context)
inject_msg(context, 0xF0, encode_msg(0, p, ::hash(buffer, RAND_SIZE)));
p->state = 0;
- imp->rsa_notify(context, -3); // соединение разорвано вручную
+ imp->rsa_notify(context, -3); // соединение разорвано вручную
return 1;
}
@@ -302,12 +302,12 @@ int __cdecl rsa_disabled(HANDLE context)
Sent_NetLog("rsa_disabled: %08x", context);
#endif
pCNTX ptr = get_context_on_id(context); if (!ptr) return 0;
- rsa_free(ptr); // удалим трэд и очередь сообщений
+ rsa_free(ptr); // удалим трэд и очередь сообщений
pRSADATA p = (pRSADATA)cpp_alloc_pdata(ptr);
p->state = 0;
inject_msg(context, 0xFF, null);
- // imp->rsa_notify(-context,-8); // соединение разорвано по причине "disabled"
+ // imp->rsa_notify(-context,-8); // соединение разорвано по причине "disabled"
return 1;
}
@@ -332,38 +332,38 @@ LPSTR __cdecl rsa_recv(HANDLE context, LPCSTR msg)
#if defined(_DEBUG) || defined(NETLIB_LOG)
Sent_NetLog("rsa_recv: %02x %d", type, p->state);
#endif
- if (type > 0x10 && type < 0xE0) // проверим тип сообщения (когда соединение еще не установлено)
- if (p->state == 0 || p->state != (type >> 4)) { // неверное состояние
- // шлем перерывание сессии
+ if (type > 0x10 && type < 0xE0) // проверим тип сообщения (когда соединение еще не установлено)
+ if (p->state == 0 || p->state != (type >> 4)) { // неверное состояние
+ // шлем перерывание сессии
p->state = 0; p->time = 0;
- rsa_free(ptr); // удалим трэд и очередь сообщений
- null_msg(context, 0x00, -1); // сессия разорвана по ошибке, неверный тип сообщения
+ rsa_free(ptr); // удалим трэд и очередь сообщений
+ null_msg(context, 0x00, -1); // сессия разорвана по ошибке, неверный тип сообщения
return nullptr;
}
switch (type) {
- case 0x00: // прерывание сессии по ошибке другой стороной
+ case 0x00: // прерывание сессии по ошибке другой стороной
{
- // если соединение установлено - ничего не делаем
+ // если соединение установлено - ничего не делаем
if (p->state == 0 || p->state == 7) return nullptr;
- // иначе сбрасываем текущее состояние
+ // иначе сбрасываем текущее состояние
p->state = 0; p->time = 0;
- imp->rsa_notify(context, -2); // сессия разорвана по ошибке другой стороной
+ imp->rsa_notify(context, -2); // сессия разорвана по ошибке другой стороной
} break;
- // это все будем обрабатывать в отдельном потоке, чтобы избежать таймаутов
- case 0x10: // запрос на установку соединения
- case 0x22: // получили удаленный паблик, отправляем уже криптоключ
- case 0x23: // отправляем локальный паблик
- case 0x24: // получили удаленный паблик, отправим локальный паблик
- case 0x33: // получили удаленный паблик, отправляем криптоключ
+ // это все будем обрабатывать в отдельном потоке, чтобы избежать таймаутов
+ case 0x10: // запрос на установку соединения
+ case 0x22: // получили удаленный паблик, отправляем уже криптоключ
+ case 0x23: // отправляем локальный паблик
+ case 0x24: // получили удаленный паблик, отправим локальный паблик
+ case 0x33: // получили удаленный паблик, отправляем криптоключ
case 0x34:
- case 0x21: // получили криптоключ, отправляем криптотест
+ case 0x21: // получили криптоключ, отправляем криптотест
case 0x32:
case 0x40:
- case 0x0D: // запрос паблика
- case 0xD0: // ответ пабликом
+ case 0x0D: // запрос паблика
+ case 0xD0: // ответ пабликом
if (!p->event) {
p->event = CreateEvent(nullptr, FALSE, FALSE, nullptr);
unsigned int tID;
@@ -376,13 +376,13 @@ LPSTR __cdecl rsa_recv(HANDLE context, LPCSTR msg)
mir_cslock lck(localQueueMutex);
p->queue->push(tlv(type, data));
}
- SetEvent(p->event); // сказали обрабатывать :)
+ SetEvent(p->event); // сказали обрабатывать :)
break;
- case 0x50: // получили криптотест, отправляем свой криптотест
+ case 0x50: // получили криптотест, отправляем свой криптотест
if (!decode_msg(p, data).length()) {
p->state = 0; p->time = 0;
- null_msg(context, 0x00, -type); // сессия разорвана по ошибке
+ null_msg(context, 0x00, -type); // сессия разорвана по ошибке
return nullptr;
}
{
@@ -391,60 +391,60 @@ LPSTR __cdecl rsa_recv(HANDLE context, LPCSTR msg)
inject_msg(context, 0x60, encode_msg(0, p, ::hash(buffer, RAND_SIZE)));
}
p->state = 7; p->time = 0;
- rsa_free_thread(p); // удалим трэд и очередь сообщений
- imp->rsa_notify(context, 1); // заебися, криптосессия установлена
+ rsa_free_thread(p); // удалим трэд и очередь сообщений
+ imp->rsa_notify(context, 1); // заебися, криптосессия установлена
break;
- case 0x60: // получили криптотест, сессия установлена
+ case 0x60: // получили криптотест, сессия установлена
if (!decode_msg(p, data).length()) {
p->state = 0; p->time = 0;
- null_msg(context, 0x00, -type); // сессия разорвана по ошибке
+ null_msg(context, 0x00, -type); // сессия разорвана по ошибке
return nullptr;
}
p->state = 7; p->time = 0;
- rsa_free_thread(p); // удалим трэд и очередь сообщений
- imp->rsa_notify(context, 1); // заебися, криптосессия установлена
+ rsa_free_thread(p); // удалим трэд и очередь сообщений
+ imp->rsa_notify(context, 1); // заебися, криптосессия установлена
break;
- case 0x70: // получили AES сообщение, декодируем
+ case 0x70: // получили AES сообщение, декодируем
{
mir_free(ptr->tmp);
string msg = decode_msg(p, data);
if (msg.length())
return ptr->tmp = mir_strdup(msg.c_str());
else {
- imp->rsa_notify(context, -5); // ошибка декодирования AES сообщения
+ imp->rsa_notify(context, -5); // ошибка декодирования AES сообщения
return ptr->tmp = nullptr;
}
}
- case 0xE0: // получили RSA сообщение, декодируем
+ case 0xE0: // получили RSA сообщение, декодируем
{
mir_free(ptr->tmp);
string msg = decode_rsa(p, r, data);
if (msg.length())
return ptr->tmp = mir_strdup(msg.c_str());
else {
- imp->rsa_notify(context, -6); // ошибка декодирования RSA сообщения
+ imp->rsa_notify(context, -6); // ошибка декодирования RSA сообщения
return ptr->tmp = nullptr;
}
}
- case 0xF0: // разрыв соединения вручную
+ case 0xF0: // разрыв соединения вручную
{
if (p->state != 7) return nullptr;
string msg = decode_msg(p, data);
if (!msg.length()) return nullptr;
p->state = 0;
- rsa_free(ptr); // удалим трэд и очередь сообщений
- imp->rsa_notify(context, -4); // соединение разорвано вручную другой стороной
+ rsa_free(ptr); // удалим трэд и очередь сообщений
+ imp->rsa_notify(context, -4); // соединение разорвано вручную другой стороной
}
break;
- case 0xFF: // разрыв соединения по причине "disabled"
+ case 0xFF: // разрыв соединения по причине "disabled"
p->state = 0;
- rsa_free(ptr); // удалим трэд и очередь сообщений
- imp->rsa_notify(context, -8); // соединение разорвано по причине "disabled"
+ rsa_free(ptr); // удалим трэд и очередь сообщений
+ imp->rsa_notify(context, -8); // соединение разорвано по причине "disabled"
break;
}
@@ -459,11 +459,11 @@ int __cdecl rsa_send(HANDLE context, LPCSTR msg)
pCNTX ptr = get_context_on_id(context); if (!ptr) return 0;
pRSADATA p = (pRSADATA)cpp_alloc_pdata(ptr); if (p->state != 0 && p->state != 7) return 0;
- if (p->state == 7) // сессия установлена, шифруем AES и отправляем
+ if (p->state == 7) // сессия установлена, шифруем AES и отправляем
inject_msg(context, 0x70, encode_msg(1, p, string(msg)));
- else if (p->state == 0) { // сессия установлена, отправляем RSA сообщение
+ else if (p->state == 0) { // сессия установлена, отправляем RSA сообщение
if (!p->pub_k.length()) return 0;
- // есть паблик ключ - отправим сообщение
+ // есть паблик ключ - отправим сообщение
pRSAPRIV r = rsa_get_priv(ptr);
inject_msg(context, 0xE0, encode_rsa(1, p, r, string(msg)));
}
@@ -646,7 +646,7 @@ void rsa_timeout(HANDLE context, pRSADATA p)
#endif
p->state = 0; p->time = 0;
// null_msg(context,0x00,-7);
- imp->rsa_notify(context, -7); // сессия разорвана по таймауту
+ imp->rsa_notify(context, -7); // сессия разорвана по таймауту
}
int __cdecl rsa_encrypt_file(HANDLE context, LPCSTR file_in, LPCSTR file_out)
@@ -707,19 +707,19 @@ int __cdecl rsa_recv_thread(HANDLE context, string& msg)
un_tlv(un_tlv(un_tlv(data, t[0], features), t[1], sha1), t[2], sha2);
BOOL lr = (p->pub_s == sha1); BOOL ll = (r->pub_s == sha2);
switch ((lr << 4) | ll) {
- case 0x11: // оба паблика совпали
+ case 0x11: // оба паблика совпали
inject_msg(context, 0x21, gen_aes_key_iv(ptr->mode, p, r));
p->state = 5;
break;
- case 0x10: // совпал удаленный паблик, нужен локальный
+ case 0x10: // совпал удаленный паблик, нужен локальный
inject_msg(context, 0x22, tlv(0, features) + tlv(1, r->pub_k) + tlv(2, r->pub_s));
p->state = 3;
break;
- case 0x01: // совпал локальный паблик, нужен удаленный
+ case 0x01: // совпал локальный паблик, нужен удаленный
inject_msg(context, 0x23, tlv(0, features));
p->state = 3;
break;
- case 0x00: // не совпали оба паблика
+ case 0x00: // не совпали оба паблика
inject_msg(context, 0x24, tlv(0, features) + tlv(1, r->pub_k) + tlv(2, r->pub_s));
p->state = 3;
break;
@@ -727,14 +727,14 @@ int __cdecl rsa_recv_thread(HANDLE context, string& msg)
}
break;
- case 0x22: // получили удаленный паблик, отправляем уже криптоключ
+ case 0x22: // получили удаленный паблик, отправляем уже криптоключ
{
string pub;
un_tlv(un_tlv(data, t[0], features), t[1], pub);
string sig = ::hash(pub);
if (!imp->rsa_check_pub(context, (PBYTE)pub.data(), (int)pub.length(), (PBYTE)sig.data(), (int)sig.length())) {
p->state = 0; p->time = 0;
- null_msg(context, 0x00, -type); // сессия разорвана по ошибке
+ null_msg(context, 0x00, -type); // сессия разорвана по ошибке
return 0;
}
init_pub(p, pub);
@@ -747,20 +747,20 @@ int __cdecl rsa_recv_thread(HANDLE context, string& msg)
}
break;
- case 0x23: // отправляем локальный паблик
+ case 0x23: // отправляем локальный паблик
un_tlv(data, t[0], features);
inject_msg(context, 0x33, tlv(1, r->pub_k) + tlv(2, r->pub_s));
p->state = 4;
break;
- case 0x24: // получили удаленный паблик, отправим локальный паблик
+ case 0x24: // получили удаленный паблик, отправим локальный паблик
{
string pub;
un_tlv(un_tlv(data, t[0], features), t[1], pub);
string sig = ::hash(pub);
if (!imp->rsa_check_pub(context, (PBYTE)pub.data(), (int)pub.length(), (PBYTE)sig.data(), (int)sig.length())) {
p->state = 0; p->time = 0;
- null_msg(context, 0x00, -type); // сессия разорвана по ошибке
+ null_msg(context, 0x00, -type); // сессия разорвана по ошибке
return 0;
}
init_pub(p, pub);
@@ -773,7 +773,7 @@ int __cdecl rsa_recv_thread(HANDLE context, string& msg)
}
break;
- case 0x33: // получили удаленный паблик, отправляем криптоключ
+ case 0x33: // получили удаленный паблик, отправляем криптоключ
case 0x34:
{
string pub;
@@ -781,7 +781,7 @@ int __cdecl rsa_recv_thread(HANDLE context, string& msg)
string sig = ::hash(pub);
if (!imp->rsa_check_pub(context, (PBYTE)pub.data(), (int)pub.length(), (PBYTE)sig.data(), (int)sig.length())) {
p->state = 0; p->time = 0;
- null_msg(context, 0x00, -type); // сессия разорвана по ошибке
+ null_msg(context, 0x00, -type); // сессия разорвана по ошибке
return 0;
}
init_pub(p, pub);
@@ -794,14 +794,14 @@ int __cdecl rsa_recv_thread(HANDLE context, string& msg)
}
break;
- case 0x21: // получили криптоключ, отправляем криптотест
+ case 0x21: // получили криптоключ, отправляем криптотест
case 0x32:
case 0x40:
{
string key = decode_rsa(p, r, data);
if (!key.length()) {
p->state = 0; p->time = 0;
- null_msg(context, 0x00, -type); // сессия разорвана по ошибке
+ null_msg(context, 0x00, -type); // сессия разорвана по ошибке
return 0;
}
un_tlv(key, t[0], p->aes_k);
@@ -813,21 +813,21 @@ int __cdecl rsa_recv_thread(HANDLE context, string& msg)
}
break;
- case 0x0D: // запрос паблика
- case 0xD0: // ответ пабликом
+ case 0x0D: // запрос паблика
+ case 0xD0: // ответ пабликом
{
string pub, sha;
un_tlv(un_tlv(un_tlv(data, t[0], features), t[1], pub), t[2], sha);
- if (p->pub_k != pub) { // пришел новый паблик
+ if (p->pub_k != pub) { // пришел новый паблик
string sig = ::hash(pub);
if (!imp->rsa_check_pub(context, (PBYTE)pub.data(), (int)pub.length(), (PBYTE)sig.data(), (int)sig.length())) {
p->state = 0; p->time = 0;
- null_msg(context, 0x00, -type); // сессия разорвана по ошибке
+ null_msg(context, 0x00, -type); // сессия разорвана по ошибке
return 0;
}
init_pub(p, pub);
}
- if (type == 0x0D) // нужно отправить мой паблик
+ if (type == 0x0D) // нужно отправить мой паблик
inject_msg(context, 0xD0, tlv(0, features) + tlv(1, r->pub_k) + tlv(2, p->pub_s));
p->state = 0; p->time = 0;
@@ -859,7 +859,7 @@ int rsa_free(pCNTX ptr)
return true;
if (p->event) {
- p->thread_exit = 2; // отпускаем поток в свободное плавание
+ p->thread_exit = 2; // отпускаем поток в свободное плавание
SetEvent(p->event);
return false;
}
@@ -875,7 +875,7 @@ void rsa_free_thread(pRSADATA p)
if (p->event) {
p->thread_exit = 1;
SetEvent(p->event);
- // ждем завершения потока
+ // ждем завершения потока
WaitForSingleObject(p->thread, INFINITE);
CloseHandle(p->thread);
CloseHandle(p->event);
@@ -911,7 +911,7 @@ unsigned __stdcall sttConnectThread(LPVOID arg)
WaitForSingleObject(p->event, INFINITE); // dwMsec rc==WAIT_TIMEOUT
if (p->thread_exit == 1) return 0;
if (p->thread_exit == 2) {
- // мы в свободном плавании - освободим память и завершим трэд
+ // мы в свободном плавании - освободим память и завершим трэд
CloseHandle(p->thread);
CloseHandle(p->event);
SAFE_DELETE(p->queue);
@@ -919,11 +919,11 @@ unsigned __stdcall sttConnectThread(LPVOID arg)
return 0;
}
- // дождались сообщения в очереди
+ // дождались сообщения в очереди
while (!p->thread_exit && p->queue && !p->queue->empty()) {
- // обработаем сообщения из очереди
+ // обработаем сообщения из очереди
if (rsa_recv_thread(context, p->queue->front()) == -1) {
- // очистить очередь
+ // очистить очередь
clear_queue(p);
break;
}
generated by cgit v1.2.3 (git 2.25.1) at 2025-01-16 16:58:18 +0000