Revise AccountManagerAsh to support multiple receivers

Changes AccountManagerAsh to use ReceiverSet instead of a single
Receiver. This allows having multiple clients talking to the same
AccountManagerAsh instance and also prepares the upcoming unification of
AccountManagerFacade implementations. AccountManagerAsh ownership will
be revised in subsequent CLs.

Bug: 1161699, 1148448
Change-Id: Ida66bce494df802bf5ce4fd99f78d081a9540b95
Reviewed-on: https://chromium-review.googlesource.com/c/chromium/src/+/2614788Reviewed-by: James Cook <jamescook@chromium.org>
Commit-Queue: Boris Sazonov <bsazonov@chromium.org>
Cr-Commit-Position: refs/heads/master@{#841428}

chrome/browser/chromeos/crosapi/account_manager_ash.cc

@@ -13,10 +13,8 @@
 
 namespace crosapi {
 
-AccountManagerAsh::AccountManagerAsh(
-    chromeos::AccountManager* account_manager,
-    mojo::PendingReceiver<mojom::AccountManager> receiver)
-    : account_manager_(account_manager), receiver_(this, std::move(receiver)) {
+AccountManagerAsh::AccountManagerAsh(chromeos::AccountManager* account_manager)
+    : account_manager_(account_manager) {
   DCHECK(account_manager_);
   account_manager_->AddObserver(this);
 }
@@ -25,6 +23,11 @@ AccountManagerAsh::~AccountManagerAsh() {
   account_manager_->RemoveObserver(this);
 }
 
+void AccountManagerAsh::BindReceiver(
+    mojo::PendingReceiver<mojom::AccountManager> receiver) {
+  receivers_.Add(this, std::move(receiver));
+}
+
 void AccountManagerAsh::IsInitialized(IsInitializedCallback callback) {
   std::move(callback).Run(account_manager_->IsInitialized());
 }

chrome/browser/chromeos/crosapi/account_manager_ash.h

@@ -10,7 +10,7 @@
 #include "chromeos/crosapi/mojom/account_manager.mojom.h"
 #include "components/account_manager_core/account.h"
 #include "mojo/public/cpp/bindings/pending_receiver.h"
-#include "mojo/public/cpp/bindings/receiver.h"
+#include "mojo/public/cpp/bindings/receiver_set.h"
 #include "mojo/public/cpp/bindings/remote_set.h"
 
 namespace crosapi {
@@ -21,12 +21,13 @@ namespace crosapi {
 class AccountManagerAsh : public mojom::AccountManager,
                           public chromeos::AccountManager::Observer {
  public:
-  AccountManagerAsh(chromeos::AccountManager* account_manager,
-                    mojo::PendingReceiver<mojom::AccountManager> receiver);
+  explicit AccountManagerAsh(chromeos::AccountManager* account_manager);
   AccountManagerAsh(const AccountManagerAsh&) = delete;
   AccountManagerAsh& operator=(const AccountManagerAsh&) = delete;
   ~AccountManagerAsh() override;
 
+  void BindReceiver(mojo::PendingReceiver<mojom::AccountManager> receiver);
+
   // crosapi::mojom::AccountManager:
   void IsInitialized(IsInitializedCallback callback) override;
   void AddObserver(AddObserverCallback callback) override;
@@ -42,7 +43,7 @@ class AccountManagerAsh : public mojom::AccountManager,
   void FlushMojoForTesting();
 
   chromeos::AccountManager* const account_manager_;
-  mojo::Receiver<mojom::AccountManager> receiver_;
+  mojo::ReceiverSet<mojom::AccountManager> receivers_;
   mojo::RemoteSet<mojom::AccountManagerObserver> observers_;
 };
 

chrome/browser/chromeos/crosapi/account_manager_ash_unittest.cc

@@ -93,8 +93,9 @@ class AccountManagerAshTest : public ::testing::Test {
 
  protected:
   void SetUp() override {
-    account_manager_ash_ = std::make_unique<AccountManagerAsh>(
-        &account_manager_, remote_.BindNewPipeAndPassReceiver());
+    account_manager_ash_ =
+        std::make_unique<AccountManagerAsh>(&account_manager_);
+    account_manager_ash_->BindReceiver(remote_.BindNewPipeAndPassReceiver());
     account_manager_async_waiter_ =
         std::make_unique<mojom::AccountManagerAsyncWaiter>(
             account_manager_ash_.get());

chrome/browser/chromeos/crosapi/ash_chrome_service_impl.cc

@@ -62,7 +62,9 @@ AshChromeServiceImpl::~AshChromeServiceImpl() = default;
 
 void AshChromeServiceImpl::BindAccountManager(
     mojo::PendingReceiver<mojom::AccountManager> receiver) {
-  DVLOG(1) << "Binding AccountManager receiver";
+  // TODO(https://crrev.com/c/2601750): Move AccountManagerAsh ownership to
+  // chromeos::AccountManager.
+  if (!account_manager_ash_) {
     // Assumptions:
     // 1. TODO(https://crbug.com/1102768): Multi-Signin / Fast-User-Switching is
     // disabled.
@@ -86,11 +88,12 @@ void AshChromeServiceImpl::BindAccountManager(
     chromeos::AccountManager* const account_manager =
         g_browser_process->platform_part()
             ->GetAccountManagerFactory()
-          ->GetAccountManager(/* profile_path = */ profile->GetPath().value());
-  // TODO(https://crbug.com/1148448): Convert this to allow multiple,
-  // simultaneous crosapi clients. See BindScreenManager for an example.
-  account_manager_ash_ = std::make_unique<crosapi::AccountManagerAsh>(
-      account_manager, std::move(receiver));
+            ->GetAccountManager(
+                /* profile_path = */ profile->GetPath().value());
+    account_manager_ash_ =
+        std::make_unique<crosapi::AccountManagerAsh>(account_manager);
+  }
+  account_manager_ash_->BindReceiver(std::move(receiver));
 }
 
 void AshChromeServiceImpl::BindFileManager(