DO NOT REVIEW Plumb push messaging registration through to gcm.

content/renderer/push_messaging_dispatcher.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 "content/renderer/push_messaging_dispatcher.h"
+
+#include "content/common/push_messaging_messages.h"
+#include "content/renderer/render_view_impl.h"
+#include "third_party/WebKit/public/platform/WebPushRegistration.h"
+#include "third_party/WebKit/public/platform/WebString.h"
+
+namespace content {
+
+PushMessagingDispatcher::PushMessagingDispatcher(RenderViewImpl* render_view)
+    : RenderViewObserver(render_view) {}
+
+PushMessagingDispatcher::~PushMessagingDispatcher() {}
+
+bool PushMessagingDispatcher::OnMessageReceived(const IPC::Message& message) {
+  bool handled = true;
+  IPC_BEGIN_MESSAGE_MAP(PushMessagingDispatcher, message)
+  IPC_MESSAGE_HANDLER(PushMessagingMsg_RegisterSuccess, OnRegisterSuccess)
+  IPC_MESSAGE_HANDLER(PushMessagingMsg_RegisterError, OnRegisterError)
+  IPC_MESSAGE_UNHANDLED(handled = false)
+  IPC_END_MESSAGE_MAP()
+  return handled;
+}
+
+void PushMessagingDispatcher::registerPushMessaging(
+    const blink::WebString& channel_name,
+    blink::WebPushRegistrationCallbacks* callbacks) {
+  DCHECK(callbacks);
+  int callbacks_id = registration_callbacks_.Add(callbacks);
+  Send(new PushMessagingHostMsg_Register(
+      routing_id(), callbacks_id, channel_name.utf8()));
+}
+
+void PushMessagingDispatcher::OnRegisterSuccess(
+    int32 callbacks_id,
+    const std::string& endpoint,
+    const std::string& registration_id,
+    const std::string& channel_name) {
+  blink::WebPushRegistrationCallbacks* callbacks =
+      registration_callbacks_.Lookup(callbacks_id);
+  DCHECK(callbacks);
+  if (!callbacks)
+    return;
+
+  callbacks->onSuccess(new blink::WebPushRegistration(
+      blink::WebString::fromUTF8(endpoint),
+      blink::WebString::fromUTF8(registration_id),
+      blink::WebString::fromUTF8(channel_name)));
+  registration_callbacks_.Remove(callbacks_id);
+}
+
+void PushMessagingDispatcher::OnRegisterError(int32 callbacks_id,
+                                              PushMessagingStatus status) {
+  blink::WebPushRegistrationCallbacks* callbacks =
+      registration_callbacks_.Lookup(callbacks_id);
+  DCHECK(callbacks);
+  if (!callbacks)
+    return;
+
+  scoped_ptr<blink::WebPushMessagingError> error(
+      new blink::WebPushMessagingError(
+          blink::WebPushMessagingError::AbortError,
+          blink::WebString::fromUTF8(PushMessagingStatusToString(status))));
+  callbacks->onError(error.release());
+  registration_callbacks_.Remove(callbacks_id);
+}
+
+}  // namespace content