// 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/browser/ui/performance_controls/performance_controls_hats_service.h"

#include <memory>

#include "base/byte_size.h"
#include "base/memory/raw_ptr.h"
#include "base/metrics/field_trial_params.h"
#include "base/test/power_monitor_test_utils.h"
#include "base/test/scoped_feature_list.h"
#include "chrome/browser/browser_process.h"
#include "chrome/browser/performance_manager/test_support/test_user_performance_tuning_manager_environment.h"
#include "chrome/browser/ui/hats/hats_service_factory.h"
#include "chrome/browser/ui/hats/mock_hats_service.h"
#include "chrome/test/base/testing_browser_process.h"
#include "chrome/test/base/testing_profile.h"
#include "chrome/test/base/testing_profile_manager.h"
#include "components/performance_manager/public/features.h"
#include "components/performance_manager/public/user_tuning/prefs.h"
#include "components/prefs/testing_pref_service.h"
#include "content/public/test/browser_task_environment.h"
#include "testing/gmock/include/gmock/gmock.h"
#include "testing/gtest/include/gtest/gtest.h"

#if BUILDFLAG(IS_CHROMEOS)
#include "ash/constants/ash_features.h"
#endif

namespace {

using performance_manager::features::kPerformanceControlsPPMSurveyMaxDelay;
using performance_manager::features::kPerformanceControlsPPMSurveyMinDelay;
using ::testing::_;
using ::testing::Pair;
using ::testing::UnorderedElementsAre;

const char* kBatterySaverPSDName =
    PerformanceControlsHatsService::kBatterySaverPSDName;
const char* kChannelPSDName = PerformanceControlsHatsService::kChannelPSDName;
const char* kMemorySaverPSDName =
    PerformanceControlsHatsService::kMemorySaverPSDName;
const char* kPerformanceSegmentPSDName =
    PerformanceControlsHatsService::kPerformanceSegmentPSDName;
const char* kUniformSamplePSDName =
    PerformanceControlsHatsService::kUniformSamplePSDName;

// GMock matcher for any expected "channel" string
auto MatchesAnyChannel() {
  // Channel can be "unknown" in some test configs.
  return ::testing::AnyOf("canary", "dev", "beta", "stable", "unknown");
}

}  // namespace

class PerformanceControlsHatsServicePPMTest : public testing::Test {
 protected:
  void SetUp() override {
    testing::Test::SetUp();

    profile_manager_ = std::make_unique<TestingProfileManager>(
        TestingBrowserProcess::GetGlobal());
    ASSERT_TRUE(profile_manager_->SetUp());
    TestingProfile* profile = profile_manager_->CreateTestingProfile("Test");

    mock_hats_service_ = static_cast<MockHatsService*>(
        HatsServiceFactory::GetInstance()->SetTestingFactoryAndUse(
            profile, base::BindRepeating(&BuildMockHatsService)));
    EXPECT_CALL(*mock_hats_service(), CanShowAnySurvey(_))
        .WillRepeatedly(testing::Return(true));

    feature_list_.InitWithFeaturesAndParameters(
        {
            {performance_manager::features::kPerformanceControlsPPMSurvey,
             GetFieldTrialParams()},
        },
        {});
    performance_manager::user_tuning::prefs::RegisterLocalStatePrefs(
        local_state_.registry());
    environment_.SetUp(&local_state_);

    performance_controls_hats_service_ =
        std::make_unique<PerformanceControlsHatsService>(profile);

    // Override the random delay.
    performance_controls_hats_service()->SetDelayBeforePPMSurveyForTesting(
        (kPerformanceControlsPPMSurveyMinDelay.Get() +
         kPerformanceControlsPPMSurveyMaxDelay.Get()) /
        2);
  }

  void TearDown() override {
    testing::Test::TearDown();
    // The service has to be destroyed before the UserPerformanceTuningManager
    // is destroyed by `environment_.TearDown()`, otherwise the service will try
    // to unregister as an observer on a freed UserPerformanceTuningManager.
    performance_controls_hats_service_.reset();
    environment_.TearDown();
  }

  virtual base::FieldTrialParams GetFieldTrialParams() const { return {}; }

