Add support for BAP reporting endpoint

components/brave_rewards/browser/rewards_service.cc

@@ -92,6 +92,7 @@ void RewardsService::RegisterProfilePrefs(PrefRegistrySimple* registry) {
  registry->RegisterStringPref(prefs::kParametersMonthlyTipChoices, "");
  registry->RegisterBooleanPref(prefs::kFetchOldBalance, true);
  registry->RegisterBooleanPref(prefs::kEmptyBalanceChecked, false);
+ registry->RegisterBooleanPref(prefs::kBAPReported, false);
  registry->RegisterStringPref(prefs::kWalletBrave, "");
  registry->RegisterStringPref(prefs::kWalletUphold, "");
 }

components/brave_rewards/browser/rewards_service_impl.cc

@@ -1498,6 +1498,9 @@ bool RewardsServiceImpl::GetBooleanOption(const std::string& name) const {
  return false;
  }
 
+ if (name == ledger::option::kShouldReportBAPAmount)
+ return OnlyAnonWallet();
+
  const auto it = kBoolOptions.find(name);
  DCHECK(it != kBoolOptions.end());
 

components/brave_rewards/browser/test/common/rewards_browsertest_response.cc

@@ -258,6 +258,12 @@ void RewardsBrowserTestResponse::Get(
  return;
  }
 
+ if (url.find("/v1/promotions/report-bap") != std::string::npos) {
+ *response = "";
+ *response_status_code = net::HTTP_OK;
+ return;
+ }
+
  if (url.find("/v1/captchas") != std::string::npos) {
  *response = captcha_;
  }

components/brave_rewards/browser/test/rewards_browsertest.cc

@@ -22,6 +22,7 @@
 #include "brave/components/brave_rewards/browser/test/common/rewards_browsertest_promotion.h"
 #include "brave/components/brave_rewards/browser/test/common/rewards_browsertest_response.h"
 #include "brave/components/brave_rewards/browser/test/common/rewards_browsertest_util.h"
+#include "brave/components/brave_rewards/common/pref_names.h"
 #include "chrome/browser/ui/views/frame/browser_view.h"
 #include "chrome/test/base/in_process_browser_test.h"
 #include "chrome/test/base/testing_profile.h"
@@ -522,4 +523,36 @@ IN_PROC_BROWSER_TEST_F(RewardsBrowserTest, BAPPopup) {
  EXPECT_TRUE(popup_shown);
 }
 
+IN_PROC_BROWSER_TEST_F(RewardsBrowserTest, BAPReporting) {
+ rewards_browsertest_util::StartProcess(rewards_service_);
+ rewards_browsertest_util::CreateWallet(rewards_service_);
+ rewards_service_->FetchPromotions();
+ promotion_->WaitForPromotionInitialization();
+ promotion_->ClaimPromotionViaCode();
+
+ rewards_browsertest_util::WaitForLedgerStop(rewards_service_);
+
+ rewards_browsertest_util::StartProcess(rewards_service_);
+ auto* prefs = browser()->profile()->GetPrefs();
+ rewards_browsertest_util::WaitForLedgerStop(rewards_service_);
+
+ EXPECT_FALSE(prefs->GetBoolean(brave_rewards::prefs::kBAPReported));
+
+ prefs->SetInteger(country_codes::kCountryIDAtInstall, 19024);
+
+ base::RunLoop run_loop;
+ PrefChangeRegistrar prefs_listener;
+ prefs_listener.Init(browser()->profile()->GetPrefs());
+ prefs_listener.Add(brave_rewards::prefs::kBAPReported,
+ base::BindLambdaForTesting(
+ [&run_loop](const std::string&) { run_loop.Quit(); }));
+
+ // Start the ledger process and wait for pref to be set, indicating that the
+ // reporting completed successfully.
+ rewards_browsertest_util::StartProcess(rewards_service_);
+ run_loop.Run();
+
+ EXPECT_TRUE(prefs->GetBoolean(brave_rewards::prefs::kBAPReported));
+}
+
 } // namespace rewards_browsertest

components/brave_rewards/common/pref_names.cc

@@ -64,6 +64,7 @@ const char kFetchOldBalance[] =
  "brave.rewards.fetch_old_balance";
 const char kEmptyBalanceChecked[] =
  "brave.rewards.empty_balance_checked";
