File: download_bubble_accessible_alerts_map.cc

package info (click to toggle)
chromium 138.0.7204.157-1
  • links: PTS, VCS
  • area: main
  • in suites: trixie
  • size: 6,071,864 kB
  • sloc: cpp: 34,936,859; ansic: 7,176,967; javascript: 4,110,704; python: 1,419,953; asm: 946,768; xml: 739,967; pascal: 187,324; sh: 89,623; perl: 88,663; objc: 79,944; sql: 50,304; cs: 41,786; fortran: 24,137; makefile: 21,806; php: 13,980; tcl: 13,166; yacc: 8,925; ruby: 7,485; awk: 3,720; lisp: 3,096; lex: 1,327; ada: 727; jsp: 228; sed: 36
file content (128 lines) | stat: -rw-r--r-- 4,941 bytes parent folder | download | duplicates (4)
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
// Copyright 2024 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.

#include "chrome/browser/download/bubble/download_bubble_accessible_alerts_map.h"

#include <map>
#include <string>
#include <vector>

namespace {
// Only alert about a given download if it has been at least 3 minutes since
// the last alert for that download.
constexpr base::TimeDelta kAlertInterval = base::Minutes(3);
// Discard an alert if it has been more than 1 minute since it was added, even
// if it has never been announced. After this time interval, we consider it
// too stale to announce.
constexpr base::TimeDelta kAlertMaxStaleness = base::Minutes(1);
// Only track last-alerted times for 6 minutes. If no one attempts to
// re-announce an alert for a download within 6 minutes, we can garbage collect
// the last-alerted time and it will be as if that download was never announced.
constexpr base::TimeDelta kTrackAlertedTimesThreshold = base::Minutes(6);

using offline_items_collection::ContentId;
}  // namespace

DownloadBubbleAccessibleAlertsMap::Alert::Alert(Urgency urgency,
                                                std::u16string_view alert_text)
    : urgency(urgency),
      added_time(base::Time::Now()),
      text(std::u16string(alert_text)) {}

DownloadBubbleAccessibleAlertsMap::Alert::Alert(const Alert& other) = default;

DownloadBubbleAccessibleAlertsMap::Alert&
DownloadBubbleAccessibleAlertsMap::Alert::operator=(const Alert& other) =
    default;

DownloadBubbleAccessibleAlertsMap::Alert::Alert(Alert&& other) = default;

DownloadBubbleAccessibleAlertsMap::Alert&
DownloadBubbleAccessibleAlertsMap::Alert::operator=(Alert&& other) = default;

bool DownloadBubbleAccessibleAlertsMap::Alert::ShouldBeReplacedBy(
    const DownloadBubbleAccessibleAlertsMap::Alert& newer) const {
  return newer.added_time >= added_time && newer.urgency <= urgency;
}

bool DownloadBubbleAccessibleAlertsMap::Alert::IsStale() const {
  return base::Time::Now() - added_time > kAlertMaxStaleness;
}

DownloadBubbleAccessibleAlertsMap::DownloadBubbleAccessibleAlertsMap() =
    default;

DownloadBubbleAccessibleAlertsMap::~DownloadBubbleAccessibleAlertsMap() =
    default;

bool DownloadBubbleAccessibleAlertsMap::MaybeAddAccessibleAlert(
    const offline_items_collection::ContentId& content_id,
    Alert alert) {
  if (alert.text.empty()) {
    return false;
  }

  if (auto it = unannounced_alerts_.find(content_id);
      it != unannounced_alerts_.end()) {
    if (it->second.ShouldBeReplacedBy(alert) || it->second.IsStale()) {
      it->second = std::move(alert);
      return true;
    }
    return false;
  }
  return unannounced_alerts_.emplace(content_id, std::move(alert)).second;
}

std::vector<std::u16string>
DownloadBubbleAccessibleAlertsMap::TakeAlertsForAnnouncement() {
  std::vector<std::u16string> to_announce;
  base::Time now = base::Time::Now();

  // Iterate over the two maps together.
  for (struct {
         AlertsMap::iterator alerts_it;
         LastAlertedTimesMap::iterator times_it;
       } its = {unannounced_alerts_.begin(), last_alerted_times_.begin()};
       its.alerts_it != unannounced_alerts_.end();) {
    const ContentId& alert_content_id = its.alerts_it->first;

    // Move the iterator to the position of or just past the
    // last-alerted-time for this content_id.
    while (its.times_it != last_alerted_times_.end() &&
           its.times_it->first < alert_content_id) {
      ++its.times_it;
    }
    bool has_previous_announcement =
        its.times_it != last_alerted_times_.end() &&
        its.times_it->first == alert_content_id;

    // If the alert is stale, don't announce it. If the alert is kAlertSoon,
    // definitely announce it. If the alert is kAlertWhenAppropriate, only
    // announce it if we have not previously announced for this download, or if
    // the last announcement for this download was long enough in the past.
    if (!its.alerts_it->second.IsStale() &&
        (its.alerts_it->second.urgency == Alert::Urgency::kAlertSoon ||
         !has_previous_announcement ||
         now - its.times_it->second > kAlertInterval)) {
      to_announce.emplace_back(std::move(its.alerts_it->second.text));
      its.times_it = last_alerted_times_.insert_or_assign(
          its.times_it, alert_content_id, now);
      its.alerts_it = unannounced_alerts_.erase(its.alerts_it);
    } else if (its.alerts_it->second.IsStale()) {
      its.alerts_it = unannounced_alerts_.erase(its.alerts_it);
    } else {
      ++its.alerts_it;
    }
  }
  return to_announce;
}

void DownloadBubbleAccessibleAlertsMap::GarbageCollect() {
  std::erase_if(unannounced_alerts_,
                [](const auto& kv) { return kv.second.IsStale(); });
  base::Time now = base::Time::Now();
  std::erase_if(last_alerted_times_, [now](const auto& kv) {
    return now - kv.second > kTrackAlertedTimesThreshold;
  });
}