  void SetBatterySaverMode(
      const performance_manager::user_tuning::prefs::BatterySaverModeState
          battery_saver_mode) {
    local_state()->SetInteger(
        performance_manager::user_tuning::prefs::kBatterySaverModeState,
        static_cast<int>(battery_saver_mode));
  }

  void SetMemorySaverEnabled(const bool memory_saver_enabled) {
    performance_manager::user_tuning::UserPerformanceTuningManager::
        GetInstance()
            ->SetMemorySaverModeEnabled(memory_saver_enabled);
  }

  PerformanceControlsHatsService* performance_controls_hats_service() {
    return performance_controls_hats_service_.get();
  }
  MockHatsService* mock_hats_service() { return mock_hats_service_; }
  TestingPrefServiceSimple* local_state() { return &local_state_; }

  content::BrowserTaskEnvironment& task_env() { return task_environment_; }

 private:
  performance_manager::user_tuning::TestUserPerformanceTuningManagerEnvironment
      environment_;
  content::BrowserTaskEnvironment task_environment_{
      content::BrowserTaskEnvironment::TimeSource::MOCK_TIME};
  base::test::ScopedFeatureList feature_list_;
  TestingPrefServiceSimple local_state_;
  std::unique_ptr<TestingProfileManager> profile_manager_;
  std::unique_ptr<PerformanceControlsHatsService>
      performance_controls_hats_service_;
  raw_ptr<MockHatsService> mock_hats_service_;
};

TEST_F(PerformanceControlsHatsServicePPMTest, NoPPMSurveyBeforeDelay) {
  EXPECT_CALL(
      *mock_hats_service(),
      LaunchSurvey(kHatsSurveyTriggerPerformanceControlsPPM, _, _, _, _, _, _))
      .Times(0);
  performance_controls_hats_service()->OpenedNewTabPage();
}

TEST_F(PerformanceControlsHatsServicePPMTest, LaunchesPPMSurveyAfterDelay) {
  EXPECT_CALL(
      *mock_hats_service(),
      LaunchSurvey(
          kHatsSurveyTriggerPerformanceControlsPPM, _, _,
          UnorderedElementsAre(Pair(kMemorySaverPSDName, _),
                               Pair(kBatterySaverPSDName, _),
                               Pair(kUniformSamplePSDName, true)),
          UnorderedElementsAre(Pair(kPerformanceSegmentPSDName, _),
                               Pair(kChannelPSDName, MatchesAnyChannel())),
          _, _));
  task_env().FastForwardBy(
      performance_controls_hats_service()->delay_before_ppm_survey());
  performance_controls_hats_service()->OpenedNewTabPage();
}

TEST_F(PerformanceControlsHatsServicePPMTest, NoPPMSurveyAfterMaxTimeout) {
  EXPECT_CALL(
      *mock_hats_service(),
      LaunchSurvey(kHatsSurveyTriggerPerformanceControlsPPM, _, _, _, _, _, _))
      .Times(0);
  task_env().FastForwardBy(kPerformanceControlsPPMSurveyMaxDelay.Get() +
                           base::Seconds(1));
  performance_controls_hats_service()->OpenedNewTabPage();
}

// Make sure there's a grace period if the PPM survey delay randomly lands at
// the max timeout.
TEST_F(PerformanceControlsHatsServicePPMTest,
       LaunchesPPMSurveyWithDelayAtMaxTimeout) {
  performance_controls_hats_service()->SetDelayBeforePPMSurveyForTesting(
      kPerformanceControlsPPMSurveyMaxDelay.Get());
  EXPECT_CALL(
      *mock_hats_service(),
      LaunchSurvey(kHatsSurveyTriggerPerformanceControlsPPM, _, _, _, _, _, _));
  task_env().FastForwardBy(kPerformanceControlsPPMSurveyMaxDelay.Get() +
                           base::Seconds(1));
  performance_controls_hats_service()->OpenedNewTabPage();
}

class PerformanceControlsHatsServicePPM2SegmentTest
    : public PerformanceControlsHatsServicePPMTest {
 protected:
  base::FieldTrialParams GetFieldTrialParams() const override {
    return {
        // <= 8 GB
        {"ppm_survey_segment_name1", "Low Memory"},
        {"ppm_survey_segment_max_memory_gb1", "8"},
        // > 8 GB
        {"ppm_survey_segment_name2", "High Memory"},
    };
  }
};

