// Copyright 2012 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/test/chromedriver/commands.h"

#include <stddef.h>

#include <memory>
#include <string>
#include <utility>
#include <vector>

#include "base/compiler_specific.h"
#include "base/files/file_path.h"
#include "base/functional/bind.h"
#include "base/functional/callback.h"
#include "base/location.h"
#include "base/run_loop.h"
#include "base/synchronization/lock.h"
#include "base/task/single_thread_task_runner.h"
#include "base/test/bind.h"
#include "base/test/task_environment.h"
#include "base/threading/thread.h"
#include "base/time/time.h"
#include "base/values.h"
#include "chrome/test/chromedriver/chrome/status.h"
#include "chrome/test/chromedriver/chrome/stub_chrome.h"
#include "chrome/test/chromedriver/chrome/stub_web_view.h"
#include "chrome/test/chromedriver/chrome/web_view.h"
#include "chrome/test/chromedriver/command_listener_proxy.h"
#include "chrome/test/chromedriver/element_commands.h"
#include "chrome/test/chromedriver/session.h"
#include "chrome/test/chromedriver/session_commands.h"
#include "chrome/test/chromedriver/window_commands.h"
#include "testing/gmock/include/gmock/gmock.h"
#include "testing/gtest/include/gtest/gtest.h"
#include "third_party/selenium-atoms/atoms.h"

using testing::ContainsRegex;
using testing::Eq;
using testing::HasSubstr;
using testing::Optional;
using testing::Pointee;

namespace {

template <int Code>
testing::AssertionResult StatusCodeIs(const Status& status) {
  if (status.code() == Code) {
    return testing::AssertionSuccess();
  } else {
    return testing::AssertionFailure() << status.message();
  }
}

testing::AssertionResult StatusOk(const Status& status) {
  return StatusCodeIs<kOk>(status);
}

void AssertGetStatusExtendedData(base::Value::Dict* dict) {
  ASSERT_TRUE(dict->FindByDottedPath("os.name"));
  ASSERT_TRUE(dict->FindByDottedPath("os.version"));
  ASSERT_TRUE(dict->FindByDottedPath("os.arch"));
  ASSERT_TRUE(dict->FindByDottedPath("build.version"));
}

void OnGetStatus(const Status& status,
                 std::unique_ptr<base::Value> value,
                 const std::string& session_id,
                 bool w3c_compliant) {
  ASSERT_EQ(kOk, status.code());
  base::Value::Dict* dict = value->GetIfDict();
  ASSERT_TRUE(dict);
  std::optional<bool> ready = dict->FindBool("ready");
  ASSERT_TRUE(ready.has_value() && ready.value());
  ASSERT_TRUE(dict->Find("message"));
  AssertGetStatusExtendedData(dict);
}

}  // namespace

TEST(CommandsTest, GetStatus) {
  base::Value::Dict params;
  ExecuteGetStatus(params, std::string(), base::BindRepeating(&OnGetStatus));
}

namespace {

void OnBidiSessionStatusNoSession(const Status& status,
                                  std::unique_ptr<base::Value> value,
                                  const std::string& session_id,
                                  bool w3c_compliant) {
  ASSERT_EQ(kOk, status.code());
  base::Value::Dict* dict = value->GetIfDict();
  ASSERT_TRUE(dict);
  ASSERT_THAT(dict->FindBool("ready"), Optional(Eq(true)));
  ASSERT_THAT(dict->FindString("message"),
              Pointee(HasSubstr("ready for new sessions.")));
  AssertGetStatusExtendedData(dict);
}

}  // namespace

TEST(CommandsTest, BidiSessionStatusNoSession) {
  base::Value::Dict params;
  ExecuteBidiSessionStatus(params, std::string(),
                           base::BindRepeating(&OnBidiSessionStatusNoSession));
}

namespace {

void OnBidiSessionStatusWithSession(const Status& status,
                                    std::unique_ptr<base::Value> value,
                                    const std::string& session_id,
                                    bool w3c_compliant) {
  ASSERT_EQ(kOk, status.code());
  base::Value::Dict* dict = value->GetIfDict();
  ASSERT_TRUE(dict);
  ASSERT_THAT(dict->FindBool("ready"), Optional(Eq(false)));
  ASSERT_THAT(dict->FindString("message"),
              Pointee(HasSubstr("already connected")));
  AssertGetStatusExtendedData(dict);
}

}  // namespace

TEST(CommandsTest, BidiSessionStatusWithSession) {
  base::Value::Dict params;
  ExecuteBidiSessionStatus(
      params, "some_session",
      base::BindRepeating(&OnBidiSessionStatusWithSession));
}

