1 files changed, 163 insertions, 0 deletions
diff --git a/mobile/android/geckoview/src/main/java/org/mozilla/gecko/media/RemoteMediaDrmBridge.java b/mobile/android/geckoview/src/main/java/org/mozilla/gecko/media/RemoteMediaDrmBridge.java
new file mode 100644
index 0000000000..b90f720300
--- /dev/null
+++ b/mobile/android/geckoview/src/main/java/org/mozilla/gecko/media/RemoteMediaDrmBridge.java
@@ -0,0 +1,163 @@
+/* This Source Code Form is subject to the terms of the Mozilla Public
+ * License, v. 2.0. If a copy of the MPL was not distributed with this
+ * file, You can obtain one at http://mozilla.org/MPL/2.0/. */
+
+package org.mozilla.gecko.media;
+
+import android.media.MediaCrypto;
+import android.util.Log;
+
+final class RemoteMediaDrmBridge implements GeckoMediaDrm {
+  private static final String LOGTAG = "RemoteMediaDrmBridge";
+  private static final boolean DEBUG = false;
+  private CallbacksForwarder mCallbacksFwd;
+  private IMediaDrmBridge mRemote;
+
+  // Forward callbacks from remote bridge stub to MediaDrmProxy.
+  private static class CallbacksForwarder extends IMediaDrmBridgeCallbacks.Stub {
+    private final GeckoMediaDrm.Callbacks mProxyCallbacks;
+
+    CallbacksForwarder(final Callbacks callbacks) {
+      assertTrue(callbacks != null);
+      mProxyCallbacks = callbacks;
+    }
+
+    @Override
+    public void onSessionCreated(
+        final int createSessionToken,
+        final int promiseId,
+        final byte[] sessionId,
+        final byte[] request) {
+      mProxyCallbacks.onSessionCreated(createSessionToken, promiseId, sessionId, request);
+    }
+
+    @Override
+    public void onSessionUpdated(final int promiseId, final byte[] sessionId) {
+      mProxyCallbacks.onSessionUpdated(promiseId, sessionId);
+    }
+
+    @Override
+    public void onSessionClosed(final int promiseId, final byte[] sessionId) {
+      mProxyCallbacks.onSessionClosed(promiseId, sessionId);
+    }
+
+    @Override
+    public void onSessionMessage(
+        final byte[] sessionId, final int sessionMessageType, final byte[] request) {
+      mProxyCallbacks.onSessionMessage(sessionId, sessionMessageType, request);
+    }
+
+    @Override
+    public void onSessionError(final byte[] sessionId, final String message) {
+      mProxyCallbacks.onSessionError(sessionId, message);
+    }
+
+    @Override
+    public void onSessionBatchedKeyChanged(
+        final byte[] sessionId, final SessionKeyInfo[] keyInfos) {
+      mProxyCallbacks.onSessionBatchedKeyChanged(sessionId, keyInfos);
+    }
+
+    @Override
+    public void onRejectPromise(final int promiseId, final String message) {
+      mProxyCallbacks.onRejectPromise(promiseId, message);
+    }
+  } // CallbacksForwarder
+
+  /* package-private */ static void assertTrue(final boolean condition) {
+    if (DEBUG && !condition) {
+      throw new AssertionError("Expected condition to be true");
+    }
+  }
+
+  public RemoteMediaDrmBridge(final IMediaDrmBridge remoteBridge) {
+    assertTrue(remoteBridge != null);
+    mRemote = remoteBridge;
+  }
+
+  @Override
+  public synchronized void setCallbacks(final Callbacks callbacks) {
+    if (DEBUG) Log.d(LOGTAG, "setCallbacks()");
+    assertTrue(callbacks != null);
+    assertTrue(mRemote != null);
+
+    mCallbacksFwd = new CallbacksForwarder(callbacks);
+    try {
+      mRemote.setCallbacks(mCallbacksFwd);
+    } catch (final Exception e) {
+      Log.e(LOGTAG, "Got exception during setCallbacks", e);
+    }
+  }
+
+  @Override
+  public synchronized void createSession(
+      final int createSessionToken,
+      final int promiseId,
+      final String initDataType,
+      final byte[] initData) {
+    if (DEBUG) Log.d(LOGTAG, "createSession()");
+
+    try {
+      mRemote.createSession(createSessionToken, promiseId, initDataType, initData);
+    } catch (final Exception e) {
+      Log.e(LOGTAG, "Got exception while creating remote session.", e);
+      mCallbacksFwd.onRejectPromise(promiseId, "Failed to create session.");
+    }
+  }
+
+  @Override
+  public synchronized void updateSession(
+      final int promiseId, final String sessionId, final byte[] response) {
+    if (DEBUG) Log.d(LOGTAG, "updateSession()");
+
+    try {
+      mRemote.updateSession(promiseId, sessionId, response);
+    } catch (final Exception e) {
+      Log.e(LOGTAG, "Got exception while updating remote session.", e);
+      mCallbacksFwd.onRejectPromise(promiseId, "Failed to update session.");
+    }
+  }
+
+  @Override
+  public synchronized void closeSession(final int promiseId, final String sessionId) {
+    if (DEBUG) Log.d(LOGTAG, "closeSession()");
+
+    try {
+      mRemote.closeSession(promiseId, sessionId);
+    } catch (final Exception e) {
+      Log.e(LOGTAG, "Got exception while closing remote session.", e);
+      mCallbacksFwd.onRejectPromise(promiseId, "Failed to close session.");
+    }
+  }
+
+  @Override
+  public synchronized void release() {
+    if (DEBUG) Log.d(LOGTAG, "release()");
+
+    try {
+      mRemote.release();
+    } catch (final Exception e) {
+      Log.e(LOGTAG, "Got exception while releasing RemoteDrmBridge.", e);
+    }
+    RemoteManager.getInstance().onRemoteMediaDrmBridgeReleased(mRemote);
+    mRemote = null;
+    mCallbacksFwd = null;
+  }
+
+  @Override
+  public synchronized MediaCrypto getMediaCrypto() {
+    if (DEBUG) Log.d(LOGTAG, "getMediaCrypto(), should not enter here!");
+    assertTrue(false);
+    return null;
+  }
+
+  @Override
+  public synchronized void setServerCertificate(final byte[] cert) {
+    try {
+      mRemote.setServerCertificate(cert);
+    } catch (final Exception e) {
+      Log.e(LOGTAG, "Got exception while setting server certificate.", e);
+      throw new RuntimeException(e);
+    }
+  }
+}