Implement the ability to get all notifications in Chromium.

content/browser/notifications/platform_notification_context_impl.cc

 // Copyright 2015 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 "content/browser/notifications/platform_notification_context_impl.h"
 
 #include "base/bind_helpers.h"
 #include "base/files/file_util.h"
 #include "base/threading/sequenced_worker_pool.h"
 #include "content/browser/notifications/notification_database.h"
@@ skipping 98 matching lines @@
   // Blow away the database if reading data failed due to corruption.
   if (status == NotificationDatabase::STATUS_ERROR_CORRUPTED)
     DestroyDatabase();
 
   BrowserThread::PostTask(
       BrowserThread::IO,
       FROM_HERE,
       base::Bind(callback, false /* success */, NotificationDatabaseData()));
 }
 
+void PlatformNotificationContextImpl::
+    ReadAllNotificationDataForServiceWorkerRegistration(
+    const GURL& origin,
+    int64_t service_worker_registration_id,
+    const ReadAllResultCallback& callback) {
+  DCHECK_CURRENTLY_ON(BrowserThread::IO);
+  LazyInitialize(
+       base::Bind(&PlatformNotificationContextImpl::
+                      DoReadAllNotificationDataForServiceWorkerRegistration,
+                  this, origin, service_worker_registration_id, callback),
+       base::Bind(callback,
+                  false /* success */,
+                  std::vector<NotificationDatabaseData>()));
+}
+
+void PlatformNotificationContextImpl::
+    DoReadAllNotificationDataForServiceWorkerRegistration(
+    const GURL& origin,
+    int64_t service_worker_registration_id,
+    const ReadAllResultCallback& callback) {
+  DCHECK(task_runner_->RunsTasksOnCurrentThread());
+
+  std::vector<NotificationDatabaseData> notification_datas;
+
+  NotificationDatabase::Status status =
+      database_->ReadAllNotificationDataForServiceWorkerRegistration(
+          origin, service_worker_registration_id, &notification_datas);
+
+  // TODO(peter): Record UMA on |status| for reading from the database.

[johnme, 2015/04/08 18:12:41]

Since you wrote this patch, the other methods now log UMA. When you rebase this,
consider logging to Notifications.Database.ReadResult ?

[Peter Beverloo, 2015/04/14 18:01:27]

Done.

+
+  if (status == NotificationDatabase::STATUS_OK) {
+    BrowserThread::PostTask(BrowserThread::IO,
+                            FROM_HERE,
+                            base::Bind(callback,
+                                       true /* success */,
+                                       notification_datas));
+    return;
+  }
+
+  // Blow away the database if reading data failed due to corruption.
+  if (status == NotificationDatabase::STATUS_ERROR_CORRUPTED)
+    DestroyDatabase();
+
+  BrowserThread::PostTask(
+      BrowserThread::IO,
+      FROM_HERE,
+      base::Bind(callback,
+                 false /* success */,
+                 std::vector<NotificationDatabaseData>()));
+}
+
 void PlatformNotificationContextImpl::WriteNotificationData(
     const GURL& origin,
     const NotificationDatabaseData& database_data,
     const WriteResultCallback& callback) {
   DCHECK_CURRENTLY_ON(BrowserThread::IO);
   LazyInitialize(
        base::Bind(&PlatformNotificationContextImpl::DoWriteNotificationData,
                   this, origin, database_data, callback),
        base::Bind(callback, false /* success */, 0 /* notification_id */));
 }
@@ skipping 188 matching lines @@
 
   return path_.Append(kPlatformNotificationsDirectory);
 }
 
 void PlatformNotificationContextImpl::SetTaskRunnerForTesting(
     const scoped_refptr<base::SequencedTaskRunner>& task_runner) {
   task_runner_ = task_runner;
 }
 
 }  // namespace content