namespace {

void ExecuteStubGetSession(int* count,
                           const base::Value::Dict& params,
                           const std::string& session_id,
                           const CommandCallback& callback) {
  if (*count == 0) {
    EXPECT_STREQ("id", session_id.c_str());
  } else {
    EXPECT_STREQ("id2", session_id.c_str());
  }
  (*count)++;

  base::Value::Dict capabilities;
  capabilities.Set("capability1", "test1");
  capabilities.Set("capability2", "test2");

  callback.Run(Status(kOk),
               std::make_unique<base::Value>(std::move(capabilities)),
               session_id, false);
}

void OnGetSessions(const Status& status,
                   std::unique_ptr<base::Value> value,
                   const std::string& session_id,
                   bool w3c_compliant) {
  ASSERT_EQ(kOk, status.code());
  ASSERT_TRUE(value.get());
  const base::Value::List& sessions_list = value->GetList();
  ASSERT_EQ(static_cast<size_t>(2), sessions_list.size());

  const base::Value& session1 = sessions_list[0];
  const base::Value& session2 = sessions_list[1];
  ASSERT_TRUE(session1.is_dict());
  ASSERT_TRUE(session2.is_dict());

  ASSERT_EQ(static_cast<size_t>(2), session1.GetDict().size());
  ASSERT_EQ(static_cast<size_t>(2), session2.GetDict().size());

  const std::string* session1_id = session1.GetDict().FindString("id");
  const std::string* session2_id = session2.GetDict().FindString("id");
  const base::Value::Dict* session1_capabilities =
      session1.GetDict().FindDict("capabilities");
  const base::Value::Dict* session2_capabilities =
      session2.GetDict().FindDict("capabilities");

  ASSERT_TRUE(session1_id);
  ASSERT_TRUE(session2_id);
  ASSERT_TRUE(session1_capabilities);
  ASSERT_TRUE(session2_capabilities);

  ASSERT_EQ((size_t)2, session1_capabilities->size());
  ASSERT_EQ((size_t)2, session2_capabilities->size());
  ASSERT_EQ("id", *session1_id);
  ASSERT_EQ("id2", *session2_id);

  const std::string* session1_capability1 =
      session1_capabilities->FindString("capability1");
  const std::string* session1_capability2 =
      session1_capabilities->FindString("capability2");
  const std::string* session2_capability1 =
      session2_capabilities->FindString("capability1");
  const std::string* session2_capability2 =
      session2_capabilities->FindString("capability2");

  ASSERT_TRUE(session1_capability1);
  ASSERT_TRUE(session1_capability2);
  ASSERT_TRUE(session2_capability1);
  ASSERT_TRUE(session2_capability2);

  ASSERT_EQ("test1", *session1_capability1);
  ASSERT_EQ("test2", *session1_capability2);
  ASSERT_EQ("test1", *session2_capability1);
  ASSERT_EQ("test2", *session2_capability2);
}

}  // namespace

TEST(CommandsTest, GetSessions) {
  SessionThreadMap map;
  Session session("id");
  Session session2("id2");
  map[session.id] = std::make_unique<SessionThreadInfo>("1", true);
  map[session2.id] = std::make_unique<SessionThreadInfo>("2", true);

  int count = 0;

  Command cmd = base::BindRepeating(&ExecuteStubGetSession, &count);

  base::Value::Dict params;
  base::test::SingleThreadTaskEnvironment task_environment;

  ExecuteGetSessions(cmd, &map, params, std::string(),
                     base::BindRepeating(&OnGetSessions));
  ASSERT_EQ(2, count);
}

namespace {

void ExecuteStubQuit(int* count,
                     const base::Value::Dict& params,
                     const std::string& session_id,
                     const CommandCallback& callback) {
  if (*count == 0) {
    EXPECT_STREQ("id", session_id.c_str());
  } else {
    EXPECT_STREQ("id2", session_id.c_str());
  }
  (*count)++;
  callback.Run(Status(kOk), std::unique_ptr<base::Value>(), session_id, false);
}

void OnQuitAll(const Status& status,
               std::unique_ptr<base::Value> value,
               const std::string& session_id,
               bool w3c_compliant) {
  ASSERT_EQ(kOk, status.code());
  ASSERT_FALSE(value.get());
}

}  // namespace

