// Copyright 2023 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.

#include "chrome/updater/test/request_matcher.h"

#include <algorithm>
#include <array>
#include <optional>
#include <string>
#include <string_view>
#include <utility>
#include <vector>

#include "base/containers/flat_map.h"
#include "base/json/json_reader.h"
#include "base/logging.h"
#include "base/strings/strcat.h"
#include "base/strings/string_number_conversions.h"
#include "base/strings/string_util.h"
#include "base/test/bind.h"
#include "base/values.h"
#include "base/version.h"
#include "chrome/updater/branded_constants.h"
#include "chrome/updater/test/http_request.h"
#include "chrome/updater/test/unit_test_util.h"
#include "chrome/updater/update_service.h"
#include "chrome/updater/updater_scope.h"
#include "chrome/updater/util/util.h"
#include "testing/gtest/include/gtest/gtest.h"
#include "third_party/abseil-cpp/absl/strings/str_format.h"
#include "third_party/re2/src/re2/re2.h"
#include "url/gurl.h"

namespace updater::test::request {

FormExpectations::FormExpectations(const std::string& name,
                                   std::vector<std::string> regexes)
    : name(name), regex_sequence(std::move(regexes)) {}

FormExpectations::FormExpectations(const FormExpectations&) = default;
FormExpectations& FormExpectations::operator=(const FormExpectations& other) =
    default;
FormExpectations::~FormExpectations() = default;

Matcher GetPathMatcher(const std::string& expected_path_regex) {
  return base::BindLambdaForTesting(
      [expected_path_regex](const HttpRequest& request) {
        if (!re2::RE2::FullMatch(request.relative_url, expected_path_regex)) {
          ADD_FAILURE() << "Request path [" << request.relative_url
                        << "], did not match expected path regex ["
                        << expected_path_regex << "], request content: "
                        << GetPrintableContent(request);
          return false;
        }
        return true;
      });
}

Matcher GetHeaderMatcher(
    const base::flat_map<std::string, std::string> expected_headers) {
  return base::BindLambdaForTesting([expected_headers](
                                        const HttpRequest& request) {
    for (const auto& [header_name, expected_header_regex] : expected_headers) {
      re2::RE2::Options opt;
      opt.set_case_sensitive(false);
      HttpRequest::HeaderMap::const_iterator it =
          request.headers.find(header_name);
      if (it == request.headers.end()) {
        ADD_FAILURE() << "Request header '" << header_name
                      << "' not found, expected regex "
                      << expected_header_regex;
        return false;
      } else if (!re2::RE2::FullMatch(it->second,
                                      re2::RE2(expected_header_regex, opt))) {
        ADD_FAILURE() << "Request header [" << it->first << " = '" << it->second
                      << "], did not match expected regex ["
                      << expected_header_regex << "]";
        return false;
      }
    }
    return true;
  });
}

Matcher GetUpdaterUserAgentMatcher(const base::Version& updater_version) {
  return GetHeaderMatcher(
      {{"User-Agent",
        base::StrCat({GetUpdaterUserAgent(updater_version), "|",
                      PRODUCT_FULLNAME_STRING, "_test/",
                      base::NumberToString(updater_version.components()[2]),
                      ".*"})}});
}

Matcher GetTargetURLMatcher(GURL target_url) {
  return base::BindLambdaForTesting([target_url](const HttpRequest& request) {
    const std::string post_target = base::StrCat({"POST ", target_url.spec()});
    if (!base::StartsWith(request.all_headers, post_target,
                          base::CompareCase::INSENSITIVE_ASCII)) {
      ADD_FAILURE() << "Request all_headers [" << request.all_headers
                    << "] does not start with the expected [" << post_target
                    << "]";
      return false;
    }
    return GetHeaderMatcher({{"Host", target_url.GetHost()}}).Run(request);
  });
}

Matcher GetContentMatcher(
    const std::vector<std::string>& expected_content_regex_sequence) {
  return base::BindLambdaForTesting(
      [expected_content_regex_sequence](const HttpRequest& request) {
        std::string_view input(request.decoded_content);
        for (const std::string& regex : expected_content_regex_sequence) {
          re2::RE2::Options opt;
          opt.set_case_sensitive(false);
          if (re2::RE2::FindAndConsume(&input, re2::RE2(regex, opt))) {
            VLOG(3) << "Found regex: [" << regex << "]";
          } else {
            ADD_FAILURE() << "Request content match failed. Expected regex: ["
                          << regex << "] not found in content: ["
                          << GetPrintableContent(request) << "]";
            return false;
          }
        }
        return true;
      });
}

Matcher GetScopeMatcher(UpdaterScope scope) {
  return base::BindLambdaForTesting([scope](const HttpRequest& request) {
    const bool is_match = [&scope, &request] {
      const std::optional<base::DictValue> doc = base::JSONReader::ReadDict(
          request.decoded_content, base::JSON_PARSE_CHROMIUM_EXTENSIONS);
      if (!doc) {
        return false;
      }
      const base::DictValue* object_request = doc->FindDict("request");
      if (!object_request) {
        return false;
      }
      std::optional<bool> ismachine = object_request->FindBool("ismachine");
      if (!ismachine.has_value()) {
        return false;
      }
      switch (scope) {
        case UpdaterScope::kSystem:
          return *ismachine;
        case UpdaterScope::kUser:
          return !*ismachine;
      }
    }();
    if (!is_match) {
      ADD_FAILURE() << "Request does not match scope [" << scope
                    << "]: " << GetPrintableContent(request);
    }
    return is_match;
  });
}

Matcher GetAppPriorityMatcher(const std::string& app_id,
                              UpdateService::Priority priority) {
  return base::BindLambdaForTesting([app_id,
                                     priority](const HttpRequest& request) {
    const bool is_match = [&app_id, priority, &request] {
      const std::optional<base::DictValue> doc = base::JSONReader::ReadDict(
          request.decoded_content, base::JSON_PARSE_CHROMIUM_EXTENSIONS);
      if (!doc) {
        return false;
      }
      const base::ListValue* app_list =
          doc->FindListByDottedPath("request.apps");
      if (!app_list) {
        app_list = doc->FindListByDottedPath("request.app");  // V3 fallback.
        if (!app_list) {
          return false;
        }
      }
      for (const base::Value& app : *app_list) {
        if (const auto* dict = app.GetIfDict()) {
          if (const auto* appid = dict->FindString("appid"); *appid == app_id) {
            if (const auto* install_source =
                    dict->FindString("installsource")) {
              static constexpr auto kInstallSources =
                  std::array{"ondemand", "taggedmi", "policy"};
              return std::ranges::contains(kInstallSources, *install_source) ==
                     (priority == UpdateService::Priority::kForeground);
            }
          }
        }
      }
      return priority != UpdateService::Priority::kForeground;
    }();
    if (!is_match) {
      ADD_FAILURE() << "Request does not match app_id [" << app_id
                    << "], priority [" << priority
                    << "]: " << GetPrintableContent(request);
    }
    return is_match;
  });
}

Matcher GetUpdaterEnableUpdatesMatcher() {
  return base::BindLambdaForTesting([](const HttpRequest& request) {
    const bool update_disabled = [&request] {
      const std::optional<base::DictValue> doc = base::JSONReader::ReadDict(
          request.decoded_content, base::JSON_PARSE_CHROMIUM_EXTENSIONS);
      if (!doc) {
        return false;
      }
      const base::ListValue* app_list =
          doc->FindListByDottedPath("request.apps");
      if (!app_list) {
        return false;
      }
      for (const base::Value& app : *app_list) {
        if (const auto* dict = app.GetIfDict()) {
          if (const auto* appid = dict->FindString("appid");
              *appid == kUpdaterAppId) {
            if (const auto* update_check = dict->FindDict("updatecheck")) {
              return update_check->FindBool("updatedisabled").value_or(false);
            }
          }
        }
      }
      return false;
    }();
    if (update_disabled) {
      ADD_FAILURE() << R"(Update is wrongfully disabled for updater itself: )"
                    << GetPrintableContent(request);
    }
    return !update_disabled;
  });
}

Matcher GetMultipartContentMatcher(
    const std::vector<FormExpectations>& form_expections) {
  return base::BindLambdaForTesting([form_expections](
                                        const HttpRequest& request) {
    static constexpr char kMultifpartBoundaryPrefix[] =
        "multipart/form-data; boundary=";
    if (!request.headers.contains("Content-Type")) {
      ADD_FAILURE() << "Content-Type header not found, which is expected "
                    << "for multipart content.";
      return false;
    }

    const std::string content_type = request.headers.at("Content-Type");
    if (!content_type.starts_with(kMultifpartBoundaryPrefix)) {
      ADD_FAILURE() << "Content-Type value is not the expected "
                    << "[multipart/form-data].";
      return false;
    }

    const std::string form_data_boundary = content_type.substr(
        std::string_view(kMultifpartBoundaryPrefix).length());

    re2::RE2::Options opt;
    opt.set_case_sensitive(false);
    std::string_view input(request.decoded_content);

    for (const FormExpectations& form_expectation : form_expections) {
      if (re2::RE2::FindAndConsume(&input, form_data_boundary)) {
        VLOG(3) << "Advancing to next form in the multipart content.";
      } else {
        ADD_FAILURE() << "No boundary separator found between multipart forms.";
        return false;
      }

      const std::string& form_name = form_expectation.name;
      if (re2::RE2::FindAndConsume(
              &input,
              absl::StrFormat(R"(Content-Disposition: form-data; name="%s")",
                              form_name.c_str()))) {
        VLOG(3) << "Found form with name [" << form_name << "]";
      } else {
        ADD_FAILURE() << "Form [" << form_name << "] not found.";
        return false;
      }

      for (const std::string& regex : form_expectation.regex_sequence) {
        if (re2::RE2::FindAndConsume(&input, re2::RE2(regex, opt))) {
          VLOG(3) << "Found regex: [" << regex << "]";
        } else {
          ADD_FAILURE() << "Form [" << form_name << "] match failed. "
                        << "Expected regex: [" << regex << "] not found in "
                        << "content: [" << GetPrintableContent(request) << "]";
          return false;
        }
      }
    }

    if (!re2::RE2::FindAndConsume(&input, form_data_boundary)) {
      ADD_FAILURE() << "Multipart data should end with boundary separator.";
      return false;
    }

    return true;
  });
}

Matcher GetJSONContentMatcher(const base::DictValue& expected_target) {
  // Capture `expected_target` by value, since the reference might be local
  // to the test scope, but the matcher callback is used asynchronously.
  return base::BindLambdaForTesting(
      [target =
           base::Value(expected_target.Clone())](const HttpRequest& request) {
        std::optional<base::DictValue> doc = base::JSONReader::ReadDict(
            request.decoded_content, base::JSON_PARSE_CHROMIUM_EXTENSIONS);
        if (!doc) {
          ADD_FAILURE() << "Could not parse decoded content as a JSON dict: "
                        << GetPrintableContent(request);
          return false;
        }

        base::Value doc_value(std::move(*doc));
        if (!IsJSONSubset(target, doc_value,
                          [](const std::string& a, const std::string& b) {
                            return base::EqualsCaseInsensitiveASCII(a, b);
                          })) {
          ADD_FAILURE() << "Expected JSON subset: [" << target.DebugString()
                        << "] not found in (parsed) request content: ["
                        << doc_value.DebugString() << "]";
          return false;
        }

        return true;
      });
}

}  // namespace updater::test::request