#include "components/policy/core/common/cloud/realtime_reporting_job_configuration.h"
#include <optional>
#include <utility>
#include "base/json/json_reader.h"
#include "components/enterprise/common/strings.h"
#include "components/policy/core/common/cloud/cloud_policy_client.h"
#include "services/network/public/cpp/shared_url_loader_factory.h"
namespace policy {
const char RealtimeReportingJobConfiguration::kContextKey[] = …;
const char RealtimeReportingJobConfiguration::kEventListKey[] = …;
const char RealtimeReportingJobConfiguration::kEventIdKey[] = …;
const char RealtimeReportingJobConfiguration::kUploadedEventsKey[] = …;
const char RealtimeReportingJobConfiguration::kFailedUploadsKey[] = …;
const char RealtimeReportingJobConfiguration::kPermanentFailedUploadsKey[] = …;
base::Value::Dict RealtimeReportingJobConfiguration::BuildReport(
base::Value::List events,
base::Value::Dict context) { … }
RealtimeReportingJobConfiguration::RealtimeReportingJobConfiguration(
CloudPolicyClient* client,
const std::string& server_url,
bool include_device_info,
UploadCompleteCallback callback)
: … { … }
RealtimeReportingJobConfiguration::~RealtimeReportingJobConfiguration() =
default;
bool RealtimeReportingJobConfiguration::AddReport(base::Value::Dict report) { … }
void RealtimeReportingJobConfiguration::InitializePayloadInternal(
CloudPolicyClient* client,
bool include_device_info) { … }
DeviceManagementService::Job::RetryMethod
RealtimeReportingJobConfiguration::ShouldRetryInternal(
int response_code,
const std::string& response_body) { … }
void RealtimeReportingJobConfiguration::OnBeforeRetryInternal(
int response_code,
const std::string& response_body) { … }
bool RealtimeReportingJobConfiguration::ShouldRecordUma() const { … }
std::string RealtimeReportingJobConfiguration::GetUmaString() const { … }
std::set<std::string> RealtimeReportingJobConfiguration::GetFailedUploadIds(
const std::string& response_body) const { … }
}