diff options
Diffstat (limited to 'Telegram/SourceFiles/payments/payments_checkout_process.cpp')
| -rw-r--r-- | Telegram/SourceFiles/payments/payments_checkout_process.cpp | 240 |
1 files changed, 240 insertions, 0 deletions
diff --git a/Telegram/SourceFiles/payments/payments_checkout_process.cpp b/Telegram/SourceFiles/payments/payments_checkout_process.cpp new file mode 100644 index 0000000000..916150a204 --- /dev/null +++ b/Telegram/SourceFiles/payments/payments_checkout_process.cpp @@ -0,0 +1,240 @@ +/* +This file is part of Telegram Desktop, +the official desktop application for the Telegram messaging service. + +For license and copyright information please follow this link: +https://github.com/telegramdesktop/tdesktop/blob/master/LEGAL +*/ +#include "payments/payments_checkout_process.h" + +#include "payments/payments_form.h" +#include "payments/ui/payments_panel.h" +#include "payments/ui/payments_webview.h" +#include "main/main_session.h" +#include "main/main_account.h" +#include "history/history_item.h" +#include "history/history.h" +#include "core/local_url_handlers.h" // TryConvertUrlToLocal. +#include "apiwrap.h" + +// #TODO payments errors +#include "mainwindow.h" +#include "ui/toast/toast.h" + +#include <QJsonDocument> +#include <QJsonObject> +#include <QJsonArray> +#include <QJsonValue> + +namespace Payments { +namespace { + +struct SessionProcesses { + base::flat_map<FullMsgId, std::unique_ptr<CheckoutProcess>> map; + rpl::lifetime lifetime; +}; + +base::flat_map<not_null<Main::Session*>, SessionProcesses> Processes; + +[[nodiscard]] SessionProcesses &LookupSessionProcesses( + not_null<const HistoryItem*> item) { + const auto session = &item->history()->session(); + const auto i = Processes.find(session); + if (i != end(Processes)) { + return i->second; + } + const auto j = Processes.emplace(session).first; + auto &result = j->second; + session->account().sessionChanges( + ) | rpl::start_with_next([=] { + Processes.erase(session); + }, result.lifetime); + return result; +} + +} // namespace + +void CheckoutProcess::Start(not_null<const HistoryItem*> item) { + auto &processes = LookupSessionProcesses(item); + const auto session = &item->history()->session(); + const auto id = item->fullId(); + const auto i = processes.map.find(id); + if (i != end(processes.map)) { + i->second->requestActivate(); + return; + } + const auto j = processes.map.emplace( + id, + std::make_unique<CheckoutProcess>(session, id, PrivateTag{})).first; + j->second->requestActivate(); +} + +CheckoutProcess::CheckoutProcess( + not_null<Main::Session*> session, + FullMsgId itemId, + PrivateTag) +: _session(session) +, _form(std::make_unique<Form>(session, itemId)) +, _panel(std::make_unique<Ui::Panel>(panelDelegate())) { + _form->updates( + ) | rpl::start_with_next([=](const FormUpdate &update) { + handleFormUpdate(update); + }, _lifetime); +} + +CheckoutProcess::~CheckoutProcess() { +} + +void CheckoutProcess::requestActivate() { + _panel->requestActivate(); +} + +not_null<Ui::PanelDelegate*> CheckoutProcess::panelDelegate() { + return static_cast<PanelDelegate*>(this); +} + +void CheckoutProcess::handleFormUpdate(const FormUpdate &update) { + v::match(update.data, [&](const FormReady &) { + _panel->showForm(_form->invoice()); + }, [&](const FormError &error) { + handleFormError(error); + }, [&](const SendError &error) { + handleSendError(error); + }, [&](const VerificationNeeded &info) { + if (_webviewWindow) { + _webviewWindow->navigate(info.url); + } else { + _webviewWindow = std::make_unique<Ui::WebviewWindow>( + info.url, + panelDelegate()); + if (!_webviewWindow->shown()) { + // #TODO payments errors + } + } + }, [&](const PaymentFinished &result) { + const auto weak = base::make_weak(this); + _session->api().applyUpdates(result.updates); + if (weak) { + panelCloseSure(); + } + }); +} + +void CheckoutProcess::handleFormError(const FormError &error) { + // #TODO payments errors + const auto &type = error.type; + if (type == u"PROVIDER_ACCOUNT_INVALID"_q) { + + } else if (type == u"PROVIDER_ACCOUNT_TIMEOUT"_q) { + + } else if (type == u"INVOICE_ALREADY_PAID"_q) { + + } + App::wnd()->activate(); + Ui::Toast::Show("payments.getPaymentForm: " + type); +} + +void CheckoutProcess::handleSendError(const SendError &error) { + // #TODO payments errors + const auto &type = error.type; + if (type == u"REQUESTED_INFO_INVALID"_q) { + + } else if (type == u"SHIPPING_OPTION_INVALID"_q) { + + } else if (type == u"PAYMENT_FAILED"_q) { + + } else if (type == u"PAYMENT_CREDENTIALS_INVALID"_q) { + + } else if (type == u"PAYMENT_CREDENTIALS_ID_INVALID"_q) { + + } else if (type == u"BOT_PRECHECKOUT_FAILED"_q) { + + } + App::wnd()->activate(); + Ui::Toast::Show("payments.sendPaymentForm: " + type); +} + +void CheckoutProcess::panelRequestClose() { + panelCloseSure(); // #TODO payments confirmation +} + +void CheckoutProcess::panelCloseSure() { + const auto i = Processes.find(_session); + if (i == end(Processes)) { + return; + } + const auto j = ranges::find(i->second.map, this, [](const auto &pair) { + return pair.second.get(); + }); + if (j == end(i->second.map)) { + return; + } + i->second.map.erase(j); + if (i->second.map.empty()) { + Processes.erase(i); + } +} + +void CheckoutProcess::panelSubmit() { + _webviewWindow = std::make_unique<Ui::WebviewWindow>( + _form->details().url, + panelDelegate()); + if (!_webviewWindow->shown()) { + // #TODO payments errors + } +} + +void CheckoutProcess::panelWebviewMessage(const QJsonDocument &message) { + if (!message.isArray()) { + LOG(("Payments Error: " + "Not an array received in buy_callback arguments.")); + return; + } + const auto list = message.array(); + if (list.at(0).toString() != "payment_form_submit") { + return; + } else if (!list.at(1).isString()) { + LOG(("Payments Error: " + "Not a string received in buy_callback result.")); + return; + } + + auto error = QJsonParseError(); + const auto document = QJsonDocument::fromJson( + list.at(1).toString().toUtf8(), + &error); + if (error.error != QJsonParseError::NoError) { + LOG(("Payments Error: " + "Failed to parse buy_callback arguments, error: %1." + ).arg(error.errorString())); + return; + } else if (!document.isObject()) { + LOG(("Payments Error: " + "Not an object decoded in buy_callback result.")); + return; + } + const auto root = document.object(); + const auto title = root.value("title").toString(); + const auto credentials = root.value("credentials"); + if (!credentials.isObject()) { + LOG(("Payments Error: " + "Not an object received in payment credentials.")); + return; + } + const auto serializedCredentials = QJsonDocument( + credentials.toObject() + ).toJson(QJsonDocument::Compact); + + _form->send(serializedCredentials); +} + +bool CheckoutProcess::panelWebviewNavigationAttempt(const QString &uri) { + if (Core::TryConvertUrlToLocal(uri) == uri) { + return true; + } + panelCloseSure(); + App::wnd()->activate(); + return false; +} + +} // namespace Payments |