Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(21)

Unified Diff: content/browser/push_messaging/push_messaging_message_filter.cc

Issue 1129833003: Rename "register" -> "subscribe" in the Push Messaging code. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@p-userVisible-tests
Patch Set: Created 5 years, 7 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: content/browser/push_messaging/push_messaging_message_filter.cc
diff --git a/content/browser/push_messaging/push_messaging_message_filter.cc b/content/browser/push_messaging/push_messaging_message_filter.cc
index da9d510f10eac493902c0fd86cd5a5978fe7cb19..c14359ba0f108ab5c93911e42a790220f92ceb96 100644
--- a/content/browser/push_messaging/push_messaging_message_filter.cc
+++ b/content/browser/push_messaging/push_messaging_message_filter.cc
@@ -26,39 +26,39 @@
namespace content {
const char kPushSenderIdServiceWorkerKey[] = "push_sender_id";
-const char kPushRegistrationIdServiceWorkerKey[] = "push_registration_id";
+const char kPushSubscriptionIdServiceWorkerKey[] = "push_registration_id";
namespace {
// These UMA methods are only called from IO thread, but it would be acceptable
// (even though slightly racy) to call them from UI thread as well, see
// https://groups.google.com/a/chromium.org/d/msg/chromium-dev/FNzZRJtN2aw/Aw0CWAXJJ1kJ
-void RecordRegistrationStatus(PushRegistrationStatus status) {
+void RecordSubscriptionStatus(PushSubscriptionStatus status) {
DCHECK_CURRENTLY_ON(BrowserThread::IO);
UMA_HISTOGRAM_ENUMERATION("PushMessaging.RegistrationStatus",
status,
- PUSH_REGISTRATION_STATUS_LAST + 1);
+ PUSH_SUBSCRIPTION_STATUS_LAST + 1);
}
-void RecordUnregistrationStatus(PushUnregistrationStatus status) {
+void RecordUnsubscriptionStatus(PushUnsubscriptionStatus status) {
DCHECK_CURRENTLY_ON(BrowserThread::IO);
UMA_HISTOGRAM_ENUMERATION("PushMessaging.UnregistrationStatus",
status,
- PUSH_UNREGISTRATION_STATUS_LAST + 1);
+ PUSH_UNSUBSCRIPTION_STATUS_LAST + 1);
}
-void RecordGetRegistrationStatus(PushGetRegistrationStatus status) {
+void RecordGetSubscriptionStatus(PushGetSubscriptionStatus status) {
DCHECK_CURRENTLY_ON(BrowserThread::IO);
UMA_HISTOGRAM_ENUMERATION("PushMessaging.GetRegistrationStatus",
status,
- PUSH_GETREGISTRATION_STATUS_LAST + 1);
+ PUSH_GETSUBSCRIPTION_STATUS_LAST + 1);
}
} // namespace
-struct PushMessagingMessageFilter::RegisterData {
- RegisterData();
- RegisterData(const RegisterData& other) = default;
+struct PushMessagingMessageFilter::SubscribeData {
+ SubscribeData();
+ SubscribeData(const SubscribeData& other) = default;
bool FromDocument() const;
int request_id;
GURL requesting_origin;
@@ -75,18 +75,18 @@ class PushMessagingMessageFilter::Core {
Core(const base::WeakPtr<PushMessagingMessageFilter>& io_parent,
int render_process_id);
- // Public Register methods on UI thread --------------------------------------
+ // Public Subscribe methods on UI thread -------------------------------------
// Called via PostTask from IO thread.
- void RegisterOnUI(const RegisterData& data, const std::string& sender_id);
+ void SubscribeOnUI(const SubscribeData& data, const std::string& sender_id);
- // Public Unregister methods on UI thread ------------------------------------
+ // Public Unsubscribe methods on UI thread -----------------------------------
// Called via PostTask from IO thread.
- void UnregisterFromService(int request_id,
- int64_t service_worker_registration_id,
- const GURL& requesting_origin,
- const std::string& sender_id);
+ void UnsubscribeFromService(int request_id,
+ int64_t service_worker_registration_id,
+ const GURL& requesting_origin,
+ const std::string& sender_id);
// Public GetPermission methods on UI thread ---------------------------------
@@ -109,17 +109,18 @@ class PushMessagingMessageFilter::Core {
~Core();
- // Private Register methods on UI thread -------------------------------------
+ // Private Subscribe methods on UI thread ------------------------------------
- void DidRegister(const RegisterData& data,
- const std::string& push_registration_id,
- PushRegistrationStatus status);
+ void DidSubscribe(const SubscribeData& data,
+ const std::string& push_subscription_id,
+ PushSubscriptionStatus status);
- // Private Unregister methods on UI thread -----------------------------------
+ // Private Unsubscribe methods on UI thread ----------------------------------
- void DidUnregisterFromService(int request_id,
- int64_t service_worker_registration_id,
- PushUnregistrationStatus unregistration_status);
+ void DidUnsubscribeFromService(
+ int request_id,
+ int64_t service_worker_registration_id,
+ PushUnsubscriptionStatus unsubscription_status);
// Private helper methods on UI thread ---------------------------------------
@@ -138,14 +139,14 @@ class PushMessagingMessageFilter::Core {
};
-PushMessagingMessageFilter::RegisterData::RegisterData()
+PushMessagingMessageFilter::SubscribeData::SubscribeData()
: request_id(0),
service_worker_registration_id(0),
user_visible(false),
render_frame_id(ChildProcessHost::kInvalidUniqueID) {
}
-bool PushMessagingMessageFilter::RegisterData::FromDocument() const {
+bool PushMessagingMessageFilter::SubscribeData::FromDocument() const {
return render_frame_id != ChildProcessHost::kInvalidUniqueID;
}
@@ -191,13 +192,14 @@ bool PushMessagingMessageFilter::OnMessageReceived(
const IPC::Message& message) {
bool handled = true;
IPC_BEGIN_MESSAGE_MAP(PushMessagingMessageFilter, message)
- IPC_MESSAGE_HANDLER(PushMessagingHostMsg_RegisterFromDocument,
- OnRegisterFromDocument)
- IPC_MESSAGE_HANDLER(PushMessagingHostMsg_RegisterFromWorker,
- OnRegisterFromWorker)
- IPC_MESSAGE_HANDLER(PushMessagingHostMsg_Unregister,
- OnUnregister)
- IPC_MESSAGE_HANDLER(PushMessagingHostMsg_GetRegistration, OnGetRegistration)
+ IPC_MESSAGE_HANDLER(PushMessagingHostMsg_SubscribeFromDocument,
+ OnSubscribeFromDocument)
+ IPC_MESSAGE_HANDLER(PushMessagingHostMsg_SubscribeFromWorker,
+ OnSubscribeFromWorker)
+ IPC_MESSAGE_HANDLER(PushMessagingHostMsg_Unsubscribe,
+ OnUnsubscribe)
+ IPC_MESSAGE_HANDLER(PushMessagingHostMsg_GetSubscription,
+ OnGetSubscription)
IPC_MESSAGE_HANDLER(PushMessagingHostMsg_GetPermissionStatus,
OnGetPermissionStatus)
IPC_MESSAGE_UNHANDLED(handled = false)
@@ -205,11 +207,11 @@ bool PushMessagingMessageFilter::OnMessageReceived(
return handled;
}
-// Register methods on both IO and UI threads, merged in order of use from
+// Subscription methods on both IO and UI threads, merged in order of use from
johnme 2015/05/07 13:31:25 Nit: "Subscribe" for consistency (even though it's
// PushMessagingMessageFilter and Core.
// -----------------------------------------------------------------------------
-void PushMessagingMessageFilter::OnRegisterFromDocument(
+void PushMessagingMessageFilter::OnSubscribeFromDocument(
int render_frame_id,
int request_id,
const std::string& sender_id,
@@ -218,7 +220,7 @@ void PushMessagingMessageFilter::OnRegisterFromDocument(
DCHECK_CURRENTLY_ON(BrowserThread::IO);
// TODO(mvanouwerkerk): Validate arguments?
// TODO(peter): Persist |user_visible| in Service Worker storage.
- RegisterData data;
+ SubscribeData data;
data.request_id = request_id;
data.service_worker_registration_id = service_worker_registration_id;
data.render_frame_id = render_frame_id;
@@ -229,7 +231,7 @@ void PushMessagingMessageFilter::OnRegisterFromDocument(
service_worker_registration_id);
if (!service_worker_registration ||
!service_worker_registration->active_version()) {
- SendRegisterError(data, PUSH_REGISTRATION_STATUS_NO_SERVICE_WORKER);
+ SendSubscribeError(data, PUSH_SUBSCRIPTION_STATUS_NO_SERVICE_WORKER);
return;
}
data.requesting_origin = service_worker_registration->pattern().GetOrigin();
@@ -244,12 +246,12 @@ void PushMessagingMessageFilter::OnRegisterFromDocument(
data, sender_id));
}
-void PushMessagingMessageFilter::OnRegisterFromWorker(
+void PushMessagingMessageFilter::OnSubscribeFromWorker(
int request_id,
int64_t service_worker_registration_id,
bool user_visible) {
DCHECK_CURRENTLY_ON(BrowserThread::IO);
- RegisterData data;
+ SubscribeData data;
data.request_id = request_id;
data.service_worker_registration_id = service_worker_registration_id;
data.user_visible = user_visible;
@@ -258,57 +260,57 @@ void PushMessagingMessageFilter::OnRegisterFromWorker(
service_worker_context_->GetLiveRegistration(
service_worker_registration_id);
if (!service_worker_registration) {
- SendRegisterError(data, PUSH_REGISTRATION_STATUS_NO_SERVICE_WORKER);
+ SendSubscribeError(data, PUSH_SUBSCRIPTION_STATUS_NO_SERVICE_WORKER);
return;
}
data.requesting_origin = service_worker_registration->pattern().GetOrigin();
// This sender_id will be ignored; instead it will be fetched from storage.
- CheckForExistingRegistration(data, std::string() /* sender_id */);
+ CheckForExistingSubscription(data, std::string() /* sender_id */);
}
void PushMessagingMessageFilter::DidPersistSenderId(
- const RegisterData& data,
+ const SubscribeData& data,
const std::string& sender_id,
ServiceWorkerStatusCode service_worker_status) {
DCHECK_CURRENTLY_ON(BrowserThread::IO);
if (service_worker_status != SERVICE_WORKER_OK)
- SendRegisterError(data, PUSH_REGISTRATION_STATUS_STORAGE_ERROR);
+ SendSubscribeError(data, PUSH_SUBSCRIPTION_STATUS_STORAGE_ERROR);
else
- CheckForExistingRegistration(data, sender_id);
+ CheckForExistingSubscription(data, sender_id);
}
-void PushMessagingMessageFilter::CheckForExistingRegistration(
- const RegisterData& data,
+void PushMessagingMessageFilter::CheckForExistingSubscription(
+ const SubscribeData& data,
const std::string& sender_id) {
DCHECK_CURRENTLY_ON(BrowserThread::IO);
service_worker_context_->GetRegistrationUserData(
data.service_worker_registration_id,
- kPushRegistrationIdServiceWorkerKey,
- base::Bind(&PushMessagingMessageFilter::DidCheckForExistingRegistration,
+ kPushSubscriptionIdServiceWorkerKey,
+ base::Bind(&PushMessagingMessageFilter::DidCheckForExistingSubscription,
weak_factory_io_to_io_.GetWeakPtr(), data, sender_id));
}
-void PushMessagingMessageFilter::DidCheckForExistingRegistration(
- const RegisterData& data,
+void PushMessagingMessageFilter::DidCheckForExistingSubscription(
+ const SubscribeData& data,
const std::string& sender_id,
- const std::string& push_registration_id,
+ const std::string& push_subscription_id,
ServiceWorkerStatusCode service_worker_status) {
DCHECK_CURRENTLY_ON(BrowserThread::IO);
if (service_worker_status == SERVICE_WORKER_OK) {
- SendRegisterSuccess(data, PUSH_REGISTRATION_STATUS_SUCCESS_FROM_CACHE,
- push_registration_id);
+ SendSubscribeSuccess(data, PUSH_SUBSCRIPTION_STATUS_SUCCESS_FROM_CACHE,
+ push_subscription_id);
return;
}
- // TODO(johnme): The spec allows the register algorithm to reject with an
+ // TODO(johnme): The spec allows the subscription algorithm to reject with an
// AbortError when accessing storage fails. Perhaps we should do that if
// service_worker_status != SERVICE_WORKER_ERROR_NOT_FOUND instead of
- // attempting to do a fresh registration?
- // https://w3c.github.io/push-api/#widl-PushRegistrationManager-register-Promise-PushRegistration
+ // attempting to do a fresh subscription?
+ // https://w3c.github.io/push-api/#widl-PushManager-subscribe-Promise-PushSubscription--PushSubscriptionOptions-options
if (data.FromDocument()) {
BrowserThread::PostTask(
BrowserThread::UI, FROM_HERE,
- base::Bind(&Core::RegisterOnUI, base::Unretained(ui_core_.get()),
+ base::Bind(&Core::SubscribeOnUI, base::Unretained(ui_core_.get()),
data, sender_id));
} else {
service_worker_context_->GetRegistrationUserData(
@@ -320,22 +322,22 @@ void PushMessagingMessageFilter::DidCheckForExistingRegistration(
}
void PushMessagingMessageFilter::DidGetSenderIdFromStorage(
- const RegisterData& data,
+ const SubscribeData& data,
const std::string& sender_id,
ServiceWorkerStatusCode service_worker_status) {
DCHECK_CURRENTLY_ON(BrowserThread::IO);
if (service_worker_status != SERVICE_WORKER_OK) {
- SendRegisterError(data, PUSH_REGISTRATION_STATUS_NO_SENDER_ID);
+ SendSubscribeError(data, PUSH_SUBSCRIPTION_STATUS_NO_SENDER_ID);
return;
}
BrowserThread::PostTask(
BrowserThread::UI, FROM_HERE,
- base::Bind(&Core::RegisterOnUI, base::Unretained(ui_core_.get()),
+ base::Bind(&Core::SubscribeOnUI, base::Unretained(ui_core_.get()),
data, sender_id));
}
-void PushMessagingMessageFilter::Core::RegisterOnUI(
- const PushMessagingMessageFilter::RegisterData& data,
+void PushMessagingMessageFilter::Core::SubscribeOnUI(
+ const PushMessagingMessageFilter::SubscribeData& data,
const std::string& sender_id) {
DCHECK_CURRENTLY_ON(BrowserThread::UI);
PushMessagingService* push_service = service();
@@ -344,9 +346,9 @@ void PushMessagingMessageFilter::Core::RegisterOnUI(
// TODO(johnme): Might be better not to expose the API in this case.
BrowserThread::PostTask(
BrowserThread::IO, FROM_HERE,
- base::Bind(&PushMessagingMessageFilter::SendRegisterError,
+ base::Bind(&PushMessagingMessageFilter::SendSubscribeError,
io_parent_,
- data, PUSH_REGISTRATION_STATUS_SERVICE_NOT_AVAILABLE));
+ data, PUSH_SUBSCRIPTION_STATUS_SERVICE_NOT_AVAILABLE));
} else {
// Prevent websites from detecting incognito mode, by emulating what would
// have happened if we had a PushMessagingService available.
@@ -354,10 +356,10 @@ void PushMessagingMessageFilter::Core::RegisterOnUI(
// Throw a permission denied error under the same circumstances.
BrowserThread::PostTask(
BrowserThread::IO, FROM_HERE,
- base::Bind(&PushMessagingMessageFilter::SendRegisterError,
+ base::Bind(&PushMessagingMessageFilter::SendSubscribeError,
io_parent_,
data,
- PUSH_REGISTRATION_STATUS_INCOGNITO_PERMISSION_DENIED));
+ PUSH_SUBSCRIPTION_STATUS_INCOGNITO_PERMISSION_DENIED));
}
// Else leave the promise hanging forever, to simulate a user ignoring the
// infobar. TODO(johnme): Simulate the user dismissing the infobar after a
@@ -367,135 +369,137 @@ void PushMessagingMessageFilter::Core::RegisterOnUI(
}
if (data.FromDocument()) {
- push_service->RegisterFromDocument(
+ push_service->SubscribeFromDocument(
data.requesting_origin, data.service_worker_registration_id, sender_id,
render_process_id_, data.render_frame_id, data.user_visible,
- base::Bind(&Core::DidRegister, weak_factory_ui_to_ui_.GetWeakPtr(),
+ base::Bind(&Core::DidSubscribe, weak_factory_ui_to_ui_.GetWeakPtr(),
data));
} else {
- push_service->RegisterFromWorker(
+ push_service->SubscribeFromWorker(
data.requesting_origin, data.service_worker_registration_id, sender_id,
data.user_visible,
- base::Bind(&Core::DidRegister, weak_factory_ui_to_ui_.GetWeakPtr(),
+ base::Bind(&Core::DidSubscribe, weak_factory_ui_to_ui_.GetWeakPtr(),
data));
}
}
-void PushMessagingMessageFilter::Core::DidRegister(
- const RegisterData& data,
- const std::string& push_registration_id,
- PushRegistrationStatus status) {
+void PushMessagingMessageFilter::Core::DidSubscribe(
+ const SubscribeData& data,
+ const std::string& push_subscription_id,
+ PushSubscriptionStatus status) {
DCHECK_CURRENTLY_ON(BrowserThread::UI);
- if (status == PUSH_REGISTRATION_STATUS_SUCCESS_FROM_PUSH_SERVICE) {
+ if (status == PUSH_SUBSCRIPTION_STATUS_SUCCESS_FROM_PUSH_SERVICE) {
BrowserThread::PostTask(
BrowserThread::IO, FROM_HERE,
- base::Bind(&PushMessagingMessageFilter::PersistRegistrationOnIO,
- io_parent_, data, push_registration_id));
+ base::Bind(&PushMessagingMessageFilter::PersistSubscriptionOnIO,
+ io_parent_, data, push_subscription_id));
} else {
BrowserThread::PostTask(
BrowserThread::IO, FROM_HERE,
- base::Bind(&PushMessagingMessageFilter::SendRegisterError, io_parent_,
+ base::Bind(&PushMessagingMessageFilter::SendSubscribeError, io_parent_,
data, status));
}
}
-void PushMessagingMessageFilter::PersistRegistrationOnIO(
- const RegisterData& data,
- const std::string& push_registration_id) {
+void PushMessagingMessageFilter::PersistSubscriptionOnIO(
+ const SubscribeData& data,
+ const std::string& push_subscription_id) {
DCHECK_CURRENTLY_ON(BrowserThread::IO);
service_worker_context_->StoreRegistrationUserData(
data.service_worker_registration_id,
data.requesting_origin,
- kPushRegistrationIdServiceWorkerKey,
- push_registration_id,
- base::Bind(&PushMessagingMessageFilter::DidPersistRegistrationOnIO,
+ kPushSubscriptionIdServiceWorkerKey,
+ push_subscription_id,
+ base::Bind(&PushMessagingMessageFilter::DidPersistSubscriptionOnIO,
weak_factory_io_to_io_.GetWeakPtr(),
- data, push_registration_id));
+ data, push_subscription_id));
}
-void PushMessagingMessageFilter::DidPersistRegistrationOnIO(
- const RegisterData& data,
- const std::string& push_registration_id,
+void PushMessagingMessageFilter::DidPersistSubscriptionOnIO(
+ const SubscribeData& data,
+ const std::string& push_subscription_id,
ServiceWorkerStatusCode service_worker_status) {
DCHECK_CURRENTLY_ON(BrowserThread::IO);
if (service_worker_status == SERVICE_WORKER_OK) {
- SendRegisterSuccess(data,
- PUSH_REGISTRATION_STATUS_SUCCESS_FROM_PUSH_SERVICE,
- push_registration_id);
+ SendSubscribeSuccess(data,
+ PUSH_SUBSCRIPTION_STATUS_SUCCESS_FROM_PUSH_SERVICE,
+ push_subscription_id);
} else {
- // TODO(johnme): Unregister, so PushMessagingServiceImpl can decrease count.
- SendRegisterError(data, PUSH_REGISTRATION_STATUS_STORAGE_ERROR);
+ // TODO(johnme): Unsubscribe, so PushMessagingServiceImpl can decrease
+ // count.
+ SendSubscribeError(data, PUSH_SUBSCRIPTION_STATUS_STORAGE_ERROR);
}
}
-void PushMessagingMessageFilter::SendRegisterError(
- const RegisterData& data, PushRegistrationStatus status) {
+void PushMessagingMessageFilter::SendSubscribeError(
+ const SubscribeData& data, PushSubscriptionStatus status) {
// Only called from IO thread, but would be safe to call from UI thread.
DCHECK_CURRENTLY_ON(BrowserThread::IO);
if (data.FromDocument()) {
- Send(new PushMessagingMsg_RegisterFromDocumentError(
+ Send(new PushMessagingMsg_SubscribeFromDocumentError(
data.render_frame_id, data.request_id, status));
} else {
- Send(new PushMessagingMsg_RegisterFromWorkerError(
+ Send(new PushMessagingMsg_SubscribeFromWorkerError(
data.request_id, status));
}
- RecordRegistrationStatus(status);
+ RecordSubscriptionStatus(status);
}
-void PushMessagingMessageFilter::SendRegisterSuccess(
- const RegisterData& data,
- PushRegistrationStatus status,
- const std::string& push_registration_id) {
+void PushMessagingMessageFilter::SendSubscribeSuccess(
+ const SubscribeData& data,
+ PushSubscriptionStatus status,
+ const std::string& push_subscription_id) {
// Only called from IO thread, but would be safe to call from UI thread.
DCHECK_CURRENTLY_ON(BrowserThread::IO);
if (push_endpoint_.is_empty()) {
// This shouldn't be possible in incognito mode, since we've already checked
- // that we have an existing registration. Hence it's ok to throw an error.
+ // that we have an existing subscription. Hence it's ok to throw an error.
DCHECK(!ui_core_->is_incognito());
- SendRegisterError(data, PUSH_REGISTRATION_STATUS_SERVICE_NOT_AVAILABLE);
+ SendSubscribeError(data, PUSH_SUBSCRIPTION_STATUS_SERVICE_NOT_AVAILABLE);
return;
}
if (data.FromDocument()) {
- Send(new PushMessagingMsg_RegisterFromDocumentSuccess(
+ Send(new PushMessagingMsg_SubscribeFromDocumentSuccess(
data.render_frame_id,
- data.request_id, push_endpoint_, push_registration_id));
+ data.request_id, push_endpoint_, push_subscription_id));
} else {
- Send(new PushMessagingMsg_RegisterFromWorkerSuccess(
- data.request_id, push_endpoint_, push_registration_id));
+ Send(new PushMessagingMsg_SubscribeFromWorkerSuccess(
+ data.request_id, push_endpoint_, push_subscription_id));
}
- RecordRegistrationStatus(status);
+ RecordSubscriptionStatus(status);
}
-// Unregister methods on both IO and UI threads, merged in order of use from
+// Unsubscribe methods on both IO and UI threads, merged in order of use from
// PushMessagingMessageFilter and Core.
// -----------------------------------------------------------------------------
-void PushMessagingMessageFilter::OnUnregister(
+void PushMessagingMessageFilter::OnUnsubscribe(
int request_id, int64_t service_worker_registration_id) {
DCHECK_CURRENTLY_ON(BrowserThread::IO);
ServiceWorkerRegistration* service_worker_registration =
service_worker_context_->GetLiveRegistration(
service_worker_registration_id);
if (!service_worker_registration) {
- DidUnregister(request_id, PUSH_UNREGISTRATION_STATUS_NO_SERVICE_WORKER);
+ DidUnsubscribe(request_id, PUSH_UNSUBSCRIPTION_STATUS_NO_SERVICE_WORKER);
return;
}
service_worker_context_->GetRegistrationUserData(
service_worker_registration_id,
- kPushRegistrationIdServiceWorkerKey,
+ kPushSubscriptionIdServiceWorkerKey,
base::Bind(
- &PushMessagingMessageFilter::UnregisterHavingGottenPushRegistrationId,
+ &PushMessagingMessageFilter
+ ::UnsubscribeHavingGottenPushSubscriptionId,
weak_factory_io_to_io_.GetWeakPtr(), request_id,
service_worker_registration_id,
service_worker_registration->pattern().GetOrigin()));
}
-void PushMessagingMessageFilter::UnregisterHavingGottenPushRegistrationId(
+void PushMessagingMessageFilter::UnsubscribeHavingGottenPushSubscriptionId(
int request_id,
int64_t service_worker_registration_id,
const GURL& requesting_origin,
- const std::string& push_registration_id, // Unused, we just want the status
+ const std::string& push_subscription_id, // Unused, we just want the status
ServiceWorkerStatusCode service_worker_status) {
DCHECK_CURRENTLY_ON(BrowserThread::IO);
@@ -504,22 +508,22 @@ void PushMessagingMessageFilter::UnregisterHavingGottenPushRegistrationId(
service_worker_registration_id,
kPushSenderIdServiceWorkerKey,
base::Bind(
- &PushMessagingMessageFilter::UnregisterHavingGottenSenderId,
+ &PushMessagingMessageFilter::UnsubscribeHavingGottenSenderId,
weak_factory_io_to_io_.GetWeakPtr(),
request_id,
service_worker_registration_id,
requesting_origin));
} else {
// Errors are handled the same, whether we were trying to get the
- // push_registration_id or the sender_id.
- UnregisterHavingGottenSenderId(request_id, service_worker_registration_id,
- requesting_origin,
- std::string() /* sender_id */,
- service_worker_status);
+ // push_subscription_id or the sender_id.
+ UnsubscribeHavingGottenSenderId(request_id, service_worker_registration_id,
+ requesting_origin,
+ std::string() /* sender_id */,
+ service_worker_status);
}
}
-void PushMessagingMessageFilter::UnregisterHavingGottenSenderId(
+void PushMessagingMessageFilter::UnsubscribeHavingGottenSenderId(
int request_id,
int64_t service_worker_registration_id,
const GURL& requesting_origin,
@@ -531,20 +535,20 @@ void PushMessagingMessageFilter::UnregisterHavingGottenSenderId(
case SERVICE_WORKER_OK:
BrowserThread::PostTask(
BrowserThread::UI, FROM_HERE,
- base::Bind(&Core::UnregisterFromService,
+ base::Bind(&Core::UnsubscribeFromService,
base::Unretained(ui_core_.get()), request_id,
service_worker_registration_id, requesting_origin,
sender_id));
break;
case SERVICE_WORKER_ERROR_NOT_FOUND:
- // We did not find a registration, stop here and notify the renderer that
- // it was a success even though we did not unregister.
- DidUnregister(request_id,
- PUSH_UNREGISTRATION_STATUS_SUCCESS_WAS_NOT_REGISTERED);
+ // We did not find a subscription, stop here and notify the renderer that
+ // it was a success even though we did not unsubscribe.
+ DidUnsubscribe(request_id,
+ PUSH_UNSUBSCRIPTION_STATUS_SUCCESS_WAS_NOT_SUBSCRIBED);
break;
case SERVICE_WORKER_ERROR_FAILED:
- DidUnregister(request_id,
- PUSH_UNREGISTRATION_STATUS_STORAGE_ERROR);
+ DidUnsubscribe(request_id,
+ PUSH_UNSUBSCRIPTION_STATUS_STORAGE_ERROR);
break;
case SERVICE_WORKER_ERROR_ABORT:
case SERVICE_WORKER_ERROR_START_WORKER_FAILED:
@@ -563,12 +567,12 @@ void PushMessagingMessageFilter::UnregisterHavingGottenSenderId(
case SERVICE_WORKER_ERROR_MAX_VALUE:
NOTREACHED() << "Got unexpected error code: " << service_worker_status
<< " " << ServiceWorkerStatusToString(service_worker_status);
- DidUnregister(request_id, PUSH_UNREGISTRATION_STATUS_STORAGE_ERROR);
+ DidUnsubscribe(request_id, PUSH_UNSUBSCRIPTION_STATUS_STORAGE_ERROR);
break;
}
}
-void PushMessagingMessageFilter::Core::UnregisterFromService(
+void PushMessagingMessageFilter::Core::UnsubscribeFromService(
int request_id,
int64_t service_worker_registration_id,
const GURL& requesting_origin,
@@ -577,150 +581,150 @@ void PushMessagingMessageFilter::Core::UnregisterFromService(
PushMessagingService* push_service = service();
if (!push_service) {
// This shouldn't be possible in incognito mode, since we've already checked
- // that we have an existing registration. Hence it's ok to throw an error.
+ // that we have an existing subscription. Hence it's ok to throw an error.
DCHECK(!is_incognito());
BrowserThread::PostTask(
BrowserThread::IO, FROM_HERE,
- base::Bind(&PushMessagingMessageFilter::DidUnregister, io_parent_,
+ base::Bind(&PushMessagingMessageFilter::DidUnsubscribe, io_parent_,
request_id,
- PUSH_UNREGISTRATION_STATUS_SERVICE_NOT_AVAILABLE));
+ PUSH_UNSUBSCRIPTION_STATUS_SERVICE_NOT_AVAILABLE));
return;
}
- push_service->Unregister(
+ push_service->Unsubscribe(
requesting_origin, service_worker_registration_id, sender_id,
- base::Bind(&Core::DidUnregisterFromService,
+ base::Bind(&Core::DidUnsubscribeFromService,
weak_factory_ui_to_ui_.GetWeakPtr(),
request_id, service_worker_registration_id));
}
-void PushMessagingMessageFilter::Core::DidUnregisterFromService(
+void PushMessagingMessageFilter::Core::DidUnsubscribeFromService(
int request_id,
int64_t service_worker_registration_id,
- PushUnregistrationStatus unregistration_status) {
+ PushUnsubscriptionStatus unsubscription_status) {
DCHECK_CURRENTLY_ON(BrowserThread::UI);
- switch (unregistration_status) {
- case PUSH_UNREGISTRATION_STATUS_SUCCESS_UNREGISTERED:
- case PUSH_UNREGISTRATION_STATUS_SUCCESS_WAS_NOT_REGISTERED:
- case PUSH_UNREGISTRATION_STATUS_PENDING_NETWORK_ERROR:
- case PUSH_UNREGISTRATION_STATUS_PENDING_SERVICE_ERROR:
+ switch (unsubscription_status) {
+ case PUSH_UNSUBSCRIPTION_STATUS_SUCCESS_UNSUBSCRIBED:
+ case PUSH_UNSUBSCRIPTION_STATUS_SUCCESS_WAS_NOT_SUBSCRIBED:
+ case PUSH_UNSUBSCRIPTION_STATUS_PENDING_NETWORK_ERROR:
+ case PUSH_UNSUBSCRIPTION_STATUS_PENDING_SERVICE_ERROR:
BrowserThread::PostTask(
BrowserThread::IO, FROM_HERE,
- base::Bind(&PushMessagingMessageFilter::ClearRegistrationData,
+ base::Bind(&PushMessagingMessageFilter::ClearSubscriptionData,
io_parent_, request_id, service_worker_registration_id,
- unregistration_status));
+ unsubscription_status));
break;
- case PUSH_UNREGISTRATION_STATUS_NO_SERVICE_WORKER:
- case PUSH_UNREGISTRATION_STATUS_SERVICE_NOT_AVAILABLE:
- case PUSH_UNREGISTRATION_STATUS_STORAGE_ERROR:
- case PUSH_UNREGISTRATION_STATUS_NETWORK_ERROR:
+ case PUSH_UNSUBSCRIPTION_STATUS_NO_SERVICE_WORKER:
+ case PUSH_UNSUBSCRIPTION_STATUS_SERVICE_NOT_AVAILABLE:
+ case PUSH_UNSUBSCRIPTION_STATUS_STORAGE_ERROR:
+ case PUSH_UNSUBSCRIPTION_STATUS_NETWORK_ERROR:
NOTREACHED();
break;
}
}
-void PushMessagingMessageFilter::ClearRegistrationData(
+void PushMessagingMessageFilter::ClearSubscriptionData(
int request_id,
int64_t service_worker_registration_id,
- PushUnregistrationStatus unregistration_status) {
+ PushUnsubscriptionStatus unsubscription_status) {
DCHECK_CURRENTLY_ON(BrowserThread::IO);
service_worker_context_->ClearRegistrationUserData(
service_worker_registration_id,
- kPushRegistrationIdServiceWorkerKey,
- base::Bind(&PushMessagingMessageFilter::DidClearRegistrationData,
+ kPushSubscriptionIdServiceWorkerKey,
+ base::Bind(&PushMessagingMessageFilter::DidClearSubscriptionData,
weak_factory_io_to_io_.GetWeakPtr(),
- request_id, unregistration_status));
+ request_id, unsubscription_status));
}
-void PushMessagingMessageFilter::DidClearRegistrationData(
+void PushMessagingMessageFilter::DidClearSubscriptionData(
int request_id,
- PushUnregistrationStatus unregistration_status,
+ PushUnsubscriptionStatus unsubscription_status,
ServiceWorkerStatusCode service_worker_status) {
DCHECK_CURRENTLY_ON(BrowserThread::IO);
if (service_worker_status != SERVICE_WORKER_OK &&
service_worker_status != SERVICE_WORKER_ERROR_NOT_FOUND) {
- unregistration_status = PUSH_UNREGISTRATION_STATUS_STORAGE_ERROR;
+ unsubscription_status = PUSH_UNSUBSCRIPTION_STATUS_STORAGE_ERROR;
DLOG(WARNING) << "Got unexpected error code: " << service_worker_status
<< " " << ServiceWorkerStatusToString(service_worker_status);
}
- DidUnregister(request_id, unregistration_status);
+ DidUnsubscribe(request_id, unsubscription_status);
}
-void PushMessagingMessageFilter::DidUnregister(
+void PushMessagingMessageFilter::DidUnsubscribe(
int request_id,
- PushUnregistrationStatus unregistration_status) {
+ PushUnsubscriptionStatus unsubscription_status) {
// Only called from IO thread, but would be safe to call from UI thread.
DCHECK_CURRENTLY_ON(BrowserThread::IO);
- switch (unregistration_status) {
- case PUSH_UNREGISTRATION_STATUS_SUCCESS_UNREGISTERED:
- case PUSH_UNREGISTRATION_STATUS_PENDING_NETWORK_ERROR:
- case PUSH_UNREGISTRATION_STATUS_PENDING_SERVICE_ERROR:
- Send(new PushMessagingMsg_UnregisterSuccess(request_id, true));
+ switch (unsubscription_status) {
+ case PUSH_UNSUBSCRIPTION_STATUS_SUCCESS_UNSUBSCRIBED:
+ case PUSH_UNSUBSCRIPTION_STATUS_PENDING_NETWORK_ERROR:
+ case PUSH_UNSUBSCRIPTION_STATUS_PENDING_SERVICE_ERROR:
+ Send(new PushMessagingMsg_UnsubscribeSuccess(request_id, true));
break;
- case PUSH_UNREGISTRATION_STATUS_SUCCESS_WAS_NOT_REGISTERED:
- Send(new PushMessagingMsg_UnregisterSuccess(request_id, false));
+ case PUSH_UNSUBSCRIPTION_STATUS_SUCCESS_WAS_NOT_SUBSCRIBED:
+ Send(new PushMessagingMsg_UnsubscribeSuccess(request_id, false));
break;
- case PUSH_UNREGISTRATION_STATUS_NO_SERVICE_WORKER:
- case PUSH_UNREGISTRATION_STATUS_SERVICE_NOT_AVAILABLE:
- case PUSH_UNREGISTRATION_STATUS_STORAGE_ERROR:
- Send(new PushMessagingMsg_UnregisterError(
+ case PUSH_UNSUBSCRIPTION_STATUS_NO_SERVICE_WORKER:
+ case PUSH_UNSUBSCRIPTION_STATUS_SERVICE_NOT_AVAILABLE:
+ case PUSH_UNSUBSCRIPTION_STATUS_STORAGE_ERROR:
+ Send(new PushMessagingMsg_UnsubscribeError(
request_id, blink::WebPushError::ErrorTypeAbort,
- PushUnregistrationStatusToString(unregistration_status)));
+ PushUnsubscriptionStatusToString(unsubscription_status)));
break;
- case PUSH_UNREGISTRATION_STATUS_NETWORK_ERROR:
+ case PUSH_UNSUBSCRIPTION_STATUS_NETWORK_ERROR:
NOTREACHED();
break;
}
- RecordUnregistrationStatus(unregistration_status);
+ RecordUnsubscriptionStatus(unsubscription_status);
}
-// GetRegistration methods on both IO and UI threads, merged in order of use
+// GetSubscription methods on both IO and UI threads, merged in order of use
// from PushMessagingMessageFilter and Core.
// -----------------------------------------------------------------------------
-void PushMessagingMessageFilter::OnGetRegistration(
+void PushMessagingMessageFilter::OnGetSubscription(
int request_id,
int64_t service_worker_registration_id) {
DCHECK_CURRENTLY_ON(BrowserThread::IO);
// TODO(johnme): Validate arguments?
service_worker_context_->GetRegistrationUserData(
service_worker_registration_id,
- kPushRegistrationIdServiceWorkerKey,
- base::Bind(&PushMessagingMessageFilter::DidGetRegistration,
+ kPushSubscriptionIdServiceWorkerKey,
+ base::Bind(&PushMessagingMessageFilter::DidGetSubscription,
weak_factory_io_to_io_.GetWeakPtr(), request_id));
}
-void PushMessagingMessageFilter::DidGetRegistration(
+void PushMessagingMessageFilter::DidGetSubscription(
int request_id,
- const std::string& push_registration_id,
+ const std::string& push_subscription_id,
ServiceWorkerStatusCode service_worker_status) {
DCHECK_CURRENTLY_ON(BrowserThread::IO);
- PushGetRegistrationStatus get_status =
- PUSH_GETREGISTRATION_STATUS_STORAGE_ERROR;
+ PushGetSubscriptionStatus get_status =
+ PUSH_GETSUBSCRIPTION_STATUS_STORAGE_ERROR;
switch (service_worker_status) {
case SERVICE_WORKER_OK:
if (push_endpoint_.is_empty()) {
// Return not found in incognito mode, so websites can't detect it.
get_status =
ui_core_->is_incognito()
- ? PUSH_GETREGISTRATION_STATUS_INCOGNITO_REGISTRATION_NOT_FOUND
- : PUSH_GETREGISTRATION_STATUS_SERVICE_NOT_AVAILABLE;
+ ? PUSH_GETSUBSCRIPTION_STATUS_INCOGNITO_SUBSCRIPTION_NOT_FOUND
+ : PUSH_GETSUBSCRIPTION_STATUS_SERVICE_NOT_AVAILABLE;
break;
}
- Send(new PushMessagingMsg_GetRegistrationSuccess(request_id,
+ Send(new PushMessagingMsg_GetSubscriptionSuccess(request_id,
push_endpoint_,
- push_registration_id));
- RecordGetRegistrationStatus(PUSH_GETREGISTRATION_STATUS_SUCCESS);
+ push_subscription_id));
+ RecordGetSubscriptionStatus(PUSH_GETSUBSCRIPTION_STATUS_SUCCESS);
return;
case SERVICE_WORKER_ERROR_NOT_FOUND:
- get_status = PUSH_GETREGISTRATION_STATUS_REGISTRATION_NOT_FOUND;
+ get_status = PUSH_GETSUBSCRIPTION_STATUS_SUBSCRIPTION_NOT_FOUND;
break;
case SERVICE_WORKER_ERROR_FAILED:
- get_status = PUSH_GETREGISTRATION_STATUS_STORAGE_ERROR;
+ get_status = PUSH_GETSUBSCRIPTION_STATUS_STORAGE_ERROR;
break;
case SERVICE_WORKER_ERROR_ABORT:
case SERVICE_WORKER_ERROR_START_WORKER_FAILED:
@@ -739,11 +743,11 @@ void PushMessagingMessageFilter::DidGetRegistration(
case SERVICE_WORKER_ERROR_MAX_VALUE:
NOTREACHED() << "Got unexpected error code: " << service_worker_status
<< " " << ServiceWorkerStatusToString(service_worker_status);
- get_status = PUSH_GETREGISTRATION_STATUS_STORAGE_ERROR;
+ get_status = PUSH_GETSUBSCRIPTION_STATUS_STORAGE_ERROR;
break;
}
- Send(new PushMessagingMsg_GetRegistrationError(request_id, get_status));
- RecordGetRegistrationStatus(get_status);
+ Send(new PushMessagingMsg_GetSubscriptionError(request_id, get_status));
+ RecordGetSubscriptionStatus(get_status);
}
// GetPermission methods on both IO and UI threads, merged in order of use from

Powered by Google App Engine
This is Rietveld 408576698