+const char kBAPReported[] = "brave.rewards.bap_reported";
 const char kWalletBrave[] =
  "brave.rewards.wallets.brave";
 const char kWalletUphold[] =

components/brave_rewards/common/pref_names.h

@@ -52,6 +52,7 @@ extern const char kParametersTipChoices[];
 extern const char kParametersMonthlyTipChoices[];
 extern const char kFetchOldBalance[];
 extern const char kEmptyBalanceChecked[];
+extern const char kBAPReported[];
 extern const char kWalletBrave[];
 extern const char kWalletUphold[];
 

vendor/bat-native-ledger/BUILD.gn

@@ -387,6 +387,10 @@ source_set("ledger") {
  "src/bat/ledger/internal/logging/logging.h",
  "src/bat/ledger/internal/logging/logging_util.cc",
  "src/bat/ledger/internal/logging/logging_util.h",
+ "src/bat/ledger/internal/promotion/bap_reporter.cc",
+ "src/bat/ledger/internal/promotion/bap_reporter.h",
+ "src/bat/ledger/internal/promotion/bap_reporter_endpoint.cc",
+ "src/bat/ledger/internal/promotion/bap_reporter_endpoint.h",
  "src/bat/ledger/internal/promotion/promotion.cc",
  "src/bat/ledger/internal/promotion/promotion.h",
  "src/bat/ledger/internal/promotion/promotion_transfer.cc",

vendor/bat-native-ledger/include/bat/ledger/option_keys.h

@@ -3,8 +3,8 @@
  * License, v. 2.0. If a copy of the MPL was not distributed with this
  * file, You can obtain one at http://mozilla.org/MPL/2.0/. */
 
-#ifndef BRAVELEDGER_OPTION_KEYS_H_
-#define BRAVELEDGER_OPTION_KEYS_H_
+#ifndef BRAVE_VENDOR_BAT_NATIVE_LEDGER_INCLUDE_BAT_LEDGER_OPTION_KEYS_H_
+#define BRAVE_VENDOR_BAT_NATIVE_LEDGER_INCLUDE_BAT_LEDGER_OPTION_KEYS_H_
 
 #include <string>
 
@@ -15,8 +15,9 @@ const char kPublisherListRefreshInterval[] = "publisher_list_refresh_interval";
 const char kClaimUGP[] = "claim_ugp";
 const char kContributionsDisabledForBAPMigration[] =
  "contributions_disabled_for_bap_migration";
+const char kShouldReportBAPAmount[] = "should_report_bap";
 
 } // namespace option
 } // namespace ledger
 
-#endif // BRAVELEDGER_OPTION_KEYS_H_
+#endif // BRAVE_VENDOR_BAT_NATIVE_LEDGER_INCLUDE_BAT_LEDGER_OPTION_KEYS_H_

vendor/bat-native-ledger/src/bat/ledger/internal/promotion/bap_reporter.cc

