HTML MessagePort as mojo::MessagePipeHandle

chrome/android/java/src/org/chromium/chrome/browser/customtabs/PostMessageHandler.java

 // Copyright 2016 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.
 
 package org.chromium.chrome.browser.customtabs;
 
 import android.content.Context;
 import android.net.Uri;
 import android.support.customtabs.CustomTabsService;
 import android.support.customtabs.CustomTabsSessionToken;
 import android.support.customtabs.PostMessageServiceConnection;
 
 import org.chromium.base.ContextUtils;
 import org.chromium.base.ThreadUtils;
 import org.chromium.chrome.browser.tab.Tab;
 import org.chromium.content.browser.AppWebMessagePort;
-import org.chromium.content.browser.AppWebMessagePortService;
-import org.chromium.content.browser.AppWebMessagePortService.MessageChannelObserver;
-import org.chromium.content.browser.PostMessageSender;
-import org.chromium.content.browser.PostMessageSender.PostMessageSenderDelegate;
 import org.chromium.content_public.browser.MessagePort;
 import org.chromium.content_public.browser.MessagePort.MessageCallback;
 import org.chromium.content_public.browser.WebContents;
 import org.chromium.content_public.browser.WebContentsObserver;
 
 /**
  * A class that handles postMessage communications with a designated {@link CustomTabsSessionToken}.
  */
 public class PostMessageHandler extends PostMessageServiceConnection {
-    private static AppWebMessagePortService sService;
-
     private final MessageCallback mMessageCallback;
     private WebContents mWebContents;
     private boolean mMessageChannelCreated;
     private boolean mBoundToService;
     private AppWebMessagePort[] mChannel;
-    private PostMessageSender mPostMessageSender;
-    private PostMessageSenderDelegate mSenderDelegate;
     private Uri mOrigin;
 
-    private static AppWebMessagePortService getAppWebMessagePortService() {
-        if (sService == null) sService = new AppWebMessagePortService();
-        return sService;
-    }
-
     /**
      * Basic constructor. Everytime the given {@link CustomTabsSessionToken} is associated with a
      * new {@link WebContents},
      * {@link PostMessageHandler#reset(WebContents)} should be called to
      * reset all internal state.
      * @param session The {@link CustomTabsSessionToken} to establish the postMessage communication
      *                with.
      */
     public PostMessageHandler(CustomTabsSessionToken session) {
         super(session);
@@ skipping 48 matching lines @@
 
             @Override
             public void documentLoadedInFrame(long frameId, boolean isMainFrame) {
                 if (!isMainFrame || mChannel != null) return;
                 initializeWithWebContents(webContents);
             }
         };
     }
 
     private void initializeWithWebContents(final WebContents webContents) {
-        final AppWebMessagePortService service = getAppWebMessagePortService();
-        mChannel = (AppWebMessagePort[]) webContents.createMessageChannel(service);
+        mChannel = (AppWebMessagePort[]) webContents.createMessageChannel();
         mChannel[0].setMessageCallback(mMessageCallback, null);
-        mSenderDelegate = new PostMessageSenderDelegate() {
-            @Override
-            public void postMessageToWeb(
-                    String frameName, String message, String targetOrigin,
-                    int[] sentPortIds) {
-                if (webContents.isDestroyed()) {
-                    disconnectChannel();
-                    unbindFromContext(ContextUtils.getApplicationContext());
-                    return;
-                }
-                webContents.postMessageToFrame(
-                        frameName, message, mOrigin.toString(), targetOrigin, sentPortIds);
-            }
 
-            @Override
-            public void onPostMessageQueueEmpty() {}
+        webContents.postMessageToFrame(
+                null, "", mOrigin.toString(), "", new AppWebMessagePort[] {mChannel[1]});
 
-            @Override
-            public boolean isPostMessageSenderReady() {
-                return true;
-            }
-        };
-        mPostMessageSender = new PostMessageSender(
-                mSenderDelegate, getAppWebMessagePortService());
-        service.addObserver(new MessageChannelObserver() {
-            @Override
-            public void onMessageChannelCreated() {
-                service.removeObserver(this);
-                if (mChannel == null) return;
-                mPostMessageSender.postMessage(
-                        null, "", "", new AppWebMessagePort[] {mChannel[1]});
-                mMessageChannelCreated = true;
-                if (mBoundToService) notifyMessageChannelReady(null);
-            }
-        });
+        mMessageChannelCreated = true;
+        if (mBoundToService) notifyMessageChannelReady(null);
     }
 
     private void disconnectChannel() {
         if (mChannel == null) return;
         mChannel[0].close();
         mChannel = null;
-        mSenderDelegate = null;
-        mPostMessageSender = null;
         mWebContents = null;
     }
 
     /**
      * Sets the postMessage origin for this session to the given {@link Uri}.
      * @param origin The origin value to be set.
      */
     public void initializeWithOrigin(Uri origin) {
         mOrigin = origin;
         if (mWebContents != null && !mWebContents.isDestroyed()) {
@@ skipping 35 matching lines @@
     public void onPostMessageServiceConnected() {
         mBoundToService = true;
         if (mMessageChannelCreated) notifyMessageChannelReady(null);
     }
 
     @Override
     public void onPostMessageServiceDisconnected() {
         mBoundToService = false;
     }
 }