//
// Copyright (C) 2011 The Android Open Source Project
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//      http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
//

#include "update_engine/chrome_browser_proxy_resolver.h"

#include <utility>

#include <base/bind.h>
#include <base/memory/ptr_util.h>
#include <base/strings/string_util.h>
#include <brillo/http/http_proxy.h>

#include "update_engine/dbus_connection.h"

namespace chromeos_update_engine {

ChromeBrowserProxyResolver::ChromeBrowserProxyResolver()
    : next_request_id_(kProxyRequestIdNull + 1),
      weak_ptr_factory_(this) {}

ChromeBrowserProxyResolver::~ChromeBrowserProxyResolver() = default;

ProxyRequestId ChromeBrowserProxyResolver::GetProxiesForUrl(
    const std::string& url, const ProxiesResolvedFn& callback) {
  const ProxyRequestId id = next_request_id_++;
  brillo::http::GetChromeProxyServersAsync(
      DBusConnection::Get()->GetDBus(), url,
      base::Bind(&ChromeBrowserProxyResolver::OnGetChromeProxyServers,
                 weak_ptr_factory_.GetWeakPtr(), id));
  pending_callbacks_[id] = callback;
  return id;
}

bool ChromeBrowserProxyResolver::CancelProxyRequest(ProxyRequestId request) {
  return pending_callbacks_.erase(request) != 0;
}

void ChromeBrowserProxyResolver::OnGetChromeProxyServers(
    ProxyRequestId request_id, bool success,
    const std::vector<std::string>& proxies) {
  // If |success| is false, |proxies| will still hold the direct proxy option
  // which is what we do in our error case.
  auto it = pending_callbacks_.find(request_id);
  if (it == pending_callbacks_.end())
    return;

  ProxiesResolvedFn callback = it->second;
  pending_callbacks_.erase(it);
  callback.Run(std::deque<std::string>(proxies.begin(), proxies.end()));
}

}  // namespace chromeos_update_engine