blob: b8ecffe74d316f87c808333e91aeb277b68b9998 [file] [log] [blame]
// Copyright 2018 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 <memory>
#include <string>
#include <utility>
#include <vector>
#include "base/callback.h"
#include "base/memory/weak_ptr.h"
#include "url/gurl.h"
namespace base {
class Value;
} // namespace base
namespace net {
class HttpRequestHeaders;
namespace network {
class SimpleURLLoader;
class SharedURLLoaderFactory;
} // namespace network
namespace journey {
// This class represents a request of journey info. It encapsulates the
// request-response lifecycle. It is also responsible for building and
// serializing the request body protos.
class JourneyInfoJsonRequest {
// Callbacks for JSON parsing to allow injecting platform-dependent code.
using SuccessCallback =
base::RepeatingCallback<void(std::unique_ptr<base::Value> result)>;
using ErrorCallback = base::RepeatingCallback<void(const std::string& error)>;
using ParseJSONCallback =
base::RepeatingCallback<void(const std::string& raw_json_string,
const SuccessCallback& success_callback,
const ErrorCallback& error_callback)>;
using CompletedCallback =
base::OnceCallback<void(std::unique_ptr<base::Value> result,
const std::string& error_detail)>;
// This class is used to build authenticated and non-authenticated
// JourneyInfoJsonRequest.
class Builder {
// This method is used to builds a Request object that contains all
// data to fetch new snippets.
std::unique_ptr<JourneyInfoJsonRequest> Build() const;
Builder& SetAuthentication(const std::string& auth_header);
Builder& SetParseJsonCallback(ParseJSONCallback callback);
Builder& SetTimestamps(const std::vector<int64_t>& timestamps);
std::unique_ptr<network::SimpleURLLoader> BuildSimpleURLLoader() const;
net::HttpRequestHeaders BuildSimpleURLLoaderHeaders() const;
// The url for which we're fetching journey info.
GURL url_;
std::string auth_header_;
std::string body_;
ParseJSONCallback parse_json_callback_;
explicit JourneyInfoJsonRequest(const ParseJSONCallback& callback);
// This method is used to start fetching journey info using |loader_factory|
// to create a URLLoader, and call |callback| when finished.
void Start(
CompletedCallback callback,
const scoped_refptr<network::SharedURLLoaderFactory>& loader_factory);
// Get the last response as a string
const std::string& GetResponseString() const;
void OnSimpleURLLoaderComplete(std::unique_ptr<std::string> response_body);
void OnJsonParsed(std::unique_ptr<base::Value> result);
void OnJsonError(const std::string& error);
// This callback is called to parse a json string. It contains callbacks for
// error and success cases.
ParseJSONCallback parse_json_callback_;
// The loader for downloading the snippets. Only non-null if a fetch is
// currently ongoing.
std::unique_ptr<network::SimpleURLLoader> simple_url_loader_;
std::string last_response_string_;
// The callback to call when journey info are available.
CompletedCallback completed_callback_;
base::WeakPtrFactory<JourneyInfoJsonRequest> weak_ptr_factory_;
} // namespace journey