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
|
// Copyright 2025 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#ifndef CHROME_BROWSER_ENTERPRISE_CONNECTORS_REPORTING_TELOMERE_REPORTING_CONTEXT_H_
#define CHROME_BROWSER_ENTERPRISE_CONNECTORS_REPORTING_TELOMERE_REPORTING_CONTEXT_H_
#include "base/memory/raw_ptr.h"
#include "base/memory/singleton.h"
#include "base/timer/timer.h"
#include "chrome/browser/enterprise/connectors/reporting/telomere_event_router.h"
#include "components/enterprise/browser/controller/chrome_browser_cloud_management_controller.h"
namespace enterprise_connectors {
class RealtimeReportingClient;
// TODO(crbug.com/407535337): Refactor to share code with CrashReportingContext.
class TelomereReportingContext
: public policy::ChromeBrowserCloudManagementController::Observer {
public:
friend struct base::DefaultSingletonTraits<TelomereReportingContext>;
TelomereReportingContext(const TelomereReportingContext&) = delete;
TelomereReportingContext(TelomereReportingContext&&) = delete;
TelomereReportingContext operator=(const TelomereReportingContext&) = delete;
TelomereReportingContext operator=(TelomereReportingContext&&) = delete;
~TelomereReportingContext() override;
static TelomereReportingContext* GetInstance();
void AddProfile(TelomereEventRouter* router, Profile* profile);
RealtimeReportingClient* GetReportingClient() const;
bool HasActiveProfile() const;
void RemoveProfile(TelomereEventRouter* router);
// policy::Chromepolicy::ChromeBrowserCloudManagementController::Observer
void OnBrowserUnenrolled(bool succeeded) override;
void OnCloudReportingLaunched(
enterprise_reporting::ReportScheduler* report_scheduler) override;
void OnShutdown() override;
private:
TelomereReportingContext();
base::RepeatingTimer repeating_telomere_log_;
std::unordered_map<TelomereEventRouter*, raw_ptr<Profile, CtnExperimental>>
active_profiles_;
};
// Utility function to list all the log dumps updated after
// `latest_creation_time` and return them as a <file contents, timestamp> pair.
std::vector<std::pair<std::string, time_t>> GetLogsFromPath(
time_t latest_creation_time,
base::FilePath sysmon_logs_path);
// Update the local_state pref with the latest telomere upload timestamp.
// Included in header for testing.
void SetLatestTelomereReportTime(PrefService* local_state, time_t timestamp);
// Get the current value of the latest telomere upload timestamp. Included in
// header for testing.
time_t GetLatestTelomereReportTime(PrefService* local_state);
// Upload a telomere event to the reporting server if available and update
// latest telomere upload timestamp if one or more such events are uploaded.
// Included in header for testing.
void UploadToReportingServer(
base::WeakPtr<RealtimeReportingClient> reporting_client,
PrefService* local_state,
std::vector<std::pair<std::string, time_t>> reports);
// Get the time interval with which to query the filesystem location containing
// telomere dumps. Included in header for testing.
base::TimeDelta GetTelomerePollingInterval();
} // namespace enterprise_connectors
#endif // CHROME_BROWSER_ENTERPRISE_CONNECTORS_REPORTING_TELOMERE_REPORTING_CONTEXT_H_
|
