Adds pagination to publisher list

Resolves brave/brave-browser#9607

components/brave_rewards/browser/rewards_service_browsertest.cc

@@ -391,8 +391,8 @@ class BraveRewardsBrowserTest
     } else if (URLMatches(url, "/captchas", PREFIX_V1,
                           ServerTypes::kPromotion)) {
       *response = brave_test_resp::captcha_;
-    } else if (URLMatches(url, GET_PUBLISHERS_LIST, "",
-                          ServerTypes::PUBLISHER_DISTRO)) {
+    } else if (URLMatches(url, "/api/v3/public/channels", "",
+                          ServerTypes::kPublisher)) {
       if (alter_publisher_list_) {
         *response =
             "["

vendor/bat-native-ledger/BUILD.gn

@@ -245,6 +245,8 @@ source_set("ledger") {
     "src/bat/ledger/internal/request/request_attestation.h",
     "src/bat/ledger/internal/request/request_promotion.cc",
     "src/bat/ledger/internal/request/request_promotion.h",
+    "src/bat/ledger/internal/request/request_publisher.cc",
+    "src/bat/ledger/internal/request/request_publisher.h",
     "src/bat/ledger/internal/request/request_sku.cc",
     "src/bat/ledger/internal/request/request_sku.h",
     "src/bat/ledger/internal/request/request_util.cc",

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

@@ -138,6 +138,8 @@ using ServerPublisherInfoPtr = mojom::ServerPublisherInfoPtr;
 
 using ServerPublisherPartial = mojom::ServerPublisherPartial;
 using ServerPublisherPartialPtr = mojom::ServerPublisherPartialPtr;
+using ServerPublisherPartialList =
+    std::vector<mojom::ServerPublisherPartialPtr>;
 
 using SKUOrder = mojom::SKUOrder;
 using SKUOrderPtr = mojom::SKUOrderPtr;

vendor/bat-native-ledger/include/bat/ledger/public/interfaces/ledger.mojom

@@ -248,7 +248,8 @@ enum Result {
   DATABASE_INIT_FAILED = 28,
   RETRY = 29,
   RETRY_SHORT = 30,
-  RETRY_LONG = 30
+  RETRY_LONG = 31,
+  CONTINUE = 32
 };
 
 enum PublisherStatus {

vendor/bat-native-ledger/src/bat/ledger/internal/publisher/publisher.cc

@@ -56,7 +56,7 @@ void Publisher::OnTimer(uint32_t timer_id) {
 void Publisher::RefreshPublisher(
       const std::string& publisher_key,
       ledger::OnRefreshPublisherCallback callback) {
-  server_list_->Download(std::bind(&Publisher::OnRefreshPublisher,
+  server_list_->Start(std::bind(&Publisher::OnRefreshPublisher,
           this,
           _1,
           publisher_key,

vendor/bat-native-ledger/src/bat/ledger/internal/publisher/publisher.h

@@ -27,10 +27,6 @@ namespace braveledger_publisher {
 
 class PublisherServerList;
 
-using ParsePublisherListCallback = std::function<void(const ledger::Result)>;
-using DownloadServerPublisherListCallback =
-    std::function<void(const ledger::Result)>;
-
 class Publisher {
  public:
   explicit Publisher(bat_ledger::LedgerImpl* ledger);
@@ -92,7 +88,7 @@ class Publisher {
 
   void ParsePublisherList(
       const std::string& data,
-      ParsePublisherListCallback callback);
+      ledger::ResultCallback callback);
 
   void getPublisherActivityFromUrl(
       uint64_t windowId,

vendor/bat-native-ledger/src/bat/ledger/internal/publisher/publisher_server_list.cc

@@ -11,6 +11,7 @@
 #include "bat/ledger/internal/ledger_impl.h"
 #include "bat/ledger/internal/publisher/publisher_server_list.h"
 #include "bat/ledger/internal/state_keys.h"
+#include "bat/ledger/internal/request/request_publisher.h"
 #include "bat/ledger/internal/request/request_util.h"
 #include "bat/ledger/internal/static_values.h"
 #include "bat/ledger/option_keys.h"
@@ -25,6 +26,12 @@ using std::placeholders::_1;
 using std::placeholders::_2;
 using std::placeholders::_3;
 
+namespace {
+
+const int kHardLimit = 100;
+
+}  // namespace
+
 namespace braveledger_publisher {
 
 PublisherServerList::PublisherServerList(bat_ledger::LedgerImpl* ledger) :
@@ -38,19 +45,29 @@ PublisherServerList::~PublisherServerList() {
 void PublisherServerList::OnTimer(uint32_t timer_id) {
   if (timer_id == server_list_timer_id_) {
     server_list_timer_id_ = 0;
-    Download([](const ledger::Result _){});
+    Start([](const ledger::Result _){});
+  }
+}
+
+void PublisherServerList::Start(ledger::ResultCallback callback) {
+  if (in_progress_) {
+    BLOG(ledger_, ledger::LogLevel::LOG_INFO) << "Publisher list in progress";
+    callback(ledger::Result::LEDGER_OK);
+    return;
   }
+
+  in_progress_ = true;
+  current_page_ = 1;
+
+  Download(callback);
 }
 
-void PublisherServerList::Download(
-    DownloadServerPublisherListCallback callback) {
+void PublisherServerList::Download(ledger::ResultCallback callback) {
   std::vector<std::string> headers;
   headers.push_back("Accept-Encoding: gzip");
 
-  const std::string url = braveledger_request_util::BuildUrl(
-      GET_PUBLISHERS_LIST,
-      "",
-      braveledger_request_util::ServerTypes::PUBLISHER_DISTRO);
+  const std::string url =
+      braveledger_request_util::GetPublisherListUrl(current_page_);
 
   const ledger::LoadURLCallback download_callback = std::bind(
       &PublisherServerList::OnDownload,
@@ -73,13 +90,20 @@ void PublisherServerList::OnDownload(
     int response_status_code,
     const std::string& response,
     const std::map<std::string, std::string>& headers,
-    DownloadServerPublisherListCallback callback) {
+    ledger::ResultCallback callback) {
   ledger_->LogResponse(
       __func__,
       response_status_code,
       "Publisher list",
       headers);
 
+  // we iterated through all pages
+  if (response_status_code == net::HTTP_NO_CONTENT) {
+    in_progress_ = false;
+    OnParsePublisherList(ledger::Result::LEDGER_OK, callback);
+    return;
+  }
+
   if (response_status_code == net::HTTP_OK && !response.empty()) {
     const auto parse_callback =
       std::bind(&PublisherServerList::OnParsePublisherList, this, _1, callback);
@@ -103,15 +127,22 @@ void PublisherServerList::OnDownload(
 
 void PublisherServerList::OnParsePublisherList(
     const ledger::Result result,
-    DownloadServerPublisherListCallback callback) {
+    ledger::ResultCallback callback) {
+  if (result == ledger::Result::CONTINUE && current_page_ < kHardLimit) {
+    current_page_++;
+    Download(callback);
+    return;
+  }
+
   uint64_t new_time = 0ull;
-  if (result == ledger::Result::LEDGER_OK) {
+  if (result != ledger::Result::LEDGER_ERROR) {
     ledger_->ContributeUnverifiedPublishers();
     new_time = braveledger_time_util::GetCurrentTimeStamp();
   }
 
   ledger_->SetUint64State(ledger::kStateServerPublisherListStamp, new_time);
 
+  in_progress_ = false;
   bool retry_after_error = result != ledger::Result::LEDGER_OK;
   SetTimer(retry_after_error);
 
@@ -166,7 +197,7 @@ uint64_t PublisherServerList::GetTimerTime(
       ? 0ull
       : now_seconds - last_download;
 
-  uint64_t interval =
+  const uint64_t interval =
       ledger_->GetUint64Option(ledger::kOptionPublisherListRefreshInterval);
 
   if (now_seconds == last_download) {
@@ -196,7 +227,7 @@ ledger::PublisherStatus PublisherServerList::ParsePublisherStatus(
 
 void PublisherServerList::ParsePublisherList(
     const std::string& data,
-    ParsePublisherListCallback callback) {
+    ledger::ResultCallback callback) {
   auto list_publisher =
       std::make_shared<std::vector<ledger::ServerPublisherPartial>>();
   auto list_banner = std::make_shared<std::vector<ledger::PublisherBanner>>();
@@ -247,18 +278,29 @@ void PublisherServerList::ParsePublisherList(
   }
 
   if (list_publisher->empty()) {
+    BLOG(ledger_, ledger::LogLevel::LOG_ERROR) << "Publisher list is empty";
     callback(ledger::Result::LEDGER_ERROR);
     return;
   }
 
-  auto clear_callback = std::bind(&PublisherServerList::SaveParsedData,
+  // we need to clear table when we process first page, but only once
+  if (current_page_ == 1) {
+    auto clear_callback = std::bind(&PublisherServerList::SaveParsedData,
       this,
       _1,
       list_publisher,
       list_banner,
       callback);
 
-  ledger_->ClearServerPublisherList(clear_callback);
+    ledger_->ClearServerPublisherList(clear_callback);
+    return;
+  }
+
+  SaveParsedData(
+      ledger::Result::LEDGER_OK,
+      list_publisher,
+      list_banner,
+      callback);
 }
 
 void PublisherServerList::ParsePublisherBanner(
@@ -312,91 +354,63 @@ void PublisherServerList::SaveParsedData(
     const ledger::Result result,
     const SharedServerPublisherPartial& list_publisher,
     const SharedPublisherBanner& list_banner,
-    ParsePublisherListCallback callback) {
+    ledger::ResultCallback callback) {
   if (result != ledger::Result::LEDGER_OK) {
+    BLOG(ledger_, ledger::LogLevel::LOG_ERROR) << "DB was not cleared";
     callback(result);
     return;
   }
 
-  if (list_publisher && !list_publisher->empty()) {
-    SavePublishers(list_publisher, list_banner, callback);
+  if (!list_publisher || list_publisher->empty()) {
+    BLOG(ledger_, ledger::LogLevel::LOG_ERROR) << "Publisher list is null";
+    callback(ledger::Result::LEDGER_ERROR);
     return;
   }
 
-  if (list_banner && !list_banner->empty()) {
-    SaveBanners(list_banner, callback);
-    return;
-  }
+  auto save_callback = std::bind(&PublisherServerList::SaveBanners,
+      this,
+      _1,
+      list_banner,
+      callback);
 
-  callback(ledger::Result::LEDGER_OK);
+  ledger_->InsertServerPublisherList(*list_publisher, save_callback);
 }
 
-void PublisherServerList::SavePublishers(
-    const SharedServerPublisherPartial& list_publisher,
+void PublisherServerList::SaveBanners(
+    const ledger::Result result,
     const SharedPublisherBanner& list_banner,
-    ParsePublisherListCallback callback) {
-  if (!list_publisher) {
-    callback(ledger::Result::LEDGER_OK);
+    ledger::ResultCallback callback) {
+  if (!list_banner || result != ledger::Result::LEDGER_OK) {
+    BLOG(ledger_, ledger::LogLevel::LOG_ERROR) <<
+        "Publisher list was not saved";
+    callback(ledger::Result::LEDGER_ERROR);
     return;
   }
 
-  const int max_insert_records_ = 100000;
-
-  int32_t interval = max_insert_records_;
-  const auto list_size = list_publisher->size();
-  if (list_size < max_insert_records_) {
-    interval = list_size;
+  if (list_banner->empty()) {
+    callback(ledger::Result::CONTINUE);
+    return;
   }
 
-  std::vector<ledger::ServerPublisherPartial> save_list(
-      list_publisher->begin(),
-      list_publisher->begin() + interval);
-  auto new_list_publisher =
-      std::make_shared<std::vector<ledger::ServerPublisherPartial>>(
-          list_publisher->begin() + interval,
-          list_publisher->end());
-
-  auto save_callback = std::bind(&PublisherServerList::SaveParsedData,
+  auto save_callback = std::bind(&PublisherServerList::BannerSaved,
       this,
       _1,
-      new_list_publisher,
-      list_banner,
       callback);
 
-  ledger_->InsertServerPublisherList(save_list, save_callback);
+  ledger_->InsertPublisherBannerList(*list_banner, save_callback);
 }
 
-void PublisherServerList::SaveBanners(
-    const SharedPublisherBanner& list_banner,
-    ParsePublisherListCallback callback) {
-  if (!list_banner) {
-    callback(ledger::Result::LEDGER_OK);
+void PublisherServerList::BannerSaved(
+    const ledger::Result result,
+    ledger::ResultCallback callback) {
+  if (result == ledger::Result::LEDGER_OK) {
+    callback(ledger::Result::CONTINUE);
     return;
   }
 
-  const int max_insert_records_ = 80000;
-
-  int32_t interval = max_insert_records_;
-  const auto list_size = list_banner->size();
-  if (list_size < max_insert_records_) {
-    interval = list_size;
-  }
 
-  std::vector<ledger::PublisherBanner> save_list(
-      list_banner->begin(),
-      list_banner->begin() + interval);
-  auto new_list_banner = std::make_shared<std::vector<ledger::PublisherBanner>>(
-      list_banner->begin() + interval,
-      list_banner->end());
-
-  auto save_callback = std::bind(&PublisherServerList::SaveParsedData,
-      this,
-      _1,
-      nullptr,
-      new_list_banner,
-      callback);
-
-  ledger_->InsertPublisherBannerList(save_list, save_callback);
+  BLOG(ledger_, ledger::LogLevel::LOG_ERROR) << "Banners were not saved";
+  callback(result);
 }
 
 void PublisherServerList::ClearTimer() {