TEST(CommandsTest, QuitAll) {
  SessionThreadMap map;
  Session session("id");
  Session session2("id2");
  map[session.id] = std::make_unique<SessionThreadInfo>("1", true);
  map[session2.id] = std::make_unique<SessionThreadInfo>("2", true);

  int count = 0;
  Command cmd = base::BindRepeating(&ExecuteStubQuit, &count);
  base::Value::Dict params;
  base::test::SingleThreadTaskEnvironment task_environment;
  ExecuteQuitAll(cmd, &map, params, std::string(),
                 base::BindRepeating(&OnQuitAll));
  ASSERT_EQ(2, count);
}

namespace {

Status ExecuteSimpleCommand(const std::string& expected_id,
                            base::Value::Dict* expected_params,
                            base::Value* value,
                            Session* session,
                            const base::Value::Dict& params,
                            std::unique_ptr<base::Value>* return_value) {
  EXPECT_EQ(expected_id, session->id);
  EXPECT_EQ(*expected_params, params);
  *return_value = base::Value::ToUniquePtrValue(value->Clone());
  session->quit = true;
  return Status(kOk);
}

void OnSimpleCommand(base::RunLoop* run_loop,
                     const std::string& expected_session_id,
                     base::Value* expected_value,
                     const Status& status,
                     std::unique_ptr<base::Value> value,
                     const std::string& session_id,
                     bool w3c_compliant) {
  ASSERT_EQ(kOk, status.code());
  ASSERT_EQ(*expected_value, *value);
  ASSERT_EQ(expected_session_id, session_id);
  run_loop->Quit();
}

}  // namespace

TEST(CommandsTest, ExecuteSessionCommand) {
  SessionThreadMap map;
  SessionConnectionMap session_connection_map;
  auto thread_info = std::make_unique<SessionThreadInfo>("1", true);
  base::Thread* thread = thread_info->thread();
  ASSERT_TRUE(thread->Start());
  std::string id("id");
  thread->task_runner()->PostTask(
      FROM_HERE,
      base::BindOnce(&internal::CreateSessionOnSessionThreadForTesting, id));
  map[id] = std::move(thread_info);

  base::Value::Dict params;
  params.Set("param", 5);
  base::Value expected_value(6);
  SessionCommand cmd =
      base::BindRepeating(&ExecuteSimpleCommand, id, &params, &expected_value);

  base::test::SingleThreadTaskEnvironment task_environment;
  base::RunLoop run_loop;
  ExecuteSessionCommand(
      &map, "cmd", cmd, true /*w3c_standard_command*/, false, params, id,
      base::BindRepeating(&OnSimpleCommand, &run_loop, id, &expected_value));
  run_loop.Run();
}

namespace {

Status ShouldNotBeCalled(Session* session,
                         const base::Value::Dict& params,
                         std::unique_ptr<base::Value>* value) {
  EXPECT_TRUE(false);
  return Status(kOk);
}

void OnNoSuchSession(const Status& status,
                     std::unique_ptr<base::Value> value,
                     const std::string& session_id,
                     bool w3c_compliant) {
  EXPECT_EQ(kInvalidSessionId, status.code());
  EXPECT_FALSE(value.get());
}

void OnNoSuchSessionIsOk(const Status& status,
                         std::unique_ptr<base::Value> value,
                         const std::string& session_id,
                         bool w3c_compliant) {
  EXPECT_EQ(kOk, status.code());
  EXPECT_FALSE(value.get());
}

}  // namespace

TEST(CommandsTest, ExecuteSessionCommandOnNoSuchSession) {
  SessionThreadMap map;
  SessionConnectionMap session_connection_map;
  base::Value::Dict params;
  ExecuteSessionCommand(&map, "cmd", base::BindRepeating(&ShouldNotBeCalled),
                        true /*w3c_standard_command*/, false, params, "session",
                        base::BindRepeating(&OnNoSuchSession));
}

TEST(CommandsTest, ExecuteSessionCommandOnNoSuchSessionWhenItExpectsOk) {
  SessionThreadMap map;
  SessionConnectionMap session_connection_map;
  base::Value::Dict params;
  ExecuteSessionCommand(&map, "cmd", base::BindRepeating(&ShouldNotBeCalled),
                        true /*w3c_standard_command*/, true, params, "session",
                        base::BindRepeating(&OnNoSuchSessionIsOk));
}

namespace {

void OnNoSuchSessionAndQuit(base::RunLoop* run_loop,
                            const Status& status,
                            std::unique_ptr<base::Value> value,
                            const std::string& session_id,
                            bool w3c_compliant) {
  run_loop->Quit();
  EXPECT_EQ(kInvalidSessionId, status.code());
  EXPECT_FALSE(value.get());
}

}  // namespace

