Revert "Refresh access token only for auth error."

This reverts commit c9b5d530.

Reason for revert: Compile failure: https://ci.chromium.org/buildbot/chromium.chrome/Google%20Chrome%20ChromeOS/56793

Original change's description:
> Refresh access token only for auth error.
> 
> Bug: b:114756954
> Test: Manual
> Change-Id: I1d58906771ad789232d8c01f6de06ea44ad8e3f8
> Reviewed-on: https://chromium-review.googlesource.com/1226527
> Commit-Queue: Yilei Li <yileili@google.com>
> Reviewed-by: Xiaohui Chen <xiaohuic@chromium.org>
> Cr-Commit-Position: refs/heads/master@{#592467}

TBR=xiaohuic@chromium.org,dmblack@google.com,yileili@google.com

Change-Id: I47b836b3b8d1d49e3dde93a8133d80c27a411a5a
No-Presubmit: true
No-Tree-Checks: true
No-Try: true
Bug: b:114756954
Reviewed-on: https://chromium-review.googlesource.com/1234895Reviewed-by: Asanka Herath <asanka@chromium.org>
Commit-Queue: Asanka Herath <asanka@chromium.org>
Cr-Commit-Position: refs/heads/master@{#592512}

chromeos/services/assistant/assistant_manager_service_impl.cc

@@ -642,14 +642,6 @@ void AssistantManagerServiceImpl::OnNotificationRemoved(
           weak_factory_.GetWeakPtr(), grouping_key));
 }
 
-void AssistantManagerServiceImpl::OnCommunicationError(int error_code) {
-  main_thread_task_runner_->PostTask(
-      FROM_HERE,
-      base::BindOnce(
-          &AssistantManagerServiceImpl::OnCommunicationErrorOnMainThread,
-          weak_factory_.GetWeakPtr(), error_code));
-}
-
 void AssistantManagerServiceImpl::OnVoiceInteractionSettingsEnabled(
     bool enabled) {
   assistant_enabled_ = enabled;
@@ -896,12 +888,6 @@ void AssistantManagerServiceImpl::OnNotificationRemovedOnMainThread(
       [grouping_key](auto* ptr) { ptr->OnRemoveNotification(grouping_key); });
 }
 
