Service Worker event dispatcher for Background Fetch

content/browser/background_fetch/background_fetch_event_dispatcher.h

Index: content/browser/background_fetch/background_fetch_event_dispatcher.h
diff --git a/content/browser/background_fetch/background_fetch_event_dispatcher.h b/content/browser/background_fetch/background_fetch_event_dispatcher.h
new file mode 100644
index 0000000000000000000000000000000000000000..186468ab639c33a78a6137a1a0e0fce4e5c48214
--- /dev/null
+++ b/content/browser/background_fetch/background_fetch_event_dispatcher.h
@@ -0,0 +1,116 @@
+// Copyright 2017 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.
+
+#ifndef CONTENT_BROWSER_BACKGROUND_FETCH_BACKGROUND_FETCH_EVENT_DISPATCHER_H_
+#define CONTENT_BROWSER_BACKGROUND_FETCH_BACKGROUND_FETCH_EVENT_DISPATCHER_H_
+
+#include <stdint.h>
+#include <string>
+
+#include "base/callback_forward.h"
+#include "base/macros.h"
+#include "base/memory/ref_counted.h"
+#include "content/browser/service_worker/service_worker_metrics.h"
+#include "content/common/content_export.h"
+#include "content/common/service_worker/service_worker_event_dispatcher.mojom.h"
+
+namespace content {
+
+class ServiceWorkerContextWrapper;
+class ServiceWorkerRegistration;
+class ServiceWorkerVersion;
+
+// Responsible for dispatching the Background Fetch API events on a given
+// Service Worker. Must only be used on the IO thread.
+class CONTENT_EXPORT BackgroundFetchEventDispatcher {
+ public:
+  // This enumeration is used for recording histograms. Treat as append-only.
+  enum DispatchResult {
+    DISPATCH_RESULT_SUCCESS = 0,
+    DISPATCH_RESULT_CANNOT_FIND_WORKER = 1,
+    DISPATCH_RESULT_CANNOT_START_WORKER = 2,
+    DISPATCH_RESULT_CANNOT_DISPATCH_EVENT = 3,
+
+    DISPATCH_RESULT_MAX = DISPATCH_RESULT_CANNOT_DISPATCH_EVENT

[Ilya Sherman, 2017/03/16 03:58:50]

Optional: I find that it's easier to work with DISPATCH_RESULT_COUNT = 4 than
MAX = 3, but either is okay as long as you make the C++ code match correctly.

[Peter Beverloo, 2017/03/16 16:05:58]

We need MAX now that I've updated the .cc to use UmaHistogramEnumeration(), so
while this indeed is more tedious to update, it avoids needing to subtract one
at usage. Happy to flip it around if you still prefer that, too.

[Ilya Sherman, 2017/03/16 22:36:02]

You should still use COUNT or MAX+1, even with UmaHistogramEnumeration().  I was
just looking at the docs today, and agree that it's pretty confusing.  The idea
of the histogram_functions code is to exactly match the macros.  If you have
some time to update the documentation, I'd be happy to review the changes!  (If
not, I'll try to get to it sometime soon, if I don't get sidetracked.)

[Peter Beverloo, 2017/03/17 13:43:28]

Ack as discussed - changed to DISPATCH_RESULT_COUNT.

+  };
+
+  explicit BackgroundFetchEventDispatcher(
+      const scoped_refptr<ServiceWorkerContextWrapper>& service_worker_context);
+  ~BackgroundFetchEventDispatcher();
+
+  // TODO(peter): Support the `backgroundfetched` event.
+  // TODO(peter): Support the `backgroundfetchfail` event.
+
+  // Dispatches the `backgroundfetchabort` event, which indicates that an active
+  // background fetch was aborted by the user or another external event.
+  void DispatchBackgroundFetchAbortEvent(int64_t service_worker_registration_id,
+                                         const std::string& tag,
+                                         base::Closure finished_closure);
+
+  // Dispatches the `backgroundfetchclick` event, which indicates that the user
+  // interface displayed for an active background fetch was activated.
+  void DispatchBackgroundFetchClickEvent(int64_t service_worker_registration_id,
+                                         const std::string& tag,
+                                         mojom::BackgroundFetchState state,
+                                         base::Closure finished_closure);
+
+ private:
+  using ServiceWorkerLoadedCallback =
+      base::Callback<void(scoped_refptr<ServiceWorkerVersion>, int)>;
+
+  // Phase at which the dispatching process finished. Used for UMA.
+  enum class DispatchPhase { FINDING, STARTING, DISPATCHING };
+
+  // Loads the Service Worker identified by |service_worker_registration_id| and
+  // ensures that there is an activated version. Will invoke |finished_closure|,
+  // log UMA and abort on error, or invoke |loaded_callback| on success.
+  void LoadServiceWorkerRegistrationForDispatch(
+      ServiceWorkerMetrics::EventType event,
+      int64_t service_worker_registration_id,
+      base::Closure finished_closure,

[harkness, 2017/03/16 17:42:18]

nit: error_closure? "finished" is harder to distinguish from "loaded".

[Peter Beverloo, 2017/03/17 13:43:28]

We always invoke the |finished_closure|, so that's really what it is. Happy to
rename later if we come up with a better name.

+      ServiceWorkerLoadedCallback loaded_callback);
+
+  // Verifies that the |registration| has successfully been loaded, then starts
+  // the active Service Worker on the registration to dispatch |event|. Will
+  // invoke |finished_closure|, log UMA and abort on error, or invoke the
+  // |loaded_callback| on success.
+  static void StartActiveWorkerForDispatch(
+      ServiceWorkerMetrics::EventType event,
+      base::Closure finished_closure,
+      ServiceWorkerLoadedCallback loaded_callback,
+      ServiceWorkerStatusCode service_worker_status,
+      scoped_refptr<ServiceWorkerRegistration> registration);
+
+  // Dispatches the actual event after the Service Worker has been started.
+  static void DispatchEvent(
+      ServiceWorkerMetrics::EventType event,
+      base::Closure finished_closure,
+      ServiceWorkerLoadedCallback loaded_callback,
+      scoped_refptr<ServiceWorkerVersion> service_worker_version);
+
+  // Called when an event of type |event| has finished dispatching.
+  static void DidDispatchEvent(ServiceWorkerMetrics::EventType event,
+                               base::Closure finished_closure,
+                               DispatchPhase dispatch_phase,
+                               ServiceWorkerStatusCode service_worker_status);
+
+  // Methods that actually invoke the event on an activated Service Worker.
+  static void DoDispatchBackgroundFetchAbortEvent(
+      const std::string& tag,
+      scoped_refptr<ServiceWorkerVersion> service_worker_version,
+      int request_id);
+  static void DoDispatchBackgroundFetchClickEvent(
+      const std::string& tag,
+      mojom::BackgroundFetchState state,
+      scoped_refptr<ServiceWorkerVersion> service_worker_version,
+      int request_id);
+
+  scoped_refptr<ServiceWorkerContextWrapper> service_worker_context_;
+
+  DISALLOW_COPY_AND_ASSIGN(BackgroundFetchEventDispatcher);
+};
+
+}  // namespace content
+
+#endif  // CONTENT_BROWSER_BACKGROUND_FETCH_BACKGROUND_FETCH_EVENT_DISPATCHER_H_