TEST(CommandsTest, ExecuteSessionCommandOnJustDeletedSession) {
  SessionThreadMap map;
  SessionConnectionMap session_connection_map;
  auto thread_info = std::make_unique<SessionThreadInfo>("1", true);
  ASSERT_TRUE(thread_info->thread()->Start());
  std::string id("id");
  map[id] = std::move(thread_info);

  base::test::SingleThreadTaskEnvironment task_environment;
  base::Value::Dict params;
  base::RunLoop run_loop;
  ExecuteSessionCommand(
      &map, "cmd", base::BindRepeating(&ShouldNotBeCalled),
      true /*w3c_standard_command*/, false, params, "session",
      base::BindRepeating(&OnNoSuchSessionAndQuit, &run_loop));
  run_loop.Run();
}

namespace {

enum TestScenario {
  kElementExistsQueryOnce = 0,
  kElementExistsQueryTwice,
  kElementNotExistsQueryOnce,
  kElementExistsTimeout
};

class FindElementWebView : public StubWebView {
 public:
  FindElementWebView(bool only_one, TestScenario scenario)
      : StubWebView("1"), only_one_(only_one), scenario_(scenario),
        current_count_(0) {
    switch (scenario_) {
      case kElementExistsQueryOnce:
      case kElementExistsQueryTwice:
      case kElementExistsTimeout: {
        if (only_one_) {
          base::Value::Dict element;
          element.Set("ELEMENT", "1");
          result_ = std::make_unique<base::Value>(std::move(element));
        } else {
          base::Value::Dict element1;
          element1.Set("ELEMENT", "1");
          base::Value::Dict element2;
          element2.Set("ELEMENT", "2");
          base::Value::List list;
          list.Append(std::move(element1));
          list.Append(std::move(element2));
          result_ = std::make_unique<base::Value>(std::move(list));
        }
        break;
      }
      case kElementNotExistsQueryOnce: {
        if (only_one_)
          result_ = std::make_unique<base::Value>();
        else
          result_ = base::Value::ToUniquePtrValue(
              base::Value(base::Value::Type::LIST));
        break;
      }
    }
  }
  ~FindElementWebView() override = default;

  void Verify(const std::string& expected_frame,
              const base::Value* expected_args,
              const base::Value* actual_result) {
    ASSERT_TRUE(expected_args->is_list());
    EXPECT_EQ(expected_frame, frame_);
    std::string function;
    if (only_one_)
      function = webdriver::atoms::asString(webdriver::atoms::FIND_ELEMENT);
    else
      function = webdriver::atoms::asString(webdriver::atoms::FIND_ELEMENTS);
    EXPECT_EQ(function, function_);
    ASSERT_TRUE(args_.get());
    EXPECT_EQ(*expected_args, *args_);
    ASSERT_TRUE(actual_result);
    EXPECT_EQ(*result_, *actual_result);
  }

  // Overridden from WebView:
  Status CallFunction(const std::string& frame,
                      const std::string& function,
                      const base::Value::List& args,
                      std::unique_ptr<base::Value>* result) override {
    ++current_count_;
    if (scenario_ == kElementExistsTimeout ||
        (scenario_ == kElementExistsQueryTwice && current_count_ == 1)) {
        // Always return empty result when testing timeout.
        if (only_one_)
          *result = std::make_unique<base::Value>();
        else
          *result = base::Value::ToUniquePtrValue(base::Value());
    } else {
      switch (scenario_) {
        case kElementExistsQueryOnce:
        case kElementNotExistsQueryOnce: {
          EXPECT_EQ(1, current_count_);
          break;
        }
        case kElementExistsQueryTwice: {
          EXPECT_EQ(2, current_count_);
          break;
        }
        default: {
          break;
        }
      }

      *result = base::Value::ToUniquePtrValue(result_->Clone());
      frame_ = frame;
      function_ = function;
      args_ = std::make_unique<base::Value>(args.Clone());
    }
    return Status(kOk);
  }

 private:
  bool only_one_;
  TestScenario scenario_;
  int current_count_;
  std::string frame_;
  std::string function_;
  std::unique_ptr<base::Value> args_;
  std::unique_ptr<base::Value> result_;
};

}  // namespace

