ServiceWorker: Implement attributes of ExtendableMessageEvent

content/child/service_worker/web_service_worker_impl.cc

 // Copyright 2013 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/child/service_worker/web_service_worker_impl.h"
 
 #include <utility>
 
 #include "base/macros.h"
 #include "content/child/service_worker/service_worker_dispatcher.h"
 #include "content/child/service_worker/service_worker_handle_reference.h"
 #include "content/child/thread_safe_sender.h"
 #include "content/child/webmessageportchannel_impl.h"
 #include "content/common/service_worker/service_worker_messages.h"
 #include "third_party/WebKit/public/platform/WebString.h"
 #include "third_party/WebKit/public/platform/modules/serviceworker/WebServiceWorkerProxy.h"
+#include "third_party/WebKit/public/web/WebRuntimeFeatures.h"
 
 using blink::WebMessagePortChannel;
 using blink::WebMessagePortChannelArray;
 using blink::WebMessagePortChannelClient;
+using blink::WebRuntimeFeatures;
 using blink::WebString;
 
 namespace content {
 
 namespace {
 
 class HandleImpl : public blink::WebServiceWorker::Handle {
  public:
   explicit HandleImpl(const scoped_refptr<WebServiceWorkerImpl>& worker)
       : worker_(worker) {}
   ~HandleImpl() override {}
 
   blink::WebServiceWorker* serviceWorker() override { return worker_.get(); }
 
  private:
   scoped_refptr<WebServiceWorkerImpl> worker_;
 
   DISALLOW_COPY_AND_ASSIGN(HandleImpl);
 };
 
 void SendPostMessageToWorkerOnMainThread(
     ThreadSafeSender* thread_safe_sender,
     int handle_id,
     const base::string16& message,
     scoped_ptr<WebMessagePortChannelArray> channels) {
-  // TODO(nhiroki): Switch to PostMessageToClient message after
-  // ExtendableMessageEvent is implemented (crbug.com/543198).
-  thread_safe_sender->Send(
-      new ServiceWorkerHostMsg_DeprecatedPostMessageToWorker(
-          handle_id, message, WebMessagePortChannelImpl::ExtractMessagePortIDs(
-                                  std::move(channels))));
+  if (WebRuntimeFeatures::isServiceWorkerExtendableMessageEventEnabled()) {
+    thread_safe_sender->Send(new ServiceWorkerHostMsg_PostMessageToWorker(
+        handle_id, message,
+        WebMessagePortChannelImpl::ExtractMessagePortIDs(std::move(channels))));
+  } else {
+    thread_safe_sender->Send(
+        new ServiceWorkerHostMsg_DeprecatedPostMessageToWorker(
+            handle_id, message,
+            WebMessagePortChannelImpl::ExtractMessagePortIDs(
+                std::move(channels))));
+  }
 }
 
 }  // namespace
 
 WebServiceWorkerImpl::WebServiceWorkerImpl(
     scoped_ptr<ServiceWorkerHandleReference> handle_ref,
     ThreadSafeSender* thread_safe_sender)
     : handle_ref_(std::move(handle_ref)),
       state_(handle_ref_->state()),
       thread_safe_sender_(thread_safe_sender),
@@ skipping 65 matching lines @@
 }
 
 WebServiceWorkerImpl::~WebServiceWorkerImpl() {
   ServiceWorkerDispatcher* dispatcher =
       ServiceWorkerDispatcher::GetThreadSpecificInstance();
   if (dispatcher)
     dispatcher->RemoveServiceWorker(handle_ref_->handle_id());
 }
 
 }  // namespace content