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
|
// Copyright 2020 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#include "chromeos/ash/components/phonehub/notification_manager.h"
#include <sstream>
#include "chromeos/ash/components/multidevice/logging/logging.h"
namespace ash::phonehub {
namespace {
std::string GetIdStream(const base::flat_set<int64_t>& notification_ids) {
std::ostringstream output(std::ostringstream::ate);
for (const auto& id : notification_ids) {
output << id << " ";
}
return output.str();
}
} // namespace
NotificationManager::NotificationManager() = default;
NotificationManager::~NotificationManager() = default;
void NotificationManager::AddObserver(Observer* observer) {
observer_list_.AddObserver(observer);
}
void NotificationManager::RemoveObserver(Observer* observer) {
observer_list_.RemoveObserver(observer);
}
void NotificationManager::NotifyNotificationsAdded(
const base::flat_set<int64_t>& notification_ids) {
PA_LOG(INFO) << "Added the following notification ids: "
<< GetIdStream(notification_ids);
for (auto& observer : observer_list_)
observer.OnNotificationsAdded(notification_ids);
}
void NotificationManager::NotifyNotificationsUpdated(
const base::flat_set<int64_t>& notification_ids) {
PA_LOG(INFO) << "Updated the following notification id: "
<< GetIdStream(notification_ids);
for (auto& observer : observer_list_)
observer.OnNotificationsUpdated(notification_ids);
}
void NotificationManager::NotifyNotificationsRemoved(
const base::flat_set<int64_t>& notification_ids) {
PA_LOG(INFO) << "Removed the following notification id: "
<< GetIdStream(notification_ids);
for (auto& observer : observer_list_)
observer.OnNotificationsRemoved(notification_ids);
}
void NotificationManager::SetNotificationsInternal(
const base::flat_set<Notification>& notifications) {
base::flat_set<int64_t> added_ids;
base::flat_set<int64_t> updated_ids;
for (const Notification& notification : notifications) {
int64_t id = notification.id();
auto it = id_to_notification_map_.find(id);
if (it == id_to_notification_map_.end()) {
id_to_notification_map_.emplace(id, notification);
added_ids.emplace(id);
continue;
}
it->second = notification;
updated_ids.emplace(id);
}
if (!added_ids.empty())
NotifyNotificationsAdded(added_ids);
if (!updated_ids.empty())
NotifyNotificationsUpdated(updated_ids);
}
void NotificationManager::RemoveNotificationsInternal(
const base::flat_set<int64_t>& notification_ids) {
if (notification_ids.empty())
return;
for (int64_t id : notification_ids) {
auto it = id_to_notification_map_.find(id);
if (it == id_to_notification_map_.end())
continue;
id_to_notification_map_.erase(it);
}
NotifyNotificationsRemoved(notification_ids);
}
void NotificationManager::ClearNotificationsInternal() {
base::flat_set<int64_t> removed_ids;
for (const auto& pair : id_to_notification_map_) {
removed_ids.emplace(pair.first);
}
if (!removed_ids.empty()) {
id_to_notification_map_.clear();
NotifyNotificationsRemoved(removed_ids);
}
}
const Notification* NotificationManager::GetNotification(
int64_t notification_id) const {
auto it = id_to_notification_map_.find(notification_id);
if (it == id_to_notification_map_.end())
return nullptr;
return &it->second;
}
} // namespace ash::phonehub
|
