chrome/renderer/extensions/cast_streaming_native_handler.h

   1 // Copyright 2013 The Chromium Authors. All rights reserved.
   2 // Use of this source code is governed by a BSD-style license that can be
   3 // found in the LICENSE file.
   4
   5 #ifndef CHROME_RENDERER_EXTENSIONS_CAST_STREAMING_NATIVE_HANDLER_H_
   6 #define CHROME_RENDERER_EXTENSIONS_CAST_STREAMING_NATIVE_HANDLER_H_
   7
   8 #include <map>
   9
  10 #include "base/memory/linked_ptr.h"
  11 #include "base/memory/weak_ptr.h"
  12 #include "extensions/renderer/object_backed_native_handler.h"
  13 #include "v8/include/v8.h"
  14
  15 class CastRtpStream;
  16 class CastUdpTransport;
  17
  18 namespace base {
  19 class BinaryValue;
  20 class DictionaryValue;
  21 }
  22
  23 namespace blink {
  24 class WebMediaStream;
  25 }
  26
  27 namespace net {
  28 class IPEndPoint;
  29 }
  30
  31 namespace media {
  32 class AudioCapturerSource;
  33 class AudioParameters;
  34 class VideoCapturerSource;
  35 namespace cast {
  36 struct FrameReceiverConfig;
  37 }
  38 }
  39
  40 namespace extensions {
  41
  42 // Native code that handle chrome.webrtc custom bindings.
  43 class CastStreamingNativeHandler : public ObjectBackedNativeHandler {
  44  public:
  45   explicit CastStreamingNativeHandler(ScriptContext* context);
  46   ~CastStreamingNativeHandler() override;
  47
  48  private:
  49   void CreateCastSession(
  50       const v8::FunctionCallbackInfo<v8::Value>& args);
  51
  52   void DestroyCastRtpStream(
  53       const v8::FunctionCallbackInfo<v8::Value>& args);
  54   void CreateParamsCastRtpStream(
  55       const v8::FunctionCallbackInfo<v8::Value>& args);
  56   void GetSupportedParamsCastRtpStream(
  57       const v8::FunctionCallbackInfo<v8::Value>& args);
  58   void StartCastRtpStream(
  59       const v8::FunctionCallbackInfo<v8::Value>& args);
  60   void StopCastRtpStream(
  61       const v8::FunctionCallbackInfo<v8::Value>& args);
  62
  63   void DestroyCastUdpTransport(
  64       const v8::FunctionCallbackInfo<v8::Value>& args);
  65   void SetDestinationCastUdpTransport(
  66       const v8::FunctionCallbackInfo<v8::Value>& args);
  67   void SetOptionsCastUdpTransport(
  68       const v8::FunctionCallbackInfo<v8::Value>& args);
  69   void StopCastUdpTransport(
  70       const v8::FunctionCallbackInfo<v8::Value>& args);
  71   void StartCastRtpReceiver(
  72       const v8::FunctionCallbackInfo<v8::Value>& args);
  73
  74   void ToggleLogging(const v8::FunctionCallbackInfo<v8::Value>& args);
  75   void GetRawEvents(const v8::FunctionCallbackInfo<v8::Value>& args);
  76   void GetStats(const v8::FunctionCallbackInfo<v8::Value>& args);
  77
  78   // Helper method to call the v8 callback function after a session is
  79   // created.
  80   void CallCreateCallback(scoped_ptr<CastRtpStream> stream1,
  81                           scoped_ptr<CastRtpStream> stream2,
  82                           scoped_ptr<CastUdpTransport> udp_transport);
  83
  84   void CallStartCallback(int stream_id);
  85   void CallStopCallback(int stream_id);
  86   void CallErrorCallback(int stream_id, const std::string& message);
  87
  88   // Callback called after a cast receiver has been started. Adds the
  89   // output audio/video streams to the MediaStream specified by |url|.
  90   void AddTracksToMediaStream(
  91       const std::string& url,
  92       const media::AudioParameters& params,
  93       scoped_refptr<media::AudioCapturerSource> audio,
  94       scoped_ptr<media::VideoCapturerSource> video);
  95
  96   // |function| is a javascript function that will take |error_message| as
  97   // an argument. Called when something goes wrong in a cast receiver.
  98   void CallReceiverErrorCallback(
  99       v8::CopyablePersistentTraits<v8::Function>::CopyablePersistent function,
 100       const std::string& error_message);
 101
 102   void CallGetRawEventsCallback(int transport_id,
 103                                 scoped_ptr<base::BinaryValue> raw_events);
 104   void CallGetStatsCallback(int transport_id,
 105                             scoped_ptr<base::DictionaryValue> stats);
 106
 107   // Gets the RTP stream or UDP transport indexed by an ID.
 108   // If not found, returns NULL and throws a V8 exception.
 109   CastRtpStream* GetRtpStreamOrThrow(int stream_id) const;
 110   CastUdpTransport* GetUdpTransportOrThrow(int transport_id) const;
 111
 112   // Fills out a media::cast::FrameReceiverConfig from the v8
 113   // equivialent. (cast.streaming.receiverSession.RtpReceiverParams)
 114   // Returns true if everything was ok, raises a v8 exception and
 115   // returns false if anything went wrong.
 116   bool FrameReceiverConfigFromArg(
 117       v8::Isolate* isolate,
 118       const v8::Handle<v8::Value>& arg,
 119       media::cast::FrameReceiverConfig* config);
 120
 121   bool IPEndPointFromArg(v8::Isolate* isolate,
 122                          const v8::Handle<v8::Value>& arg,
 123                          net::IPEndPoint* ip_endpoint);
 124
 125   int last_transport_id_;
 126
 127   typedef std::map<int, linked_ptr<CastRtpStream> > RtpStreamMap;
 128   RtpStreamMap rtp_stream_map_;
 129
 130   typedef std::map<int, linked_ptr<CastUdpTransport> > UdpTransportMap;
 131   UdpTransportMap udp_transport_map_;
 132
 133   v8::Global<v8::Function> create_callback_;
 134
 135   typedef std::map<int, linked_ptr<v8::Global<v8::Function>>>
 136       RtpStreamCallbackMap;
 137   RtpStreamCallbackMap get_raw_events_callbacks_;
 138   RtpStreamCallbackMap get_stats_callbacks_;
 139
 140   base::WeakPtrFactory<CastStreamingNativeHandler> weak_factory_;
 141
 142   DISALLOW_COPY_AND_ASSIGN(CastStreamingNativeHandler);
 143 };
 144
 145 }  // namespace extensions
 146
 147 #endif  // CHROME_RENDERER_EXTENSIONS_CAST_STREAMING_NATIVE_HANDLER_H_