| Index: components/sync_driver/sync_stopped_reporter.cc
|
| diff --git a/components/sync_driver/sync_stopped_reporter.cc b/components/sync_driver/sync_stopped_reporter.cc
|
| deleted file mode 100644
|
| index 37b8fccb762ae8b6aa9ace9274e0da111d966a3f..0000000000000000000000000000000000000000
|
| --- a/components/sync_driver/sync_stopped_reporter.cc
|
| +++ /dev/null
|
| @@ -1,120 +0,0 @@
|
| -// Copyright 2015 The Chromium Authors. All rights reserved.
|
| -// Use of this source code is governed by a BSD-style license that can be
|
| -// found in the LICENSE file.
|
| -
|
| -#include "components/sync_driver/sync_stopped_reporter.h"
|
| -
|
| -#include "base/location.h"
|
| -#include "base/logging.h"
|
| -#include "base/single_thread_task_runner.h"
|
| -#include "base/strings/stringprintf.h"
|
| -#include "base/threading/thread_task_runner_handle.h"
|
| -#include "base/timer/timer.h"
|
| -#include "components/sync/protocol/sync.pb.h"
|
| -#include "net/base/load_flags.h"
|
| -#include "net/http/http_status_code.h"
|
| -#include "net/url_request/url_fetcher.h"
|
| -#include "net/url_request/url_request_context_getter.h"
|
| -
|
| -namespace {
|
| -
|
| -const char kEventEndpoint[] = "event";
|
| -
|
| -// The request is tiny, so even on poor connections 10 seconds should be
|
| -// plenty of time. Since sync is off when this request is started, we don't
|
| -// want anything sync-related hanging around for very long from a human
|
| -// perspective either. This seems like a good compromise.
|
| -const int kRequestTimeoutSeconds = 10;
|
| -
|
| -} // namespace
|
| -
|
| -namespace browser_sync {
|
| -
|
| -SyncStoppedReporter::SyncStoppedReporter(
|
| - const GURL& sync_service_url,
|
| - const std::string& user_agent,
|
| - const scoped_refptr<net::URLRequestContextGetter>& request_context,
|
| - const ResultCallback& callback)
|
| - : sync_event_url_(GetSyncEventURL(sync_service_url)),
|
| - user_agent_(user_agent),
|
| - request_context_(request_context),
|
| - callback_(callback) {
|
| - DCHECK(!sync_service_url.is_empty());
|
| - DCHECK(!user_agent_.empty());
|
| - DCHECK(request_context);
|
| -}
|
| -
|
| -SyncStoppedReporter::~SyncStoppedReporter() {}
|
| -
|
| -void SyncStoppedReporter::ReportSyncStopped(const std::string& access_token,
|
| - const std::string& cache_guid,
|
| - const std::string& birthday) {
|
| - DCHECK(!access_token.empty());
|
| - DCHECK(!cache_guid.empty());
|
| - DCHECK(!birthday.empty());
|
| -
|
| - // Make the request proto with the GUID identifying this client.
|
| - sync_pb::EventRequest event_request;
|
| - sync_pb::SyncDisabledEvent* sync_disabled_event =
|
| - event_request.mutable_sync_disabled();
|
| - sync_disabled_event->set_cache_guid(cache_guid);
|
| - sync_disabled_event->set_store_birthday(birthday);
|
| -
|
| - std::string msg;
|
| - event_request.SerializeToString(&msg);
|
| -
|
| - fetcher_ =
|
| - net::URLFetcher::Create(sync_event_url_, net::URLFetcher::POST, this);
|
| - fetcher_->AddExtraRequestHeader(base::StringPrintf(
|
| - "%s: Bearer %s", net::HttpRequestHeaders::kAuthorization,
|
| - access_token.c_str()));
|
| - fetcher_->AddExtraRequestHeader(base::StringPrintf(
|
| - "%s: %s", net::HttpRequestHeaders::kUserAgent, user_agent_.c_str()));
|
| - fetcher_->SetRequestContext(request_context_.get());
|
| - fetcher_->SetUploadData("application/octet-stream", msg);
|
| - fetcher_->SetLoadFlags(net::LOAD_BYPASS_CACHE |
|
| - net::LOAD_DISABLE_CACHE |
|
| - net::LOAD_DO_NOT_SAVE_COOKIES |
|
| - net::LOAD_DO_NOT_SEND_COOKIES);
|
| - fetcher_->Start();
|
| - timer_.Start(FROM_HERE, base::TimeDelta::FromSeconds(kRequestTimeoutSeconds),
|
| - this, &SyncStoppedReporter::OnTimeout);
|
| -}
|
| -
|
| -void SyncStoppedReporter::OnURLFetchComplete(const net::URLFetcher* source) {
|
| - Result result = source->GetResponseCode() == net::HTTP_OK
|
| - ? RESULT_SUCCESS : RESULT_ERROR;
|
| - fetcher_.reset();
|
| - timer_.Stop();
|
| - if (!callback_.is_null()) {
|
| - base::ThreadTaskRunnerHandle::Get()->PostTask(
|
| - FROM_HERE, base::Bind(callback_, result));
|
| - }
|
| -}
|
| -
|
| -void SyncStoppedReporter::OnTimeout() {
|
| - fetcher_.reset();
|
| - if (!callback_.is_null()) {
|
| - base::ThreadTaskRunnerHandle::Get()->PostTask(
|
| - FROM_HERE, base::Bind(callback_, RESULT_TIMEOUT));
|
| - }
|
| -}
|
| -
|
| -// Static.
|
| -GURL SyncStoppedReporter::GetSyncEventURL(const GURL& sync_service_url) {
|
| - std::string path = sync_service_url.path();
|
| - if (path.empty() || *path.rbegin() != '/') {
|
| - path += '/';
|
| - }
|
| - path += kEventEndpoint;
|
| - GURL::Replacements replacements;
|
| - replacements.SetPathStr(path);
|
| - return sync_service_url.ReplaceComponents(replacements);
|
| -}
|
| -
|
| -void SyncStoppedReporter::SetTimerTaskRunnerForTest(
|
| - const scoped_refptr<base::SingleThreadTaskRunner>& task_runner) {
|
| - timer_.SetTaskRunner(task_runner);
|
| -}
|
| -
|
| -} // namespace browser_sync
|
|
|