TEST(CommandsTest, SuccessfulFindElement) {
  FindElementWebView web_view(true, kElementExistsQueryTwice);
  Session session("id");
  session.implicit_wait = base::Seconds(1);
  session.SwitchToSubFrame("frame_id1", std::string());
  base::Value::Dict params;
  params.Set("using", "css selector");
  params.Set("value", "#a");
  std::unique_ptr<base::Value> result;
  ASSERT_EQ(kOk,
            ExecuteFindElement(1, &session, &web_view, params, &result, nullptr)
                .code());
  base::Value::Dict param;
  param.Set("css selector", "#a");
  base::Value expected_args(base::Value::Type::LIST);
  expected_args.GetList().Append(std::move(param));
  web_view.Verify("frame_id1", &expected_args, result.get());
}

TEST(CommandsTest, FailedFindElement) {
  FindElementWebView web_view(true, kElementNotExistsQueryOnce);
  Session session("id");
  base::Value::Dict params;
  params.Set("using", "css selector");
  params.Set("value", "#a");
  std::unique_ptr<base::Value> result;
  ASSERT_EQ(kNoSuchElement,
            ExecuteFindElement(1, &session, &web_view, params, &result, nullptr)
                .code());
}

TEST(CommandsTest, SuccessfulFindElements) {
  FindElementWebView web_view(false, kElementExistsQueryTwice);
  Session session("id");
  session.implicit_wait = base::Seconds(1);
  session.SwitchToSubFrame("frame_id2", std::string());
  base::Value::Dict params;
  params.Set("using", "css selector");
  params.Set("value", "*[name='b']");
  std::unique_ptr<base::Value> result;
  ASSERT_EQ(
      kOk, ExecuteFindElements(1, &session, &web_view, params, &result, nullptr)
               .code());
  base::Value::Dict param;
  param.Set("css selector", "*[name='b']");
  base::Value expected_args(base::Value::Type::LIST);
  expected_args.GetList().Append(std::move(param));
  web_view.Verify("frame_id2", &expected_args, result.get());
}

TEST(CommandsTest, FailedFindElements) {
  Session session("id");
  FindElementWebView web_view(false, kElementNotExistsQueryOnce);
  base::Value::Dict params;
  params.Set("using", "css selector");
  params.Set("value", "#a");
  std::unique_ptr<base::Value> result;
  ASSERT_EQ(
      kOk, ExecuteFindElements(1, &session, &web_view, params, &result, nullptr)
               .code());
  ASSERT_TRUE(result->is_list());
  ASSERT_EQ(0U, result->GetList().size());
}

TEST(CommandsTest, SuccessfulFindChildElement) {
  FindElementWebView web_view(true, kElementExistsQueryTwice);
  Session session("id");
  session.w3c_compliant = false;
  session.implicit_wait = base::Seconds(1);
  session.SwitchToSubFrame("frame_id3", std::string());
  base::Value::Dict params;
  params.Set("using", "css selector");
  params.Set("value", "div");
  std::string element_id = "1";
  std::unique_ptr<base::Value> result;
  ASSERT_EQ(kOk, ExecuteFindChildElement(1, &session, &web_view, element_id,
                                         params, &result)
                     .code());
  base::Value::Dict locator_param;
  locator_param.Set("css selector", "div");
  base::Value::Dict root_element_param;
  root_element_param.Set("ELEMENT", element_id);
  base::Value expected_args(base::Value::Type::LIST);
  expected_args.GetList().Append(std::move(locator_param));
  expected_args.GetList().Append(std::move(root_element_param));
  web_view.Verify("frame_id3", &expected_args, result.get());
}

TEST(CommandsTest, FailedFindChildElement) {
  Session session("id");
  FindElementWebView web_view(true, kElementNotExistsQueryOnce);
  base::Value::Dict params;
  params.Set("using", "css selector");
  params.Set("value", "#a");
  std::string element_id = "1";
  std::unique_ptr<base::Value> result;
  ASSERT_EQ(kNoSuchElement, ExecuteFindChildElement(1, &session, &web_view,
                                                    element_id, params, &result)
                                .code());
}

TEST(CommandsTest, SuccessfulFindChildElements) {
  FindElementWebView web_view(false, kElementExistsQueryTwice);
  Session session("id");
  session.w3c_compliant = false;
  session.implicit_wait = base::Seconds(1);
  session.SwitchToSubFrame("frame_id4", std::string());
  base::Value::Dict params;
  params.Set("using", "css selector");
  params.Set("value", ".c");
  std::string element_id = "1";
  std::unique_ptr<base::Value> result;
  ASSERT_EQ(kOk, ExecuteFindChildElements(1, &session, &web_view, element_id,
                                          params, &result)
                     .code());
  base::Value::Dict locator_param;
  locator_param.Set("css selector", ".c");
  base::Value::Dict root_element_param;
  root_element_param.Set("ELEMENT", element_id);
  base::Value expected_args(base::Value::Type::LIST);
  expected_args.GetList().Append(std::move(locator_param));
  expected_args.GetList().Append(std::move(root_element_param));
  web_view.Verify("frame_id4", &expected_args, result.get());
}

