Enable messaging over a navigator.connect initiated channel.

content/browser/navigator_connect/navigator_connect_dispatcher_host.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/browser/navigator_connect/navigator_connect_dispatcher_host.h"
 
 #include "content/browser/message_port_service.h"
+#include "content/browser/navigator_connect/navigator_connect_context.h"
 #include "content/browser/service_worker/service_worker_context_wrapper.h"
 #include "content/common/navigator_connect_messages.h"
 #include "content/common/navigator_connect_types.h"
 
 namespace content {
 
 NavigatorConnectDispatcherHost::NavigatorConnectDispatcherHost(
-    const scoped_refptr<ServiceWorkerContextWrapper>& service_worker_context)
+    const scoped_refptr<ServiceWorkerContextWrapper>& service_worker_context,
+    const scoped_refptr<NavigatorConnectContext>& navigator_connect_context)
     : BrowserMessageFilter(NavigatorConnectMsgStart),
-      service_worker_context_(service_worker_context) {
+      service_worker_context_(service_worker_context),
+      navigator_connect_context_(navigator_connect_context) {
 }
 
 NavigatorConnectDispatcherHost::~NavigatorConnectDispatcherHost() {
 }
 
 bool NavigatorConnectDispatcherHost::OnMessageReceived(
     const IPC::Message& message) {
   bool handled = true;
   IPC_BEGIN_MESSAGE_MAP(NavigatorConnectDispatcherHost, message)
     IPC_MESSAGE_HANDLER(NavigatorConnectHostMsg_Connect, OnConnect)
@@ skipping 51 matching lines @@
     const CrossOriginServiceWorkerClient& client,
     const scoped_refptr<ServiceWorkerRegistration>& registration,
     ServiceWorkerStatusCode status,
     bool accept_connection) {
   DCHECK_CURRENTLY_ON(BrowserThread::IO);
 
   if (status != SERVICE_WORKER_OK || !accept_connection) {
     // Close port since connection failed.
     MessagePortService::GetInstance()->ClosePort(client.message_port_id);
     Send(new NavigatorConnectMsg_ConnectResult(thread_id, request_id, false));
-  } else {
-    // TODO(mek): Update MessagePortService to make communication between client
-    // and service possible.
-    Send(new NavigatorConnectMsg_ConnectResult(thread_id, request_id, true));
+    return;
   }
+
+  // Register connection and post back result.
+  navigator_connect_context_->RegisterConnection(client, registration);
+  Send(new NavigatorConnectMsg_ConnectResult(thread_id, request_id, true));
 }
 
 }  // namespace content