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
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
|
// Copyright (c) 2012 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 "chrome/browser/notifications/notification_ui_manager_impl.h"
#include "base/logging.h"
#include "base/prefs/pref_service.h"
#include "base/memory/linked_ptr.h"
#include "base/stl_util.h"
#include "chrome/browser/browser_process.h"
#include "chrome/browser/fullscreen.h"
#include "chrome/browser/idle.h"
#include "chrome/browser/notifications/balloon_collection.h"
#include "chrome/browser/notifications/notification.h"
#include "chrome/common/chrome_notification_types.h"
#include "chrome/common/pref_names.h"
#include "content/public/browser/notification_service.h"
namespace {
const int kUserStatePollingIntervalSeconds = 1;
}
// A class which represents a notification waiting to be shown.
class QueuedNotification {
public:
QueuedNotification(const Notification& notification, Profile* profile)
: notification_(notification),
profile_(profile) {
}
const Notification& notification() const { return notification_; }
Profile* profile() const { return profile_; }
void Replace(const Notification& new_notification) {
notification_ = new_notification;
}
private:
// The notification to be shown.
Notification notification_;
// Non owned pointer to the user's profile.
Profile* profile_;
DISALLOW_COPY_AND_ASSIGN(QueuedNotification);
};
NotificationUIManagerImpl::NotificationUIManagerImpl()
: is_user_active_(true) {
registrar_.Add(this, chrome::NOTIFICATION_APP_TERMINATING,
content::NotificationService::AllSources());
}
NotificationUIManagerImpl::~NotificationUIManagerImpl() {
}
void NotificationUIManagerImpl::Add(const Notification& notification,
Profile* profile) {
if (TryReplacement(notification, profile)) {
return;
}
VLOG(1) << "Added notification. URL: "
<< notification.content_url().spec();
show_queue_.push_back(linked_ptr<QueuedNotification>(
new QueuedNotification(notification, profile)));
CheckAndShowNotifications();
}
bool NotificationUIManagerImpl::DoesIdExist(const std::string& id) {
for (NotificationDeque::iterator iter = show_queue_.begin();
iter != show_queue_.end(); ++iter) {
if ((*iter)->notification().notification_id() == id)
return true;
}
return false;
}
bool NotificationUIManagerImpl::CancelById(const std::string& id) {
// See if this ID hasn't been shown yet.
for (NotificationDeque::iterator iter = show_queue_.begin();
iter != show_queue_.end(); ++iter) {
if ((*iter)->notification().notification_id() == id) {
show_queue_.erase(iter);
return true;
}
}
return false;
}
bool NotificationUIManagerImpl::CancelAllBySourceOrigin(const GURL& source) {
// Same pattern as CancelById, but more complicated than the above
// because there may be multiple notifications from the same source.
bool removed = false;
for (NotificationDeque::iterator loopiter = show_queue_.begin();
loopiter != show_queue_.end(); ) {
NotificationDeque::iterator curiter = loopiter++;
if ((*curiter)->notification().origin_url() == source) {
show_queue_.erase(curiter);
removed = true;
}
}
return removed;
}
bool NotificationUIManagerImpl::CancelAllByProfile(Profile* profile) {
// Same pattern as CancelAllBySourceOrigin.
bool removed = false;
for (NotificationDeque::iterator loopiter = show_queue_.begin();
loopiter != show_queue_.end(); ) {
NotificationDeque::iterator curiter = loopiter++;
if ((*curiter)->profile() == profile) {
show_queue_.erase(curiter);
removed = true;
}
}
return removed;
}
void NotificationUIManagerImpl::CancelAll() {
}
void NotificationUIManagerImpl::CheckAndShowNotifications() {
CheckUserState();
if (is_user_active_)
ShowNotifications();
}
void NotificationUIManagerImpl::CheckUserState() {
bool is_user_active_previously = is_user_active_;
is_user_active_ = !CheckIdleStateIsLocked() && !IsFullScreenMode();
if (is_user_active_ == is_user_active_previously)
return;
if (is_user_active_) {
user_state_check_timer_.Stop();
// We need to show any postponed nofications when the user becomes active
// again.
ShowNotifications();
} else if (!user_state_check_timer_.IsRunning()) {
// Start a timer to detect the moment at which the user becomes active.
user_state_check_timer_.Start(FROM_HERE,
base::TimeDelta::FromSeconds(kUserStatePollingIntervalSeconds), this,
&NotificationUIManagerImpl::CheckUserState);
}
}
// Attempts to show each notification, leaving any failures in the queue.
// TODO(dewittj): Eliminate recursion when BallonCollection is used to render
// the Notification UI surfaces.
void NotificationUIManagerImpl::ShowNotifications() {
while (!show_queue_.empty()) {
linked_ptr<QueuedNotification> queued_notification(show_queue_.front());
show_queue_.pop_front();
if (!ShowNotification(queued_notification->notification(),
queued_notification->profile())) {
// Subclass could not show notification, put it back in the queue.
show_queue_.push_front(queued_notification);
return;
}
}
}
bool NotificationUIManagerImpl::TryReplacement(
const Notification& notification, Profile* profile) {
const GURL& origin = notification.origin_url();
const string16& replace_id = notification.replace_id();
if (replace_id.empty())
return false;
// First check the queue of pending notifications for replacement.
// Then check the list of notifications already being shown.
for (NotificationDeque::const_iterator iter = show_queue_.begin();
iter != show_queue_.end(); ++iter) {
if (profile == (*iter)->profile() &&
origin == (*iter)->notification().origin_url() &&
replace_id == (*iter)->notification().replace_id()) {
(*iter)->Replace(notification);
return true;
}
}
// Give the subclass the opportunity to update existing notification.
return UpdateNotification(notification, profile);
}
void NotificationUIManagerImpl::GetQueuedNotificationsForTesting(
std::vector<const Notification*>* notifications) {
for (NotificationDeque::const_iterator iter = show_queue_.begin();
iter != show_queue_.end(); ++iter) {
notifications->push_back(&(*iter)->notification());
}
}
void NotificationUIManagerImpl::Observe(
int type,
const content::NotificationSource& source,
const content::NotificationDetails& details) {
if (type == chrome::NOTIFICATION_APP_TERMINATING) {
CancelAll();
} else {
NOTREACHED();
}
}
|