-void AssistantManagerServiceImpl::OnCommunicationErrorOnMainThread(
-    int error_code) {
-  if (IsAuthError(error_code))
-    service_->RequestAccessToken();
-}
-
 void AssistantManagerServiceImpl::OnRecognitionStateChangedOnMainThread(
     assistant_client::ConversationStateListener::RecognitionState state,
     const assistant_client::ConversationStateListener::RecognitionResult&

chromeos/services/assistant/assistant_manager_service_impl.h

@@ -124,7 +124,6 @@ class AssistantManagerServiceImpl
   bool IsSettingSupported(const std::string& setting_id) override;
   bool SupportsModifySettings() override;
   void OnNotificationRemoved(const std::string& grouping_key) override;
-  void OnCommunicationError(int error_code) override;
   // Last search source will be cleared after it is retrieved.
   std::string GetLastSearchSource() override;
 
@@ -172,7 +171,6 @@ class AssistantManagerServiceImpl
   void OnShowNotificationOnMainThread(
       const mojom::AssistantNotificationPtr& notification);
   void OnNotificationRemovedOnMainThread(const std::string& grouping_id);
-  void OnCommunicationErrorOnMainThread(int error_code);
   void OnRecognitionStateChangedOnMainThread(
       assistant_client::ConversationStateListener::RecognitionState state,
       const assistant_client::ConversationStateListener::RecognitionResult&

chromeos/services/assistant/service.cc

@@ -59,6 +59,7 @@ Service::Service()
       main_thread_task_runner_(base::ThreadTaskRunnerHandle::Get()),
       power_manager_observer_(this),
       voice_interaction_observer_binding_(this),
+      assistant_interaction_subscriber_binding_(this),
       weak_ptr_factory_(this) {
   registry_.AddInterface<mojom::AssistantPlatform>(base::BindRepeating(
       &Service::BindAssistantPlatformConnection, base::Unretained(this)));
@@ -167,6 +168,15 @@ void Service::OnVoiceInteractionHotwordEnabled(bool enabled) {
   RequestAccessToken();
 }
 
+void Service::OnInteractionFinished(
+    mojom::AssistantInteractionResolution resolution) {
+  if (resolution == mojom::AssistantInteractionResolution::kError) {
+    // When communicateion error happens, it could be caused by auth errors.
+    // Retry with a new auth token to attempt recovery.
+    RequestAccessToken();
+  }
+}
+
 void Service::BindAssistantSettingsManager(
     mojom::AssistantSettingsManagerRequest request) {
   DCHECK(assistant_settings_manager_);
@@ -299,6 +309,14 @@ void Service::CreateAssistantManagerService(bool enable_hotword) {
       assistant_manager_service_.get()->GetAssistantSettingsManager();
   registry_.AddInterface<mojom::AssistantSettingsManager>(base::BindRepeating(
       &Service::BindAssistantSettingsManager, base::Unretained(this)));
+
+  // Subscribe to Assistant interaction events.
+  chromeos::assistant::mojom::AssistantInteractionSubscriberPtr
+      interaction_subscriber_ptr;
+  assistant_interaction_subscriber_binding_.Bind(
+      mojo::MakeRequest(&interaction_subscriber_ptr));
+  assistant_manager_service_->AddAssistantInteractionSubscriber(
+      std::move(interaction_subscriber_ptr));
 #endif
 }
 

chromeos/services/assistant/service.h

@@ -42,6 +42,7 @@ class AssistantSettingsManager;
 class Service : public service_manager::Service,
                 public chromeos::PowerManagerClient::Observer,
                 public ash::mojom::SessionActivationObserver,
+                public mojom::AssistantInteractionSubscriber,
                 public mojom::AssistantPlatform,
                 public ash::mojom::VoiceInteractionObserver {
  public:
@@ -54,8 +55,6 @@ class Service : public service_manager::Service,
     return assistant_controller_.get();
   }
 
-  void RequestAccessToken();
-
   void SetIdentityManagerForTesting(
       identity::mojom::IdentityManagerPtr identity_manager);
 
@@ -96,9 +95,30 @@ class Service : public service_manager::Service,
       ash::mojom::AssistantAllowedState state) override {}
   void OnLocaleChanged(const std::string& locale) override {}
 
+  // chromeos::assistant::mojom::AssistantInteractionSubscriber:
+  void OnInteractionStarted(bool is_voice_interaction) override{};
+  void OnInteractionFinished(
+      mojom::AssistantInteractionResolution resolution) override;
+  void OnHtmlResponse(const std::string& response) override{};
+  void OnSuggestionsResponse(
+      std::vector<mojom::AssistantSuggestionPtr> response) override{};
+  void OnTextResponse(const std::string& response) override{};
+  void OnOpenUrlResponse(const GURL& url) override{};
+  void OnSpeechRecognitionStarted() override{};
+  void OnSpeechRecognitionIntermediateResult(
+      const std::string& high_confidence_text,
+      const std::string& low_confidence_text) override{};
+  void OnSpeechRecognitionEndOfUtterance() override{};
+  void OnSpeechRecognitionFinalResult(
+      const std::string& final_result) override{};
+  void OnSpeechLevelUpdated(float speech_level) override{};
+  void OnTtsStarted(bool due_to_error) override{};
+
   void BindAssistantSettingsManager(
       mojom::AssistantSettingsManagerRequest request);
 
+  void RequestAccessToken();
+
   identity::mojom::IdentityManager* GetIdentityManager();
 
   void GetPrimaryAccountInfoCallback(
@@ -153,6 +173,8 @@ class Service : public service_manager::Service,
   ash::mojom::VoiceInteractionControllerPtr voice_interaction_controller_;
   mojo::Binding<ash::mojom::VoiceInteractionObserver>
       voice_interaction_observer_binding_;
+  mojo::Binding<chromeos::assistant::mojom::AssistantInteractionSubscriber>
+      assistant_interaction_subscriber_binding_;
 
   base::WeakPtrFactory<Service> weak_ptr_factory_;