MFCDMChild.h - mozsearch

Enable keyboard shortcuts

/* 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/. */

#ifndef DOM_MEDIA_IPC_MFCDMCHILD_H_

#define DOM_MEDIA_IPC_MFCDMCHILD_H_

#include <unordered_map>

#include "mozilla/Atomics.h"

#include "mozilla/MozPromise.h"

#include "mozilla/PMFCDMChild.h"

namespace mozilla {

class WMFCDMProxyCallback;

/**

 * MFCDMChild is a content process proxy to MFCDMParent and the actual CDM

 * running in utility process.

*/

class MFCDMChild final : public PMFCDMChild {

 public:

  NS_INLINE_DECL_THREADSAFE_REFCOUNTING(MFCDMChild);

  explicit MFCDMChild(const nsAString& aKeySystem);

  using CapabilitiesPromise = MozPromise<MFCDMCapabilitiesIPDL, nsresult, true>;

  RefPtr<CapabilitiesPromise> GetCapabilities(

      MFCDMCapabilitiesRequest&& aRequest);

  template <typename PromiseType>

  already_AddRefed<PromiseType> InvokeAsync(

      std::function<void()>&& aCall, StaticString aCallerName,

      MozPromiseHolder<PromiseType>& aPromise);

  using InitPromise = MozPromise<MFCDMInitIPDL, nsresult, true>;

  RefPtr<InitPromise> Init(

      const nsAString& aOrigin, const CopyableTArray<nsString>& aInitDataTypes,

      const KeySystemConfig::Requirement aPersistentState,

      const KeySystemConfig::Requirement aDistinctiveID,

      const CopyableTArray<MFCDMMediaCapability>& aAudioCapabilities,

      const CopyableTArray<MFCDMMediaCapability>& aVideoCapabilities,

      WMFCDMProxyCallback* aProxyCallback);

  using SessionPromise = MozPromise<nsString, nsresult, true>;

  RefPtr<SessionPromise> CreateSessionAndGenerateRequest(

      uint32_t aPromiseId, const KeySystemConfig::SessionType aSessionType,

      const nsAString& aInitDataType, const nsTArray<uint8_t>& aInitData);

  RefPtr<GenericPromise> LoadSession(

      uint32_t aPromiseId, const KeySystemConfig::SessionType aSessionType,

      const nsAString& aSessionId);

  RefPtr<GenericPromise> UpdateSession(uint32_t aPromiseId,

                                       const nsAString& aSessionId,

                                       nsTArray<uint8_t>& aResponse);

  RefPtr<GenericPromise> CloseSession(uint32_t aPromiseId,

                                      const nsAString& aSessionId);

  RefPtr<GenericPromise> RemoveSession(uint32_t aPromiseId,

                                       const nsAString& aSessionId);

  RefPtr<GenericPromise> SetServerCertificate(uint32_t aPromiseId,

                                              nsTArray<uint8_t>& aCert);

  RefPtr<GenericPromise> GetStatusForPolicy(

      uint32_t aPromiseId, const dom::HDCPVersion& aMinHdcpVersion);

  mozilla::ipc::IPCResult RecvOnSessionKeyMessage(

      const MFCDMKeyMessage& aMessage);

  mozilla::ipc::IPCResult RecvOnSessionKeyStatusesChanged(

      const MFCDMKeyStatusChange& aKeyStatuses);

  mozilla::ipc::IPCResult RecvOnSessionKeyExpiration(

      const MFCDMKeyExpiration& aExpiration);

  uint64_t Id() const { return mId; }

  const nsString& KeySystem() const { return mKeySystem; }

  void IPDLActorDestroyed() {

    AssertOnManagerThread();

    mIPDLSelfRef = nullptr;

    if (!mShutdown) {

      // Remote crashed!

      mState = NS_ERROR_NOT_AVAILABLE;

  void EnsureRemote();

  void Shutdown();

  nsISerialEventTarget* ManagerThread() { return mManagerThread; }

  void AssertOnManagerThread() const {

    MOZ_ASSERT(mManagerThread->IsOnCurrentThread());

 private:

  ~MFCDMChild();

  void AssertSendable();

  const nsString mKeySystem;

  const RefPtr<nsISerialEventTarget> mManagerThread;

  RefPtr<MFCDMChild> mIPDLSelfRef;

  using RemotePromise = GenericNonExclusivePromise;

  RefPtr<RemotePromise> mRemotePromise;

  MozPromiseHolder<RemotePromise> mRemotePromiseHolder;

  MozPromiseRequestHolder<RemotePromise> mRemoteRequest;

  // Before EnsureRemote(): NS_ERROR_NOT_INITIALIZED; After EnsureRemote():

  // NS_OK or some error code.

  Atomic<nsresult> mState;

  MozPromiseHolder<CapabilitiesPromise> mCapabilitiesPromiseHolder;

  Atomic<bool> mShutdown;

  // This represents an unique Id to indentify the CDM in the remote process.

  // 0(zero) means the CDM is not yet initialized.

  // Modified on the manager thread, and read on other threads.

  Atomic<uint64_t> mId;

  MozPromiseHolder<InitPromise> mInitPromiseHolder;

  using InitIPDLPromise = MozPromise<mozilla::MFCDMInitResult,

                                     mozilla::ipc::ResponseRejectReason, true>;

  MozPromiseRequestHolder<InitIPDLPromise> mInitRequest;

  MozPromiseHolder<SessionPromise> mCreateSessionPromiseHolder;

  MozPromiseRequestHolder<CreateSessionAndGenerateRequestPromise>

      mCreateSessionRequest;

  MozPromiseHolder<GenericPromise> mLoadSessionPromiseHolder;

  MozPromiseRequestHolder<LoadSessionPromise> mLoadSessionRequest;

  MozPromiseHolder<GenericPromise> mUpdateSessionPromiseHolder;

  MozPromiseRequestHolder<UpdateSessionPromise> mUpdateSessionRequest;

  MozPromiseHolder<GenericPromise> mCloseSessionPromiseHolder;

  MozPromiseRequestHolder<CloseSessionPromise> mCloseSessionRequest;

  MozPromiseHolder<GenericPromise> mRemoveSessionPromiseHolder;

  MozPromiseRequestHolder<RemoveSessionPromise> mRemoveSessionRequest;

  std::unordered_map<uint32_t, MozPromiseHolder<SessionPromise>>

      mPendingSessionPromises;

  std::unordered_map<uint32_t, MozPromiseHolder<GenericPromise>>

      mPendingGenericPromises;

  RefPtr<WMFCDMProxyCallback> mProxyCallback;

};

}  // namespace mozilla

#endif  // DOM_MEDIA_IPC_MFCDMCHILD_H_