1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
|
// Copyright 2019 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#include "chrome/browser/ui/global_media_controls/cast_media_session_controller.h"
#include "base/time/time.h"
#include "components/media_router/common/mojom/media_status.mojom.h"
#include "content/public/browser/browser_task_traits.h"
#include "content/public/browser/browser_thread.h"
#include "services/media_session/public/mojom/constants.mojom.h"
namespace {
constexpr base::TimeDelta kDefaultSeekTimeSeconds =
base::Seconds(media_session::mojom::kDefaultSeekTimeSeconds);
bool IsPlaying(const media_router::mojom::MediaStatusPtr& media_status) {
return media_status &&
media_status->play_state ==
media_router::mojom::MediaStatus::PlayState::PLAYING;
}
} // namespace
CastMediaSessionController::CastMediaSessionController(
mojo::Remote<media_router::mojom::MediaController> route_controller)
: route_controller_(std::move(route_controller)) {}
CastMediaSessionController::~CastMediaSessionController() = default;
void CastMediaSessionController::Send(
media_session::mojom::MediaSessionAction action) {
if (!media_status_) {
return;
}
switch (action) {
case media_session::mojom::MediaSessionAction::kPlay:
route_controller_->Play();
return;
case media_session::mojom::MediaSessionAction::kPause:
route_controller_->Pause();
return;
case media_session::mojom::MediaSessionAction::kPreviousTrack:
route_controller_->PreviousTrack();
return;
case media_session::mojom::MediaSessionAction::kNextTrack:
route_controller_->NextTrack();
return;
case media_session::mojom::MediaSessionAction::kSeekBackward:
route_controller_->Seek(PutWithinBounds(media_status_->current_time -
kDefaultSeekTimeSeconds));
return;
case media_session::mojom::MediaSessionAction::kSeekForward:
route_controller_->Seek(PutWithinBounds(media_status_->current_time +
kDefaultSeekTimeSeconds));
return;
case media_session::mojom::MediaSessionAction::kStop:
route_controller_->Pause();
return;
case media_session::mojom::MediaSessionAction::kSkipAd:
case media_session::mojom::MediaSessionAction::kSeekTo:
case media_session::mojom::MediaSessionAction::kScrubTo:
case media_session::mojom::MediaSessionAction::kEnterPictureInPicture:
case media_session::mojom::MediaSessionAction::kExitPictureInPicture:
case media_session::mojom::MediaSessionAction::kSwitchAudioDevice:
case media_session::mojom::MediaSessionAction::kToggleMicrophone:
case media_session::mojom::MediaSessionAction::kToggleCamera:
case media_session::mojom::MediaSessionAction::kHangUp:
case media_session::mojom::MediaSessionAction::kRaise:
case media_session::mojom::MediaSessionAction::kSetMute:
case media_session::mojom::MediaSessionAction::kPreviousSlide:
case media_session::mojom::MediaSessionAction::kNextSlide:
case media_session::mojom::MediaSessionAction::kEnterAutoPictureInPicture:
NOTREACHED();
}
}
void CastMediaSessionController::OnMediaStatusUpdated(
media_router::mojom::MediaStatusPtr media_status) {
media_status_ = std::move(media_status);
// We start incrementing |media_status_->current_time|, so that we
// know the approximate playback position, which is used as the baseline from
// which we seek forward or backward. We must do this because the Cast
// receiver only gives an update when the playback state changes (e.g. paused,
// seeked), and not when the current position is incremented every second.
if (IsPlaying(media_status_)) {
IncrementCurrentTimeAfterOneSecond();
}
}
void CastMediaSessionController::SeekTo(base::TimeDelta time) {
if (!media_status_) {
return;
}
route_controller_->Seek(time);
}
void CastMediaSessionController::SetMute(bool mute) {
if (!media_status_) {
return;
}
route_controller_->SetMute(mute);
}
void CastMediaSessionController::SetVolume(float volume) {
if (!media_status_) {
return;
}
route_controller_->SetVolume(volume);
}
void CastMediaSessionController::FlushForTesting() {
route_controller_.FlushForTesting();
}
media_router::mojom::MediaStatusPtr
CastMediaSessionController::GetMediaStatusForTesting() {
return media_status_.Clone();
}
base::TimeDelta CastMediaSessionController::PutWithinBounds(
const base::TimeDelta& time) {
if (time.is_negative() || !media_status_) {
return base::TimeDelta();
}
if (time > media_status_->duration) {
return media_status_->duration;
}
return time;
}
void CastMediaSessionController::IncrementCurrentTimeAfterOneSecond() {
// Reset() cancels the previously posted callback, if it exists.
increment_current_time_callback_.Reset(
base::BindOnce(&CastMediaSessionController::IncrementCurrentTime,
weak_ptr_factory_.GetWeakPtr()));
// TODO(crbug.com/40118765): If the playback rate is not 1, we must increment
// at a different rate.
content::GetUIThreadTaskRunner({})->PostDelayedTask(
FROM_HERE, increment_current_time_callback_.callback(), base::Seconds(1));
}
void CastMediaSessionController::IncrementCurrentTime() {
if (!IsPlaying(media_status_)) {
return;
}
if (media_status_->current_time < media_status_->duration) {
IncrementCurrentTimeAfterOneSecond();
}
media_status_->current_time =
PutWithinBounds(media_status_->current_time + base::Seconds(1));
}
|
