Add polling and audio check to copresence.

chrome/browser/extensions/api/copresence/copresence_api.cc

 // Copyright 2014 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "chrome/browser/extensions/api/copresence/copresence_api.h"
 
 #include "base/lazy_instance.h"
 #include "base/memory/linked_ptr.h"
 #include "chrome/browser/copresence/chrome_whispernet_client.h"
 #include "chrome/common/chrome_version_info.h"
@@ skipping 97 matching lines @@
       new Event(api::copresence::OnMessagesReceived::kEventName,
                 api::copresence::OnMessagesReceived::Create(subscription_id,
                                                             api_messages),
                 browser_context_));
   EventRouter::Get(browser_context_)
       ->DispatchEventToExtension(app_id, event.Pass());
   DVLOG(2) << "Passed " << api_messages.size() << " messages to app \""
            << app_id << "\" for subscription \"" << subscription_id << "\"";
 }
 
+void CopresenceService::HandleStatusUpdate(
+    copresence::CopresenceStatus status) {
+  // Update all apps using copresence with the new status update.
+  for (const std::string& app_id : copresence_apps_) {
+    scoped_ptr<Event> event(
+        new Event(api::copresence::OnStatusUpdated::kEventName,
+                  api::copresence::OnStatusUpdated::Create(
+                      api::copresence::STATUS_AUDIOFAILED),
+                  browser_context_));
+    EventRouter::Get(browser_context_)
+        ->DispatchEventToExtension(app_id, event.Pass());
+    DVLOG(2) << "Sent Audio Failed status update to app_id: " << app_id;
+  }
+}
+
 net::URLRequestContextGetter* CopresenceService::GetRequestContext() const {
   return browser_context_->GetRequestContext();
 }
 
 const std::string CopresenceService::GetPlatformVersionString() const {
   return chrome::VersionInfo().CreateVersionString();
 }
 
 const std::string CopresenceService::GetAPIKey(const std::string& app_id)
     const {
@@ skipping 32 matching lines @@
 
   // Each execute will correspond to one ReportRequest protocol buffer.
   copresence::ReportRequest request;
   if (!PrepareReportRequestProto(params->operations,
                                  extension_id(),
                                  &service->apps_by_subscription_id(),
                                  &request)) {
     return RespondNow(Error(kInvalidOperationsMessage));
   }
 
+  service->copresence_apps().insert(extension_id());
   service->manager()->ExecuteReportRequest(
       request,
       extension_id(),
       base::Bind(&CopresenceExecuteFunction::SendResult, this));
   return RespondLater();
 }
 
 void CopresenceExecuteFunction::SendResult(
     copresence::CopresenceStatus status) {
   api::copresence::ExecuteStatus api_status =
@@ skipping 21 matching lines @@
   EXTENSION_FUNCTION_VALIDATE(params.get());
 
   // The token may be set to empty, to clear it.
   // TODO(ckehoe): Scope the auth token appropriately (crbug/423517).
   CopresenceService::GetFactoryInstance()->Get(browser_context())
       ->set_auth_token(params->token);
   return RespondNow(NoArguments());
 }
 
 }  // namespace extensions