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
|
// Copyright 2014 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.
#include "base/basictypes.h"
#include "base/run_loop.h"
#include "content/browser/service_worker/embedded_worker_registry.h"
#include "content/browser/service_worker/embedded_worker_test_helper.h"
#include "content/browser/service_worker/service_worker_context_core.h"
#include "content/browser/service_worker/service_worker_handle.h"
#include "content/browser/service_worker/service_worker_registration.h"
#include "content/browser/service_worker/service_worker_test_utils.h"
#include "content/browser/service_worker/service_worker_version.h"
#include "content/common/service_worker/embedded_worker_messages.h"
#include "content/common/service_worker/service_worker_messages.h"
#include "content/public/test/test_browser_thread_bundle.h"
#include "ipc/ipc_message.h"
#include "ipc/ipc_test_sink.h"
#include "testing/gtest/include/gtest/gtest.h"
#include "third_party/WebKit/public/platform/WebServiceWorkerState.h"
namespace content {
namespace {
const int kRenderProcessId = 88; // A dummy ID for testing.
void VerifyStateChangedMessage(int expected_handle_id,
blink::WebServiceWorkerState expected_state,
const IPC::Message* message) {
ASSERT_TRUE(message != NULL);
ServiceWorkerMsg_ServiceWorkerStateChanged::Param param;
ASSERT_TRUE(ServiceWorkerMsg_ServiceWorkerStateChanged::Read(
message, ¶m));
EXPECT_EQ(expected_handle_id, get<1>(param));
EXPECT_EQ(expected_state, get<2>(param));
}
} // namespace
class ServiceWorkerHandleTest : public testing::Test {
public:
ServiceWorkerHandleTest()
: browser_thread_bundle_(TestBrowserThreadBundle::IO_MAINLOOP) {}
void SetUp() override {
helper_.reset(new EmbeddedWorkerTestHelper(kRenderProcessId));
const GURL pattern("http://www.example.com/");
registration_ = new ServiceWorkerRegistration(
pattern,
1L,
helper_->context()->AsWeakPtr());
version_ = new ServiceWorkerVersion(
registration_.get(),
GURL("http://www.example.com/service_worker.js"),
1L,
helper_->context()->AsWeakPtr());
helper_->SimulateAddProcessToPattern(pattern, kRenderProcessId);
}
void TearDown() override {
registration_ = NULL;
version_ = NULL;
helper_.reset();
}
IPC::TestSink* ipc_sink() { return helper_->ipc_sink(); }
TestBrowserThreadBundle browser_thread_bundle_;
scoped_ptr<EmbeddedWorkerTestHelper> helper_;
scoped_refptr<ServiceWorkerRegistration> registration_;
scoped_refptr<ServiceWorkerVersion> version_;
private:
DISALLOW_COPY_AND_ASSIGN(ServiceWorkerHandleTest);
};
TEST_F(ServiceWorkerHandleTest, OnVersionStateChanged) {
scoped_ptr<ServiceWorkerHandle> handle =
ServiceWorkerHandle::Create(helper_->context()->AsWeakPtr(),
helper_.get(),
version_.get());
// Start the worker, and then...
ServiceWorkerStatusCode status = SERVICE_WORKER_ERROR_FAILED;
version_->StartWorker(CreateReceiverOnCurrentThread(&status));
base::RunLoop().RunUntilIdle();
EXPECT_EQ(SERVICE_WORKER_OK, status);
// ...dispatch install event.
status = SERVICE_WORKER_ERROR_FAILED;
version_->SetStatus(ServiceWorkerVersion::INSTALLING);
version_->DispatchInstallEvent(-1, CreateReceiverOnCurrentThread(&status));
base::RunLoop().RunUntilIdle();
EXPECT_EQ(SERVICE_WORKER_OK, status);
version_->SetStatus(ServiceWorkerVersion::INSTALLED);
ASSERT_EQ(4UL, ipc_sink()->message_count());
// We should be sending 1. StartWorker,
EXPECT_EQ(EmbeddedWorkerMsg_StartWorker::ID,
ipc_sink()->GetMessageAt(0)->type());
// 2. StateChanged (state == Installing),
VerifyStateChangedMessage(handle->handle_id(),
blink::WebServiceWorkerStateInstalling,
ipc_sink()->GetMessageAt(1));
// 3. SendMessageToWorker (to send InstallEvent), and
EXPECT_EQ(EmbeddedWorkerContextMsg_MessageToWorker::ID,
ipc_sink()->GetMessageAt(2)->type());
// 4. StateChanged (state == Installed).
VerifyStateChangedMessage(handle->handle_id(),
blink::WebServiceWorkerStateInstalled,
ipc_sink()->GetMessageAt(3));
}
} // namespace content
|
