OLD | NEW |
1 // Copyright 2016 The Chromium Authors. All rights reserved. | 1 // Copyright 2016 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "modules/remoteplayback/RemotePlayback.h" | 5 #include "modules/remoteplayback/RemotePlayback.h" |
6 | 6 |
7 #include "bindings/core/v8/ScriptPromiseResolver.h" | 7 #include "bindings/core/v8/ScriptPromiseResolver.h" |
8 #include "core/HTMLNames.h" | 8 #include "core/HTMLNames.h" |
9 #include "core/dom/DOMException.h" | 9 #include "core/dom/DOMException.h" |
10 #include "core/dom/Document.h" | 10 #include "core/dom/Document.h" |
(...skipping 75 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
86 // TODO(avayvod): implement steps 4, 5, 8, 9 of the algorithm. | 86 // TODO(avayvod): implement steps 4, 5, 8, 9 of the algorithm. |
87 // https://crbug.com/647441 | 87 // https://crbug.com/647441 |
88 ScriptPromiseResolver* resolver = ScriptPromiseResolver::create(scriptState)
; | 88 ScriptPromiseResolver* resolver = ScriptPromiseResolver::create(scriptState)
; |
89 ScriptPromise promise = resolver->promise(); | 89 ScriptPromise promise = resolver->promise(); |
90 | 90 |
91 if (m_mediaElement->fastHasAttribute(HTMLNames::disableremoteplaybackAttr))
{ | 91 if (m_mediaElement->fastHasAttribute(HTMLNames::disableremoteplaybackAttr))
{ |
92 resolver->reject(DOMException::create(InvalidStateError, "disableRemoteP
layback attribute is present.")); | 92 resolver->reject(DOMException::create(InvalidStateError, "disableRemoteP
layback attribute is present.")); |
93 return promise; | 93 return promise; |
94 } | 94 } |
95 | 95 |
96 // TODO(avayvod): should we have a separate flag to disable the user gesture | 96 if (m_promptPromiseResolver) { |
97 // requirement (for tests) or reuse the one for the PresentationRequest::sta
rt()? | 97 resolver->reject(DOMException::create(OperationError, "A prompt is alrea
dy being shown for this media element.")); |
| 98 return promise; |
| 99 } |
| 100 |
98 if (!UserGestureIndicator::utilizeUserGesture()) { | 101 if (!UserGestureIndicator::utilizeUserGesture()) { |
99 resolver->reject(DOMException::create(InvalidAccessError, "RemotePlaybac
k::prompt() requires user gesture.")); | 102 resolver->reject(DOMException::create(InvalidAccessError, "RemotePlaybac
k::prompt() requires user gesture.")); |
100 return promise; | 103 return promise; |
101 } | 104 } |
102 | 105 |
103 if (m_state == WebRemotePlaybackState::Disconnected) { | 106 if (m_state == WebRemotePlaybackState::Disconnected) { |
104 m_promptPromiseResolvers.append(resolver); | 107 m_promptPromiseResolver = resolver; |
105 m_mediaElement->requestRemotePlayback(); | 108 m_mediaElement->requestRemotePlayback(); |
106 } else { | 109 } else { |
107 m_mediaElement->requestRemotePlaybackControl(); | 110 m_mediaElement->requestRemotePlaybackControl(); |
108 // TODO(avayvod): Need to keep the resolver until user chooses to stop | 111 // TODO(avayvod): Need to keep the resolver until user chooses to stop |
109 // the remote playback (resolve) or dismisses the UI (reject). | 112 // the remote playback (resolve) or dismisses the UI (reject). |
110 // Steps 11 and 12 of the prompt() algorithm. | 113 // Steps 11 and 12 of the prompt() algorithm. |
111 // https://crbug.com/647441 | 114 // https://crbug.com/647441 |
112 resolver->resolve(); | 115 resolver->resolve(); |
113 } | 116 } |
114 | 117 |
115 return promise; | 118 return promise; |
116 } | 119 } |
117 | 120 |
118 String RemotePlayback::state() const | 121 String RemotePlayback::state() const |
119 { | 122 { |
120 return remotePlaybackStateToString(m_state); | 123 return remotePlaybackStateToString(m_state); |
121 } | 124 } |
122 | 125 |
123 bool RemotePlayback::hasPendingActivity() const | 126 bool RemotePlayback::hasPendingActivity() const |
124 { | 127 { |
125 return hasEventListeners() | 128 return hasEventListeners() |
126 || !m_availabilityObjects.isEmpty() | 129 || !m_availabilityObjects.isEmpty() |
127 || !m_promptPromiseResolvers.isEmpty(); | 130 || m_promptPromiseResolver; |
128 } | 131 } |
129 | 132 |
130 void RemotePlayback::stateChanged(WebRemotePlaybackState state) | 133 void RemotePlayback::stateChanged(WebRemotePlaybackState state) |
131 { | 134 { |
132 // We may get a "disconnected" state change while in the "disconnected" | 135 // We may get a "disconnected" state change while in the "disconnected" |
133 // state if initiated connection fails. So cleanup the promise resolvers | 136 // state if initiated connection fails. So cleanup the promise resolvers |
134 // before checking if anything changed. | 137 // before checking if anything changed. |
135 // TODO(avayvod): cleanup this logic when we implementing the "connecting" | 138 // TODO(avayvod): cleanup this logic when we implementing the "connecting" |
136 // state. | 139 // state. |
137 if (state != WebRemotePlaybackState::Disconnected) { | 140 if (m_promptPromiseResolver) { |
138 for (auto& resolver : m_promptPromiseResolvers) | 141 if (state != WebRemotePlaybackState::Disconnected) |
139 resolver->resolve(); | 142 m_promptPromiseResolver->resolve(); |
140 } else { | 143 else |
141 for (auto& resolver : m_promptPromiseResolvers) | 144 m_promptPromiseResolver->reject(DOMException::create(AbortError, "Fa
iled to connect to the remote device.")); |
142 resolver->reject(DOMException::create(AbortError, "Failed to connect
to the remote device.")); | 145 m_promptPromiseResolver = nullptr; |
143 } | 146 } |
144 m_promptPromiseResolvers.clear(); | |
145 | 147 |
146 if (m_state == state) | 148 if (m_state == state) |
147 return; | 149 return; |
148 | 150 |
149 m_state = state; | 151 m_state = state; |
150 dispatchEvent(Event::create(EventTypeNames::statechange)); | 152 dispatchEvent(Event::create(EventTypeNames::statechange)); |
151 } | 153 } |
152 | 154 |
153 void RemotePlayback::availabilityChanged(bool available) | 155 void RemotePlayback::availabilityChanged(bool available) |
154 { | 156 { |
155 if (m_availability == available) | 157 if (m_availability == available) |
156 return; | 158 return; |
157 | 159 |
158 m_availability = available; | 160 m_availability = available; |
159 for (auto& availabilityObject : m_availabilityObjects) | 161 for (auto& availabilityObject : m_availabilityObjects) |
160 availabilityObject->availabilityChanged(available); | 162 availabilityObject->availabilityChanged(available); |
161 } | 163 } |
162 | 164 |
163 void RemotePlayback::promptCancelled() | 165 void RemotePlayback::promptCancelled() |
164 { | 166 { |
165 for (auto& resolver : m_promptPromiseResolvers) | 167 if (!m_promptPromiseResolver) |
166 resolver->resolve(); | 168 return; |
167 m_promptPromiseResolvers.clear(); | 169 |
| 170 m_promptPromiseResolver->resolve(); |
| 171 m_promptPromiseResolver = nullptr; |
168 } | 172 } |
169 | 173 |
170 DEFINE_TRACE(RemotePlayback) | 174 DEFINE_TRACE(RemotePlayback) |
171 { | 175 { |
172 visitor->trace(m_availabilityObjects); | 176 visitor->trace(m_availabilityObjects); |
173 visitor->trace(m_promptPromiseResolvers); | 177 visitor->trace(m_promptPromiseResolver); |
174 visitor->trace(m_mediaElement); | 178 visitor->trace(m_mediaElement); |
175 EventTargetWithInlineData::trace(visitor); | 179 EventTargetWithInlineData::trace(visitor); |
176 } | 180 } |
177 | 181 |
178 } // namespace blink | 182 } // namespace blink |
OLD | NEW |