#ifndef MediaStream_h
#define MediaStream_h
#if ENABLE(MEDIA_STREAM)
#include "ContextDestructionObserver.h"
#include "EventTarget.h"
#include "ExceptionBase.h"
#include "MediaStreamPrivate.h"
#include "MediaStreamTrack.h"
#include "ScriptWrappable.h"
#include "Timer.h"
#include "URLRegistry.h"
#include <wtf/HashMap.h>
#include <wtf/RefCounted.h>
#include <wtf/RefPtr.h>
namespace WebCore {
class MediaStream final : public URLRegistrable, public ScriptWrappable, public MediaStreamPrivateClient, public EventTargetWithInlineData, public ContextDestructionObserver, public MediaStreamTrack::Observer {
public:
class Observer {
public:
virtual ~Observer() { }
virtual void didAddOrRemoveTrack() = 0;
};
static Ref<MediaStream> create(ScriptExecutionContext&);
static Ref<MediaStream> create(ScriptExecutionContext&, MediaStream*);
static Ref<MediaStream> create(ScriptExecutionContext&, const Vector<RefPtr<MediaStreamTrack>>&);
static Ref<MediaStream> create(ScriptExecutionContext&, RefPtr<MediaStreamPrivate>&&);
virtual ~MediaStream();
String id() const { return m_private->id(); }
void addTrack(RefPtr<MediaStreamTrack>&&);
void removeTrack(MediaStreamTrack*);
MediaStreamTrack* getTrackById(String);
Vector<RefPtr<MediaStreamTrack>> getAudioTracks() override final;
Vector<RefPtr<MediaStreamTrack>> getVideoTracks() override final;
Vector<RefPtr<MediaStreamTrack>> getTracks() const;
RefPtr<MediaStream> clone();
bool active() const { return m_isActive; }
MediaStreamPrivate* privateStream() const { return m_private.get(); }
virtual EventTargetInterface eventTargetInterface() const final { return MediaStreamEventTargetInterfaceType; }
virtual ScriptExecutionContext* scriptExecutionContext() const final { return ContextDestructionObserver::scriptExecutionContext(); }
using RefCounted<MediaStreamPrivateClient>::ref;
using RefCounted<MediaStreamPrivateClient>::deref;
virtual URLRegistry& registry() const override;
void addObserver(Observer*);
void removeObserver(Observer*);
protected:
MediaStream(ScriptExecutionContext&, const Vector<RefPtr<MediaStreamTrack>>&);
MediaStream(ScriptExecutionContext&, RefPtr<MediaStreamPrivate>&&);
virtual void contextDestroyed() override final;
private:
enum class StreamModifier { DomAPI, Platform };
virtual void refEventTarget() override final { ref(); }
virtual void derefEventTarget() override final { deref(); }
virtual void trackDidEnd() override final;
virtual void activeStatusChanged() override final;
virtual void didAddTrackToPrivate(MediaStreamTrackPrivate&) override final;
virtual void didRemoveTrackFromPrivate(MediaStreamTrackPrivate&) override final;
bool internalAddTrack(RefPtr<MediaStreamTrack>&&, StreamModifier);
bool internalRemoveTrack(RefPtr<MediaStreamTrack>&&, StreamModifier);
void scheduleActiveStateChange();
void activityEventTimerFired();
Vector<RefPtr<MediaStreamTrack>> trackVectorForType(RealtimeMediaSource::Type) const;
RefPtr<MediaStreamPrivate> m_private;
bool m_isActive;
HashMap<String, RefPtr<MediaStreamTrack>> m_trackSet;
Timer m_activityEventTimer;
Vector<RefPtr<Event>> m_scheduledActivityEvents;
Vector<Observer*> m_observers;
};
}
#endif // ENABLE(MEDIA_STREAM)
#endif // MediaStream_h