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 "core/page/EventSource.h" | 5 #include "core/page/EventSource.h" |
6 | 6 |
7 #include "bindings/core/v8/ExceptionState.h" | 7 #include "bindings/core/v8/ExceptionState.h" |
8 #include "bindings/core/v8/ScriptState.h" | 8 #include "bindings/core/v8/ScriptState.h" |
9 #include "bindings/core/v8/ScriptValue.h" | 9 #include "bindings/core/v8/ScriptValue.h" |
10 #include "bindings/core/v8/SerializedScriptValue.h" | 10 #include "bindings/core/v8/SerializedScriptValue.h" |
(...skipping 255 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
266 enqueue("retry:123\n"); | 266 enqueue("retry:123\n"); |
267 EXPECT_NE(EventSource::defaultReconnectDelay, source()->reconnectDelayForTes
t()); | 267 EXPECT_NE(EventSource::defaultReconnectDelay, source()->reconnectDelayForTes
t()); |
268 EXPECT_EQ(123u, source()->reconnectDelayForTest()); | 268 EXPECT_EQ(123u, source()->reconnectDelayForTest()); |
269 | 269 |
270 enqueue("retry:a0\n"); | 270 enqueue("retry:a0\n"); |
271 EXPECT_EQ(123u, source()->reconnectDelayForTest()); | 271 EXPECT_EQ(123u, source()->reconnectDelayForTest()); |
272 enqueue("retry:xi\n"); | 272 enqueue("retry:xi\n"); |
273 EXPECT_EQ(123u, source()->reconnectDelayForTest()); | 273 EXPECT_EQ(123u, source()->reconnectDelayForTest()); |
274 | 274 |
275 enqueue("retry:2a\n"); | 275 enqueue("retry:2a\n"); |
276 // TODO(yhirano): Should be ignored. | 276 EXPECT_EQ(123u, source()->reconnectDelayForTest()); |
277 // EXPECT_EQ(123u, source()->reconnectDelayForTest()); | |
278 EXPECT_EQ(2u, source()->reconnectDelayForTest()); | |
279 | 277 |
280 enqueue("retry:09a\n"); | 278 enqueue("retry:09a\n"); |
281 // TODO(yhirano): Should be ignored. | 279 EXPECT_EQ(123u, source()->reconnectDelayForTest()); |
282 // EXPECT_EQ(123u, source()->reconnectDelayForTest()); | |
283 EXPECT_EQ(9u, source()->reconnectDelayForTest()); | |
284 | 280 |
285 enqueue("retry:1\b\n"); | 281 enqueue("retry:1\b\n"); |
286 // TODO(yhirano): Should be ignored. | 282 EXPECT_EQ(123u, source()->reconnectDelayForTest()); |
287 // EXPECT_EQ(123u, source()->reconnectDelayForTest()); | |
288 EXPECT_EQ(1u, source()->reconnectDelayForTest()); | |
289 | 283 |
290 enqueue("retry: 1234\n"); | 284 enqueue("retry: 1234\n"); |
291 // TODO(yhirano): Should be ignored. | 285 EXPECT_EQ(123u, source()->reconnectDelayForTest()); |
292 // EXPECT_EQ(123u, source()->reconnectDelayForTest()); | |
293 EXPECT_EQ(1234u, source()->reconnectDelayForTest()); | |
294 | 286 |
295 enqueue("retry:456 \n"); | 287 enqueue("retry:456 \n"); |
296 // TODO(yhirano): Should be ignored. | 288 EXPECT_EQ(123u, source()->reconnectDelayForTest()); |
297 // EXPECT_EQ(123u, source()->reconnectDelayForTest()); | |
298 EXPECT_EQ(456u, source()->reconnectDelayForTest()); | |
299 | 289 |
300 EXPECT_EQ(0u, listener->events().size()); | 290 EXPECT_EQ(0u, listener->events().size()); |
301 } | 291 } |
302 | 292 |
303 TEST_F(EventSourceTest, UnrecognizedFieldShouldBeIgnored) | 293 TEST_F(EventSourceTest, UnrecognizedFieldShouldBeIgnored) |
304 { | 294 { |
305 RefPtrWillBeRawPtr<FakeEventListener> listener = FakeEventListener::create()
; | 295 RefPtrWillBeRawPtr<FakeEventListener> listener = FakeEventListener::create()
; |
306 | 296 |
307 source()->addEventListener("message", listener); | 297 source()->addEventListener("message", listener); |
308 enqueue("data:hello\nhoge:fuga\npiyo\n\n"); | 298 enqueue("data:hello\nhoge:fuga\npiyo\n\n"); |
(...skipping 119 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
428 ASSERT_EQ("message", messageListener->events()[0]->type()); | 418 ASSERT_EQ("message", messageListener->events()[0]->type()); |
429 RefPtrWillBeRawPtr<MessageEvent> messageEvent = static_cast<MessageEvent*>(m
essageListener->events()[0].get()); | 419 RefPtrWillBeRawPtr<MessageEvent> messageEvent = static_cast<MessageEvent*>(m
essageListener->events()[0].get()); |
430 ASSERT_EQ(MessageEvent::DataTypeSerializedScriptValue, messageEvent->dataTyp
e()); | 420 ASSERT_EQ(MessageEvent::DataTypeSerializedScriptValue, messageEvent->dataTyp
e()); |
431 EXPECT_EQ("bye", dataAsString(scriptState(), messageEvent.get())); | 421 EXPECT_EQ("bye", dataAsString(scriptState(), messageEvent.get())); |
432 EXPECT_EQ("8", messageEvent->lastEventId()); | 422 EXPECT_EQ("8", messageEvent->lastEventId()); |
433 } | 423 } |
434 | 424 |
435 } // namespace | 425 } // namespace |
436 | 426 |
437 } // namespace blink | 427 } // namespace blink |
OLD | NEW |