From 1979fd80424d16b2e489f9b57d01d9c7811d25a2 Mon Sep 17 00:00:00 2001 From: dartraiden Date: Mon, 2 Jan 2023 21:10:29 +0300 Subject: Update copyrights --- protocols/Omegle/src/chat.cpp | 2 +- protocols/Omegle/src/client.h | 2 +- protocols/Omegle/src/communication.cpp | 1524 ++++++++++++++++---------------- protocols/Omegle/src/connection.cpp | 2 +- protocols/Omegle/src/constants.h | 2 +- protocols/Omegle/src/db.h | 2 +- protocols/Omegle/src/dialogs.cpp | 2 +- protocols/Omegle/src/dialogs.h | 2 +- protocols/Omegle/src/http.cpp | 2 +- protocols/Omegle/src/http.h | 2 +- protocols/Omegle/src/main.cpp | 2 +- protocols/Omegle/src/messages.cpp | 148 ++-- protocols/Omegle/src/proto.cpp | 2 +- protocols/Omegle/src/proto.h | 2 +- protocols/Omegle/src/stdafx.cxx | 2 +- protocols/Omegle/src/stdafx.h | 2 +- protocols/Omegle/src/theme.cpp | 2 +- protocols/Omegle/src/theme.h | 2 +- protocols/Omegle/src/version.h | 2 +- 19 files changed, 853 insertions(+), 853 deletions(-) (limited to 'protocols/Omegle/src') diff --git a/protocols/Omegle/src/chat.cpp b/protocols/Omegle/src/chat.cpp index 1e732b8004..484d7b0e34 100644 --- a/protocols/Omegle/src/chat.cpp +++ b/protocols/Omegle/src/chat.cpp @@ -3,7 +3,7 @@ Omegle plugin for Miranda Instant Messenger _____________________________________________ -Copyright © 2011-17 Robert Pösel, 2017-22 Miranda NG team +Copyright © 2011-17 Robert Pösel, 2017-23 Miranda NG team This program is free software: you can redistribute it and/or modify it under the terms of the GNU General Public License as published by diff --git a/protocols/Omegle/src/client.h b/protocols/Omegle/src/client.h index ae3da3ca3a..1a34b20629 100644 --- a/protocols/Omegle/src/client.h +++ b/protocols/Omegle/src/client.h @@ -3,7 +3,7 @@ Omegle plugin for Miranda Instant Messenger _____________________________________________ -Copyright © 2011-17 Robert Pösel, 2017-22 Miranda NG team +Copyright © 2011-17 Robert Pösel, 2017-23 Miranda NG team This program is free software: you can redistribute it and/or modify it under the terms of the GNU General Public License as published by diff --git a/protocols/Omegle/src/communication.cpp b/protocols/Omegle/src/communication.cpp index f033cd93a6..dfd1dc4dd4 100644 --- a/protocols/Omegle/src/communication.cpp +++ b/protocols/Omegle/src/communication.cpp @@ -1,762 +1,762 @@ -/* - -Omegle plugin for Miranda Instant Messenger -_____________________________________________ - -Copyright © 2011-17 Robert Pösel, 2017-22 Miranda NG team - -This program 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 2 of the License, or -(at your option) any later version. - -This program 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. - -You should have received a copy of the GNU General Public License -along with this program. If not, see . -*/ - -#include "stdafx.h" - -http::response Omegle_client::flap(const int request_type, std::string *post_data, std::string *get_data) -{ - http::response resp; - - // Prepare the request - NETLIBHTTPREQUEST nlhr = { sizeof(NETLIBHTTPREQUEST) }; - - // Set request URL - std::string url = choose_server(request_type) + choose_action(request_type, get_data); - nlhr.szUrl = (char*)url.c_str(); - - // Set timeout (bigger for channel request) - nlhr.timeout = 1000 * ((request_type == OMEGLE_REQUEST_EVENTS) ? 65 : 20); - - // Set request type (GET/POST) and eventually also POST data - if (post_data != nullptr) { - nlhr.requestType = REQUEST_POST; - nlhr.pData = (char*)(*post_data).c_str(); - nlhr.dataLength = (int)post_data->length(); - } - else { - nlhr.requestType = REQUEST_GET; - } - - // Set headers - it depends on requestType so it must be after setting that - nlhr.headers = get_request_headers(nlhr.requestType, &nlhr.headersCount); - - // Set flags - nlhr.flags = NLHRF_HTTP11; - -#ifdef _DEBUG - nlhr.flags |= NLHRF_DUMPASTEXT; -#else - nlhr.flags |= NLHRF_NODUMP; -#endif - - // Set persistent connection (or not) - switch (request_type) - { - case OMEGLE_REQUEST_HOME: - nlhr.nlc = nullptr; - break; - - case OMEGLE_REQUEST_EVENTS: - nlhr.nlc = hEventsConnection; - nlhr.flags |= NLHRF_PERSISTENT; - break; - - default: - WaitForSingleObject(connection_lock_, INFINITE); - nlhr.nlc = hConnection; - nlhr.flags |= NLHRF_PERSISTENT; - break; - } - - parent->debugLogA("@@@@@ Sending request to '%s'", nlhr.szUrl); - - // Send the request - NLHR_PTR pnlhr(Netlib_HttpTransaction(handle_, &nlhr)); - - mir_free(nlhr.headers); - - // Remember the persistent connection handle (or not) - switch (request_type) - { - case OMEGLE_REQUEST_HOME: - break; - - case OMEGLE_REQUEST_EVENTS: - hEventsConnection = pnlhr ? pnlhr->nlc : nullptr; - break; - - default: - ReleaseMutex(connection_lock_); - hConnection = pnlhr ? pnlhr->nlc : nullptr; - break; - } - - // Check and copy response data - if (pnlhr != nullptr) - { - parent->debugLogA("@@@@@ Got response with code %d", pnlhr->resultCode); - store_headers(&resp, pnlhr->headers, pnlhr->headersCount); - resp.code = pnlhr->resultCode; - resp.data = pnlhr->pData ? pnlhr->pData : ""; - - // This error code gives us some error page, but we don't need that, so clear the response - if (pnlhr->resultCode == HTTP_CODE_WEB_SERVER_IS_DOWN) { - resp.data = ""; - } - - parent->debugLogA("&&&&& Got response: %s", resp.data.c_str()); - } - else { - parent->debugLogA("!!!!! No response from server (time-out)"); - resp.code = HTTP_CODE_FAKE_DISCONNECTED; - // Better to have something set explicitely as this value is compaired in all communication requests - } - - return resp; -} - -bool Omegle_client::handle_entry(const std::string &method) -{ - parent->debugLogA(" >> Entering %s()", method.c_str()); - return true; -} - -bool Omegle_client::handle_success(const std::string &method) -{ - parent->debugLogA(" << Quitting %s()", method.c_str()); - reset_error(); - return true; -} - -bool Omegle_client::handle_error(const std::string &method, bool force_disconnect) -{ - bool result; - increment_error(); - parent->debugLogA("!!!!! %s(): Something with Omegle went wrong", method.c_str()); - - if (force_disconnect) - result = false; - else if (error_count_ <= (UINT)db_get_b(0, parent->m_szModuleName, OMEGLE_KEY_TIMEOUTS_LIMIT, OMEGLE_TIMEOUTS_LIMIT)) - result = true; - else - result = false; - - if (result == false) - { - reset_error(); - parent->UpdateChat(nullptr, TranslateT("Connection error.")); - parent->StopChat(false); - } - - return result; -} - -////////////////////////////////////////////////////////////////////////////// - -std::string Omegle_client::get_server(bool not_last) -{ - int q = not_last ? 1 : 0; - - int server = db_get_b(0, parent->m_szModuleName, OMEGLE_KEY_SERVER, 0); - if (server < 0 || server >= (int)(_countof(servers) - q)) - server = 0; - - if (server == 0) { - srand(::time(0)); - server = (rand() % (_countof(servers) - 1 - q)) + 1; - } - - return servers[server]; -} - -std::string Omegle_client::get_language() -{ - int language = db_get_b(0, parent->m_szModuleName, OMEGLE_KEY_LANGUAGE, 0); - if (language < 0 || language >= (_countof(languages))) - language = 0; - - return language > 0 ? languages[language].id : "en"; -} - -std::string Omegle_client::choose_server(int request_type) -{ - switch (request_type) - { - case OMEGLE_REQUEST_HOME: - return OMEGLE_SERVER_REGULAR; - - /* case OMEGLE_REQUEST_START: - case OMEGLE_REQUEST_STOP: - case OMEGLE_REQUEST_SEND: - case OMEGLE_REQUEST_EVENTS: - case OMEGLE_REQUEST_TYPING_START: - case OMEGLE_REQUEST_TYPING_STOP: - case OMEGLE_REQUEST_RECAPTCHA: - case OMEGLE_REQUEST_COUNT: - */ default: - std::string server = OMEGLE_SERVER_CHAT; - utils::text::replace_first(&server, "%s", this->server_); - return server; - } -} - -std::string Omegle_client::choose_action(int request_type, std::string* get_data) -{ - switch (request_type) - { - case OMEGLE_REQUEST_START: - { - std::string action = "/start?caps=recaptcha2,t&rcs=1&spid=&lang="; - action += get_language(); - if (get_data != nullptr) - action += (*get_data); - - return action; - } - - case OMEGLE_REQUEST_STOP: - return "/disconnect"; - - case OMEGLE_REQUEST_SEND: - return "/send"; - - case OMEGLE_REQUEST_EVENTS: - return "/events"; - - case OMEGLE_REQUEST_TYPING_START: - return "/typing"; - - case OMEGLE_REQUEST_TYPING_STOP: - return "/stoppedtyping"; - - case OMEGLE_REQUEST_RECAPTCHA: - return "/recaptcha"; - - case OMEGLE_REQUEST_COUNT: - return "/count"; - - // "/stoplookingforcommonlikes" - - /* case OMEGLE_REQUEST_HOME: - */ default: - return "/"; - } -} - - -NETLIBHTTPHEADER* Omegle_client::get_request_headers(int request_type, int* headers_count) -{ - if (request_type == REQUEST_POST) - *headers_count = 4; - else - *headers_count = 3; - - NETLIBHTTPHEADER *headers = (NETLIBHTTPHEADER*)mir_calloc(sizeof(NETLIBHTTPHEADER)*(*headers_count)); - - if (request_type == REQUEST_POST) { - headers[3].szName = "Content-Type"; - headers[3].szValue = "application/x-www-form-urlencoded; charset=utf-8"; - } - - headers[2].szName = "User-Agent"; - headers[2].szValue = Netlib_GetUserAgent(); - headers[1].szName = "Accept"; - headers[1].szValue = "*/*"; - headers[0].szName = "Accept-Language"; - headers[0].szValue = "en,en-US;q=0.9"; - - return headers; -} - -void Omegle_client::store_headers(http::response* resp, NETLIBHTTPHEADER* headers, int headersCount) -{ - for (size_t i = 0; i < (size_t)headersCount; i++) - { - std::string header_name = headers[i].szName; - std::string header_value = headers[i].szValue; - - // TODO RM: (un)comment - //parent->debugLogA("----- Got header '%s': %s", header_name.c_str(), header_value.c_str()); - resp->headers[header_name] = header_value; - } -} - -////////////////////////////////////////////////////////////////////////////// - -bool Omegle_client::start() -{ - HANDLE_ENTRY; - - this->server_ = get_server(); - //parent->debugLogA("Chosing server %s", this->server_.c_str()); - //std::string log = Translate("Chosing server: ") + this->server_; - //parent->UpdateChat(NULL, log.c_str()); - - std::string data; - - if (this->spy_mode_) { - //// get last server from list, which is for spy mode - //this->server_ = servers[_countof(servers)-1]; - - if (this->question_.empty()) { - data = "&wantsspy=1"; - } - else { - data = "&ask=" + utils::url::encode(this->question_); - data += "&cansavequestion="; - data += db_get_b(0, parent->m_szModuleName, OMEGLE_KEY_REUSE_QUESTION, 0) ? "1" : "0"; - } - } - else if (db_get_b(0, parent->m_szModuleName, OMEGLE_KEY_MEET_COMMON, 0)) - { - DBVARIANT dbv; - if (!db_get_utf(NULL, parent->m_szModuleName, OMEGLE_KEY_INTERESTS, &dbv)) - { - std::string topics = dbv.pszVal; - std::string topic; - - db_free(&dbv); - - std::string::size_type pos = 0; - std::string::size_type pos2 = 0; - while ((pos2 = topics.find(",", pos)) != std::string::npos) { - topic = topics.substr(pos, pos2 - pos); - topic = utils::text::trim(topic); - - if (!topic.empty()) { - if (pos > 0) - data += ","; - - data += "\"" + topic + "\""; - } - - pos = pos2 + 1; - } - - topic = topics.substr(pos); - topic = utils::text::trim(topic); - if (!topic.empty()) { - if (pos > 0) - data += ","; - data += "\"" + topic + "\""; - } - - parent->debugLogA("TOPICS: %s", data.c_str()); - - if (!data.empty()) { - data = "[" + data + "]"; - data = "&topics=" + utils::url::encode(data); - } - - //// get any server but last, which is for spy mode - //this->server_ = get_server(true); - } - } - - if (db_get_b(0, parent->m_szModuleName, OMEGLE_KEY_SERVER_INFO, 0)) - { - std::string count = get_page(OMEGLE_REQUEST_COUNT); - if (!count.empty()) { - char str[255]; - mir_snprintf(str, Translate("Connected to server %s. There are %s users online now."), server_.c_str(), count.c_str()); - - wchar_t *msg = mir_a2u(str); - parent->UpdateChat(nullptr, msg); - mir_free(msg); - } - } - else { - char str[255]; - mir_snprintf(str, Translate("Connected to server %s."), server_.c_str()); - - wchar_t *msg = mir_a2u(str); - parent->UpdateChat(nullptr, msg); - mir_free(msg); - } - - // Send validation - http::response resp = flap(OMEGLE_REQUEST_START, nullptr, &data); - - switch (resp.code) - { - case HTTP_CODE_FAKE_DISCONNECTED: - { - // If is is only timeout error, try login once more - if (HANDLE_ERROR(false)) - return start(); - else - return false; - } - - case HTTP_CODE_OK: - { - if (!resp.data.empty()) { - this->chat_id_ = resp.data.substr(1, resp.data.length() - 2); - this->state_ = STATE_WAITING; - - return HANDLE_SUCCESS; - } - else { - return HANDLE_ERROR(FORCE_DISCONNECT); - } - } - - default: - return HANDLE_ERROR(FORCE_DISCONNECT); - } -} - -bool Omegle_client::stop() -{ - if (parent->isOffline()) - return true; - - HANDLE_ENTRY; - - std::string data = "id=" + this->chat_id_; - - http::response resp = flap(OMEGLE_REQUEST_STOP, &data); - - Netlib_Shutdown(hConnection); - Netlib_Shutdown(hEventsConnection); - - return (resp.data == "win") ? HANDLE_SUCCESS : HANDLE_ERROR(false); -} - -bool Omegle_client::events() -{ - HANDLE_ENTRY; - - std::string post_data = "id=" + this->chat_id_; - - // Get update - http::response resp = flap(OMEGLE_REQUEST_EVENTS, &post_data); - - // Return - switch (resp.code) - { - case HTTP_CODE_OK: - { - if (resp.data == "null") { - // Everything is OK, no new message received -- OR it is a problem - // TODO: if we are waiting for Stranger with common likes, then we should try standard Stranger if this takes too long - return HANDLE_ERROR(false); - } - else if (resp.data == "fail") { - // Something went wrong - return HANDLE_ERROR(false); - } - - JSONROOT root(resp.data.c_str()); - if (root == nullptr) - return HANDLE_ERROR(false); - - bool newStranger = false; - bool waiting = false; - - for (size_t i = 0; i < json_size(root); i++) { - JSONNode *item = json_at(root, i); - if (item == nullptr) - continue; - - std::string name = _T2A(json_as_string(json_at(item, 0))); - - if (name == "waiting") { - // We are just waiting for new Stranger - waiting = true; - } - else if (name == "identDigests") { - // We get some comma separated hashes, I'm not sure what for - } - else if (name == "statusInfo") { - JSONNode *data = json_at(item, 1); - - // We got some object as second parameter - //data["antinudepercent"]; // probably 1 by default - //data["antinudeservers"]; // array of server names, like "waw3.omegle.com" - //data["rtmfp"]; // some rtmfp protocol address - //data["servers"]; // array of server names, like "front5.omegle.com" - //data["spyeeQueueTime"]; // some float number, e.g. 0.0701999903 - //data["spyQueueTime"]; // some float number, e.g. 4.7505000114 - //data["timestamp"]; // e.g. 1445336566.0196209 - - // We got info about count of connected people there - ptrW count(json_as_string(json_get(data, "count"))); - wchar_t strT[255]; - mir_snwprintf(strT, TranslateT("On whole Omegle are %s strangers online now."), count.get()); - - parent->UpdateChat(nullptr, strT); - } - else if (name == "serverMessage") { - ptrW message(json_as_string(json_at(item, 1))); - parent->UpdateChat(nullptr, TranslateW(message)); - } - else if (name == "connected") { - // Stranger connected - if (this->spy_mode_ && !this->question_.empty()) { - parent->AddChatContact(TranslateT("Stranger 1")); - parent->AddChatContact(TranslateT("Stranger 2")); - this->state_ = STATE_SPY; - } - else { - parent->AddChatContact(TranslateT("Stranger")); - this->state_ = STATE_ACTIVE; - } - - newStranger = true; - waiting = false; - } - else if (name == "commonLikes") { - std::wstring likes = TranslateT("You and the Stranger both like: "); - - JSONNode *items = json_at(item, 1); - size_t size = json_size(items); - for (size_t j = 0; j < size; j++) { - likes += ptrW(json_as_string(json_at(items, j))); - if (j < size - 1) - likes += L", "; - } - - parent->debugLogW(L"Got common likes: '%s'", likes.c_str()); - parent->SetTopic(likes.c_str()); - } - else if (name == "question") { - ptrW question(json_as_string(json_at(item, 1))); - parent->SetTopic(question); - } - else if (name == "typing" || name == "spyTyping") { - // Stranger is typing, not supported by chat module yet - Skin_PlaySound("StrangerTyp"); - - ptrW who(name == "spyTyping" ? json_as_string(json_at(item, 1)) : mir_wstrdup(L"Stranger")); - Srmm_SetStatusText(parent->GetChatHandle(), CMStringW(FORMAT, TranslateT("%s is typing."), TranslateW(who)), g_plugin.getIcon(IDI_TYPING_ON)); - } - else if (name == "stoppedTyping" || name == "spyStoppedTyping") { - // Stranger stopped typing, not supported by chat module yet - Skin_PlaySound("StrangerTypStop"); - - ptrW who(name == "spyTyping" ? json_as_string(json_at(item, 1)) : mir_wstrdup(L"Stranger")); - Srmm_SetStatusText(parent->GetChatHandle(), CMStringW(FORMAT, TranslateT("%s stopped typing."), TranslateW(who)), g_plugin.getIcon(IDI_TYPING_OFF)); - } - else if (name == "gotMessage") { - Srmm_SetStatusText(parent->GetChatHandle(), nullptr); - - // Play sound as we received message - Skin_PlaySound("StrangerMessage"); - - if (state_ == STATE_ACTIVE) { - ptrW msg(json_as_string(json_at(item, 1))); - parent->UpdateChat(TranslateT("Stranger"), msg); - } - } - else if (name == "spyMessage") { - Srmm_SetStatusText(parent->GetChatHandle(), nullptr); - - // Play sound as we received message - Skin_PlaySound("StrangerMessage"); - - if (state_ == STATE_SPY) { - ptrW stranger(json_as_string(json_at(item, 1))); - ptrW msg(json_as_string(json_at(item, 2))); - parent->UpdateChat(stranger, msg); - } - } - else if (name == "strangerDisconnected") { - Srmm_SetStatusText(parent->GetChatHandle(), nullptr); - - // Stranger disconnected - if (db_get_b(0, parent->m_szModuleName, OMEGLE_KEY_DONT_STOP, 0)) - { - Skin_PlaySound("StrangerChange"); - parent->NewChat(); - } - else - parent->StopChat(false); - } - else if (name == "spyDisconnected") { - Srmm_SetStatusText(parent->GetChatHandle(), nullptr); - - ptrW stranger(json_as_string(json_at(item, 1))); - - wchar_t strT[255]; - mir_snwprintf(strT, TranslateT("%s disconnected."), TranslateW(stranger)); - parent->UpdateChat(nullptr, strT); - - // Stranger disconnected - if (db_get_b(0, parent->m_szModuleName, OMEGLE_KEY_DONT_STOP, 0)) - { - Skin_PlaySound("StrangerChange"); - parent->NewChat(); - } - else - parent->StopChat(false); - } - else if (name == "recaptchaRequired") { - // Nothing to do with recaptcha - parent->UpdateChat(nullptr, TranslateT("Recaptcha is required.\nOpen http://omegle.com , solve Recaptcha and try again.")); - parent->StopChat(false); - } - else if (name == "recaptchaRejected") { - // Nothing to do with recaptcha - parent->StopChat(false); - } - else if (name == "error") { - ptrW error(json_as_string(json_at(item, 1))); - - wchar_t strT[255]; - mir_snwprintf(strT, TranslateT("Error: %s"), TranslateW(error)); - parent->UpdateChat(nullptr, strT); - } - } - - if (newStranger && !spy_mode_) { - // We got new stranger in this event, lets say him "Hi message" if enabled - if (db_get_b(0, parent->m_szModuleName, OMEGLE_KEY_HI_ENABLED, 0)) { - DBVARIANT dbv; - if (!db_get_utf(NULL, parent->m_szModuleName, OMEGLE_KEY_HI, &dbv)) { - std::vector messages; - utils::text::explode(std::string(dbv.pszVal), "\r\n", &messages); - db_free(&dbv); - - int pos = rand() % messages.size(); - std::string *message = new std::string(messages.at(pos)); - - parent->debugLogA("**Chat - saying Hi! message"); - parent->ForkThread(&OmegleProto::SendMsgWorker, message); - } - else parent->debugLogA("**Chat - Hi message is enabled but not used"); - } - } - - if (waiting) { - // If we are only waiting in this event... - parent->UpdateChat(nullptr, TranslateT("We are still waiting...")); - } - - return HANDLE_SUCCESS; - } - - case HTTP_CODE_FAKE_DISCONNECTED: - // timeout - return HANDLE_SUCCESS; - - default: - return HANDLE_ERROR(false); - } -} - -bool Omegle_client::send_message(const std::string &message_text) -{ - HANDLE_ENTRY; - - std::string data = "msg=" + utils::url::encode(message_text); - data += "&id=" + this->chat_id_; - - http::response resp = flap(OMEGLE_REQUEST_SEND, &data); - - switch (resp.code) - { - case HTTP_CODE_OK: - if (resp.data == "win") { - return HANDLE_SUCCESS; - } - - case HTTP_CODE_FAKE_DISCONNECTED: - default: - return HANDLE_ERROR(false); - } -} - -bool Omegle_client::typing_start() -{ - HANDLE_ENTRY; - - std::string data = "id=" + this->chat_id_; - - http::response resp = flap(OMEGLE_REQUEST_TYPING_START, &data); - - switch (resp.code) - { - case HTTP_CODE_OK: - if (resp.data == "win") { - return HANDLE_SUCCESS; - } - - case HTTP_CODE_FAKE_DISCONNECTED: - default: - return HANDLE_ERROR(false); - } -} - -bool Omegle_client::typing_stop() -{ - HANDLE_ENTRY; - - std::string data = "id=" + this->chat_id_; - - http::response resp = flap(OMEGLE_REQUEST_TYPING_STOP, &data); - - switch (resp.code) - { - case HTTP_CODE_OK: - if (resp.data == "win") { - return HANDLE_SUCCESS; - } - - case HTTP_CODE_FAKE_DISCONNECTED: - default: - return HANDLE_ERROR(false); - } -} - -bool Omegle_client::recaptcha() -{ - // TODO: Implement! - - HANDLE_ENTRY; - - // data:{id:this.clientID,challenge:b,response:a}} - //std::string data = "?id=...&challenge= ..., &response= ..."; - - http::response resp = flap(OMEGLE_REQUEST_RECAPTCHA); - - switch (resp.code) - { - case HTTP_CODE_OK: - /* if (resp.data == "win") { - return handle_success( "typing_start" ); - }*/ - - case HTTP_CODE_FAKE_DISCONNECTED: - default: - return HANDLE_ERROR(false); - } -} - -std::string Omegle_client::get_page(const int request_type) -{ - HANDLE_ENTRY; - - http::response resp = flap(request_type); - - switch (resp.code) - { - case HTTP_CODE_OK: - HANDLE_SUCCESS; - break; - - case HTTP_CODE_FAKE_DISCONNECTED: - default: - HANDLE_ERROR(false); - } - - return resp.data; -} +/* + +Omegle plugin for Miranda Instant Messenger +_____________________________________________ + +Copyright © 2011-17 Robert Pösel, 2017-23 Miranda NG team + +This program 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 2 of the License, or +(at your option) any later version. + +This program 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. + +You should have received a copy of the GNU General Public License +along with this program. If not, see . +*/ + +#include "stdafx.h" + +http::response Omegle_client::flap(const int request_type, std::string *post_data, std::string *get_data) +{ + http::response resp; + + // Prepare the request + NETLIBHTTPREQUEST nlhr = { sizeof(NETLIBHTTPREQUEST) }; + + // Set request URL + std::string url = choose_server(request_type) + choose_action(request_type, get_data); + nlhr.szUrl = (char*)url.c_str(); + + // Set timeout (bigger for channel request) + nlhr.timeout = 1000 * ((request_type == OMEGLE_REQUEST_EVENTS) ? 65 : 20); + + // Set request type (GET/POST) and eventually also POST data + if (post_data != nullptr) { + nlhr.requestType = REQUEST_POST; + nlhr.pData = (char*)(*post_data).c_str(); + nlhr.dataLength = (int)post_data->length(); + } + else { + nlhr.requestType = REQUEST_GET; + } + + // Set headers - it depends on requestType so it must be after setting that + nlhr.headers = get_request_headers(nlhr.requestType, &nlhr.headersCount); + + // Set flags + nlhr.flags = NLHRF_HTTP11; + +#ifdef _DEBUG + nlhr.flags |= NLHRF_DUMPASTEXT; +#else + nlhr.flags |= NLHRF_NODUMP; +#endif + + // Set persistent connection (or not) + switch (request_type) + { + case OMEGLE_REQUEST_HOME: + nlhr.nlc = nullptr; + break; + + case OMEGLE_REQUEST_EVENTS: + nlhr.nlc = hEventsConnection; + nlhr.flags |= NLHRF_PERSISTENT; + break; + + default: + WaitForSingleObject(connection_lock_, INFINITE); + nlhr.nlc = hConnection; + nlhr.flags |= NLHRF_PERSISTENT; + break; + } + + parent->debugLogA("@@@@@ Sending request to '%s'", nlhr.szUrl); + + // Send the request + NLHR_PTR pnlhr(Netlib_HttpTransaction(handle_, &nlhr)); + + mir_free(nlhr.headers); + + // Remember the persistent connection handle (or not) + switch (request_type) + { + case OMEGLE_REQUEST_HOME: + break; + + case OMEGLE_REQUEST_EVENTS: + hEventsConnection = pnlhr ? pnlhr->nlc : nullptr; + break; + + default: + ReleaseMutex(connection_lock_); + hConnection = pnlhr ? pnlhr->nlc : nullptr; + break; + } + + // Check and copy response data + if (pnlhr != nullptr) + { + parent->debugLogA("@@@@@ Got response with code %d", pnlhr->resultCode); + store_headers(&resp, pnlhr->headers, pnlhr->headersCount); + resp.code = pnlhr->resultCode; + resp.data = pnlhr->pData ? pnlhr->pData : ""; + + // This error code gives us some error page, but we don't need that, so clear the response + if (pnlhr->resultCode == HTTP_CODE_WEB_SERVER_IS_DOWN) { + resp.data = ""; + } + + parent->debugLogA("&&&&& Got response: %s", resp.data.c_str()); + } + else { + parent->debugLogA("!!!!! No response from server (time-out)"); + resp.code = HTTP_CODE_FAKE_DISCONNECTED; + // Better to have something set explicitely as this value is compaired in all communication requests + } + + return resp; +} + +bool Omegle_client::handle_entry(const std::string &method) +{ + parent->debugLogA(" >> Entering %s()", method.c_str()); + return true; +} + +bool Omegle_client::handle_success(const std::string &method) +{ + parent->debugLogA(" << Quitting %s()", method.c_str()); + reset_error(); + return true; +} + +bool Omegle_client::handle_error(const std::string &method, bool force_disconnect) +{ + bool result; + increment_error(); + parent->debugLogA("!!!!! %s(): Something with Omegle went wrong", method.c_str()); + + if (force_disconnect) + result = false; + else if (error_count_ <= (UINT)db_get_b(0, parent->m_szModuleName, OMEGLE_KEY_TIMEOUTS_LIMIT, OMEGLE_TIMEOUTS_LIMIT)) + result = true; + else + result = false; + + if (result == false) + { + reset_error(); + parent->UpdateChat(nullptr, TranslateT("Connection error.")); + parent->StopChat(false); + } + + return result; +} + +////////////////////////////////////////////////////////////////////////////// + +std::string Omegle_client::get_server(bool not_last) +{ + int q = not_last ? 1 : 0; + + int server = db_get_b(0, parent->m_szModuleName, OMEGLE_KEY_SERVER, 0); + if (server < 0 || server >= (int)(_countof(servers) - q)) + server = 0; + + if (server == 0) { + srand(::time(0)); + server = (rand() % (_countof(servers) - 1 - q)) + 1; + } + + return servers[server]; +} + +std::string Omegle_client::get_language() +{ + int language = db_get_b(0, parent->m_szModuleName, OMEGLE_KEY_LANGUAGE, 0); + if (language < 0 || language >= (_countof(languages))) + language = 0; + + return language > 0 ? languages[language].id : "en"; +} + +std::string Omegle_client::choose_server(int request_type) +{ + switch (request_type) + { + case OMEGLE_REQUEST_HOME: + return OMEGLE_SERVER_REGULAR; + + /* case OMEGLE_REQUEST_START: + case OMEGLE_REQUEST_STOP: + case OMEGLE_REQUEST_SEND: + case OMEGLE_REQUEST_EVENTS: + case OMEGLE_REQUEST_TYPING_START: + case OMEGLE_REQUEST_TYPING_STOP: + case OMEGLE_REQUEST_RECAPTCHA: + case OMEGLE_REQUEST_COUNT: + */ default: + std::string server = OMEGLE_SERVER_CHAT; + utils::text::replace_first(&server, "%s", this->server_); + return server; + } +} + +std::string Omegle_client::choose_action(int request_type, std::string* get_data) +{ + switch (request_type) + { + case OMEGLE_REQUEST_START: + { + std::string action = "/start?caps=recaptcha2,t&rcs=1&spid=&lang="; + action += get_language(); + if (get_data != nullptr) + action += (*get_data); + + return action; + } + + case OMEGLE_REQUEST_STOP: + return "/disconnect"; + + case OMEGLE_REQUEST_SEND: + return "/send"; + + case OMEGLE_REQUEST_EVENTS: + return "/events"; + + case OMEGLE_REQUEST_TYPING_START: + return "/typing"; + + case OMEGLE_REQUEST_TYPING_STOP: + return "/stoppedtyping"; + + case OMEGLE_REQUEST_RECAPTCHA: + return "/recaptcha"; + + case OMEGLE_REQUEST_COUNT: + return "/count"; + + // "/stoplookingforcommonlikes" + + /* case OMEGLE_REQUEST_HOME: + */ default: + return "/"; + } +} + + +NETLIBHTTPHEADER* Omegle_client::get_request_headers(int request_type, int* headers_count) +{ + if (request_type == REQUEST_POST) + *headers_count = 4; + else + *headers_count = 3; + + NETLIBHTTPHEADER *headers = (NETLIBHTTPHEADER*)mir_calloc(sizeof(NETLIBHTTPHEADER)*(*headers_count)); + + if (request_type == REQUEST_POST) { + headers[3].szName = "Content-Type"; + headers[3].szValue = "application/x-www-form-urlencoded; charset=utf-8"; + } + + headers[2].szName = "User-Agent"; + headers[2].szValue = Netlib_GetUserAgent(); + headers[1].szName = "Accept"; + headers[1].szValue = "*/*"; + headers[0].szName = "Accept-Language"; + headers[0].szValue = "en,en-US;q=0.9"; + + return headers; +} + +void Omegle_client::store_headers(http::response* resp, NETLIBHTTPHEADER* headers, int headersCount) +{ + for (size_t i = 0; i < (size_t)headersCount; i++) + { + std::string header_name = headers[i].szName; + std::string header_value = headers[i].szValue; + + // TODO RM: (un)comment + //parent->debugLogA("----- Got header '%s': %s", header_name.c_str(), header_value.c_str()); + resp->headers[header_name] = header_value; + } +} + +////////////////////////////////////////////////////////////////////////////// + +bool Omegle_client::start() +{ + HANDLE_ENTRY; + + this->server_ = get_server(); + //parent->debugLogA("Chosing server %s", this->server_.c_str()); + //std::string log = Translate("Chosing server: ") + this->server_; + //parent->UpdateChat(NULL, log.c_str()); + + std::string data; + + if (this->spy_mode_) { + //// get last server from list, which is for spy mode + //this->server_ = servers[_countof(servers)-1]; + + if (this->question_.empty()) { + data = "&wantsspy=1"; + } + else { + data = "&ask=" + utils::url::encode(this->question_); + data += "&cansavequestion="; + data += db_get_b(0, parent->m_szModuleName, OMEGLE_KEY_REUSE_QUESTION, 0) ? "1" : "0"; + } + } + else if (db_get_b(0, parent->m_szModuleName, OMEGLE_KEY_MEET_COMMON, 0)) + { + DBVARIANT dbv; + if (!db_get_utf(NULL, parent->m_szModuleName, OMEGLE_KEY_INTERESTS, &dbv)) + { + std::string topics = dbv.pszVal; + std::string topic; + + db_free(&dbv); + + std::string::size_type pos = 0; + std::string::size_type pos2 = 0; + while ((pos2 = topics.find(",", pos)) != std::string::npos) { + topic = topics.substr(pos, pos2 - pos); + topic = utils::text::trim(topic); + + if (!topic.empty()) { + if (pos > 0) + data += ","; + + data += "\"" + topic + "\""; + } + + pos = pos2 + 1; + } + + topic = topics.substr(pos); + topic = utils::text::trim(topic); + if (!topic.empty()) { + if (pos > 0) + data += ","; + data += "\"" + topic + "\""; + } + + parent->debugLogA("TOPICS: %s", data.c_str()); + + if (!data.empty()) { + data = "[" + data + "]"; + data = "&topics=" + utils::url::encode(data); + } + + //// get any server but last, which is for spy mode + //this->server_ = get_server(true); + } + } + + if (db_get_b(0, parent->m_szModuleName, OMEGLE_KEY_SERVER_INFO, 0)) + { + std::string count = get_page(OMEGLE_REQUEST_COUNT); + if (!count.empty()) { + char str[255]; + mir_snprintf(str, Translate("Connected to server %s. There are %s users online now."), server_.c_str(), count.c_str()); + + wchar_t *msg = mir_a2u(str); + parent->UpdateChat(nullptr, msg); + mir_free(msg); + } + } + else { + char str[255]; + mir_snprintf(str, Translate("Connected to server %s."), server_.c_str()); + + wchar_t *msg = mir_a2u(str); + parent->UpdateChat(nullptr, msg); + mir_free(msg); + } + + // Send validation + http::response resp = flap(OMEGLE_REQUEST_START, nullptr, &data); + + switch (resp.code) + { + case HTTP_CODE_FAKE_DISCONNECTED: + { + // If is is only timeout error, try login once more + if (HANDLE_ERROR(false)) + return start(); + else + return false; + } + + case HTTP_CODE_OK: + { + if (!resp.data.empty()) { + this->chat_id_ = resp.data.substr(1, resp.data.length() - 2); + this->state_ = STATE_WAITING; + + return HANDLE_SUCCESS; + } + else { + return HANDLE_ERROR(FORCE_DISCONNECT); + } + } + + default: + return HANDLE_ERROR(FORCE_DISCONNECT); + } +} + +bool Omegle_client::stop() +{ + if (parent->isOffline()) + return true; + + HANDLE_ENTRY; + + std::string data = "id=" + this->chat_id_; + + http::response resp = flap(OMEGLE_REQUEST_STOP, &data); + + Netlib_Shutdown(hConnection); + Netlib_Shutdown(hEventsConnection); + + return (resp.data == "win") ? HANDLE_SUCCESS : HANDLE_ERROR(false); +} + +bool Omegle_client::events() +{ + HANDLE_ENTRY; + + std::string post_data = "id=" + this->chat_id_; + + // Get update + http::response resp = flap(OMEGLE_REQUEST_EVENTS, &post_data); + + // Return + switch (resp.code) + { + case HTTP_CODE_OK: + { + if (resp.data == "null") { + // Everything is OK, no new message received -- OR it is a problem + // TODO: if we are waiting for Stranger with common likes, then we should try standard Stranger if this takes too long + return HANDLE_ERROR(false); + } + else if (resp.data == "fail") { + // Something went wrong + return HANDLE_ERROR(false); + } + + JSONROOT root(resp.data.c_str()); + if (root == nullptr) + return HANDLE_ERROR(false); + + bool newStranger = false; + bool waiting = false; + + for (size_t i = 0; i < json_size(root); i++) { + JSONNode *item = json_at(root, i); + if (item == nullptr) + continue; + + std::string name = _T2A(json_as_string(json_at(item, 0))); + + if (name == "waiting") { + // We are just waiting for new Stranger + waiting = true; + } + else if (name == "identDigests") { + // We get some comma separated hashes, I'm not sure what for + } + else if (name == "statusInfo") { + JSONNode *data = json_at(item, 1); + + // We got some object as second parameter + //data["antinudepercent"]; // probably 1 by default + //data["antinudeservers"]; // array of server names, like "waw3.omegle.com" + //data["rtmfp"]; // some rtmfp protocol address + //data["servers"]; // array of server names, like "front5.omegle.com" + //data["spyeeQueueTime"]; // some float number, e.g. 0.0701999903 + //data["spyQueueTime"]; // some float number, e.g. 4.7505000114 + //data["timestamp"]; // e.g. 1445336566.0196209 + + // We got info about count of connected people there + ptrW count(json_as_string(json_get(data, "count"))); + wchar_t strT[255]; + mir_snwprintf(strT, TranslateT("On whole Omegle are %s strangers online now."), count.get()); + + parent->UpdateChat(nullptr, strT); + } + else if (name == "serverMessage") { + ptrW message(json_as_string(json_at(item, 1))); + parent->UpdateChat(nullptr, TranslateW(message)); + } + else if (name == "connected") { + // Stranger connected + if (this->spy_mode_ && !this->question_.empty()) { + parent->AddChatContact(TranslateT("Stranger 1")); + parent->AddChatContact(TranslateT("Stranger 2")); + this->state_ = STATE_SPY; + } + else { + parent->AddChatContact(TranslateT("Stranger")); + this->state_ = STATE_ACTIVE; + } + + newStranger = true; + waiting = false; + } + else if (name == "commonLikes") { + std::wstring likes = TranslateT("You and the Stranger both like: "); + + JSONNode *items = json_at(item, 1); + size_t size = json_size(items); + for (size_t j = 0; j < size; j++) { + likes += ptrW(json_as_string(json_at(items, j))); + if (j < size - 1) + likes += L", "; + } + + parent->debugLogW(L"Got common likes: '%s'", likes.c_str()); + parent->SetTopic(likes.c_str()); + } + else if (name == "question") { + ptrW question(json_as_string(json_at(item, 1))); + parent->SetTopic(question); + } + else if (name == "typing" || name == "spyTyping") { + // Stranger is typing, not supported by chat module yet + Skin_PlaySound("StrangerTyp"); + + ptrW who(name == "spyTyping" ? json_as_string(json_at(item, 1)) : mir_wstrdup(L"Stranger")); + Srmm_SetStatusText(parent->GetChatHandle(), CMStringW(FORMAT, TranslateT("%s is typing."), TranslateW(who)), g_plugin.getIcon(IDI_TYPING_ON)); + } + else if (name == "stoppedTyping" || name == "spyStoppedTyping") { + // Stranger stopped typing, not supported by chat module yet + Skin_PlaySound("StrangerTypStop"); + + ptrW who(name == "spyTyping" ? json_as_string(json_at(item, 1)) : mir_wstrdup(L"Stranger")); + Srmm_SetStatusText(parent->GetChatHandle(), CMStringW(FORMAT, TranslateT("%s stopped typing."), TranslateW(who)), g_plugin.getIcon(IDI_TYPING_OFF)); + } + else if (name == "gotMessage") { + Srmm_SetStatusText(parent->GetChatHandle(), nullptr); + + // Play sound as we received message + Skin_PlaySound("StrangerMessage"); + + if (state_ == STATE_ACTIVE) { + ptrW msg(json_as_string(json_at(item, 1))); + parent->UpdateChat(TranslateT("Stranger"), msg); + } + } + else if (name == "spyMessage") { + Srmm_SetStatusText(parent->GetChatHandle(), nullptr); + + // Play sound as we received message + Skin_PlaySound("StrangerMessage"); + + if (state_ == STATE_SPY) { + ptrW stranger(json_as_string(json_at(item, 1))); + ptrW msg(json_as_string(json_at(item, 2))); + parent->UpdateChat(stranger, msg); + } + } + else if (name == "strangerDisconnected") { + Srmm_SetStatusText(parent->GetChatHandle(), nullptr); + + // Stranger disconnected + if (db_get_b(0, parent->m_szModuleName, OMEGLE_KEY_DONT_STOP, 0)) + { + Skin_PlaySound("StrangerChange"); + parent->NewChat(); + } + else + parent->StopChat(false); + } + else if (name == "spyDisconnected") { + Srmm_SetStatusText(parent->GetChatHandle(), nullptr); + + ptrW stranger(json_as_string(json_at(item, 1))); + + wchar_t strT[255]; + mir_snwprintf(strT, TranslateT("%s disconnected."), TranslateW(stranger)); + parent->UpdateChat(nullptr, strT); + + // Stranger disconnected + if (db_get_b(0, parent->m_szModuleName, OMEGLE_KEY_DONT_STOP, 0)) + { + Skin_PlaySound("StrangerChange"); + parent->NewChat(); + } + else + parent->StopChat(false); + } + else if (name == "recaptchaRequired") { + // Nothing to do with recaptcha + parent->UpdateChat(nullptr, TranslateT("Recaptcha is required.\nOpen http://omegle.com , solve Recaptcha and try again.")); + parent->StopChat(false); + } + else if (name == "recaptchaRejected") { + // Nothing to do with recaptcha + parent->StopChat(false); + } + else if (name == "error") { + ptrW error(json_as_string(json_at(item, 1))); + + wchar_t strT[255]; + mir_snwprintf(strT, TranslateT("Error: %s"), TranslateW(error)); + parent->UpdateChat(nullptr, strT); + } + } + + if (newStranger && !spy_mode_) { + // We got new stranger in this event, lets say him "Hi message" if enabled + if (db_get_b(0, parent->m_szModuleName, OMEGLE_KEY_HI_ENABLED, 0)) { + DBVARIANT dbv; + if (!db_get_utf(NULL, parent->m_szModuleName, OMEGLE_KEY_HI, &dbv)) { + std::vector messages; + utils::text::explode(std::string(dbv.pszVal), "\r\n", &messages); + db_free(&dbv); + + int pos = rand() % messages.size(); + std::string *message = new std::string(messages.at(pos)); + + parent->debugLogA("**Chat - saying Hi! message"); + parent->ForkThread(&OmegleProto::SendMsgWorker, message); + } + else parent->debugLogA("**Chat - Hi message is enabled but not used"); + } + } + + if (waiting) { + // If we are only waiting in this event... + parent->UpdateChat(nullptr, TranslateT("We are still waiting...")); + } + + return HANDLE_SUCCESS; + } + + case HTTP_CODE_FAKE_DISCONNECTED: + // timeout + return HANDLE_SUCCESS; + + default: + return HANDLE_ERROR(false); + } +} + +bool Omegle_client::send_message(const std::string &message_text) +{ + HANDLE_ENTRY; + + std::string data = "msg=" + utils::url::encode(message_text); + data += "&id=" + this->chat_id_; + + http::response resp = flap(OMEGLE_REQUEST_SEND, &data); + + switch (resp.code) + { + case HTTP_CODE_OK: + if (resp.data == "win") { + return HANDLE_SUCCESS; + } + + case HTTP_CODE_FAKE_DISCONNECTED: + default: + return HANDLE_ERROR(false); + } +} + +bool Omegle_client::typing_start() +{ + HANDLE_ENTRY; + + std::string data = "id=" + this->chat_id_; + + http::response resp = flap(OMEGLE_REQUEST_TYPING_START, &data); + + switch (resp.code) + { + case HTTP_CODE_OK: + if (resp.data == "win") { + return HANDLE_SUCCESS; + } + + case HTTP_CODE_FAKE_DISCONNECTED: + default: + return HANDLE_ERROR(false); + } +} + +bool Omegle_client::typing_stop() +{ + HANDLE_ENTRY; + + std::string data = "id=" + this->chat_id_; + + http::response resp = flap(OMEGLE_REQUEST_TYPING_STOP, &data); + + switch (resp.code) + { + case HTTP_CODE_OK: + if (resp.data == "win") { + return HANDLE_SUCCESS; + } + + case HTTP_CODE_FAKE_DISCONNECTED: + default: + return HANDLE_ERROR(false); + } +} + +bool Omegle_client::recaptcha() +{ + // TODO: Implement! + + HANDLE_ENTRY; + + // data:{id:this.clientID,challenge:b,response:a}} + //std::string data = "?id=...&challenge= ..., &response= ..."; + + http::response resp = flap(OMEGLE_REQUEST_RECAPTCHA); + + switch (resp.code) + { + case HTTP_CODE_OK: + /* if (resp.data == "win") { + return handle_success( "typing_start" ); + }*/ + + case HTTP_CODE_FAKE_DISCONNECTED: + default: + return HANDLE_ERROR(false); + } +} + +std::string Omegle_client::get_page(const int request_type) +{ + HANDLE_ENTRY; + + http::response resp = flap(request_type); + + switch (resp.code) + { + case HTTP_CODE_OK: + HANDLE_SUCCESS; + break; + + case HTTP_CODE_FAKE_DISCONNECTED: + default: + HANDLE_ERROR(false); + } + + return resp.data; +} diff --git a/protocols/Omegle/src/connection.cpp b/protocols/Omegle/src/connection.cpp index 7750fe9038..db2b73970c 100644 --- a/protocols/Omegle/src/connection.cpp +++ b/protocols/Omegle/src/connection.cpp @@ -3,7 +3,7 @@ Omegle plugin for Miranda Instant Messenger _____________________________________________ -Copyright © 2011-17 Robert Pösel, 2017-22 Miranda NG team +Copyright © 2011-17 Robert Pösel, 2017-23 Miranda NG team This program is free software: you can redistribute it and/or modify it under the terms of the GNU General Public License as published by diff --git a/protocols/Omegle/src/constants.h b/protocols/Omegle/src/constants.h index 67ce350240..5bc923f4a3 100644 --- a/protocols/Omegle/src/constants.h +++ b/protocols/Omegle/src/constants.h @@ -3,7 +3,7 @@ Omegle plugin for Miranda Instant Messenger _____________________________________________ -Copyright © 2011-17 Robert Pösel, 2017-22 Miranda NG team +Copyright © 2011-17 Robert Pösel, 2017-23 Miranda NG team This program is free software: you can redistribute it and/or modify it under the terms of the GNU General Public License as published by diff --git a/protocols/Omegle/src/db.h b/protocols/Omegle/src/db.h index 3798d0af78..45d3478828 100644 --- a/protocols/Omegle/src/db.h +++ b/protocols/Omegle/src/db.h @@ -3,7 +3,7 @@ Omegle plugin for Miranda Instant Messenger _____________________________________________ -Copyright © 2011-17 Robert Pösel, 2017-22 Miranda NG team +Copyright © 2011-17 Robert Pösel, 2017-23 Miranda NG team This program is free software: you can redistribute it and/or modify it under the terms of the GNU General Public License as published by diff --git a/protocols/Omegle/src/dialogs.cpp b/protocols/Omegle/src/dialogs.cpp index e71b6aa542..ee243053c0 100644 --- a/protocols/Omegle/src/dialogs.cpp +++ b/protocols/Omegle/src/dialogs.cpp @@ -3,7 +3,7 @@ Omegle plugin for Miranda Instant Messenger _____________________________________________ -Copyright © 2011-17 Robert Pösel, 2017-22 Miranda NG team +Copyright © 2011-17 Robert Pösel, 2017-23 Miranda NG team This program is free software: you can redistribute it and/or modify it under the terms of the GNU General Public License as published by diff --git a/protocols/Omegle/src/dialogs.h b/protocols/Omegle/src/dialogs.h index 4685b9de4c..080b36c07a 100644 --- a/protocols/Omegle/src/dialogs.h +++ b/protocols/Omegle/src/dialogs.h @@ -3,7 +3,7 @@ Omegle plugin for Miranda Instant Messenger _____________________________________________ -Copyright © 2011-17 Robert Pösel, 2017-22 Miranda NG team +Copyright © 2011-17 Robert Pösel, 2017-23 Miranda NG team This program is free software: you can redistribute it and/or modify it under the terms of the GNU General Public License as published by diff --git a/protocols/Omegle/src/http.cpp b/protocols/Omegle/src/http.cpp index b21f5e8602..45bb2a62a2 100644 --- a/protocols/Omegle/src/http.cpp +++ b/protocols/Omegle/src/http.cpp @@ -3,7 +3,7 @@ Omegle plugin for Miranda Instant Messenger _____________________________________________ -Copyright © 2011-17 Robert Pösel, 2017-22 Miranda NG team +Copyright © 2011-17 Robert Pösel, 2017-23 Miranda NG team This program is free software: you can redistribute it and/or modify it under the terms of the GNU General Public License as published by diff --git a/protocols/Omegle/src/http.h b/protocols/Omegle/src/http.h index aeffb16f51..b107aaf3a0 100644 --- a/protocols/Omegle/src/http.h +++ b/protocols/Omegle/src/http.h @@ -3,7 +3,7 @@ Omegle plugin for Miranda Instant Messenger _____________________________________________ -Copyright © 2011-17 Robert Pösel, 2017-22 Miranda NG team +Copyright © 2011-17 Robert Pösel, 2017-23 Miranda NG team This program is free software: you can redistribute it and/or modify it under the terms of the GNU General Public License as published by diff --git a/protocols/Omegle/src/main.cpp b/protocols/Omegle/src/main.cpp index 20de90c123..72b1edc3cd 100644 --- a/protocols/Omegle/src/main.cpp +++ b/protocols/Omegle/src/main.cpp @@ -3,7 +3,7 @@ Omegle plugin for Miranda Instant Messenger _____________________________________________ -Copyright © 2011-17 Robert Pösel, 2017-22 Miranda NG team +Copyright © 2011-17 Robert Pösel, 2017-23 Miranda NG team This program is free software: you can redistribute it and/or modify it under the terms of the GNU General Public License as published by diff --git a/protocols/Omegle/src/messages.cpp b/protocols/Omegle/src/messages.cpp index cd92e02be9..fd7a79e4ae 100644 --- a/protocols/Omegle/src/messages.cpp +++ b/protocols/Omegle/src/messages.cpp @@ -1,74 +1,74 @@ -/* - -Omegle plugin for Miranda Instant Messenger -_____________________________________________ - -Copyright © 2011-17 Robert Pösel, 2017-22 Miranda NG team - -This program 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 2 of the License, or -(at your option) any later version. - -This program 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. - -You should have received a copy of the GNU General Public License -along with this program. If not, see . - -*/ - -#include "stdafx.h" - -void OmegleProto::SendMsgWorker(void *p) -{ - if (p == nullptr) - return; - - std::string data = *(std::string*)p; - delete (std::string*)p; - - data = utils::text::trim(data); - - if (facy.state_ == STATE_ACTIVE && data.length() && facy.send_message(data)) { - wchar_t *msg = mir_a2u_cp(data.c_str(), CP_UTF8); - UpdateChat(facy.nick_, msg); - mir_free(msg); - } -} - -void OmegleProto::SendTypingWorker(void *p) -{ - if (p == nullptr) - return; - - // Save typing info - bool typ = (*static_cast(p) == PROTOTYPE_SELFTYPING_ON); - delete (int*)p; - - // Ignore same typing info - if (facy.typing_ == typ) - return; - - if (facy.state_ != STATE_ACTIVE) - return; - - facy.typing_ = typ; - - if (typ) - facy.typing_start(); - else - facy.typing_stop(); -} - -void OmegleProto::NewChatWorker(void*) -{ - NewChat(); -} - -void OmegleProto::StopChatWorker(void*) -{ - StopChat(); -} +/* + +Omegle plugin for Miranda Instant Messenger +_____________________________________________ + +Copyright © 2011-17 Robert Pösel, 2017-23 Miranda NG team + +This program 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 2 of the License, or +(at your option) any later version. + +This program 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. + +You should have received a copy of the GNU General Public License +along with this program. If not, see . + +*/ + +#include "stdafx.h" + +void OmegleProto::SendMsgWorker(void *p) +{ + if (p == nullptr) + return; + + std::string data = *(std::string*)p; + delete (std::string*)p; + + data = utils::text::trim(data); + + if (facy.state_ == STATE_ACTIVE && data.length() && facy.send_message(data)) { + wchar_t *msg = mir_a2u_cp(data.c_str(), CP_UTF8); + UpdateChat(facy.nick_, msg); + mir_free(msg); + } +} + +void OmegleProto::SendTypingWorker(void *p) +{ + if (p == nullptr) + return; + + // Save typing info + bool typ = (*static_cast(p) == PROTOTYPE_SELFTYPING_ON); + delete (int*)p; + + // Ignore same typing info + if (facy.typing_ == typ) + return; + + if (facy.state_ != STATE_ACTIVE) + return; + + facy.typing_ = typ; + + if (typ) + facy.typing_start(); + else + facy.typing_stop(); +} + +void OmegleProto::NewChatWorker(void*) +{ + NewChat(); +} + +void OmegleProto::StopChatWorker(void*) +{ + StopChat(); +} diff --git a/protocols/Omegle/src/proto.cpp b/protocols/Omegle/src/proto.cpp index ccc0cb9173..036dc41d6f 100644 --- a/protocols/Omegle/src/proto.cpp +++ b/protocols/Omegle/src/proto.cpp @@ -3,7 +3,7 @@ Omegle plugin for Miranda Instant Messenger _____________________________________________ -Copyright © 2011-17 Robert Pösel, 2017-22 Miranda NG team +Copyright © 2011-17 Robert Pösel, 2017-23 Miranda NG team This program is free software: you can redistribute it and/or modify it under the terms of the GNU General Public License as published by diff --git a/protocols/Omegle/src/proto.h b/protocols/Omegle/src/proto.h index 388e94299a..839d6ecb25 100644 --- a/protocols/Omegle/src/proto.h +++ b/protocols/Omegle/src/proto.h @@ -3,7 +3,7 @@ Omegle plugin for Miranda Instant Messenger _____________________________________________ -Copyright © 2011-17 Robert Pösel, 2017-22 Miranda NG team +Copyright © 2011-17 Robert Pösel, 2017-23 Miranda NG team This program is free software: you can redistribute it and/or modify it under the terms of the GNU General Public License as published by diff --git a/protocols/Omegle/src/stdafx.cxx b/protocols/Omegle/src/stdafx.cxx index f64d25234b..ebbde0ade1 100644 --- a/protocols/Omegle/src/stdafx.cxx +++ b/protocols/Omegle/src/stdafx.cxx @@ -1,5 +1,5 @@ /* -Copyright (C) 2012-22 Miranda NG team (https://miranda-ng.org) +Copyright (C) 2012-23 Miranda NG team (https://miranda-ng.org) This program is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License diff --git a/protocols/Omegle/src/stdafx.h b/protocols/Omegle/src/stdafx.h index d10351511d..81425082c5 100644 --- a/protocols/Omegle/src/stdafx.h +++ b/protocols/Omegle/src/stdafx.h @@ -3,7 +3,7 @@ Omegle plugin for Miranda Instant Messenger _____________________________________________ -Copyright © 2011-17 Robert Pösel, 2017-22 Miranda NG team +Copyright © 2011-17 Robert Pösel, 2017-23 Miranda NG team This program is free software: you can redistribute it and/or modify it under the terms of the GNU General Public License as published by diff --git a/protocols/Omegle/src/theme.cpp b/protocols/Omegle/src/theme.cpp index ce96ff5224..f9899adbe9 100644 --- a/protocols/Omegle/src/theme.cpp +++ b/protocols/Omegle/src/theme.cpp @@ -3,7 +3,7 @@ Omegle plugin for Miranda Instant Messenger _____________________________________________ -Copyright © 2011-17 Robert Pösel, 2017-22 Miranda NG team +Copyright © 2011-17 Robert Pösel, 2017-23 Miranda NG team This program is free software: you can redistribute it and/or modify it under the terms of the GNU General Public License as published by diff --git a/protocols/Omegle/src/theme.h b/protocols/Omegle/src/theme.h index 5b50f4648e..0418ca4268 100644 --- a/protocols/Omegle/src/theme.h +++ b/protocols/Omegle/src/theme.h @@ -3,7 +3,7 @@ Omegle plugin for Miranda Instant Messenger _____________________________________________ -Copyright © 2011-17 Robert Pösel, 2017-22 Miranda NG team +Copyright © 2011-17 Robert Pösel, 2017-23 Miranda NG team This program is free software: you can redistribute it and/or modify it under the terms of the GNU General Public License as published by diff --git a/protocols/Omegle/src/version.h b/protocols/Omegle/src/version.h index d30f57170c..3780281020 100644 --- a/protocols/Omegle/src/version.h +++ b/protocols/Omegle/src/version.h @@ -10,4 +10,4 @@ #define __DESCRIPTION "Omegle protocol support for Miranda NG." #define __AUTHOR "Robert Pösel" #define __AUTHORWEB "https://miranda-ng.org/p/Omegle" -#define __COPYRIGHT "© 2011-17 Robert Pösel, 2017-22 Miranda NG team" +#define __COPYRIGHT "© 2011-17 Robert Pösel, 2017-23 Miranda NG team" -- cgit v1.2.3