TEST_F(PerformanceControlsHatsServicePPM2SegmentTest, LowMemorySegment) {
  EXPECT_CALL(
      *mock_hats_service(),
      LaunchSurvey(
          kHatsSurveyTriggerPerformanceControlsPPM, _, _,
          UnorderedElementsAre(Pair(kMemorySaverPSDName, _),
                               Pair(kBatterySaverPSDName, _),
                               Pair(kUniformSamplePSDName, true)),
          UnorderedElementsAre(Pair(kPerformanceSegmentPSDName, "Low Memory"),
                               Pair(kChannelPSDName, MatchesAnyChannel())),
          _, _));
  performance_controls_hats_service()->SetAmountOfPhysicalMemoryForTesting(
      base::GiB(8));
  task_env().FastForwardBy(
      performance_controls_hats_service()->delay_before_ppm_survey());
  performance_controls_hats_service()->OpenedNewTabPage();
}

TEST_F(PerformanceControlsHatsServicePPM2SegmentTest, HighMemorySegment) {
  EXPECT_CALL(
      *mock_hats_service(),
      LaunchSurvey(
          kHatsSurveyTriggerPerformanceControlsPPM, _, _,
          UnorderedElementsAre(Pair(kMemorySaverPSDName, _),
                               Pair(kBatterySaverPSDName, _),
                               Pair(kUniformSamplePSDName, true)),
          UnorderedElementsAre(Pair(kPerformanceSegmentPSDName, "High Memory"),
                               Pair(kChannelPSDName, MatchesAnyChannel())),
          _, _));
  performance_controls_hats_service()->SetAmountOfPhysicalMemoryForTesting(
      base::GiB(12));
  task_env().FastForwardBy(
      performance_controls_hats_service()->delay_before_ppm_survey());
  performance_controls_hats_service()->OpenedNewTabPage();
}

class PerformanceControlsHatsServicePPM3SegmentTest
    : public PerformanceControlsHatsServicePPMTest {
 protected:
  base::FieldTrialParams GetFieldTrialParams() const override {
    return {
        // <= 4 GB
        {"ppm_survey_segment_name1", "Low Memory"},
        {"ppm_survey_segment_max_memory_gb1", "4"},
        // 4-8 GB
        {"ppm_survey_segment_name2", "Medium Memory"},
        {"ppm_survey_segment_max_memory_gb2", "8"},
        // > 8 GB
        {"ppm_survey_segment_name3", "High Memory"},
    };
  }
};

TEST_F(PerformanceControlsHatsServicePPM3SegmentTest, LowMemorySegment) {
  EXPECT_CALL(
      *mock_hats_service(),
      LaunchSurvey(
          kHatsSurveyTriggerPerformanceControlsPPM, _, _,
          UnorderedElementsAre(Pair(kMemorySaverPSDName, _),
                               Pair(kBatterySaverPSDName, _),
                               Pair(kUniformSamplePSDName, true)),
          UnorderedElementsAre(Pair(kPerformanceSegmentPSDName, "Low Memory"),
                               Pair(kChannelPSDName, MatchesAnyChannel())),
          _, _));
  performance_controls_hats_service()->SetAmountOfPhysicalMemoryForTesting(
      base::GiB(4));
  task_env().FastForwardBy(
      performance_controls_hats_service()->delay_before_ppm_survey());
  performance_controls_hats_service()->OpenedNewTabPage();
}

TEST_F(PerformanceControlsHatsServicePPM3SegmentTest, MediumMemorySegment) {
  EXPECT_CALL(
      *mock_hats_service(),
      LaunchSurvey(kHatsSurveyTriggerPerformanceControlsPPM, _, _,
                   UnorderedElementsAre(Pair(kMemorySaverPSDName, _),
                                        Pair(kBatterySaverPSDName, _),
                                        Pair(kUniformSamplePSDName, true)),
                   UnorderedElementsAre(
                       Pair(kPerformanceSegmentPSDName, "Medium Memory"),
                       Pair(kChannelPSDName, MatchesAnyChannel())),
                   _, _));
  performance_controls_hats_service()->SetAmountOfPhysicalMemoryForTesting(
      base::GiB(8));
  task_env().FastForwardBy(
      performance_controls_hats_service()->delay_before_ppm_survey());
  performance_controls_hats_service()->OpenedNewTabPage();
}