@@ -0,0 +1,115 @@
+/* Copyright (c) 2021 The Brave Authors. All rights reserved.
+ * This Source Code Form is subject to the terms of the Mozilla Public
+ * License, v. 2.0. If a copy of the MPL was not distributed with this
+ * file, You can obtain one at http://mozilla.org/MPL/2.0/. */
+
+#include "bat/ledger/internal/promotion/bap_reporter.h"
+
+#include "base/time/time.h"
+#include "bat/ledger/global_constants.h"
+#include "bat/ledger/internal/common/time_util.h"
+#include "bat/ledger/internal/ledger_impl.h"
+#include "bat/ledger/option_keys.h"
+
+using std::placeholders::_1;
+using std::placeholders::_2;
+
+namespace ledger {
+namespace promotion {
+
+namespace {
+
+constexpr int64_t kRetryDelay = 24 * base::Time::kSecondsPerHour;
+constexpr int64_t kRetryAfterFailureDelay = 10 * base::Time::kSecondsPerMinute;
+constexpr int64_t kMaxRetryAfterFailureDelay = 4 * base::Time::kSecondsPerHour;
+
+} // namespace
+
+BAPReporter::BAPReporter(LedgerImpl* ledger)
+ : ledger_(ledger), endpoint_(ledger) {
+ DCHECK(ledger);
+}
+
+BAPReporter::~BAPReporter() = default;
+
+void BAPReporter::ReportBAPAmount() {
+ if (running_)
+ return;
+
+ timer_.Stop();
+
+ bool should_report = ledger_->ledger_client()->GetBooleanOption(
+ option::kShouldReportBAPAmount);
+
+ // Only run this reporter if the user is in a BAP region and we haven't
+ // successfully reported yet.
+ if (!should_report || ledger_->state()->GetBAPReported())
+ return;
+
+ running_ = true;
+
+ // First, get the user's unspent BAP tokens.
+ ledger_->database()->GetSpendableUnblindedTokensByBatchTypes(
+ {type::CredsBatchType::PROMOTION},
+ std::bind(&BAPReporter::OnUnblindedTokens, this, _1));
+}
+
+void BAPReporter::OnUnblindedTokens(
+ std::vector<type::UnblindedTokenPtr> tokens) {
+ double amount = 0;
+ for (const auto& token : tokens)
+ amount += token->value;
+
+ // If the user has no BAP, then schedule a retry and exit.
+ if (amount <= 0) {
+ ScheduleRetryAfterZeroBalance();
+ return;
+ }
+
+ // Send the amount to the server.
+ endpoint_.Request(amount,
+ std::bind(&BAPReporter::OnEndpointResponse, this, _1));
+}
+
+void BAPReporter::OnEndpointResponse(bool success) {
+ // If the server reported an error, assume a temporary problem and try again
+ // later.
+ if (!success) {
+ ScheduleRetryAfterFailure();
+ return;
+ }
+
+ BLOG(1, "BAP successsfully reported");
+
+ // Set a flag to indicate that we don't need to report again.
+ ledger_->state()->SetBAPReported(true);
+ running_ = false;
+ retry_count_ = 0;
+}
+
+void BAPReporter::ScheduleRetryAfterZeroBalance() {
+ running_ = false;
+
+ base::TimeDelta delay = base::TimeDelta::FromSeconds(kRetryDelay);
+
+ BLOG(1, "User has zero balance - rescheduling BAP reporting in " << delay);
+ timer_.Start(
+ FROM_HERE, delay,
+ base::BindOnce(&BAPReporter::ReportBAPAmount, base::Unretained(this)));
+}
+
+void BAPReporter::ScheduleRetryAfterFailure() {
+ running_ = false;
+
+ base::TimeDelta delay = util::GetRandomizedDelayWithBackoff(
+ base::TimeDelta::FromSeconds(kRetryAfterFailureDelay),
+ base::TimeDelta::FromSeconds(kMaxRetryAfterFailureDelay), retry_count_++);
+
+ BLOG(1, "BAP reporting failed - rescheduling in " << delay);
+ timer_.Start(
+ FROM_HERE, delay,
+ base::BindOnce(&BAPReporter::ReportBAPAmount, base::Unretained(this)));
+}
+
+} // namespace promotion
+} // namespace ledger

vendor/bat-native-ledger/src/bat/ledger/internal/promotion/bap_reporter.h

@@ -0,0 +1,49 @@
+/* Copyright (c) 2021 The Brave Authors. All rights reserved.
+ * This Source Code Form is subject to the terms of the Mozilla Public
+ * License, v. 2.0. If a copy of the MPL was not distributed with this
+ * file, You can obtain one at http://mozilla.org/MPL/2.0/. */
+
+#ifndef BRAVE_VENDOR_BAT_NATIVE_LEDGER_SRC_BAT_LEDGER_INTERNAL_PROMOTION_BAP_REPORTER_H_
+#define BRAVE_VENDOR_BAT_NATIVE_LEDGER_SRC_BAT_LEDGER_INTERNAL_PROMOTION_BAP_REPORTER_H_
+
+#include <functional>
+#include <vector>
+
+#include "base/timer/timer.h"
+#include "bat/ledger/internal/promotion/bap_reporter_endpoint.h"
+#include "bat/ledger/ledger.h"
+
+namespace ledger {
+
+class LedgerImpl;
+
+namespace promotion {
+
+class BAPReporter {
+ public:
+ explicit BAPReporter(LedgerImpl* ledger);
+
+ BAPReporter(const BAPReporter&) = delete;
+ BAPReporter& operator=(const BAPReporter&) = delete;
+
+ ~BAPReporter();
+
+ void ReportBAPAmount();
+
+ private:
+ void OnUnblindedTokens(std::vector<type::UnblindedTokenPtr> tokens);
+ void OnEndpointResponse(bool success);
+ void ScheduleRetryAfterZeroBalance();
+ void ScheduleRetryAfterFailure();
+
+ LedgerImpl* ledger_;
+ bool running_ = false;
+ int retry_count_ = 0;
+ base::OneShotTimer timer_;
+ BAPReporterEndpoint endpoint_;
+};
+
+} // namespace promotion
+} // namespace ledger
+
+#endif // BRAVE_VENDOR_BAT_NATIVE_LEDGER_SRC_BAT_LEDGER_INTERNAL_PROMOTION_BAP_REPORTER_H_

