[Background Sync] Use Mojo IPC to fire background sync events

content/browser/service_worker/service_worker_event_dispatcher.cc

Index: content/browser/service_worker/service_worker_event_dispatcher.cc
diff --git a/content/browser/service_worker/service_worker_event_dispatcher.cc b/content/browser/service_worker/service_worker_event_dispatcher.cc
new file mode 100644
index 0000000000000000000000000000000000000000..78e8bf674a05df8a9c739024457dc459ca62e274
--- /dev/null
+++ b/content/browser/service_worker/service_worker_event_dispatcher.cc
@@ -0,0 +1,69 @@
+// Copyright 2015 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 "content/browser/service_worker/service_worker_event_dispatcher.h"
+
+#include "content/public/browser/render_process_host.h"
+#include "content/public/common/service_registry.h"
+
+namespace content {
+
+namespace {
+
+// Converts mojo enum content::ServiceWorkerEventStatus values to Chromium
+// content::ServiceWorkerStatusCode values.
+// TODO(iclelland): Make these enums equivalent so that conversion can be a
+// static cast.
+ServiceWorkerStatusCode statusCodeFromMojoStatus(
+    ServiceWorkerEventStatus status) {
+  ServiceWorkerStatusCode status_code = SERVICE_WORKER_OK;
+  if (status == SERVICE_WORKER_EVENT_STATUS_REJECTED) {
+    status_code = SERVICE_WORKER_ERROR_EVENT_WAITUNTIL_REJECTED;
+  } else if (status == SERVICE_WORKER_EVENT_STATUS_ABORT) {
+    status_code = SERVICE_WORKER_ERROR_ABORT;
+  }
+  return status_code;
+}
+
+}  // namespace
+
+ServiceWorkerEventDispatcher::ServiceWorkerEventDispatcher() {
+}
+
+void ServiceWorkerEventDispatcher::DispatchSyncEvent(
+    int render_process_id,
+    int thread_id,
+    const ServiceWorkerVersion::StatusCallback& callback,
+    const scoped_refptr<base::TaskRunner>& task_runner) {
+  DCHECK_CURRENTLY_ON(BrowserThread::UI);
+  // TODO(iclelland): Replace this with the real event registration details
+  // crbug.com/482066
+  content::SyncRegistrationPtr TEMP_null_event(
+      content::SyncRegistration::New());
+
+  RenderProcessHost* host = RenderProcessHost::FromID(render_process_id);
+  content::ServiceRegistry* registry = host->GetServiceRegistry();
+  if (!registry)
+    return;
+
+  if (!background_sync_client_.get())
+    registry->ConnectToRemoteService(mojo::GetProxy(&background_sync_client_));
+  background_sync_client_->Sync(
+      TEMP_null_event.Pass(), thread_id,
+      base::Bind(&ServiceWorkerEventDispatcher::OnEventFinished, this, callback,
+                 task_runner));
+}
+
+ServiceWorkerEventDispatcher::~ServiceWorkerEventDispatcher() {
+}
+
+void ServiceWorkerEventDispatcher::OnEventFinished(
+    const ServiceWorkerVersion::StatusCallback& callback,
+    const scoped_refptr<base::TaskRunner>& task_runner,
+    ServiceWorkerEventStatus result) {
+  task_runner->PostTask(FROM_HERE,
+                        base::Bind(callback, statusCodeFromMojoStatus(result)));
+}
+
+}  // namespace content