TEST_F(PerformanceControlsHatsServicePPM3SegmentTest, HighMemorySegment) {
  EXPECT_CALL(
      *mock_hats_service(),
      LaunchSurvey(
          kHatsSurveyTriggerPerformanceControlsPPM, _, _,
          UnorderedElementsAre(Pair(kMemorySaverPSDName, _),
                               Pair(kBatterySaverPSDName, _),
                               Pair(kUniformSamplePSDName, true)),
          UnorderedElementsAre(Pair(kPerformanceSegmentPSDName, "High Memory"),
                               Pair(kChannelPSDName, MatchesAnyChannel())),
          _, _));
  performance_controls_hats_service()->SetAmountOfPhysicalMemoryForTesting(
      base::GiB(16));
  task_env().FastForwardBy(
      performance_controls_hats_service()->delay_before_ppm_survey());
  performance_controls_hats_service()->OpenedNewTabPage();
}

class PerformanceControlsHatsServicePPMFinishedSegmentTest
    : public PerformanceControlsHatsServicePPMTest {
 protected:
  base::FieldTrialParams GetFieldTrialParams() const override {
    return {
        // uniform_sample should be disabled before a segment is finished, since
        // the weight of each segment no longer reflects the general population.
        {"ppm_survey_uniform_sample", "false"},
        // <= 4 GB
        {"ppm_survey_segment_name1", "Low Memory"},
        {"ppm_survey_segment_max_memory_gb1", "4"},
        // 4-8 GB has enough responses and shouldn't be shown.
        {"ppm_survey_segment_name2", ""},
        {"ppm_survey_segment_max_memory_gb2", "8"},
        // > 8 GB
        {"ppm_survey_segment_name3", "High Memory"},
    };
  }
};

TEST_F(PerformanceControlsHatsServicePPMFinishedSegmentTest, LowMemorySegment) {
  EXPECT_CALL(
      *mock_hats_service(),
      LaunchSurvey(
          kHatsSurveyTriggerPerformanceControlsPPM, _, _,
          UnorderedElementsAre(Pair(kMemorySaverPSDName, _),
                               Pair(kBatterySaverPSDName, _),
                               Pair(kUniformSamplePSDName, false)),
          UnorderedElementsAre(Pair(kPerformanceSegmentPSDName, "Low Memory"),
                               Pair(kChannelPSDName, MatchesAnyChannel())),
          _, _));
  performance_controls_hats_service()->SetAmountOfPhysicalMemoryForTesting(
      base::GiB(4));
  task_env().FastForwardBy(
      performance_controls_hats_service()->delay_before_ppm_survey());
  performance_controls_hats_service()->OpenedNewTabPage();
}

TEST_F(PerformanceControlsHatsServicePPMFinishedSegmentTest,
       MediumMemorySegmentDone) {
  EXPECT_CALL(
      *mock_hats_service(),
      LaunchSurvey(kHatsSurveyTriggerPerformanceControlsPPM, _, _, _, _, _, _))
      .Times(0);
  performance_controls_hats_service()->SetAmountOfPhysicalMemoryForTesting(
      base::GiB(8));
  task_env().FastForwardBy(
      performance_controls_hats_service()->delay_before_ppm_survey());
  performance_controls_hats_service()->OpenedNewTabPage();
}

TEST_F(PerformanceControlsHatsServicePPMFinishedSegmentTest,
       HighMemorySegment) {
  EXPECT_CALL(
      *mock_hats_service(),
      LaunchSurvey(
          kHatsSurveyTriggerPerformanceControlsPPM, _, _,
          UnorderedElementsAre(Pair(kMemorySaverPSDName, _),
                               Pair(kBatterySaverPSDName, _),
                               Pair(kUniformSamplePSDName, false)),
          UnorderedElementsAre(Pair(kPerformanceSegmentPSDName, "High Memory"),
                               Pair(kChannelPSDName, MatchesAnyChannel())),
          _, _));
  performance_controls_hats_service()->SetAmountOfPhysicalMemoryForTesting(
      base::GiB(16));
  task_env().FastForwardBy(
      performance_controls_hats_service()->delay_before_ppm_survey());
  performance_controls_hats_service()->OpenedNewTabPage();
}