vendor/bat-native-ledger/src/bat/ledger/internal/promotion/bap_reporter_endpoint.cc

@@ -0,0 +1,92 @@
+/* Copyright (c) 2021 The Brave Authors. All rights reserved.
+ * This Source Code Form is subject to the terms of the Mozilla Public
+ * License, v. 2.0. If a copy of the MPL was not distributed with this
+ * file, You can obtain one at http://mozilla.org/MPL/2.0/. */
+
+#include "bat/ledger/internal/promotion/bap_reporter_endpoint.h"
+
+#include <string>
+#include <utility>
+#include <vector>
+
+#include "base/json/json_writer.h"
+#include "bat/ledger/internal/common/request_util.h"
+#include "bat/ledger/internal/endpoint/promotion/promotions_util.h"
+#include "bat/ledger/internal/ledger_impl.h"
+#include "net/http/http_status_code.h"
+
+using std::placeholders::_1;
+
+namespace ledger {
+namespace promotion {
+
+namespace {
+
+const char kEndpointPath[] = "/v1/promotions/report-bap";
+
+} // namespace
+
+BAPReporterEndpoint::BAPReporterEndpoint(LedgerImpl* ledger) : ledger_(ledger) {
+ DCHECK(ledger_);
+}
+
+BAPReporterEndpoint::~BAPReporterEndpoint() = default;
+
+void BAPReporterEndpoint::Request(double amount, Callback callback) {
+ const auto wallet = ledger_->wallet()->GetWallet();
+ if (!wallet) {
+ BLOG(0, "Wallet is null");
+ callback(false);
+ return;
+ }
+
+ base::Value body(base::Value::Type::DICTIONARY);
+ body.SetDoubleKey("amount", amount);
+ std::string payload;
+ base::JSONWriter::Write(body, &payload);
+
+ const std::string sign_url = std::string("post ") + kEndpointPath;
+ auto headers = util::BuildSignHeaders(sign_url, payload, wallet->payment_id,
+ wallet->recovery_seed);
+
+ auto request = type::UrlRequest::New();
+ request->url = endpoint::promotion::GetServerUrl(kEndpointPath);
+ request->headers = std::move(headers);
+ request->content = std::move(payload);
+ request->content_type = "application/json; charset=utf-8";
+ request->method = type::UrlMethod::POST;
+ ledger_->LoadURL(
+ std::move(request),
+ std::bind(&BAPReporterEndpoint::OnFetchCompleted, this, callback, _1));
+}
+
+void BAPReporterEndpoint::OnFetchCompleted(Callback callback,
+ const type::UrlResponse& response) {
+ ledger::LogUrlResponse(__func__, response);
+
+ bool success = false;
+ switch (response.status_code) {
+ case net::HTTP_BAD_REQUEST: {
+ BLOG(0, "Invalid request");
+ break;
+ }
+ case net::HTTP_INTERNAL_SERVER_ERROR: {
+ BLOG(0, "Internal server error");
+ break;
+ }
+ case net::HTTP_OK:
+ case net::HTTP_CONFLICT: {
+ success = true;
+ break;
+ }
+ default: {
+ BLOG(0, "Unexpected reponse code " << response.status_code);
+ break;
+ }
+ }
+
+ callback(success);
+}
+
+} // namespace promotion
+} // namespace ledger