// Copyright 2019 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_SIGNALING_REMOTING_LOG_TO_SERVER_H_
#define REMOTING_SIGNALING_REMOTING_LOG_TO_SERVER_H_

#include <memory>

#include "base/callback.h"
#include "base/macros.h"
#include "base/memory/scoped_refptr.h"
#include "base/sequence_checker.h"
#include "base/timer/timer.h"
#include "net/base/backoff_entry.h"
#include "remoting/signaling/log_to_server.h"

namespace network {
class SharedURLLoaderFactory;
}  // namespace network

namespace remoting {

namespace apis {
namespace v1 {
class CreateLogEntryRequest;
class CreateLogEntryResponse;
}  // namespace v1
}  // namespace apis

class OAuthTokenGetter;
class ProtobufHttpStatus;

// RemotingLogToServer sends log entries to to the remoting telemetry server.
class RemotingLogToServer : public LogToServer {
 public:
  RemotingLogToServer(
      ServerLogEntry::Mode mode,
      std::unique_ptr<OAuthTokenGetter> token_getter,
      scoped_refptr<network::SharedURLLoaderFactory> url_loader_factory);
  ~RemotingLogToServer() override;

  // LogToServer interface.
  void Log(const ServerLogEntry& entry) override;
  ServerLogEntry::Mode mode() const override;

 private:
  static constexpr int kMaxSendLogAttempts = 5;

  using CreateLogEntryResponseCallback = base::OnceCallback<void(
      const ProtobufHttpStatus&,
      std::unique_ptr<apis::v1::CreateLogEntryResponse>)>;
  using CreateLogEntryCallback =
      base::RepeatingCallback<void(const apis::v1::CreateLogEntryRequest&,
                                   CreateLogEntryResponseCallback callback)>;

  friend class RemotingLogToServerTest;

  void SendLogRequest(const apis::v1::CreateLogEntryRequest& request,
                      int attempts_left);
  void SendLogRequestWithBackoff(const apis::v1::CreateLogEntryRequest& request,
                                 int attempts_left);
  void OnSendLogRequestResult(
      const apis::v1::CreateLogEntryRequest& request,
      int attempts_left,
      const ProtobufHttpStatus& status,
      std::unique_ptr<apis::v1::CreateLogEntryResponse> response);

  ServerLogEntry::Mode mode_;
  std::unique_ptr<OAuthTokenGetter> token_getter_;
  net::BackoffEntry backoff_;
  base::OneShotTimer backoff_timer_;

  // Callback used to send the log entry to the server. Replaceable for
  // unittest.
  CreateLogEntryCallback create_log_entry_;

  SEQUENCE_CHECKER(sequence_checker_);

  DISALLOW_COPY_AND_ASSIGN(RemotingLogToServer);
};

}  // namespace remoting

#endif  // REMOTING_SIGNALING_REMOTING_LOG_TO_SERVER_H_