// 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.

#ifndef REMOTING_HOST_GCD_REST_CLIENT_H_
#define REMOTING_HOST_GCD_REST_CLIENT_H_

#include <memory>
#include <queue>

#include "base/callback.h"
#include "base/macros.h"
#include "base/time/clock.h"
#include "net/url_request/url_fetcher_delegate.h"
#include "remoting/base/oauth_token_getter.h"
#include "remoting/base/url_request_context_getter.h"

namespace base {
class DictionaryValue;
}  // namespace base

namespace remoting {

// A client for calls to the GCD REST API.
class GcdRestClient : public net::URLFetcherDelegate {
 public:
  // Result of a GCD call.
  enum Result {
    SUCCESS,
    NETWORK_ERROR,
    NO_SUCH_HOST,
    OTHER_ERROR,
  };

  typedef base::Callback<void(Result result)> ResultCallback;

  // Note: |token_getter| must outlive this object.
  GcdRestClient(const std::string& gcd_base_url,
                const std::string& gcd_device_id,
                const scoped_refptr<net::URLRequestContextGetter>&
                    url_request_context_getter,
                OAuthTokenGetter* token_getter);

  ~GcdRestClient() override;

  // Tests whether is object is currently running a request.  Only one
  // request at a time may be pending.
  bool HasPendingRequest() { return !!url_fetcher_; }

  // Sends a 'patchState' request to the GCD API.  Constructs and
  // sends an appropriate JSON message M where |patch_details| becomes
  // the value of M.patches[0].patch.
  void PatchState(std::unique_ptr<base::DictionaryValue> patch_details,
                  const GcdRestClient::ResultCallback& callback);

  void SetClockForTest(std::unique_ptr<base::Clock> clock);

 private:
  void OnTokenReceived(OAuthTokenGetter::Status status,
                       const std::string& user_email,
                       const std::string& access_token);
  void FinishCurrentRequest(Result result);

  // URLFetcherDelegate interface.
  void OnURLFetchComplete(const net::URLFetcher* source) override;

  std::string gcd_base_url_;
  std::string gcd_device_id_;
  scoped_refptr<net::URLRequestContextGetter> url_request_context_getter_;
  OAuthTokenGetter* token_getter_;
  std::unique_ptr<base::Clock> clock_;
  std::unique_ptr<net::URLFetcher> url_fetcher_;
  ResultCallback callback_;

  DISALLOW_COPY_AND_ASSIGN(GcdRestClient);
};

}  // namespace remoting

#endif  // REMOTING_HOST_GCD_REST_CLIENT_H_