blob: febad4738d7353b45078aa9d995d5bb9241fa58c [file] [log] [blame]
// Copyright 2018 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.
#ifndef SERVICES_VIDEO_CAPTURE_PUSH_VIDEO_STREAM_SUBSCRIPTION_IMPL_H_
#define SERVICES_VIDEO_CAPTURE_PUSH_VIDEO_STREAM_SUBSCRIPTION_IMPL_H_
#include "mojo/public/cpp/bindings/pending_remote.h"
#include "mojo/public/cpp/bindings/receiver.h"
#include "mojo/public/cpp/bindings/remote.h"
#include "services/video_capture/public/mojom/device.mojom.h"
#include "services/video_capture/public/mojom/video_frame_handler.mojom.h"
#include "services/video_capture/public/mojom/video_source.mojom.h"
namespace video_capture {
class BroadcastingReceiver;
class PushVideoStreamSubscriptionImpl
: public mojom::PushVideoStreamSubscription {
public:
PushVideoStreamSubscriptionImpl(
mojo::PendingReceiver<mojom::PushVideoStreamSubscription>
subscription_receiver,
mojo::PendingRemote<mojom::VideoFrameHandler> subscriber,
const media::VideoCaptureParams& requested_settings,
mojom::VideoSource::CreatePushSubscriptionCallback creation_callback,
BroadcastingReceiver* broadcaster,
mojo::Remote<mojom::Device>* device);
~PushVideoStreamSubscriptionImpl() override;
void SetOnClosedHandler(
base::OnceCallback<void(base::OnceClosure done_cb)> handler);
void OnDeviceStartSucceededWithSettings(
const media::VideoCaptureParams& settings);
void OnDeviceStartFailed();
// mojom::PushVideoStreamSubscription implementation.
void Activate() override;
void Suspend(SuspendCallback callback) override;
void Resume() override;
void GetPhotoState(GetPhotoStateCallback callback) override;
void SetPhotoOptions(media::mojom::PhotoSettingsPtr settings,
SetPhotoOptionsCallback callback) override;
void TakePhoto(TakePhotoCallback callback) override;
void Close(CloseCallback callback) override;
private:
enum class Status {
kCreationCallbackNotYetRun,
kNotYetActivated,
kActive,
kSuspended,
kClosed
};
void OnConnectionLost();
mojo::Receiver<mojom::PushVideoStreamSubscription> receiver_;
mojo::PendingRemote<mojom::VideoFrameHandler> subscriber_;
const media::VideoCaptureParams requested_settings_;
mojom::VideoSource::CreatePushSubscriptionCallback creation_callback_;
BroadcastingReceiver* const broadcaster_;
mojo::Remote<mojom::Device>* const device_;
Status status_;
// Client id handed out by |broadcaster_| when registering |this| as its
// client.
int32_t broadcaster_client_id_;
// A callback that we invoke when this instance changes |status_| to
// kClosed via a call to Close().
base::OnceCallback<void(base::OnceClosure done_cb)> on_closed_handler_;
base::WeakPtrFactory<PushVideoStreamSubscriptionImpl> weak_factory_{this};
DISALLOW_COPY_AND_ASSIGN(PushVideoStreamSubscriptionImpl);
};
} // namespace video_capture
#endif // SERVICES_VIDEO_CAPTURE_PUSH_VIDEO_STREAM_SUBSCRIPTION_IMPL_H_