#ifndef GOOGLE_APIS_GCM_ENGINE_UNREGISTRATION_REQUEST_H_
#define GOOGLE_APIS_GCM_ENGINE_UNREGISTRATION_REQUEST_H_
#include <stdint.h>
#include <memory>
#include <optional>
#include <string>
#include "base/functional/callback.h"
#include "base/memory/raw_ptr.h"
#include "base/memory/scoped_refptr.h"
#include "base/memory/weak_ptr.h"
#include "base/task/sequenced_task_runner.h"
#include "google_apis/gcm/base/gcm_export.h"
#include "net/base/backoff_entry.h"
#include "url/gurl.h"
namespace net {
class HttpRequestHeaders;
}
namespace network {
class SharedURLLoaderFactory;
class SimpleURLLoader;
}
namespace gcm {
class GCMStatsRecorder;
class GCM_EXPORT UnregistrationRequest {
public:
enum Status {
SUCCESS,
URL_FETCHING_FAILED,
NO_RESPONSE_BODY,
RESPONSE_PARSING_FAILED,
INCORRECT_APP_ID,
INVALID_PARAMETERS,
SERVICE_UNAVAILABLE,
INTERNAL_SERVER_ERROR,
HTTP_NOT_OK,
UNKNOWN_ERROR,
REACHED_MAX_RETRIES,
DEVICE_REGISTRATION_ERROR,
UNREGISTRATION_STATUS_COUNT,
};
using UnregistrationCallback = base::OnceCallback<void(Status success)>;
struct GCM_EXPORT RequestInfo {
RequestInfo(uint64_t android_id,
uint64_t security_token,
const std::string& category,
const std::string& subtype);
~RequestInfo();
uint64_t android_id;
uint64_t security_token;
const std::string& app_id() { return subtype.empty() ? category : subtype; }
std::string category;
std::string subtype;
};
class GCM_EXPORT CustomRequestHandler {
public:
CustomRequestHandler();
virtual ~CustomRequestHandler();
virtual void BuildRequestBody(std::string* body) = 0;
virtual Status ParseResponse(const std::string& response) = 0;
};
UnregistrationRequest(
const GURL& registration_url,
const RequestInfo& request_info,
std::unique_ptr<CustomRequestHandler> custom_request_handler,
const net::BackoffEntry::Policy& backoff_policy,
UnregistrationCallback callback,
int max_retry_count,
scoped_refptr<network::SharedURLLoaderFactory> url_loader_factory,
scoped_refptr<base::SequencedTaskRunner> io_task_runner,
GCMStatsRecorder* recorder,
const std::string& source_to_record);
UnregistrationRequest(const UnregistrationRequest&) = delete;
UnregistrationRequest& operator=(const UnregistrationRequest&) = delete;
~UnregistrationRequest();
void Start();
private:
void OnURLLoadComplete(const network::SimpleURLLoader* source,
std::optional<std::string> body);
void BuildRequestHeaders(net::HttpRequestHeaders* headers);
void BuildRequestBody(std::string* body);
Status ParseResponse(const network::SimpleURLLoader* source,
std::optional<std::string> body);
void RetryWithBackoff();
UnregistrationCallback callback_;
RequestInfo request_info_;
std::unique_ptr<CustomRequestHandler> custom_request_handler_;
GURL registration_url_;
net::BackoffEntry backoff_entry_;
scoped_refptr<network::SharedURLLoaderFactory> url_loader_factory_;
std::unique_ptr<network::SimpleURLLoader> url_loader_;
int retries_left_;
const scoped_refptr<base::SequencedTaskRunner> io_task_runner_;
raw_ptr<GCMStatsRecorder> recorder_;
std::string source_to_record_;
base::WeakPtrFactory<UnregistrationRequest> weak_ptr_factory_{this};
};
}
#endif