TEST(CommandsTest, FailedFindChildElements) {
  Session session("id");
  FindElementWebView web_view(false, kElementNotExistsQueryOnce);
  base::Value::Dict params;
  params.Set("using", "css selector");
  params.Set("value", "#a");
  std::string element_id = "1";
  std::unique_ptr<base::Value> result;
  ASSERT_EQ(kOk, ExecuteFindChildElements(1, &session, &web_view, element_id,
                                          params, &result)
                     .code());
  ASSERT_TRUE(result->is_list());
  ASSERT_EQ(0U, result->GetList().size());
}

TEST(CommandsTest, TimeoutInFindElement) {
  Session session("id");
  FindElementWebView web_view(true, kElementExistsTimeout);
  session.implicit_wait = base::Milliseconds(2);
  base::Value::Dict params;
  params.Set("using", "css selector");
  params.Set("value", "#a");
  params.Set("id", "1");
  std::unique_ptr<base::Value> result;
  ASSERT_EQ(kNoSuchElement,
            ExecuteFindElement(1, &session, &web_view, params, &result, nullptr)
                .code());
}

namespace {

class NavigatingWebView : public StubWebView {
 public:
  explicit NavigatingWebView(const std::string& id) : StubWebView(id) {}

  void SetUpToRespondWithSingleElement() {
    base::Value::Dict element;
    element.Set("ELEMENT", "1");
    mocked_result = base::Value(std::move(element));
  }

  void SetUpToRespondWithMultipleElements() {
    base::Value::Dict element1;
    element1.Set("ELEMENT", "1");
    base::Value::Dict element2;
    element2.Set("ELEMENT", "2");
    base::Value::List list;
    list.Append(std::move(element1));
    list.Append(std::move(element2));
    mocked_result = base::Value(std::move(list));
  }

  Status CallFunction(const std::string& frame,
                      const std::string& function,
                      const base::Value::List& args,
                      std::unique_ptr<base::Value>* result) override {
    if (!initial_error_codes.empty()) {
      Status status{initial_error_codes.front()};
      initial_error_codes.pop_front();
      return status;
    }

    *result = std::make_unique<base::Value>(mocked_result.Clone());
    return Status{kOk};
  }

  std::list<StatusCode> initial_error_codes;
  base::Value mocked_result;

};  // NavigatingWebView

#if defined(MEMORY_SANITIZER)
base::TimeDelta kImplicitWait = base::Seconds(100);
#elif defined(NDEBUG)
base::TimeDelta kImplicitWait = base::Seconds(3);
#else
base::TimeDelta kImplicitWait = base::Seconds(100);
#endif
// #endif

}  // namespace

TEST(CommandsTest, FindElementWhileNavigating) {
  NavigatingWebView web_view("some_frame");
  web_view.initial_error_codes = {
      kNoSuchExecutionContext,
      kAbortedByNavigation,
  };
  web_view.SetUpToRespondWithSingleElement();

  base::Value::Dict params;
  params.Set("using", "css selector");
  params.Set("value", "#some");
  Session session("id");

  session.implicit_wait = kImplicitWait;
  std::unique_ptr<base::Value> result;
  EXPECT_TRUE(StatusOk(
      ExecuteFindElement(0, &session, &web_view, params, &result, nullptr)));
  EXPECT_EQ(0U, web_view.initial_error_codes.size());
}

TEST(CommandsTest, FindElementWhileNavigatingTooLong) {
  NavigatingWebView web_view("some_frame");
  web_view.initial_error_codes = {
      kAbortedByNavigation,
      kNoSuchExecutionContext,
  };
  web_view.SetUpToRespondWithSingleElement();

  base::Value::Dict params;
  params.Set("using", "css selector");
  params.Set("value", "#some");
  Session session("id");

  session.implicit_wait = base::Seconds(0);
  std::unique_ptr<base::Value> result;
  EXPECT_TRUE(StatusCodeIs<kNoSuchElement>(
      ExecuteFindElement(10, &session, &web_view, params, &result, nullptr)));
  EXPECT_LT(web_view.initial_error_codes.size(), 2U);
}

TEST(CommandsTest, FindElementsWhileNavigating) {
  NavigatingWebView web_view("some_frame");
  web_view.initial_error_codes = {
      kNoSuchExecutionContext,
      kAbortedByNavigation,
  };
  web_view.SetUpToRespondWithMultipleElements();

  base::Value::Dict params;
  params.Set("using", "css selector");
  params.Set("value", "#some");
  Session session("id");

  session.implicit_wait = kImplicitWait;
  std::unique_ptr<base::Value> result;
  EXPECT_TRUE(StatusOk(
      ExecuteFindElements(0, &session, &web_view, params, &result, nullptr)));
  EXPECT_EQ(0U, web_view.initial_error_codes.size());
}

TEST(CommandsTest, FindElementsWhileNavigatingTooLong) {
  NavigatingWebView web_view("some_frame");
  web_view.initial_error_codes = {
      kAbortedByNavigation,
      kNoSuchExecutionContext,
  };
  web_view.SetUpToRespondWithMultipleElements();

  base::Value::Dict params;
  params.Set("using", "css selector");
  params.Set("value", "#some");
  Session session("id");

  session.implicit_wait = base::Seconds(0);
  std::unique_ptr<base::Value> result;
  EXPECT_TRUE(StatusOk(
      ExecuteFindElements(10, &session, &web_view, params, &result, nullptr)));
  EXPECT_LT(web_view.initial_error_codes.size(), 2U);
  EXPECT_TRUE(result->is_list());
  EXPECT_EQ(0U, result->GetList().size());
}

namespace {

class ErrorCallFunctionWebView : public StubWebView {
 public:
  explicit ErrorCallFunctionWebView(StatusCode code)
      : StubWebView("1"), code_(code) {}
  ~ErrorCallFunctionWebView() override = default;

  // Overridden from WebView:
  Status CallFunction(const std::string& frame,
                      const std::string& function,
                      const base::Value::List& args,
                      std::unique_ptr<base::Value>* result) override {
    return Status(code_);
  }

 private:
  StatusCode code_;
};

}  // namespace

TEST(CommandsTest, ErrorFindElement) {
  Session session("id");
  ErrorCallFunctionWebView web_view(kUnknownError);
  base::Value::Dict params;
  params.Set("using", "css selector");
  params.Set("value", "#a");
  std::unique_ptr<base::Value> value;
  ASSERT_EQ(kUnknownError,
            ExecuteFindElement(1, &session, &web_view, params, &value, nullptr)
                .code());
  ASSERT_EQ(kUnknownError,
            ExecuteFindElements(1, &session, &web_view, params, &value, nullptr)
                .code());
}

TEST(CommandsTest, ErrorFindChildElement) {
  Session session("id");
  ErrorCallFunctionWebView web_view(kStaleElementReference);
  base::Value::Dict params;
  params.Set("using", "css selector");
  params.Set("value", "#a");
  std::string element_id = "1";
  std::unique_ptr<base::Value> result;
  ASSERT_EQ(kStaleElementReference,
            ExecuteFindChildElement(1, &session, &web_view, element_id, params,
                                    &result)
                .code());
  ASSERT_EQ(kStaleElementReference,
            ExecuteFindChildElements(1, &session, &web_view, element_id, params,
                                     &result)
                .code());
}

namespace {

class MockCommandListener : public CommandListener {
 public:
  MockCommandListener() : called_(false) {}
  ~MockCommandListener() override = default;

  Status BeforeCommand(const std::string& command_name) override {
    called_ = true;
    EXPECT_STREQ("cmd", command_name.c_str());
    return Status(kOk);
  }

  void VerifyCalled() {
    EXPECT_TRUE(called_);
  }

  void VerifyNotCalled() {
    EXPECT_FALSE(called_);
  }

 private:
  bool called_;
};

Status ExecuteQuitSessionCommand(Session* session,
                                 const base::Value::Dict& params,
                                 std::unique_ptr<base::Value>* return_value) {
  session->quit = true;
  return Status(kOk);
}

void OnSessionCommand(base::RunLoop* run_loop,
                      const Status& status,
                      std::unique_ptr<base::Value> value,
                      const std::string& session_id,
                      bool w3c_compliant) {
  ASSERT_EQ(kOk, status.code());
  run_loop->Quit();
}

}  // namespace

TEST(CommandsTest, SuccessNotifyingCommandListeners) {
  SessionThreadMap map;
  SessionConnectionMap session_connection_map;
  auto thread_info = std::make_unique<SessionThreadInfo>("1", true);
  base::Thread* thread = thread_info->thread();
  ASSERT_TRUE(thread->Start());
  std::string id("id");
  thread->task_runner()->PostTask(
      FROM_HERE,
      base::BindOnce(&internal::CreateSessionOnSessionThreadForTesting, id));

  map[id] = std::move(thread_info);

  base::Value::Dict params;
  auto listener = std::make_unique<MockCommandListener>();
  auto proxy = std::make_unique<CommandListenerProxy>(listener.get());
  // We add |proxy| to the session instead of adding |listener| directly so that
  // after the session is destroyed by ExecuteQuitSessionCommand, we can still
  // verify the listener was called. The session owns and will destroy |proxy|.
  SessionCommand cmd =
      base::BindLambdaForTesting([&](Session* session, const base::Value::Dict&,
                                     std::unique_ptr<base::Value>*) {
        CHECK(proxy);
        session->command_listeners.push_back(std::move(proxy));
        return Status(kOk);
      });
  base::test::SingleThreadTaskEnvironment task_environment;
  base::RunLoop run_loop_addlistener;

  // |CommandListener|s are notified immediately before commands are run.
  // Here, the command adds |listener| to the session, so |listener|
  // should not be notified since it will not have been added yet.
  ExecuteSessionCommand(
      &map, "cmd", cmd, true /*w3c_standard_command*/, false, params, id,
      base::BindRepeating(&OnSessionCommand, &run_loop_addlistener));
  run_loop_addlistener.Run();

  listener->VerifyNotCalled();

  base::RunLoop run_loop_testlistener;
  cmd = base::BindRepeating(&ExecuteQuitSessionCommand);

  // |listener| was added to |session| by ExecuteAddListenerToSessionCommand
  // and should be notified before the next command, ExecuteQuitSessionCommand.
  ExecuteSessionCommand(
      &map, "cmd", cmd, true /*w3c_standard_command*/, false, params, id,
      base::BindRepeating(&OnSessionCommand, &run_loop_testlistener));
  run_loop_testlistener.Run();

  listener->VerifyCalled();
}

namespace {

class FailingCommandListener : public CommandListener {
 public:
  FailingCommandListener() = default;
  ~FailingCommandListener() override = default;

  Status BeforeCommand(const std::string& command_name) override {
    return Status(kUnknownError);
  }
};

void AddListenerToSessionIfSessionExists(
    std::unique_ptr<CommandListener> listener) {
  Session* session = GetThreadLocalSession();
  if (session) {
    session->command_listeners.push_back(std::move(listener));
  }
}

void OnFailBecauseErrorNotifyingListeners(base::RunLoop* run_loop,
                                          const Status& status,
                                          std::unique_ptr<base::Value> value,
                                          const std::string& session_id,
                                          bool w3c_compliant) {
  EXPECT_EQ(kUnknownError, status.code());
  EXPECT_FALSE(value.get());
  run_loop->Quit();
}

void VerifySessionWasDeleted() {
  ASSERT_FALSE(GetThreadLocalSession());
}

}  // namespace

TEST(CommandsTest, ErrorNotifyingCommandListeners) {
  SessionThreadMap map;
  SessionConnectionMap session_connection_map;
  auto thread_info = std::make_unique<SessionThreadInfo>("1", true);
  base::Thread* thread = thread_info->thread();
  ASSERT_TRUE(thread->Start());
  std::string id("id");
  thread->task_runner()->PostTask(
      FROM_HERE,
      base::BindOnce(&internal::CreateSessionOnSessionThreadForTesting, id));
  map[id] = std::move(thread_info);

  // In SuccessNotifyingCommandListenersBeforeCommand, we verified BeforeCommand
  // was called before (as opposed to after) command execution. We don't need to
  // verify this again, so we can just add |listener| with PostTask.
  auto listener = std::make_unique<FailingCommandListener>();
  thread->task_runner()->PostTask(
      FROM_HERE, base::BindOnce(&AddListenerToSessionIfSessionExists,
                                std::move(listener)));

  base::Value::Dict params;
  // The command should never be executed if BeforeCommand fails for a listener.
  SessionCommand cmd = base::BindRepeating(&ShouldNotBeCalled);
  base::test::SingleThreadTaskEnvironment task_environment;
  base::RunLoop run_loop;

  ExecuteSessionCommand(
      &map, "cmd", cmd, true /*w3c_standard_command*/, false, params, id,
      base::BindRepeating(&OnFailBecauseErrorNotifyingListeners, &run_loop));
  run_loop.Run();

  thread->task_runner()->PostTask(FROM_HERE,
                                  base::BindOnce(&VerifySessionWasDeleted));
}