blob: 9a39c9c65b14f3b87db696d4b84a96c5e00894bd [file] [log] [blame]
// Copyright 2024 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/lens/lens_overlay_controller.h"
#include "base/containers/contains.h"
#include "base/functional/bind.h"
#include "base/json/json_reader.h"
#include "base/metrics/histogram_functions.h"
#include "base/no_destructor.h"
#include "base/numerics/checked_math.h"
#include "base/process/kill.h"
#include "base/strings/utf_string_conversions.h"
#include "base/system/sys_info.h"
#include "base/task/bind_post_task.h"
#include "base/task/sequenced_task_runner.h"
#include "chrome/browser/feedback/show_feedback_page.h"
#include "chrome/browser/lens/core/mojom/geometry.mojom.h"
#include "chrome/browser/lens/core/mojom/overlay_object.mojom.h"
#include "chrome/browser/lens/core/mojom/text.mojom.h"
#include "chrome/browser/profiles/profile.h"
#include "chrome/browser/search/search.h"
#include "chrome/browser/task_manager/web_contents_tags.h"
#include "chrome/browser/themes/theme_service.h"
#include "chrome/browser/ui/browser_element_identifiers.h"
#include "chrome/browser/ui/browser_window/public/browser_window_features.h"
#include "chrome/browser/ui/browser_window/public/browser_window_interface.h"
#include "chrome/browser/ui/exclusive_access/exclusive_access_manager.h"
#include "chrome/browser/ui/hats/hats_service.h"
#include "chrome/browser/ui/hats/hats_service_factory.h"
#include "chrome/browser/ui/lens/lens_overlay_entry_point_controller.h"
#include "chrome/browser/ui/lens/lens_overlay_event_handler.h"
#include "chrome/browser/ui/lens/lens_overlay_image_helper.h"
#include "chrome/browser/ui/lens/lens_overlay_languages_controller.h"
#include "chrome/browser/ui/lens/lens_overlay_query_controller.h"
#include "chrome/browser/ui/lens/lens_overlay_side_panel_coordinator.h"
#include "chrome/browser/ui/lens/lens_overlay_theme_utils.h"
#include "chrome/browser/ui/lens/lens_overlay_untrusted_ui.h"
#include "chrome/browser/ui/lens/lens_overlay_url_builder.h"
#include "chrome/browser/ui/lens/lens_permission_bubble_controller.h"
#include "chrome/browser/ui/lens/lens_preselection_bubble.h"
#include "chrome/browser/ui/tabs/public/tab_features.h"
#include "chrome/browser/ui/views/side_panel/side_panel.h"
#include "chrome/browser/ui/views/side_panel/side_panel_coordinator.h"
#include "chrome/browser/ui/views/side_panel/side_panel_enums.h"
#include "chrome/browser/ui/views/side_panel/side_panel_ui.h"
#include "chrome/browser/ui/views/side_panel/side_panel_util.h"
#include "chrome/browser/ui/webui/util/image_util.h"
#include "chrome/browser/ui/webui/webui_embedding_context.h"
#include "chrome/common/chrome_render_frame.mojom.h"
#include "chrome/common/pref_names.h"
#include "chrome/common/webui_url_constants.h"
#include "chrome/grit/branded_strings.h"
#include "components/feature_engagement/public/feature_constants.h"
#include "components/find_in_page/find_tab_helper.h"
#include "components/lens/lens_features.h"
#include "components/lens/lens_overlay_metrics.h"
#include "components/lens/lens_overlay_mime_type.h"
#include "components/lens/lens_overlay_permission_utils.h"
#include "components/lens/lens_overlay_side_panel_result.h"
#include "components/permissions/permission_request_manager.h"
#include "components/sessions/content/session_tab_helper.h"
#include "components/signin/public/identity_manager/identity_manager.h"
#include "components/viz/common/frame_timing_details.h"
#include "components/zoom/zoom_controller.h"
#include "content/public/browser/child_process_termination_info.h"
#include "content/public/browser/download_manager.h"
#include "content/public/browser/download_request_utils.h"
#include "content/public/browser/render_frame_host.h"
#include "content/public/browser/render_process_host.h"
#include "content/public/browser/render_view_host.h"
#include "content/public/browser/render_widget_host.h"
#include "content/public/browser/render_widget_host_view.h"
#include "content/public/browser/web_contents_user_data.h"
#include "content/public/browser/web_ui.h"
#include "lens_overlay_url_builder.h"
#include "net/base/network_change_notifier.h"
#include "net/base/url_search_params.h"
#include "net/base/url_util.h"
#include "pdf/buildflags.h"
#include "services/metrics/public/cpp/ukm_builders.h"
#include "services/metrics/public/cpp/ukm_source_id.h"
#include "third_party/blink/public/common/associated_interfaces/associated_interface_provider.h"
#include "third_party/lens_server_proto/lens_overlay_selection_type.pb.h"
#include "third_party/lens_server_proto/lens_overlay_service_deps.pb.h"
#include "ui/base/clipboard/scoped_clipboard_writer.h"
#include "ui/base/interaction/element_tracker.h"
#include "ui/base/l10n/l10n_util.h"
#include "ui/base/webui/web_ui_util.h"
#include "ui/base/window_open_disposition_utils.h"
#include "ui/compositor/compositor.h"
#include "ui/compositor/layer.h"
#include "ui/gfx/geometry/rounded_corners_f.h"
#include "ui/native_theme/native_theme.h"
#include "ui/views/bubble/bubble_dialog_delegate_view.h"
#include "ui/views/controls/webview/web_contents_set_background_color.h"
#include "ui/views/controls/webview/webview.h"
#include "ui/views/layout/flex_layout_types.h"
#include "ui/views/layout/flex_layout_view.h"
#include "ui/views/widget/native_widget.h"
#if BUILDFLAG(ENABLE_PDF)
#include "components/pdf/browser/pdf_document_helper.h"
#include "pdf/mojom/pdf.mojom.h"
#endif // BUILDFLAG(ENABLE_PDF)
void* kLensOverlayPreselectionWidgetIdentifier =
&kLensOverlayPreselectionWidgetIdentifier;
namespace {
// Timeout for the fadeout animation. This is purposely set to be twice the
// duration of the fade out animation on the WebUI JS because there is a delay
// between us notifying the WebUI, and the WebUI receiving our event.
constexpr base::TimeDelta kFadeoutAnimationTimeout = base::Milliseconds(300);
// The amount of time to wait for a reflow after closing the side panel before
// taking a screenshot.
constexpr base::TimeDelta kReflowWaitTimeout = base::Milliseconds(200);
// The amount of change in bytes that is considered a significant change and
// should trigger a page content update request. This provides tolerance in
// case there is slight variation in the retrievied bytes in between calls.
constexpr float kByteChangeTolerancePercent = 0.01;
// The url query param key for the search query.
inline constexpr char kTextQueryParameterKey[] = "q";
// Allows lookup of a LensOverlayController from a WebContents associated with a
// tab.
class LensOverlayControllerTabLookup
: public content::WebContentsUserData<LensOverlayControllerTabLookup> {
public:
~LensOverlayControllerTabLookup() override = default;
LensOverlayController* controller() { return controller_; }
private:
friend WebContentsUserData;
LensOverlayControllerTabLookup(content::WebContents* contents,
LensOverlayController* controller)
: content::WebContentsUserData<LensOverlayControllerTabLookup>(*contents),
controller_(controller) {}
// Semantically owns this class.
raw_ptr<LensOverlayController> controller_;
WEB_CONTENTS_USER_DATA_KEY_DECL();
};
WEB_CONTENTS_USER_DATA_KEY_IMPL(LensOverlayControllerTabLookup);
// Copy the objects of a vector into another without transferring
// ownership.
std::vector<lens::mojom::OverlayObjectPtr> CopyObjects(
const std::vector<lens::mojom::OverlayObjectPtr>& objects) {
std::vector<lens::mojom::OverlayObjectPtr> objects_copy(objects.size());
std::transform(
objects.begin(), objects.end(), objects_copy.begin(),
[](const lens::mojom::OverlayObjectPtr& obj) { return obj->Clone(); });
return objects_copy;
}
// Returns true if the two URLs have the same base url, and the same query
// parameters. This differs from comparing two GURLs using == since this method
// will ensure equivalence even if there are empty query params, viewport
// params, or different query param ordering.
bool AreSearchUrlsEquivalent(const GURL& a, const GURL& b) {
// Check urls without query and reference (fragment) for equality first.
GURL::Replacements replacements;
replacements.ClearRef();
replacements.ClearQuery();
if (a.ReplaceComponents(replacements) != b.ReplaceComponents(replacements)) {
return false;
}
// Now, compare each query param individually to ensure equivalence. Remove
// params that should not contribute to differing search results.
net::UrlSearchParams a_search_params(
lens::RemoveIgnoredSearchURLParameters(a));
net::UrlSearchParams b_search_params(
lens::RemoveIgnoredSearchURLParameters(b));
// Sort params so they are in the same order during comparison.
a_search_params.Sort();
b_search_params.Sort();
// Check Search Params for equality
// All search params, in order, need to have the same keys and the same
// values.
return a_search_params.params() == b_search_params.params();
}
// Given a BGR bitmap, converts into a RGB bitmap instead. Returns empty bitmap
// if creation fails.
SkBitmap CreateRgbBitmap(const SkBitmap& bgr_bitmap) {
// Convert bitmap from color type `kBGRA_8888_SkColorType` into a new Bitmap
// with color type `kRGBA_8888_SkColorType` which will allow the bitmap to
// render properly in the WebUI.
sk_sp<SkColorSpace> srgb_color_space =
bgr_bitmap.colorSpace()->makeSRGBGamma();
SkImageInfo rgb_info = bgr_bitmap.info()
.makeColorType(kRGBA_8888_SkColorType)
.makeColorSpace(SkColorSpace::MakeSRGB());
SkBitmap rgb_bitmap;
rgb_bitmap.setInfo(rgb_info);
rgb_bitmap.allocPixels(rgb_info);
if (rgb_bitmap.writePixels(bgr_bitmap.pixmap())) {
return rgb_bitmap;
}
// Bitmap creation failed.
return SkBitmap();
}
// Converts a JSON string array to a vector.
std::vector<std::string> JSONArrayToVector(const std::string& json_array) {
std::optional<base::Value> json_value = base::JSONReader::Read(json_array);
if (!json_value) {
return {};
}
base::Value::List* entries = json_value->GetIfList();
if (!entries) {
return {};
}
std::vector<std::string> result;
result.reserve(entries->size());
for (const base::Value& entry : *entries) {
const std::string* filter = entry.GetIfString();
if (filter) {
result.emplace_back(*filter);
}
}
return result;
}
lens::MimeType StringMimeTypeToDocumentType(const std::string& mime_type) {
if (mime_type == "application/pdf") {
return lens::MimeType::kPdf;
} else if (mime_type == "text/html") {
return lens::MimeType::kHtml;
} else if (mime_type == "text/plain") {
return lens::MimeType::kPlainText;
}
return lens::MimeType::kUnknown;
}
} // namespace
LensOverlayController::LensOverlayController(
tabs::TabInterface* tab,
variations::VariationsClient* variations_client,
signin::IdentityManager* identity_manager,
PrefService* pref_service,
syncer::SyncService* sync_service,
ThemeService* theme_service)
: tab_(tab),
variations_client_(variations_client),
identity_manager_(identity_manager),
pref_service_(pref_service),
sync_service_(sync_service),
theme_service_(theme_service),
gen204_controller_(
std::make_unique<lens::LensOverlayGen204Controller>()) {
LensOverlayControllerTabLookup::CreateForWebContents(tab_->GetContents(),
this);
tab_subscriptions_.push_back(tab_->RegisterDidActivate(base::BindRepeating(
&LensOverlayController::TabForegrounded, weak_factory_.GetWeakPtr())));
tab_subscriptions_.push_back(tab_->RegisterWillDeactivate(
base::BindRepeating(&LensOverlayController::TabWillEnterBackground,
weak_factory_.GetWeakPtr())));
tab_subscriptions_.push_back(tab_->RegisterWillDiscardContents(
base::BindRepeating(&LensOverlayController::WillDiscardContents,
weak_factory_.GetWeakPtr())));
tab_subscriptions_.push_back(tab_->RegisterWillDetach(base::BindRepeating(
&LensOverlayController::WillDetach, weak_factory_.GetWeakPtr())));
lens_overlay_event_handler_ =
std::make_unique<lens::LensOverlayEventHandler>(this);
InitializeTutorialIPHUrlMatcher();
// Listen to WebContents events
tab_contents_observer_ = std::make_unique<UnderlyingWebContentsObserver>(
tab_->GetContents(), this);
}
LensOverlayController::~LensOverlayController() {
tab_contents_observer_.reset();
tab_->GetContents()->RemoveUserData(
LensOverlayControllerTabLookup::UserDataKey());
state_ = State::kOff;
}
DEFINE_CLASS_ELEMENT_IDENTIFIER_VALUE(LensOverlayController, kOverlayId);
DEFINE_CLASS_ELEMENT_IDENTIFIER_VALUE(LensOverlayController,
kOverlaySidePanelWebViewId);
LensOverlayController::SearchQuery::SearchQuery(std::string text_query,
GURL url)
: search_query_text_(std::move(text_query)),
search_query_url_(std::move(url)) {}
LensOverlayController::SearchQuery::SearchQuery(const SearchQuery& other) {
search_query_text_ = other.search_query_text_;
if (other.selected_region_) {
selected_region_ = other.selected_region_->Clone();
}
selected_region_bitmap_ = other.selected_region_bitmap_;
selected_region_thumbnail_uri_ = other.selected_region_thumbnail_uri_;
search_query_url_ = other.search_query_url_;
selected_text_ = other.selected_text_;
lens_selection_type_ = other.lens_selection_type_;
translate_options_ = other.translate_options_;
}
LensOverlayController::SearchQuery&
LensOverlayController::SearchQuery::operator=(
const LensOverlayController::SearchQuery& other) {
search_query_text_ = other.search_query_text_;
if (other.selected_region_) {
selected_region_ = other.selected_region_->Clone();
}
selected_region_bitmap_ = other.selected_region_bitmap_;
selected_region_thumbnail_uri_ = other.selected_region_thumbnail_uri_;
search_query_url_ = other.search_query_url_;
selected_text_ = other.selected_text_;
lens_selection_type_ = other.lens_selection_type_;
translate_options_ = other.translate_options_;
return *this;
}
LensOverlayController::SearchQuery::~SearchQuery() = default;
// static.
LensOverlayController* LensOverlayController::GetController(
content::WebContents* webui_contents) {
auto* tab_interface = webui::GetTabInterface(webui_contents);
return tab_interface
? tab_interface->GetTabFeatures()->lens_overlay_controller()
: nullptr;
}
void LensOverlayController::ShowUIWithPendingRegion(
lens::LensOverlayInvocationSource invocation_source,
const gfx::Rect& tab_bounds,
const gfx::Rect& view_bounds,
const gfx::Rect& image_bounds,
const SkBitmap& region_bitmap) {
ShowUIWithPendingRegion(invocation_source,
lens::GetCenterRotatedBoxFromTabViewAndImageBounds(
tab_bounds, view_bounds, image_bounds),
region_bitmap);
}
void LensOverlayController::ShowUIWithPendingRegion(
lens::LensOverlayInvocationSource invocation_source,
lens::mojom::CenterRotatedBoxPtr region,
const SkBitmap& region_bitmap) {
pending_region_ = std::move(region);
pending_region_bitmap_ = region_bitmap;
ShowUI(invocation_source);
// Overrides value set in ShowUI since invoking lens overlay with a pending
// region is considered a search.
search_performed_in_session_ = true;
}
void LensOverlayController::ShowUI(
lens::LensOverlayInvocationSource invocation_source) {
// If UI is already showing or in the process of showing, do nothing.
if (state_ != State::kOff) {
return;
}
// The UI should only show if the tab is in the foreground or if the tab web
// contents is not in a crash state.
if (!tab_->IsActivated() || tab_->GetContents()->IsCrashed()) {
return;
}
// If a different tab-modal is showing, do nothing.
if (!tab_->CanShowModalUI()) {
return;
}
invocation_source_ = invocation_source;
// Request user permission before grabbing a screenshot.
CHECK(pref_service_);
// If contextual serachbox is enabled, show permission bubble again informing
// users of other information that will be shared. The contextual searchbox
// pref is a different pref.
if (!lens::CanSharePageScreenshotWithLensOverlay(pref_service_) ||
(lens::features::IsLensOverlayContextualSearchboxEnabled() &&
!lens::CanSharePageContentWithLensOverlay(pref_service_))) {
if (!permission_bubble_controller_) {
permission_bubble_controller_ =
std::make_unique<lens::LensPermissionBubbleController>(
tab_->GetBrowserWindowInterface(), pref_service_,
invocation_source);
}
permission_bubble_controller_->RequestPermission(
tab_->GetContents(),
base::BindRepeating(&LensOverlayController::ShowUI,
weak_factory_.GetWeakPtr(), invocation_source));
return;
}
// Increment the counter for the number of times the Lens Overlay has been
// started.
int lens_overlay_start_count =
pref_service_->GetInteger(prefs::kLensOverlayStartCount);
pref_service_->SetInteger(prefs::kLensOverlayStartCount,
lens_overlay_start_count + 1);
// Create the results side panel coordinator when showing the UI if it does
// not already exist for this tab's web contents.
if (!results_side_panel_coordinator_) {
results_side_panel_coordinator_ =
std::make_unique<lens::LensOverlaySidePanelCoordinator>(this);
}
Profile* profile =
Profile::FromBrowserContext(tab_->GetContents()->GetBrowserContext());
// Create the query controller.
lens_overlay_query_controller_ = CreateLensQueryController(
base::BindRepeating(&LensOverlayController::HandleStartQueryResponse,
weak_factory_.GetWeakPtr()),
base::BindRepeating(&LensOverlayController::HandleInteractionURLResponse,
weak_factory_.GetWeakPtr()),
base::BindRepeating(&LensOverlayController::HandleSuggestInputsResponse,
weak_factory_.GetWeakPtr()),
base::BindRepeating(&LensOverlayController::HandleThumbnailCreated,
weak_factory_.GetWeakPtr()),
variations_client_, identity_manager_, profile, invocation_source,
lens::LensOverlayShouldUseDarkMode(theme_service_),
gen204_controller_.get());
side_panel_coordinator_ =
tab_->GetBrowserWindowInterface()->GetFeatures().side_panel_coordinator();
CHECK(side_panel_coordinator_);
// Create the languages controller.
languages_controller_ =
std::make_unique<lens::LensOverlayLanguagesController>(profile);
// Setup observer to be notified of side panel opens and closes.
side_panel_shown_subscription_ =
side_panel_coordinator_->RegisterSidePanelShown(
base::BindRepeating(&LensOverlayController::OnSidePanelDidOpen,
weak_factory_.GetWeakPtr()));
if (find_in_page::FindTabHelper* const find_tab_helper =
find_in_page::FindTabHelper::FromWebContents(tab_->GetContents())) {
find_tab_observer_.Observe(find_tab_helper);
}
if (!omnibox_tab_helper_observer_.IsObserving()) {
if (auto* helper = OmniboxTabHelper::FromWebContents(tab_->GetContents())) {
omnibox_tab_helper_observer_.Observe(helper);
}
}
// This is safe because we checked if another modal was showing above.
scoped_tab_modal_ui_ = tab_->ShowModalUI();
fullscreen_observation_.Observe(tab_->GetBrowserWindowInterface()
->GetExclusiveAccessManager()
->fullscreen_controller());
NotifyUserEducationAboutOverlayUsed();
// Establish data required for session metrics.
search_performed_in_session_ = false;
invocation_time_ = base::TimeTicks::Now();
invocation_time_since_epoch_ = base::Time::Now();
hats_triggered_in_session_ = false;
// This should be the last thing called in ShowUI, so if something goes wrong
// in capturing the screenshot, the state gets cleaned up correctly.
if (side_panel_coordinator_->IsSidePanelShowing()) {
// Close the currently opened side panel synchronously. Postpone the
// screenshot for a fixed time to allow reflow.
state_ = State::kClosingOpenedSidePanel;
side_panel_coordinator_->Close(/*suppress_animations=*/true);
base::SingleThreadTaskRunner::GetCurrentDefault()
->PostNonNestableDelayedTask(
FROM_HERE,
base::BindOnce(&LensOverlayController::FinishedWaitingForReflow,
weak_factory_.GetWeakPtr()),
kReflowWaitTimeout);
} else {
CaptureScreenshot();
}
}
void LensOverlayController::CloseUIAsync(
lens::LensOverlayDismissalSource dismissal_source) {
if (state_ == State::kOff || IsOverlayClosing()) {
return;
}
// Notify the overlay so it can do any animations or cleanup. The page_ is not
// guaranteed to exist if CloseUIAsync is called during the setup process.
if (page_) {
page_->NotifyOverlayClosing();
}
if (state_ == State::kOverlayAndResults) {
if (side_panel_coordinator_->GetCurrentEntryId() ==
SidePanelEntry::Id::kLensOverlayResults) {
// If a close was triggered while our side panel is showing, instead of
// just immediately closing the overlay, we close side panel to show a
// smooth closing animation. Once the side panel deregisters, it will
// re-call our close method in OnSidePanelDidClose() which will finish the
// closing process.
state_ = State::kClosingSidePanel;
last_dismissal_source_ = dismissal_source;
side_panel_coordinator_->Close();
return;
}
}
state_ = State::kClosing;
// Set a short 200ms timeout to give the fade out time to transition.
base::SequencedTaskRunner::GetCurrentDefault()->PostDelayedTask(
FROM_HERE,
base::BindOnce(&LensOverlayController::CloseUIPart2,
weak_factory_.GetWeakPtr(), dismissal_source),
kFadeoutAnimationTimeout);
}
void LensOverlayController::CloseUISync(
lens::LensOverlayDismissalSource dismissal_source) {
if (state_ == State::kOff) {
return;
}
state_ = State::kClosing;
if (side_panel_coordinator_->GetCurrentEntryId() ==
SidePanelEntry::Id::kLensOverlayResults) {
side_panel_shown_subscription_ = base::CallbackListSubscription();
side_panel_coordinator_->Close();
}
CloseUIPart2(dismissal_source);
}
// static
const std::u16string LensOverlayController::GetFilenameForURL(const GURL& url) {
if (!url.has_host() || url.HostIsIPAddress()) {
return u"screenshot.png";
}
return base::ASCIIToUTF16(base::StrCat({"screenshot_", url.host(), ".png"}));
}
void LensOverlayController::BindOverlay(
mojo::PendingReceiver<lens::mojom::LensPageHandler> receiver,
mojo::PendingRemote<lens::mojom::LensPage> page) {
if (state_ != State::kStartingWebUI) {
return;
}
receiver_.Bind(std::move(receiver));
page_.Bind(std::move(page));
InitializeOverlay(/*initialization_data=*/nullptr);
}
void LensOverlayController::BindOverlayGhostLoader(
mojo::PendingRemote<lens::mojom::LensGhostLoaderPage> page) {
overlay_ghost_loader_page_.reset();
overlay_ghost_loader_page_.Bind(std::move(page));
}
void LensOverlayController::BindSidePanel(
mojo::PendingReceiver<lens::mojom::LensSidePanelPageHandler> receiver,
mojo::PendingRemote<lens::mojom::LensSidePanelPage> page) {
// If a side panel was already bound to this overlay controller, then we
// should reset. This can occur if the side panel is closed and then reopened
// while the overlay is open.
side_panel_receiver_.reset();
side_panel_page_.reset();
side_panel_receiver_.Bind(std::move(receiver));
side_panel_page_.Bind(std::move(page));
if (pending_side_panel_url_.has_value()) {
side_panel_page_->LoadResultsInFrame(*pending_side_panel_url_);
pending_side_panel_url_.reset();
}
// Only record and show the side panel error state if the side panel was set
// to do so. Otherwise, do nothing as this metric will be recorded when the
// first side panel navigation completes.
if (side_panel_should_show_error_page_) {
RecordAndShowSidePanelErrorPage();
}
}
void LensOverlayController::BindSidePanelGhostLoader(
mojo::PendingRemote<lens::mojom::LensGhostLoaderPage> page) {
side_panel_ghost_loader_page_.reset();
side_panel_ghost_loader_page_.Bind(std::move(page));
}
void LensOverlayController::SetSidePanelSearchboxHandler(
std::unique_ptr<RealboxHandler> handler) {
side_panel_searchbox_handler_ = std::move(handler);
}
void LensOverlayController::SetContextualSearchboxHandler(
std::unique_ptr<RealboxHandler> handler) {
overlay_searchbox_handler_ = std::move(handler);
}
void LensOverlayController::ResetSidePanelSearchboxHandler() {
side_panel_searchbox_handler_.reset();
}
uint64_t LensOverlayController::GetInvocationTimeSinceEpoch() {
return invocation_time_since_epoch_.InMillisecondsSinceUnixEpoch();
}
views::View* LensOverlayController::GetOverlayViewForTesting() {
return overlay_view_.get();
}
views::WebView* LensOverlayController::GetOverlayWebViewForTesting() {
return overlay_web_view_.get();
}
void LensOverlayController::SendText(lens::mojom::TextPtr text) {
if (!page_) {
// Store the text to send once the page is bound.
pre_initialization_text_ = std::move(text);
return;
}
page_->TextReceived(std::move(text));
}
lens::mojom::OverlayThemePtr LensOverlayController::CreateTheme(
lens::PaletteId palette_id) {
CHECK(base::Contains(lens::kPaletteColors, palette_id));
const auto& palette = lens::kPaletteColors.at(palette_id);
auto theme = lens::mojom::OverlayTheme::New();
theme->primary = palette.at(lens::ColorId::kPrimary);
theme->shader_layer_1 = palette.at(lens::ColorId::kShaderLayer1);
theme->shader_layer_2 = palette.at(lens::ColorId::kShaderLayer2);
theme->shader_layer_3 = palette.at(lens::ColorId::kShaderLayer3);
theme->shader_layer_4 = palette.at(lens::ColorId::kShaderLayer4);
theme->shader_layer_5 = palette.at(lens::ColorId::kShaderLayer5);
theme->scrim = palette.at(lens::ColorId::kScrim);
theme->surface_container_highest_light =
palette.at(lens::ColorId::kSurfaceContainerHighestLight);
theme->surface_container_highest_dark =
palette.at(lens::ColorId::kSurfaceContainerHighestDark);
theme->selection_element = palette.at(lens::ColorId::kSelectionElement);
return theme;
}
void LensOverlayController::SendObjects(
std::vector<lens::mojom::OverlayObjectPtr> objects) {
if (!page_) {
// Store the objects to send once the page is bound.
pre_initialization_objects_ = std::move(objects);
return;
}
page_->ObjectsReceived(std::move(objects));
}
void LensOverlayController::NotifyResultsPanelOpened() {
page_->NotifyResultsPanelOpened();
}
void LensOverlayController::TriggerCopyText() {
// This prevents a race condition where the overlay is closed as a keyboard
// event is being processed.
if (!page_) {
return;
}
page_->TriggerCopyText();
}
bool LensOverlayController::IsOverlayShowing() {
return state_ == State::kStartingWebUI || state_ == State::kOverlay ||
state_ == State::kOverlayAndResults ||
state_ == State::kClosingSidePanel;
}
bool LensOverlayController::IsOverlayActive() {
return IsOverlayShowing() || state_ == State::kLivePageAndResults;
}
bool LensOverlayController::IsOverlayClosing() {
return state_ == State::kClosing || state_ == State::kClosingSidePanel;
}
bool LensOverlayController::IsContextualSearchbox() {
return GetPageClassification() ==
metrics::OmniboxEventProto::CONTEXTUAL_SEARCHBOX;
}
void LensOverlayController::LoadURLInResultsFrame(const GURL& url) {
if (!IsOverlayShowing() && state() != State::kLivePageAndResults) {
return;
}
if (side_panel_page_) {
side_panel_page_->LoadResultsInFrame(url);
return;
}
pending_side_panel_url_ = std::make_optional<GURL>(url);
results_side_panel_coordinator_->RegisterEntryAndShow();
}
void LensOverlayController::SetSearchboxInputText(const std::string& text) {
if (side_panel_searchbox_handler_ &&
side_panel_searchbox_handler_->IsRemoteBound()) {
side_panel_searchbox_handler_->SetInputText(text);
} else {
// If the side panel was not bound at the time of request, we store the
// query as pending to send it to the searchbox on bind.
pending_text_query_ = text;
}
}
void LensOverlayController::AddQueryToHistory(std::string query,
GURL search_url) {
CHECK(initialization_data_);
// If we are loading the query that was just popped, do not add it to the
// stack.
auto loaded_search_query =
initialization_data_->currently_loaded_search_query_;
if (loaded_search_query &&
AreSearchUrlsEquivalent(loaded_search_query->search_query_url_,
search_url)) {
return;
}
// A search URL without a Lens mode parameter indicates a click on a related
// search or other in-SRP refinement. In this case, we should clear all
// selection and thumbnail state.
const std::string lens_mode = lens::GetLensModeParameterValue(search_url);
if (lens_mode.empty()) {
initialization_data_->selected_region_.reset();
initialization_data_->selected_region_bitmap_.reset();
initialization_data_->selected_text_.reset();
initialization_data_->additional_search_query_params_.clear();
selected_region_thumbnail_uri_.clear();
// The selection type is the searchbox input type for contextual queries.
if (!IsContextualSearchbox()) {
lens_selection_type_ = lens::UNKNOWN_SELECTION_TYPE;
}
page_->ClearAllSelections();
SetSearchboxThumbnail(std::string());
}
// In the case where a query was triggered by a selection on the overlay or
// use of the searchbox, initialization_data_, additional_search_query_params_
// and selected_region_thumbnail_uri_ will have already been set. Record
// that state in a search query struct.
SearchQuery search_query(query, search_url);
if (initialization_data_->selected_region_) {
search_query.selected_region_ =
initialization_data_->selected_region_->Clone();
}
if (!initialization_data_->selected_region_bitmap_.drawsNothing()) {
search_query.selected_region_bitmap_ =
initialization_data_->selected_region_bitmap_;
}
search_query.selected_region_thumbnail_uri_ = selected_region_thumbnail_uri_;
if (initialization_data_->selected_text_.has_value()) {
search_query.selected_text_ = initialization_data_->selected_text_.value();
}
if (initialization_data_->translate_options_.has_value()) {
search_query.translate_options_ =
initialization_data_->translate_options_.value();
}
search_query.lens_selection_type_ = lens_selection_type_;
search_query.additional_search_query_params_ =
initialization_data_->additional_search_query_params_;
// Add what was the currently loaded search query to the query stack,
// if it is present.
if (loaded_search_query) {
initialization_data_->search_query_history_stack_.push_back(
loaded_search_query.value());
side_panel_page_->SetBackArrowVisible(true);
}
// Set the currently loaded search query to the one we just created.
initialization_data_->currently_loaded_search_query_.reset();
initialization_data_->currently_loaded_search_query_ = search_query;
// Update searchbox and selection state to match the new query.
SetSearchboxInputText(query);
}
void LensOverlayController::PopAndLoadQueryFromHistory() {
if (initialization_data_->search_query_history_stack_.empty()) {
return;
}
// Get the query that we want to load in the results frame and then pop it
// from the list.
auto query = initialization_data_->search_query_history_stack_.back();
initialization_data_->search_query_history_stack_.pop_back();
if (initialization_data_->search_query_history_stack_.empty()) {
side_panel_page_->SetBackArrowVisible(false);
}
if (query.translate_options_.has_value()) {
page_->SetTranslateMode(query.translate_options_->source_language,
query.translate_options_->target_language);
initialization_data_->translate_options_ = query.translate_options_.value();
} else {
// If we were previously in translate mode, we need to send a request to end
// translate mode.
if (initialization_data_->currently_loaded_search_query_->translate_options_
.has_value()) {
IssueEndTranslateModeRequest();
SetSidePanelIsLoadingResults(true);
}
// Disable translate mode by setting source and target languages to empty
// strings. This is a no-op if translate mode is already disabled.
page_->SetTranslateMode(std::string(), std::string());
}
// Clear any active selections on the page and then re-add selections for this
// query and update the selection, thumbnail and searchbox state.
CHECK(page_);
page_->ClearAllSelections();
// We do not want to reset text selections for translated text since it may
// not be on the screen until we resend the full image request.
if (query.selected_text_.has_value() &&
!query.translate_options_.has_value()) {
page_->SetTextSelection(query.selected_text_->first,
query.selected_text_->second);
initialization_data_->selected_text_ = query.selected_text_.value();
} else if (query.selected_region_) {
page_->SetPostRegionSelection(query.selected_region_->Clone());
initialization_data_->selected_region_ = query.selected_region_->Clone();
selected_region_thumbnail_uri_ = query.selected_region_thumbnail_uri_;
}
initialization_data_->additional_search_query_params_ =
query.additional_search_query_params_;
SetSearchboxInputText(query.search_query_text_);
SetSearchboxThumbnail(query.selected_region_thumbnail_uri_);
const bool is_contextual_query =
GetPageClassification() ==
metrics::OmniboxEventProto::CONTEXTUAL_SEARCHBOX;
const bool query_has_image =
query.selected_region_ || !query.selected_region_bitmap_.drawsNothing();
const bool should_send_interaction = query_has_image || is_contextual_query;
if (should_send_interaction) {
// If the current query has a region or image bytes, we need to send a new
// interaction request in order to to keep our request IDs in sync with the
// server. If not, we will receive broken results. Because of this, we also
// want to modify the currently loaded search query so that we don't get
// duplicates added to the query history stack.
initialization_data_->currently_loaded_search_query_.reset();
if (!initialization_data_->search_query_history_stack_.empty()) {
auto previous_query =
initialization_data_->search_query_history_stack_.back();
initialization_data_->search_query_history_stack_.pop_back();
initialization_data_->currently_loaded_search_query_ = previous_query;
}
}
if (query_has_image) {
std::optional<SkBitmap> selected_region_bitmap =
query.selected_region_bitmap_.drawsNothing()
? std::nullopt
: std::make_optional<SkBitmap>(query.selected_region_bitmap_);
// If the query also has text, we should send it as a multimodal query.
if (query.search_query_text_.empty()) {
DoLensRequest(query.selected_region_->Clone(), query.lens_selection_type_,
selected_region_bitmap);
} else {
lens_overlay_query_controller_->SendMultimodalRequest(
initialization_data_->selected_region_.Clone(),
query.search_query_text_, query.lens_selection_type_,
initialization_data_->additional_search_query_params_,
selected_region_bitmap);
}
return;
}
// The query is text only. If we are in the contextual flow, resend the
// contextual query.
if (is_contextual_query) {
lens_overlay_query_controller_->SendContextualTextQuery(
query.search_query_text_, query.lens_selection_type_,
initialization_data_->additional_search_query_params_);
return;
}
// Load the popped query URL in the results frame if it does not need to
// send image bytes.
LoadURLInResultsFrame(query.search_query_url_);
// Set the currently loaded query to the one we just popped.
initialization_data_->currently_loaded_search_query_.reset();
initialization_data_->currently_loaded_search_query_ = query;
}
void LensOverlayController::GetIsContextualSearchbox(
GetIsContextualSearchboxCallback callback) {
std::move(callback).Run(IsContextualSearchbox());
}
void LensOverlayController::SetSidePanelIsLoadingResults(bool is_loading) {
if (side_panel_page_) {
side_panel_page_->SetIsLoadingResults(is_loading);
}
}
void LensOverlayController::MaybeSetSidePanelShowErrorPage(
bool should_show_error_page,
lens::SidePanelResultStatus status) {
// Only show / hide the error page if the side panel is not already in that
// state. Return early if the state should not change unless the initial load
// has not been logged (`side_panel_result_status_` set to kUnknown).
if (side_panel_should_show_error_page_ == should_show_error_page &&
side_panel_result_status_ != lens::SidePanelResultStatus::kUnknown) {
return;
}
side_panel_should_show_error_page_ = should_show_error_page;
side_panel_result_status_ = status;
if (side_panel_page_) {
RecordAndShowSidePanelErrorPage();
}
}
void LensOverlayController::SetSidePanelIsOffline(bool is_offline) {
// If the side panel is already showing an error page due to start query
// error, then this should be a no-op.
if (side_panel_result_status_ ==
lens::SidePanelResultStatus::kErrorPageShownStartQueryError) {
return;
}
MaybeSetSidePanelShowErrorPage(
is_offline, is_offline
? lens::SidePanelResultStatus::kErrorPageShownOffline
: lens::SidePanelResultStatus::kResultShown);
}
void LensOverlayController::RecordAndShowSidePanelErrorPage() {
CHECK(side_panel_page_);
side_panel_page_->SetShowErrorPage(side_panel_should_show_error_page_);
lens::RecordSidePanelResultStatus(side_panel_result_status_);
}
bool LensOverlayController::IsScreenshotPossible(
content::RenderWidgetHostView* view) {
return view && view->IsSurfaceAvailableForCopy();
}
void LensOverlayController::OnSidePanelWillHide(
SidePanelEntryHideReason reason) {
// If the tab is not in the foreground, this is not relevant.
if (!tab_->IsActivated()) {
return;
}
if (!IsOverlayClosing()) {
if (reason == SidePanelEntryHideReason::kReplaced) {
// If the Lens side panel is being replaced, don't close the side panel.
// Instead, set the state and dismissal source and wait for
// OnSidePanelHidden to be called.
state_ = State::kClosingSidePanel;
last_dismissal_source_ =
lens::LensOverlayDismissalSource::kSidePanelEntryReplaced;
} else {
// Trigger the close animation and notify the overlay that the side
// panel is closing so that it can fade out the UI.
CloseUIAsync(lens::LensOverlayDismissalSource::kSidePanelCloseButton);
}
}
}
void LensOverlayController::OnSidePanelHidden() {
if (state_ != State::kClosingSidePanel) {
return;
}
CHECK(last_dismissal_source_.has_value());
CloseUIPart2(*last_dismissal_source_);
last_dismissal_source_.reset();
}
tabs::TabInterface* LensOverlayController::GetTabInterface() {
return tab_;
}
void LensOverlayController::IssueLensRegionRequestForTesting(
lens::mojom::CenterRotatedBoxPtr region,
bool is_click) {
IssueLensRegionRequest(std::move(region), is_click);
}
void LensOverlayController::IssueTextSelectionRequestForTesting(
const std::string& text_query,
int selection_start_index,
int selection_end_index,
bool is_translate) {
IssueTextSelectionRequest(text_query, selection_start_index,
selection_end_index, is_translate);
}
void LensOverlayController::
RecordUkmAndTaskCompletionForLensOverlayInteractionForTesting(
lens::mojom::UserAction user_action) {
RecordUkmAndTaskCompletionForLensOverlayInteraction(user_action);
}
void LensOverlayController::IssueSearchBoxRequestForTesting(
const std::string& search_box_text,
AutocompleteMatchType::Type match_type,
bool is_zero_prefix_suggestion,
std::map<std::string, std::string> additional_query_params) {
IssueSearchBoxRequest(search_box_text, match_type, is_zero_prefix_suggestion,
additional_query_params);
}
void LensOverlayController::IssueTranslateSelectionRequestForTesting(
const std::string& text_query,
const std::string& content_language,
int selection_start_index,
int selection_end_index) {
IssueTranslateSelectionRequest(text_query, content_language,
selection_start_index, selection_end_index);
}
void LensOverlayController::IssueMathSelectionRequestForTesting(
const std::string& query,
const std::string& formula,
int selection_start_index,
int selection_end_index) {
IssueMathSelectionRequest(query, formula, selection_start_index,
selection_end_index);
}
void LensOverlayController::IssueTranslateFullPageRequestForTesting(
const std::string& source_language,
const std::string& target_language) {
IssueTranslateFullPageRequest(source_language, target_language);
}
void LensOverlayController::IssueEndTranslateModeRequestForTesting() {
IssueEndTranslateModeRequest();
}
void LensOverlayController::IssueTranslateFullPageRequest(
const std::string& source_language,
const std::string& target_language) {
// Remove the selection thumbnail, if it exists.
SetSearchboxThumbnail(std::string());
ClearRegionSelection();
// Set the coachmark text.
if (preselection_widget_) {
// This cast is safe since we know the widget delegate will always be a
// `lens::LensPreselectionBubble`.
auto* bubble_view = static_cast<lens::LensPreselectionBubble*>(
preselection_widget_->widget_delegate());
bubble_view->SetLabelText(
IDS_LENS_OVERLAY_INITIAL_TOAST_MESSAGE_SELECT_TEXT);
}
// Set the translate options on initialization data in case we need to
// re-enable translate mode later.
initialization_data_->translate_options_ =
TranslateOptions(source_language, target_language);
lens_overlay_query_controller_->SendFullPageTranslateQuery(source_language,
target_language);
MaybeLaunchSurvey();
}
void LensOverlayController::IssueEndTranslateModeRequest() {
// Reset the coachmark text back to default.
if (preselection_widget_) {
// This cast is safe since we know the widget delegate will always be a
// `lens::LensPreselectionBubble`.
auto* bubble_view = static_cast<lens::LensPreselectionBubble*>(
preselection_widget_->widget_delegate());
bubble_view->SetLabelText(IDS_LENS_OVERLAY_INITIAL_TOAST_MESSAGE);
}
lens_selection_type_ = lens::UNKNOWN_SELECTION_TYPE;
initialization_data_->selected_text_.reset();
initialization_data_->translate_options_.reset();
lens_overlay_query_controller_->SendEndTranslateModeQuery();
}
void LensOverlayController::NotifyOverlayInitialized() {
// Now that the overlay is actually showing, it is safe to start doing a Lens
// request without showing the page reflowing.
if (pending_region_) {
// If there is a pending region (i.e. for image right click)
// use INJECTED_IMAGE as the selection type.
DoLensRequest(std::move(pending_region_), lens::INJECTED_IMAGE,
pending_region_bitmap_);
pending_region_bitmap_.reset();
}
}
void LensOverlayController::CopyText(const std::string& text) {
ui::ScopedClipboardWriter clipboard_writer(ui::ClipboardBuffer::kCopyPaste);
clipboard_writer.WriteText(base::UTF8ToUTF16(text));
}
void LensOverlayController::CopyImage(lens::mojom::CenterRotatedBoxPtr region) {
SkBitmap cropped = lens::CropBitmapToRegion(
initialization_data_->current_screenshot_, std::move(region));
ui::ScopedClipboardWriter clipboard_writer(ui::ClipboardBuffer::kCopyPaste);
clipboard_writer.WriteImage(cropped);
}
void LensOverlayController::RecordUkmAndTaskCompletionForLensOverlayInteraction(
lens::mojom::UserAction user_action) {
ukm::SourceId source_id =
tab_->GetContents()->GetPrimaryMainFrame()->GetPageUkmSourceId();
ukm::builders::Lens_Overlay_Overlay_UserAction(source_id)
.SetUserAction(static_cast<int64_t>(user_action))
.Record(ukm::UkmRecorder::Get());
lens_overlay_query_controller_->SendTaskCompletionGen204IfEnabled(
user_action);
}
void LensOverlayController::RecordLensOverlaySemanticEvent(
lens::mojom::SemanticEvent event) {
lens_overlay_query_controller_->SendSemanticEventGen204IfEnabled(event);
}
void LensOverlayController::SaveAsImage(
lens::mojom::CenterRotatedBoxPtr region) {
SkBitmap cropped = lens::CropBitmapToRegion(
initialization_data_->current_screenshot_, std::move(region));
const GURL data_url = GURL(webui::GetBitmapDataUrl(cropped));
content::DownloadManager* download_manager =
tab_->GetBrowserWindowInterface()->GetProfile()->GetDownloadManager();
net::NetworkTrafficAnnotationTag traffic_annotation =
net::DefineNetworkTrafficAnnotation("lens_overlay_save", R"(
semantics {
sender: "Lens Overlay"
description:
"The user may capture a selection of the current screenshot in the "
"Lens overlay via a button in the overlay. The resulting image is "
"saved from a data URL to the disk on the local client."
trigger: "User clicks 'Save as image' in the Lens Overlay after "
"activating the Lens Overlay and making a selection on the "
"screenshot."
data: "A capture of a portion of a screenshot of the current page."
destination: LOCAL
last_reviewed: "2024-08-23"
user_data {
type: WEB_CONTENT
}
internal {
contacts {
owners: "//chrome/browser/ui/lens/OWNERS"
}
}
}
policy {
cookies_allowed: NO
setting:
"No user-visible setting for this feature. Configured via Finch."
policy_exception_justification:
"This is not a network request."
})");
std::unique_ptr<download::DownloadUrlParameters> params =
content::DownloadRequestUtils::CreateDownloadForWebContentsMainFrame(
overlay_web_view_->GetWebContents(), data_url, traffic_annotation);
params->set_prompt(true);
params->set_suggested_name(
GetFilenameForURL(tab_->GetContents()->GetLastCommittedURL()));
download_manager->DownloadUrl(std::move(params));
}
void LensOverlayController::MaybeShowTranslateFeaturePromo() {
auto* tracker = ui::ElementTracker::GetElementTracker();
translate_button_shown_subscription_ =
tracker->AddElementShownInAnyContextCallback(
kLensOverlayTranslateButtonElementId,
base::BindRepeating(
&LensOverlayController::TryShowTranslateFeaturePromo,
weak_factory_.GetWeakPtr()));
}
void LensOverlayController::MaybeCloseTranslateFeaturePromo(
bool feature_engaged) {
if (auto* const interface =
BrowserUserEducationInterface::MaybeGetForWebContentsInTab(
tab_->GetContents())) {
if (!interface->IsFeaturePromoActive(
feature_engagement::kIPHLensOverlayTranslateButtonFeature)) {
// Do nothing if feature promo is not active.
return;
}
if (feature_engaged) {
interface->NotifyFeaturePromoFeatureUsed(
feature_engagement::kIPHLensOverlayTranslateButtonFeature,
FeaturePromoFeatureUsedAction::kClosePromoIfPresent);
} else {
interface->AbortFeaturePromo(
feature_engagement::kIPHLensOverlayTranslateButtonFeature);
}
}
}
void LensOverlayController::FetchSupportedLanguages(
FetchSupportedLanguagesCallback callback) {
CHECK(languages_controller_);
languages_controller_->SendGetSupportedLanguagesRequest(std::move(callback));
}
void LensOverlayController::TryShowTranslateFeaturePromo(
ui::TrackedElement* element) {
if (!element) {
return;
}
if (auto* const interface =
BrowserUserEducationInterface::MaybeGetForWebContentsInTab(
tab_->GetContents())) {
interface->MaybeShowFeaturePromo(
feature_engagement::kIPHLensOverlayTranslateButtonFeature);
}
}
std::string LensOverlayController::GetInvocationSourceString() {
return lens::InvocationSourceToString(invocation_source_);
}
content::WebContents*
LensOverlayController::GetSidePanelWebContentsForTesting() {
if (!results_side_panel_coordinator_) {
return nullptr;
}
return results_side_panel_coordinator_->GetSidePanelWebContents();
}
const GURL& LensOverlayController::GetPageURLForTesting() {
return GetPageURL();
}
SessionID LensOverlayController::GetTabIdForTesting() {
return GetTabId();
}
metrics::OmniboxEventProto::PageClassification
LensOverlayController::GetPageClassificationForTesting() {
return GetPageClassification();
}
const std::string& LensOverlayController::GetThumbnailForTesting() {
return GetThumbnail();
}
void LensOverlayController::OnTextModifiedForTesting() {
OnTextModified();
}
void LensOverlayController::OnThumbnailRemovedForTesting() {
OnThumbnailRemoved();
}
void LensOverlayController::OnFocusChangedForTesting(bool focused) {
OnFocusChanged(focused);
}
void LensOverlayController::OnZeroSuggestShownForTesting() {
OnZeroSuggestShown();
}
const lens::proto::LensOverlaySuggestInputs&
LensOverlayController::GetLensSuggestInputsForTesting() {
return GetLensSuggestInputs();
}
bool LensOverlayController::IsUrlEligibleForTutorialIPHForTesting(
const GURL& url) {
return IsUrlEligibleForTutorialIPH(url);
}
std::unique_ptr<lens::LensOverlayQueryController>
LensOverlayController::CreateLensQueryController(
lens::LensOverlayFullImageResponseCallback full_image_callback,
lens::LensOverlayUrlResponseCallback url_callback,
lens::LensOverlaySuggestInputsCallback suggest_inputs_callback,
lens::LensOverlayThumbnailCreatedCallback thumbnail_created_callback,
variations::VariationsClient* variations_client,
signin::IdentityManager* identity_manager,
Profile* profile,
lens::LensOverlayInvocationSource invocation_source,
bool use_dark_mode,
lens::LensOverlayGen204Controller* gen204_controller) {
return std::make_unique<lens::LensOverlayQueryController>(
std::move(full_image_callback), std::move(url_callback),
std::move(suggest_inputs_callback), std::move(thumbnail_created_callback),
variations_client, identity_manager, profile, invocation_source,
use_dark_mode, gen204_controller);
}
LensOverlayController::OverlayInitializationData::OverlayInitializationData(
const SkBitmap& screenshot,
SkBitmap rgb_screenshot,
lens::PaletteId color_palette,
GURL page_url,
std::optional<std::string> page_title)
: current_screenshot_(screenshot),
current_rgb_screenshot_(std::move(rgb_screenshot)),
color_palette_(color_palette),
page_url_(page_url),
page_title_(page_title) {}
LensOverlayController::OverlayInitializationData::~OverlayInitializationData() =
default;
class LensOverlayController::UnderlyingWebContentsObserver
: public content::WebContentsObserver {
public:
UnderlyingWebContentsObserver(content::WebContents* web_contents,
LensOverlayController* lens_overlay_controller)
: content::WebContentsObserver(web_contents),
lens_overlay_controller_(lens_overlay_controller) {}
~UnderlyingWebContentsObserver() override = default;
UnderlyingWebContentsObserver(const UnderlyingWebContentsObserver&) = delete;
UnderlyingWebContentsObserver& operator=(
const UnderlyingWebContentsObserver&) = delete;
// content::WebContentsObserver
void DidFinishNavigation(
content::NavigationHandle* navigation_handle) override {
// If the overlay is off, check if we should display IPH.
if (lens_overlay_controller_->state() == State::kOff) {
// Only check IPH eligibility if the navigation changed the primary page.
if (base::FeatureList::IsEnabled(
feature_engagement::kIPHLensOverlayFeature) &&
navigation_handle->IsInPrimaryMainFrame() &&
!navigation_handle->IsSameDocument() &&
navigation_handle->HasCommitted()) {
lens_overlay_controller_->MaybeShowDelayedTutorialIPH(
navigation_handle->GetURL());
}
return;
}
// If the overlay is open, check if we should close it.
bool is_user_reload =
navigation_handle->GetReloadType() != content::ReloadType::NONE &&
!navigation_handle->IsRendererInitiated();
// We don't need to close if:
// 1) The navigation is not for the main page.
// 2) The navigation hasn't been committed yet.
// 3) The URL did not change and the navigation wasn't the user reloading
// the page.
if (!navigation_handle->IsInPrimaryMainFrame() ||
!navigation_handle->HasCommitted() ||
(navigation_handle->GetPreviousPrimaryMainFrameURL() ==
navigation_handle->GetURL() &&
!is_user_reload)) {
return;
}
if (lens_overlay_controller_->state() == State::kLivePageAndResults) {
lens_overlay_controller_->UpdateNavigationTime();
return;
}
lens_overlay_controller_->CloseUISync(
lens::LensOverlayDismissalSource::kPageChanged);
}
void PrimaryMainFrameRenderProcessGone(
base::TerminationStatus status) override {
// Exit early if the overlay is off or already closing.
if (lens_overlay_controller_->state() == State::kOff ||
lens_overlay_controller_->IsOverlayClosing()) {
return;
}
lens_overlay_controller_->CloseUISync(
status == base::TERMINATION_STATUS_NORMAL_TERMINATION
? lens::LensOverlayDismissalSource::kPageRendererClosedNormally
: lens::LensOverlayDismissalSource::
kPageRendererClosedUnexpectedly);
}
private:
raw_ptr<LensOverlayController> lens_overlay_controller_;
};
void LensOverlayController::CaptureScreenshot() {
state_ = State::kScreenshot;
// Begin the process of grabbing a screenshot.
content::RenderWidgetHostView* view = tab_->GetContents()
->GetPrimaryMainFrame()
->GetRenderViewHost()
->GetWidget()
->GetView();
// During initialization and shutdown a capture may not be possible.
if (!IsScreenshotPossible(view)) {
CloseUISync(
lens::LensOverlayDismissalSource::kErrorScreenshotCreationFailed);
return;
}
// Side panel is now full closed, take screenshot and open overlay.
view->CopyFromSurface(
/*src_rect=*/gfx::Rect(), /*output_size=*/gfx::Size(),
base::BindPostTask(
base::SequencedTaskRunner::GetCurrentDefault(),
base::BindOnce(
&LensOverlayController::FetchViewportImageBoundingBoxes,
weak_factory_.GetWeakPtr())));
}
void LensOverlayController::FetchViewportImageBoundingBoxes(
const SkBitmap& bitmap) {
content::RenderFrameHost* render_frame_host =
tab_->GetContents()->GetPrimaryMainFrame();
mojo::AssociatedRemote<chrome::mojom::ChromeRenderFrame> chrome_render_frame;
render_frame_host->GetRemoteAssociatedInterfaces()->GetInterface(
&chrome_render_frame);
// Bind the InterfacePtr into the callback so that it's kept alive until
// there's either a connection error or a response.
auto* frame = chrome_render_frame.get();
frame->RequestBoundsHintForAllImages(base::BindOnce(
&LensOverlayController::DidCaptureScreenshot, weak_factory_.GetWeakPtr(),
std::move(chrome_render_frame), ++screenshot_attempt_id_, bitmap));
}
void LensOverlayController::DidCaptureScreenshot(
mojo::AssociatedRemote<chrome::mojom::ChromeRenderFrame>
chrome_render_frame,
int attempt_id,
const SkBitmap& bitmap,
const std::vector<gfx::Rect>& all_bounds) {
// While capturing a screenshot the overlay was cancelled. Do nothing.
if (state_ == State::kOff || IsOverlayClosing()) {
return;
}
// An id mismatch implies this is not the most recent screenshot attempt.
if (screenshot_attempt_id_ != attempt_id) {
return;
}
// The documentation for CopyFromSurface claims that the copy can fail, but
// without providing information about how this can happen.
// Supposedly IsSurfaceAvailableForCopy() should guard against this case, but
// this is a multi-process, multi-threaded environment so there may be a
// TOCTTOU race condition.
if (bitmap.drawsNothing()) {
CloseUISync(
lens::LensOverlayDismissalSource::kErrorScreenshotCreationFailed);
return;
}
if (lens::features::IsLensOverlayEarlyStartQueryFlowOptimizationEnabled()) {
// Start the query as soon as the image is ready since it is the only
// critical asynchronous flow. This optimization parallelizes the query flow
// with other async startup processes.
lens_overlay_query_controller_->StartQueryFlow(
bitmap, GetPageURL(), GetPageTitle(),
ConvertSignificantRegionBoxes(all_bounds), std::vector<uint8_t>(),
lens::MimeType::kUnknown, GetUiScaleFactor(), invocation_time_);
}
// The following two methods happen async to parallelize the two bottlenecks
// in our invocation flow.
CreateInitializationData(bitmap, all_bounds);
ShowOverlay();
state_ = State::kStartingWebUI;
}
void LensOverlayController::CreateInitializationData(
const SkBitmap& screenshot,
const std::vector<gfx::Rect>& all_bounds) {
// Create the new RGB bitmap async to prevent the main thread from blocking on
// the encoding.
base::ThreadPool::PostTaskAndReplyWithResult(
FROM_HERE, {base::TaskPriority::USER_BLOCKING},
base::BindOnce(&CreateRgbBitmap, screenshot),
base::BindOnce(&LensOverlayController::ContinueCreateInitializationData,
weak_factory_.GetWeakPtr(), screenshot, all_bounds));
}
void LensOverlayController::ContinueCreateInitializationData(
const SkBitmap& screenshot,
const std::vector<gfx::Rect>& all_bounds,
SkBitmap rgb_screenshot) {
if (state_ != State::kStartingWebUI || rgb_screenshot.drawsNothing()) {
// TODO(b/334185985): Handle case when screenshot RGB encoding fails.
CloseUISync(
lens::LensOverlayDismissalSource::kErrorScreenshotEncodingFailed);
return;
}
// Resolve the color palette based on the vibrant screenshot color.
lens::PaletteId color_palette = lens::PaletteId::kFallback;
if (lens::features::IsDynamicThemeDetectionEnabled()) {
std::vector<SkColor> colors;
for (const auto& pair : lens::kPalettes) {
colors.emplace_back(pair.first);
}
SkColor screenshot_color = lens::ExtractVibrantOrDominantColorFromImage(
screenshot, lens::features::DynamicThemeMinPopulationPct());
SkColor theme_color = lens::FindBestMatchedColorOrTransparent(
colors, screenshot_color, lens::features::DynamicThemeMinChroma());
if (theme_color != SK_ColorTRANSPARENT) {
color_palette = lens::kPalettes.at(theme_color);
}
}
auto initialization_data = std::make_unique<OverlayInitializationData>(
screenshot, std::move(rgb_screenshot), color_palette, GetPageURL(),
GetPageTitle());
initialization_data->significant_region_boxes_ =
ConvertSignificantRegionBoxes(all_bounds);
GetPageContextualization(base::BindOnce(
&LensOverlayController::StorePageContentAndContinueInitialization,
weak_factory_.GetWeakPtr(), std::move(initialization_data)));
}
void LensOverlayController::StorePageContentAndContinueInitialization(
std::unique_ptr<OverlayInitializationData> initialization_data,
std::vector<uint8_t> bytes,
lens::MimeType content_type,
std::optional<uint32_t> page_count) {
initialization_data->page_content_bytes_ = bytes;
initialization_data->page_content_type_ = content_type;
initialization_data->pdf_page_count_ = page_count;
InitializeOverlay(std::move(initialization_data));
RecordDocumentMetrics(page_count);
}
void LensOverlayController::GetPageContextualization(
PageContentRetrievedCallback callback) {
// If the contextual searchbox is disabled, exit early.
if (!lens::features::IsLensOverlayContextualSearchboxEnabled()) {
std::move(callback).Run(std::vector<uint8_t>(), lens::MimeType::kUnknown,
std::nullopt);
return;
}
#if BUILDFLAG(ENABLE_PDF)
// Try and fetch the PDF bytes if enabled.
pdf::PDFDocumentHelper* pdf_helper =
lens::features::UsePdfsAsContext()
? pdf::PDFDocumentHelper::MaybeGetForWebContents(tab_->GetContents())
: nullptr;
if (pdf_helper) {
// Fetch the PDF bytes then initialize the overlay.
pdf_helper->GetPdfBytes(
/*size_limit=*/lens::features::GetLensOverlayFileUploadLimitBytes(),
base::BindOnce(&LensOverlayController::OnPdfBytesReceived,
weak_factory_.GetWeakPtr(), std::move(callback)));
return;
}
#endif // BUILDFLAG(ENABLE_PDF)
// Try and fetch the innerText if enabled.
auto* render_frame_host = tab_->GetContents()->GetPrimaryMainFrame();
if (lens::features::UseInnerTextAsContext() && render_frame_host) {
content_extraction::GetInnerText(
*render_frame_host, /*node_id=*/std::nullopt,
base::BindOnce(&LensOverlayController::OnInnerTextReceived,
weak_factory_.GetWeakPtr(), std::move(callback)));
return;
}
// Try and fetch the innerHTML if enabled.
if (lens::features::UseInnerHtmlAsContext() && render_frame_host) {
content_extraction::GetInnerHtml(
*render_frame_host,
base::BindOnce(&LensOverlayController::OnInnerHtmlReceived,
weak_factory_.GetWeakPtr(), std::move(callback)));
return;
}
std::move(callback).Run(std::vector<uint8_t>(), lens::MimeType::kUnknown,
std::nullopt);
}
#if BUILDFLAG(ENABLE_PDF)
void LensOverlayController::OnPdfBytesReceived(
PageContentRetrievedCallback callback,
pdf::mojom::PdfListener::GetPdfBytesStatus status,
const std::vector<uint8_t>& bytes,
uint32_t page_count) {
// TODO(b/370530197): Show user error message if status is not success.
if (status != pdf::mojom::PdfListener::GetPdfBytesStatus::kSuccess ||
page_count == 0) {
std::move(callback).Run(std::vector<uint8_t>(), lens::MimeType::kPdf,
page_count);
return;
}
std::move(callback).Run(bytes, lens::MimeType::kPdf, page_count);
}
void LensOverlayController::GetPartialPdfText(uint32_t page_count) {
pdf::PDFDocumentHelper* pdf_helper =
pdf::PDFDocumentHelper::MaybeGetForWebContents(tab_->GetContents());
if (!pdf_helper ||
lens::features::GetLensOverlayPdfSuggestCharacterTarget() == 0 ||
page_count == 0) {
return;
}
// Fetch the first page of text which will be then recursively fetch following
// pages.
initialization_data_->pdf_pages_text_.clear();
pdf_helper->GetPageText(
/*page_index=*/0,
base::BindOnce(&LensOverlayController::GetPartialPdfTextCallback,
weak_factory_.GetWeakPtr(), /*page_index=*/0, page_count,
/*total_characters_retrieved=*/0));
}
void LensOverlayController::GetPartialPdfTextCallback(
uint32_t page_index,
uint32_t total_page_count,
uint32_t total_characters_retrieved,
const std::u16string& page_text) {
// Sanity checks that the input is expected.
CHECK_GE(total_page_count, 1u);
CHECK_LT(page_index, total_page_count);
CHECK_EQ(initialization_data_->pdf_pages_text_.size(), page_index);
// Add the page text to the list of pages and update the total characters
// retrieved count.
initialization_data_->pdf_pages_text_.push_back(page_text);
// Ensure no integer overflow. If overflow, set the total characters retrieved
// to the max value so the loop will exit.
base::CheckedNumeric<uint32_t> total_characters_retrieved_check =
total_characters_retrieved;
total_characters_retrieved_check += page_text.size();
total_characters_retrieved = total_characters_retrieved_check.ValueOrDefault(
std::numeric_limits<uint32_t>::max());
pdf::PDFDocumentHelper* pdf_helper =
pdf::PDFDocumentHelper::MaybeGetForWebContents(tab_->GetContents());
// Stop the loop if the character limit is reached or if the page index is
// out of bounds or the PDF helper no longer exists.
if (!pdf_helper ||
total_characters_retrieved >=
lens::features::GetLensOverlayPdfSuggestCharacterTarget() ||
page_index + 1 >= total_page_count) {
lens_overlay_query_controller_->SendPartialPageContentRequest(
initialization_data_->pdf_pages_text_);
return;
}
pdf_helper->GetPageText(
page_index + 1,
base::BindOnce(&LensOverlayController::GetPartialPdfTextCallback,
weak_factory_.GetWeakPtr(), page_index + 1,
total_page_count, total_characters_retrieved));
}
#endif // BUILDFLAG(ENABLE_PDF)
void LensOverlayController::OnInnerTextReceived(
PageContentRetrievedCallback callback,
std::unique_ptr<content_extraction::InnerTextResult> result) {
if (!result || result->inner_text.size() >
lens::features::GetLensOverlayFileUploadLimitBytes()) {
std::move(callback).Run(std::vector<uint8_t>(), lens::MimeType::kPlainText,
std::nullopt);
return;
}
std::move(callback).Run(std::vector<uint8_t>(result->inner_text.begin(),
result->inner_text.end()),
lens::MimeType::kPlainText, std::nullopt);
}
void LensOverlayController::OnInnerHtmlReceived(
PageContentRetrievedCallback callback,
const std::optional<std::string>& result) {
if (!result.has_value() ||
result->size() > lens::features::GetLensOverlayFileUploadLimitBytes()) {
std::move(callback).Run(std::vector<uint8_t>(), lens::MimeType::kHtml,
std::nullopt);
return;
}
std::move(callback).Run(std::vector<uint8_t>(result->begin(), result->end()),
lens::MimeType::kHtml, std::nullopt);
}
std::vector<lens::mojom::CenterRotatedBoxPtr>
LensOverlayController::ConvertSignificantRegionBoxes(
const std::vector<gfx::Rect>& all_bounds) {
std::vector<lens::mojom::CenterRotatedBoxPtr> significant_region_boxes;
int max_regions = lens::features::GetLensOverlayMaxSignificantRegions();
if (max_regions == 0) {
return significant_region_boxes;
}
content::RenderFrameHost* render_frame_host =
tab_->GetContents()->GetPrimaryMainFrame();
auto view_bounds = render_frame_host->GetView()->GetViewBounds();
for (auto& image_bounds : all_bounds) {
// Check the original area of the images against the minimum area.
if (image_bounds.width() * image_bounds.height() >=
lens::features::GetLensOverlaySignificantRegionMinArea()) {
// We only have bounds for images in the main frame of the tab (i.e. not
// in iframes), so view bounds are identical to tab bounds and can be
// used for both parameters.
significant_region_boxes.emplace_back(
lens::GetCenterRotatedBoxFromTabViewAndImageBounds(
view_bounds, view_bounds, image_bounds));
}
}
// If an image is outside the viewpoint, the box will have zero area.
std::erase_if(significant_region_boxes, [](const auto& box) {
return box->box.height() == 0 || box->box.width() == 0;
});
// Sort by descending area.
std::sort(significant_region_boxes.begin(), significant_region_boxes.end(),
[](const auto& box1, const auto& box2) {
return box1->box.height() * box1->box.width() >
box2->box.height() * box2->box.width();
});
// Treat negative values of max_regions as no limit.
if (max_regions > 0 &&
significant_region_boxes.size() > (unsigned long)max_regions) {
significant_region_boxes.resize(max_regions);
}
return significant_region_boxes;
}
void LensOverlayController::TryUpdatePageContextualization() {
GetPageContextualization(
base::BindOnce(&LensOverlayController::UpdatePageContextualization,
weak_factory_.GetWeakPtr()));
}
void LensOverlayController::UpdatePageContextualization(
std::vector<uint8_t> bytes,
lens::MimeType content_type,
std::optional<uint32_t> page_count) {
if (!lens::features::IsLensOverlayContextualSearchboxEnabled()) {
return;
}
// If the bytes have not changed more than our threshold, exit early.
const float old_size = initialization_data_->page_content_bytes_.size();
const float new_size = bytes.size();
const float percent_changed = abs((new_size - old_size) / old_size);
if (percent_changed < kByteChangeTolerancePercent) {
return;
}
// Since the page content has changed so let the query controller know to
// avoid dangling pointers.
lens_overlay_query_controller_->ResetPageContentData();
initialization_data_->page_content_bytes_ = bytes;
initialization_data_->page_content_type_ = content_type;
// If no bytes were retrieved from the page, the query won't be able to be
// contextulized. Notify the side panel so the ghost loader isn't shown. No
// need to update update the overlay as this update only happens on navigation
// where the side panel will already be open.
if (bytes.empty()) {
SuppressGhostLoader();
}
// If the new page is a PDF, fetch the text from the page to be used as early
// suggest signals.
if (content_type == lens::MimeType::kPdf) {
GetPartialPdfText(page_count.value_or(0));
}
lens_overlay_query_controller_->SendPageContentUpdateRequest(
initialization_data_->page_content_bytes_,
initialization_data_->page_content_type_, GetPageURL());
RecordDocumentMetrics(page_count);
}
void LensOverlayController::SuppressGhostLoader() {
if (page_) {
page_->SuppressGhostLoader();
}
if (side_panel_page_) {
side_panel_page_->SuppressGhostLoader();
}
}
void LensOverlayController::SetLiveBlur(bool enabled) {
if (!lens_overlay_blur_layer_delegate_) {
return;
}
if (enabled) {
lens_overlay_blur_layer_delegate_->StartBackgroundImageCapture();
return;
}
lens_overlay_blur_layer_delegate_->StopBackgroundImageCapture();
}
void LensOverlayController::ShowOverlay() {
// Grab the tab contents web view and disable mouse and keyboard inputs to it.
auto* contents_web_view = tab_->GetBrowserWindowInterface()->GetWebView();
CHECK(contents_web_view);
contents_web_view->SetEnabled(false);
// If the view already exists, we just need to reshow it.
if (overlay_view_) {
CHECK(overlay_web_view_);
CHECK(!overlay_view_->GetVisible());
overlay_view_->SetVisible(true);
// Restart the live blur since the view is visible again.
SetLiveBlur(true);
// The overlay needs to be focused on show to immediately begin
// receiving key events.
overlay_web_view_->RequestFocus();
return;
}
// Create the view that will house our UI.
std::unique_ptr<views::View> host_view = CreateViewForOverlay();
// Ensure our view starts with the correct bounds.
host_view->SetBoundsRect(contents_web_view->GetLocalBounds());
auto* parent_view = contents_web_view->parent();
// Add the view as a sibling of the view housing the tab contents. The
// overlay_view_ should be stacked on top of the contents_web_view.
overlay_view_ = parent_view->AddChildView(std::move(host_view));
CHECK(parent_view->GetIndexOf(overlay_view_) >
parent_view->GetIndexOf(contents_web_view));
// Observe the contents web view to handle resizing the overlay view.
tab_contents_view_observer_.Observe(contents_web_view);
// The overlay needs to be focused on show to immediately begin
// receiving key events.
CHECK(overlay_web_view_);
overlay_web_view_->RequestFocus();
// Listen to the render process housing out overlay.
overlay_web_view_->GetWebContents()
->GetPrimaryMainFrame()
->GetProcess()
->AddObserver(this);
}
void LensOverlayController::BackgroundUI() {
overlay_view_->SetVisible(false);
SetLiveBlur(false);
HidePreselectionBubble();
// Re-enable mouse and keyboard events to the tab contents web view.
auto* contents_web_view = tab_->GetBrowserWindowInterface()->GetWebView();
CHECK(contents_web_view);
contents_web_view->SetEnabled(true);
state_ = State::kBackground;
// TODO(b/335516480): Schedule the UI to be suspended.
}
void LensOverlayController::CloseUIPart2(
lens::LensOverlayDismissalSource dismissal_source) {
if (state_ == State::kOff) {
return;
}
// Ensure that this path is not being used to close the overlay if the overlay
// is currently showing. If the overlay is currently showing, CloseUIAsync
// should be used instead.
CHECK(state_ != State::kOverlay);
CHECK(state_ != State::kOverlayAndResults);
// TODO(b/331940245): Refactor to be decoupled from permission_prompt_factory
state_ = State::kClosing;
// Closes preselection toast if it exists.
ClosePreselectionBubble();
// A permission prompt may be suspended if the overlay was showing when the
// permission was queued. Restore the suspended prompt if possible.
// TODO(b/331940245): Refactor to be decoupled from PermissionPromptFactory
content::WebContents* contents = tab_->GetContents();
CHECK(contents);
auto* permission_request_manager =
permissions::PermissionRequestManager::FromWebContents(contents);
if (permission_request_manager &&
permission_request_manager->CanRestorePrompt()) {
permission_request_manager->RestorePrompt();
}
permission_bubble_controller_.reset();
side_panel_searchbox_handler_.reset();
results_side_panel_coordinator_.reset();
pre_initialization_suggest_inputs_.reset();
pre_initialization_objects_.reset();
pre_initialization_text_.reset();
side_panel_shown_subscription_ = base::CallbackListSubscription();
side_panel_coordinator_ = nullptr;
// Re-enable mouse and keyboard events to the tab contents web view.
auto* contents_web_view = tab_->GetBrowserWindowInterface()->GetWebView();
CHECK(contents_web_view);
contents_web_view->SetEnabled(true);
if (overlay_web_view_) {
// Remove render frame observer.
overlay_web_view_->GetWebContents()
->GetPrimaryMainFrame()
->GetProcess()
->RemoveObserver(this);
}
// LensOverlayQueryController points to initialization data and therefore must
// be reset before the initialization data to avoid dangling pointers.
lens_overlay_query_controller_.reset();
initialization_data_.reset();
tab_contents_view_observer_.Reset();
omnibox_tab_helper_observer_.Reset();
find_tab_observer_.Reset();
side_panel_receiver_.reset();
side_panel_page_.reset();
receiver_.reset();
page_.reset();
languages_controller_.reset();
scoped_tab_modal_ui_.reset();
pending_side_panel_url_.reset();
pending_text_query_.reset();
pending_thumbnail_uri_.reset();
selected_region_thumbnail_uri_.clear();
pending_region_.reset();
fullscreen_observation_.Reset();
lens_overlay_blur_layer_delegate_.reset();
overlay_searchbox_handler_.reset();
last_navigation_time_.reset();
side_panel_should_show_error_page_ = false;
side_panel_result_status_ = lens::SidePanelResultStatus::kUnknown;
if (overlay_view_) {
// Remove and delete the overlay view and web view. Not doing so will result
// in dangling pointers when the browser closes. Note the trailing `T` on
// the method name -- this removes `overlay_view_` and returns a unique_ptr
// to it which we then discard. Without the `T`, it returns nothing and
// frees nothing. Since technically the views are owned by
// contents_web_view, we need to release our reference using std::exchange
// to avoid a dangling pointer which throws an error when DCHECK is on.
overlay_view_->RemoveChildViewT(std::exchange(overlay_web_view_, nullptr));
overlay_view_->parent()->RemoveChildViewT(
std::exchange(overlay_view_, nullptr));
}
overlay_web_view_ = nullptr;
overlay_view_ = nullptr;
lens_selection_type_ = lens::UNKNOWN_SELECTION_TYPE;
state_ = State::kOff;
RecordEndOfSessionMetrics(dismissal_source);
}
void LensOverlayController::InitializeOverlay(
std::unique_ptr<OverlayInitializationData> initialization_data) {
// Initialization data is ready.
if (initialization_data) {
// Confirm initialization_data has not already been assigned.
CHECK(!initialization_data_);
initialization_data_ = std::move(initialization_data);
// If suggest inputs were updated before the initialization data was ready,
// attach them to the initialization data now.
if (pre_initialization_suggest_inputs_.has_value()) {
initialization_data_->suggest_inputs_ =
pre_initialization_suggest_inputs_.value();
pre_initialization_suggest_inputs_.reset();
}
}
// We can only continue once both the WebUI is bound and the initialization
// data is processed and ready. If either of those conditions aren't met, we
// exit early and wait for the other condition to call this method again.
if (!page_ || !initialization_data_) {
return;
}
// Move the data that was stored prior to initialization into
// initialization_data_.
if (pre_initialization_objects_.has_value()) {
initialization_data_->objects_ =
std::move(pre_initialization_objects_.value());
pre_initialization_objects_.reset();
}
if (pre_initialization_text_.has_value()) {
initialization_data_->text_ = std::move(pre_initialization_text_.value());
pre_initialization_text_.reset();
}
InitializeOverlayUI(*initialization_data_);
base::UmaHistogramBoolean("Lens.Overlay.Shown", true);
// If PDF content was extracted from the page, fetch the text from the PDF to
// be used as early suggest signals.
if (initialization_data_->page_content_type_ == lens::MimeType::kPdf) {
CHECK(initialization_data_->pdf_page_count_.has_value());
GetPartialPdfText(initialization_data_->pdf_page_count_.value());
}
// If the StartQueryFlow optimization is enabled, the page contents will not
// be sent with the initial image request, so we need to send it here.
if (lens::features::IsLensOverlayContextualSearchboxEnabled() &&
lens::features::IsLensOverlayEarlyStartQueryFlowOptimizationEnabled()) {
lens_overlay_query_controller_->SendPageContentUpdateRequest(
initialization_data_->page_content_bytes_,
initialization_data_->page_content_type_, GetPageURL());
}
// Show the preselection overlay now that the overlay is initialized and ready
// to be shown.
if (!pending_region_) {
ShowPreselectionBubble();
}
// Create the blur delegate so it is ready to blur once the view is visible.
if (lens::features::GetLensOverlayUseBlur()) {
content::RenderWidgetHost* live_page_widget_host =
tab_->GetContents()
->GetPrimaryMainFrame()
->GetRenderViewHost()
->GetWidget();
lens_overlay_blur_layer_delegate_ =
std::make_unique<lens::LensOverlayBlurLayerDelegate>(
live_page_widget_host);
}
state_ = State::kOverlay;
// Only start the query flow again if we don't already have a full image
// response, unless the early start query flow optimization is enabled.
if (!initialization_data_->has_full_image_response() &&
!lens::features::IsLensOverlayEarlyStartQueryFlowOptimizationEnabled()) {
// Use std::move because significant_region_boxes_ is only used in this
// call, which should only occur once in the lifetime of
// LensOverlayQueryController and thus of LensOverlayController.
lens_overlay_query_controller_->StartQueryFlow(
initialization_data_->current_screenshot_,
initialization_data_->page_url_, initialization_data_->page_title_,
std::move(initialization_data_->significant_region_boxes_),
initialization_data_->page_content_bytes_,
initialization_data_->page_content_type_, GetUiScaleFactor(),
invocation_time_);
}
// TODO(b/352622136): We should not start the lens request until the overlay
// is open to prevent the side panel from opening while the overlay UI is
// rendering.
if (pending_region_) {
// If there is a pending region (i.e. for image right click)
// use INJECTED_IMAGE as the selection type.
DoLensRequest(std::move(pending_region_), lens::INJECTED_IMAGE,
pending_region_bitmap_);
pending_region_bitmap_.reset();
}
}
void LensOverlayController::InitializeOverlayUI(
const OverlayInitializationData& init_data) {
// This should only contain LensPage mojo calls and should not affect
// `state_`.
CHECK(page_);
// TODO(b/371593619), it would be more efficent to send all initialization
// data to the overlay web UI in a single message.
page_->ThemeReceived(CreateTheme(init_data.color_palette_));
contextual_searchbox_shown_in_session_ =
!init_data.page_content_bytes_.empty();
if (contextual_searchbox_shown_in_session_) {
contextual_searchbox_focused_in_session_ = false;
// Reset metric booleans in case they were set to true previously and the
// overlay was reopened.
contextual_zps_shown_in_session_ = false;
contextual_zps_used_in_session_ = false;
contextual_query_issued_in_session_ = false;
}
initial_page_content_type_ = init_data.page_content_type_;
initial_document_type_ =
StringMimeTypeToDocumentType(tab_->GetContents()->GetContentsMimeType());
page_->ShouldShowContextualSearchBox(contextual_searchbox_shown_in_session_);
page_->ScreenshotDataReceived(init_data.current_rgb_screenshot_);
if (!init_data.objects_.empty()) {
SendObjects(CopyObjects(init_data.objects_));
}
if (init_data.text_) {
SendText(init_data.text_->Clone());
}
if (pending_region_) {
page_->SetPostRegionSelection(pending_region_->Clone());
}
// Record the UMA for lens overlay invocation.
lens::RecordInvocation(invocation_source_, initial_document_type_);
}
std::unique_ptr<views::View> LensOverlayController::CreateViewForOverlay() {
// Create a flex layout host view to make sure the web view covers the entire
// tab.
std::unique_ptr<views::FlexLayoutView> host_view =
std::make_unique<views::FlexLayoutView>();
std::unique_ptr<views::WebView> web_view = std::make_unique<views::WebView>(
tab_->GetContents()->GetBrowserContext());
content::WebContents* web_view_contents = web_view->GetWebContents();
web_view->SetProperty(
views::kFlexBehaviorKey,
views::FlexSpecification(views::MinimumFlexSizeRule::kScaleToZero,
views::MaximumFlexSizeRule::kUnbounded));
web_view->SetProperty(views::kElementIdentifierKey, kOverlayId);
views::WebContentsSetBackgroundColor::CreateForWebContentsWithColor(
web_view_contents, SK_ColorTRANSPARENT);
// Set the label for the renderer process in Chrome Task Manager.
task_manager::WebContentsTags::CreateForToolContents(
web_view_contents, IDS_LENS_OVERLAY_RENDERER_LABEL);
// As the embedder for the lens overlay WebUI content we must set the
// appropriate tab interface here.
webui::SetTabInterface(web_view_contents, GetTabInterface());
// Set the web contents delegate to this controller so we can handle keyboard
// events. Allow accelerators (e.g. hotkeys) to work on this web view.
web_view->set_allow_accelerators(true);
web_view->GetWebContents()->SetDelegate(this);
// Load the untrusted WebUI into the web view.
web_view->LoadInitialURL(GURL(chrome::kChromeUILensOverlayUntrustedURL));
overlay_web_view_ = host_view->AddChildView(std::move(web_view));
return host_view;
}
bool LensOverlayController::HandleContextMenu(
content::RenderFrameHost& render_frame_host,
const content::ContextMenuParams& params) {
// We do not want to show the browser context menu on the overlay unless we
// are in debugging mode. Returning true is equivalent to not showing the
// context menu.
return !lens::features::IsLensOverlayDebuggingEnabled();
}
bool LensOverlayController::HandleKeyboardEvent(
content::WebContents* source,
const input::NativeWebKeyboardEvent& event) {
// This can be called before the overlay web view is attached to the overlay
// view. In that case, the focus manager could be null.
if (!overlay_web_view_ || !overlay_web_view_->GetFocusManager()) {
return false;
}
return lens_overlay_event_handler_->HandleKeyboardEvent(
source, event, overlay_web_view_->GetFocusManager());
}
void LensOverlayController::OnFullscreenStateChanged() {
// Flag is enabled to allow Lens Overlay in fullscreen no matter what so we
// can exit early.
if (lens::features::GetLensOverlayEnableInFullscreen()) {
return;
}
// If there is top chrome we can keep the overlay open.
if (tab_->GetBrowserWindowInterface()->IsTabStripVisible()) {
return;
}
CloseUISync(lens::LensOverlayDismissalSource::kFullscreened);
}
void LensOverlayController::OnViewBoundsChanged(views::View* observed_view) {
CHECK(observed_view == tab_->GetBrowserWindowInterface()->GetWebView());
// We now want to start the live blur since the screenshot has resized to
// allow the blur to peek through.
if (IsOverlayShowing()) {
SetLiveBlur(true);
}
gfx::Rect bounds = observed_view->GetLocalBounds();
overlay_view_->SetBoundsRect(bounds);
if (lens_overlay_blur_layer_delegate_) {
lens_overlay_blur_layer_delegate_->layer()->SetBounds(bounds);
}
}
#if BUILDFLAG(IS_MAC)
void LensOverlayController::OnWidgetActivationChanged(views::Widget* widget,
bool active) {
if (active && preselection_widget_) {
// On Mac, traversing out of the preselection widget into the browser causes
// the browser to restore its focus to the wrong place. Thus, when entering
// the preselection widget, make sure to clear out the browser's native
// focus. This causes the preselection widget to lose activation, so
// reactivate it manually.
tab_->GetBrowserWindowInterface()
->TopContainer()
->GetWidget()
->GetFocusManager()
->ClearNativeFocus();
preselection_widget_->Activate();
}
}
#endif
void LensOverlayController::OnWidgetDestroying(views::Widget* widget) {
preselection_widget_ = nullptr;
preselection_widget_observer_.Reset();
}
void LensOverlayController::OnOmniboxFocusChanged(
OmniboxFocusState state,
OmniboxFocusChangeReason reason) {
if (state_ == LensOverlayController::State::kOverlay) {
if (state == OMNIBOX_FOCUS_NONE) {
ShowPreselectionBubble();
} else {
HidePreselectionBubble();
}
}
}
void LensOverlayController::OnFindEmptyText(
content::WebContents* web_contents) {
if (state_ == State::kLivePageAndResults) {
return;
}
CloseUIAsync(lens::LensOverlayDismissalSource::kFindInPageInvoked);
}
void LensOverlayController::OnFindResultAvailable(
content::WebContents* web_contents) {
if (state_ == State::kLivePageAndResults) {
return;
}
CloseUIAsync(lens::LensOverlayDismissalSource::kFindInPageInvoked);
}
const GURL& LensOverlayController::GetPageURL() const {
if (lens::CanSharePageURLWithLensOverlay(pref_service_)) {
return tab_->GetContents()->GetVisibleURL();
}
return GURL::EmptyGURL();
}
SessionID LensOverlayController::GetTabId() const {
return sessions::SessionTabHelper::IdForTab(tab_->GetContents());
}
metrics::OmniboxEventProto::PageClassification
LensOverlayController::GetPageClassification() const {
// There are two cases where we are assuming to be in a contextual flow:
// 1) We are in the zero state with the overlay CSB showing.
// 2) A user has made a contextual query and the live page is now showing.
if (state_ == State::kLivePageAndResults || state_ == State::kOverlay) {
return metrics::OmniboxEventProto::CONTEXTUAL_SEARCHBOX;
}
return selected_region_thumbnail_uri_.empty()
? metrics::OmniboxEventProto::SEARCH_SIDE_PANEL_SEARCHBOX
: metrics::OmniboxEventProto::LENS_SIDE_PANEL_SEARCHBOX;
}
std::string& LensOverlayController::GetThumbnail() {
return selected_region_thumbnail_uri_;
}
const lens::proto::LensOverlaySuggestInputs&
LensOverlayController::GetLensSuggestInputs() const {
return initialization_data_
? initialization_data_->suggest_inputs_
: lens::proto::LensOverlaySuggestInputs().default_instance();
}
void LensOverlayController::OnTextModified() {
if (initialization_data_->selected_text_.has_value()) {
initialization_data_->selected_text_.reset();
page_->ClearTextSelection();
}
}
void LensOverlayController::ClearRegionSelection() {
selected_region_thumbnail_uri_.clear();
lens_selection_type_ = lens::UNKNOWN_SELECTION_TYPE;
initialization_data_->selected_region_.reset();
initialization_data_->selected_region_bitmap_.reset();
page_->ClearRegionSelection();
}
void LensOverlayController::OnThumbnailRemoved() {
// This is called by the searchbox after the thumbnail is
// removed from there, so no need to manually replace the
// searchbox thumbnail uri here.
ClearRegionSelection();
}
void LensOverlayController::OnSuggestionAccepted(
const GURL& destination_url,
AutocompleteMatchType::Type match_type,
bool is_zero_prefix_suggestion) {
std::string query_text = "";
std::map<std::string, std::string> additional_query_parameters;
net::QueryIterator query_iterator(destination_url);
while (!query_iterator.IsAtEnd()) {
std::string_view key = query_iterator.GetKey();
std::string_view value = query_iterator.GetUnescapedValue();
if (kTextQueryParameterKey == key) {
query_text = value;
} else {
additional_query_parameters.insert(std::make_pair(
query_iterator.GetKey(), query_iterator.GetUnescapedValue()));
}
query_iterator.Advance();
}
IssueSearchBoxRequest(query_text, match_type, is_zero_prefix_suggestion,
additional_query_parameters);
}
void LensOverlayController::OnFocusChanged(bool focused) {
if (!focused) {
return;
}
if (IsContextualSearchbox()) {
contextual_searchbox_focused_in_session_ = true;
// If the searchbox becomes focused, showing intent to issue a new query,
// upload the new page content for contextualization.
TryUpdatePageContextualization();
}
}
void LensOverlayController::OnPageBound() {
// If the side panel closes before the remote gets bound,
// side_panel_searchbox_handler_ could become unset. Verify it is set before
// sending to the side panel.
if (!side_panel_searchbox_handler_ ||
!side_panel_searchbox_handler_->IsRemoteBound()) {
return;
}
// Send any pending inputs for the searchbox.
if (pending_text_query_.has_value()) {
side_panel_searchbox_handler_->SetInputText(*pending_text_query_);
pending_text_query_.reset();
}
if (pending_thumbnail_uri_.has_value()) {
side_panel_searchbox_handler_->SetThumbnail(*pending_thumbnail_uri_);
pending_thumbnail_uri_.reset();
}
}
void LensOverlayController::ShowGhostLoaderErrorState() {
if (!IsContextualSearchbox()) {
return;
}
if (overlay_ghost_loader_page_) {
overlay_ghost_loader_page_->ShowErrorState();
}
if (side_panel_ghost_loader_page_) {
side_panel_ghost_loader_page_->ShowErrorState();
}
}
void LensOverlayController::OnZeroSuggestShown() {
if (IsContextualSearchbox()) {
contextual_zps_shown_in_session_ = true;
}
}
std::optional<std::string> LensOverlayController::GetPageTitle() {
std::optional<std::string> page_title;
content::WebContents* active_web_contents = tab_->GetContents();
if (lens::CanSharePageTitleWithLensOverlay(sync_service_, pref_service_)) {
page_title = std::make_optional<std::string>(
base::UTF16ToUTF8(active_web_contents->GetTitle()));
}
return page_title;
}
float LensOverlayController::GetUiScaleFactor() {
int device_scale_factor =
tab_->GetContents()->GetRenderWidgetHostView()->GetDeviceScaleFactor();
float page_scale_factor =
zoom::ZoomController::FromWebContents(tab_->GetContents())
->GetZoomPercent() /
100.0f;
return device_scale_factor * page_scale_factor;
}
void LensOverlayController::OnSidePanelDidOpen() {
// If a side panel opens that is not ours, we must close the overlay.
if (side_panel_coordinator_->GetCurrentEntryId() !=
SidePanelEntry::Id::kLensOverlayResults) {
CloseUISync(lens::LensOverlayDismissalSource::kUnexpectedSidePanelOpen);
}
}
void LensOverlayController::FinishedWaitingForReflow() {
if (state_ == State::kClosingOpenedSidePanel) {
// This path is invoked after the user invokes the overlay, but we needed
// to close the side panel before taking a screenshot. The Side panel is
// now closed so we can now take the screenshot of the page.
CaptureScreenshot();
}
}
void LensOverlayController::RenderProcessExited(
content::RenderProcessHost* host,
const content::ChildProcessTerminationInfo& info) {
// Exit early if the overlay is already closing.
if (IsOverlayClosing()) {
return;
}
// The overlay's primary main frame process has exited, either cleanly or
// unexpectedly. Close the overlay so that the user does not get into a broken
// state where the overlay cannot be dismissed. Note that RenderProcessExited
// can be called during the destruction of a frame in the overlay, so it is
// important to post a task to close the overlay to avoid double-freeing the
// overlay's frames. See https://crbug.com/371643466.
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE,
base::BindOnce(
&LensOverlayController::CloseUISync, weak_factory_.GetWeakPtr(),
info.status == base::TERMINATION_STATUS_NORMAL_TERMINATION
? lens::LensOverlayDismissalSource::kOverlayRendererClosedNormally
: lens::LensOverlayDismissalSource::
kOverlayRendererClosedUnexpectedly));
}
void LensOverlayController::TabForegrounded(tabs::TabInterface* tab) {
// If the overlay was backgrounded, reshow the overlay view.
if (state_ == State::kBackground) {
ShowOverlay();
state_ = (results_side_panel_coordinator_ &&
results_side_panel_coordinator_->IsEntryShowing())
? State::kOverlayAndResults
: State::kOverlay;
if (state_ != State::kOverlayAndResults) {
ShowPreselectionBubble();
}
if (lens::features::IsLensOverlayContextualSearchboxEnabled()) {
SuppressGhostLoader();
}
}
}
void LensOverlayController::TabWillEnterBackground(tabs::TabInterface* tab) {
// If the current tab was already backgrounded, do nothing.
if (state_ == State::kBackground) {
return;
}
// If the live page is showing, we don't need to do anything since the side
// panel will hide itself.
if (state_ == State::kLivePageAndResults) {
return;
}
// If the overlay was currently showing, then we should background the UI.
if (IsOverlayShowing()) {
BackgroundUI();
return;
}
// This is still possible when the controller is in state kScreenshot and the
// tab was backgrounded. We should close the UI as the overlay has not been
// created yet.
CloseUISync(
lens::LensOverlayDismissalSource::kTabBackgroundedWhileScreenshotting);
}
void LensOverlayController::WillDiscardContents(
tabs::TabInterface* tab,
content::WebContents* old_contents,
content::WebContents* new_contents) {
// Background tab contents discarded.
CloseUISync(lens::LensOverlayDismissalSource::kTabContentsDiscarded);
old_contents->RemoveUserData(LensOverlayControllerTabLookup::UserDataKey());
LensOverlayControllerTabLookup::CreateForWebContents(new_contents, this);
}
void LensOverlayController::WillDetach(
tabs::TabInterface* tab,
tabs::TabInterface::DetachReason reason) {
// When dragging a tab into a new window, all window-specific state must be
// reset. As this flow is not fully functional, close the overlay regardless
// of `reason`. https://crbug.com/342921671.
switch (reason) {
case tabs::TabInterface::DetachReason::kDelete:
CloseUISync(lens::LensOverlayDismissalSource::kTabClosed);
return;
case tabs::TabInterface::DetachReason::kInsertIntoOtherWindow:
CloseUISync(lens::LensOverlayDismissalSource::kTabDragNewWindow);
return;
}
}
void LensOverlayController::DoLensRequest(
lens::mojom::CenterRotatedBoxPtr region,
lens::LensOverlaySelectionType selection_type,
std::optional<SkBitmap> region_bytes) {
CHECK(initialization_data_);
CHECK(region);
SetSearchboxInputText(std::string());
initialization_data_->selected_region_ = region.Clone();
initialization_data_->selected_text_.reset();
initialization_data_->additional_search_query_params_.clear();
lens_selection_type_ = selection_type;
if (region_bytes) {
initialization_data_->selected_region_bitmap_ = region_bytes.value();
} else {
initialization_data_->selected_region_bitmap_.reset();
}
lens_overlay_query_controller_->SendRegionSearch(
region.Clone(), selection_type,
initialization_data_->additional_search_query_params_, region_bytes);
results_side_panel_coordinator_->RegisterEntryAndShow();
RecordTimeToFirstInteraction(
lens::LensOverlayFirstInteractionType::kRegionSelect);
state_ = State::kOverlayAndResults;
MaybeLaunchSurvey();
}
void LensOverlayController::ActivityRequestedByOverlay(
ui::mojom::ClickModifiersPtr click_modifiers) {
// The tab is expected to be in the foreground.
if (!tab_->IsActivated()) {
return;
}
tab_->GetBrowserWindowInterface()->OpenGURL(
GURL(lens::features::GetLensOverlayActivityURL()),
ui::DispositionFromClick(
click_modifiers->middle_button, click_modifiers->alt_key,
click_modifiers->ctrl_key, click_modifiers->meta_key,
click_modifiers->shift_key,
WindowOpenDisposition::NEW_FOREGROUND_TAB));
}
void LensOverlayController::ActivityRequestedByEvent(int event_flags) {
// The tab is expected to be in the foreground.
if (!tab_->IsActivated()) {
return;
}
tab_->GetBrowserWindowInterface()->OpenGURL(
GURL(lens::features::GetLensOverlayActivityURL()),
ui::DispositionFromEventFlags(event_flags,
WindowOpenDisposition::NEW_FOREGROUND_TAB));
}
void LensOverlayController::AddBackgroundBlur() {
// We do not blur unless the overlay is currently active and the blur delegate
// was created.
if (!lens_overlay_blur_layer_delegate_ ||
(state_ != State::kOverlay && state_ != State::kOverlayAndResults)) {
return;
}
// Add our blur layer to the view.
overlay_view_->SetPaintToLayer();
overlay_view_->layer()->Add(lens_overlay_blur_layer_delegate_->layer());
overlay_view_->layer()->StackAtBottom(
lens_overlay_blur_layer_delegate_->layer());
lens_overlay_blur_layer_delegate_->layer()->SetBounds(
overlay_view_->parent()->GetLocalBounds());
}
void LensOverlayController::CloseRequestedByOverlayCloseButton() {
CloseUIAsync(lens::LensOverlayDismissalSource::kOverlayCloseButton);
}
void LensOverlayController::CloseRequestedByOverlayBackgroundClick() {
CloseUIAsync(lens::LensOverlayDismissalSource::kOverlayBackgroundClick);
}
void LensOverlayController::FeedbackRequestedByOverlay() {
chrome::ShowFeedbackPage(
tab_->GetContents()->GetLastCommittedURL(),
tab_->GetBrowserWindowInterface()->GetProfile(),
feedback::kFeedbackSourceLensOverlay,
/*description_template=*/std::string(),
/*description_placeholder_text=*/
l10n_util::GetStringUTF8(IDS_LENS_SEND_FEEDBACK_PLACEHOLDER),
/*category_tag=*/"lens_overlay",
/*extra_diagnostics=*/std::string());
}
void LensOverlayController::FeedbackRequestedByEvent(int event_flags) {
FeedbackRequestedByOverlay();
}
void LensOverlayController::GetOverlayInvocationSource(
GetOverlayInvocationSourceCallback callback) {
std::move(callback).Run(GetInvocationSourceString());
}
void LensOverlayController::InfoRequestedByOverlay(
ui::mojom::ClickModifiersPtr click_modifiers) {
// The tab is expected to be in the foreground.
if (!tab_->IsActivated()) {
return;
}
tab_->GetBrowserWindowInterface()->OpenGURL(
GURL(lens::features::GetLensOverlayHelpCenterURL()),
ui::DispositionFromClick(
click_modifiers->middle_button, click_modifiers->alt_key,
click_modifiers->ctrl_key, click_modifiers->meta_key,
click_modifiers->shift_key,
WindowOpenDisposition::NEW_FOREGROUND_TAB));
}
void LensOverlayController::InfoRequestedByEvent(int event_flags) {
// The tab is expected to be in the foreground.
if (!tab_->IsActivated()) {
return;
}
tab_->GetBrowserWindowInterface()->OpenGURL(
GURL(lens::features::GetLensOverlayHelpCenterURL()),
ui::DispositionFromEventFlags(event_flags,
WindowOpenDisposition::NEW_FOREGROUND_TAB));
}
void LensOverlayController::IssueLensRegionRequest(
lens::mojom::CenterRotatedBoxPtr region,
bool is_click) {
DoLensRequest(std::move(region),
is_click ? lens::TAP_ON_EMPTY : lens::REGION_SEARCH,
std::nullopt);
}
void LensOverlayController::IssueLensObjectRequest(
lens::mojom::CenterRotatedBoxPtr region,
bool is_mask_click) {
DoLensRequest(std::move(region),
is_mask_click ? lens::TAP_ON_REGION_GLEAM : lens::TAP_ON_OBJECT,
std::nullopt);
}
void LensOverlayController::IssueTextSelectionRequest(const std::string& query,
int selection_start_index,
int selection_end_index,
bool is_translate) {
initialization_data_->additional_search_query_params_.clear();
lens_selection_type_ =
is_translate ? lens::SELECT_TRANSLATED_TEXT : lens::SELECT_TEXT_HIGHLIGHT;
IssueTextSelectionRequestInner(query, selection_start_index,
selection_end_index);
}
void LensOverlayController::IssueTranslateSelectionRequest(
const std::string& query,
const std::string& content_language,
int selection_start_index,
int selection_end_index) {
initialization_data_->additional_search_query_params_.clear();
lens::AppendTranslateParamsToMap(
initialization_data_->additional_search_query_params_, query, "auto");
lens_selection_type_ = lens::TRANSLATE_CHIP;
IssueTextSelectionRequestInner(query, selection_start_index,
selection_end_index);
}
void LensOverlayController::IssueMathSelectionRequest(
const std::string& query,
const std::string& formula,
int selection_start_index,
int selection_end_index) {
initialization_data_->additional_search_query_params_.clear();
lens::AppendStickinessSignalForFormula(
initialization_data_->additional_search_query_params_, formula);
lens_selection_type_ = lens::SYMBOLIC_MATH_OBJECT;
IssueTextSelectionRequestInner(query, selection_start_index,
selection_end_index);
}
void LensOverlayController::IssueTextSelectionRequestInner(
const std::string& query,
int selection_start_index,
int selection_end_index) {
initialization_data_->selected_region_.reset();
initialization_data_->selected_region_bitmap_.reset();
selected_region_thumbnail_uri_.clear();
initialization_data_->selected_text_ =
std::make_pair(selection_start_index, selection_end_index);
SetSearchboxInputText(query);
SetSearchboxThumbnail(std::string());
lens_overlay_query_controller_->SendTextOnlyQuery(
query, lens_selection_type_,
initialization_data_->additional_search_query_params_);
results_side_panel_coordinator_->RegisterEntryAndShow();
RecordTimeToFirstInteraction(
lens::LensOverlayFirstInteractionType::kTextSelect);
state_ = State::kOverlayAndResults;
MaybeLaunchSurvey();
}
void LensOverlayController::ClosePreselectionBubble() {
if (preselection_widget_) {
preselection_widget_->Close();
preselection_widget_ = nullptr;
preselection_widget_observer_.Reset();
}
}
void LensOverlayController::ShowPreselectionBubble() {
auto* anchor_view = tab_->GetBrowserWindowInterface()->TopContainer();
if (!preselection_widget_) {
preselection_widget_ = views::BubbleDialogDelegateView::CreateBubble(
std::make_unique<lens::LensPreselectionBubble>(
weak_factory_.GetWeakPtr(), anchor_view,
net::NetworkChangeNotifier::IsOffline(),
/*exit_clicked_callback=*/
base::BindRepeating(
&LensOverlayController::CloseUIAsync,
weak_factory_.GetWeakPtr(),
lens::LensOverlayDismissalSource::kPreselectionToastExitButton),
/*on_cancel_callback=*/
base::BindOnce(&LensOverlayController::CloseUIAsync,
weak_factory_.GetWeakPtr(),
lens::LensOverlayDismissalSource::
kPreselectionToastEscapeKeyPress)));
preselection_widget_->SetNativeWindowProperty(
views::kWidgetIdentifierKey,
const_cast<void*>(kLensOverlayPreselectionWidgetIdentifier));
preselection_widget_observer_.Observe(preselection_widget_);
// Setting the parent allows focus traversal out of the preselection widget.
preselection_widget_->SetFocusTraversableParent(
anchor_view->GetWidget()->GetFocusTraversable());
preselection_widget_->SetFocusTraversableParentView(anchor_view);
}
auto* bubble_view = static_cast<lens::LensPreselectionBubble*>(
preselection_widget_->widget_delegate());
bubble_view->SetCanActivate(true);
// Show inactive so that the overlay remains active.
preselection_widget_->ShowInactive();
}
void LensOverlayController::HidePreselectionBubble() {
if (preselection_widget_) {
// The preselection bubble remains in the browser's focus order even when it
// is hidden, for example, when another browser tab is active. This means it
// remains possible for the bubble to be activated by keyboard input i.e.
// tabbing into the bubble, which unhides the bubble even on a browser tab
// where the overlay is not being shown. Prevent this by setting the bubble
// to non-activatable while it is hidden.
auto* bubble_view = static_cast<lens::LensPreselectionBubble*>(
preselection_widget_->widget_delegate());
bubble_view->SetCanActivate(false);
preselection_widget_->Hide();
}
}
void LensOverlayController::IssueSearchBoxRequest(
const std::string& search_box_text,
AutocompleteMatchType::Type match_type,
bool is_zero_prefix_suggestion,
std::map<std::string, std::string> additional_query_params) {
// Log the interaction time here so the time to fetch new page bytes is not
// intcluded.
RecordContextualSearchboxTimeToInteractionAfterNavigation();
RecordTimeToFirstInteraction(
lens::LensOverlayFirstInteractionType::kSearchbox);
// Do not attempt to contextualize if CSB is disabled or if the user is not in
// the contextual search flow (aka, issues an image request already).
if (!lens::features::IsLensOverlayContextualSearchboxEnabled() ||
!IsContextualSearchbox()) {
IssueSearchBoxRequestPart2(search_box_text, match_type,
is_zero_prefix_suggestion,
additional_query_params);
return;
}
// If contextual searchbox is enabled, make sure the page bytes are current
// prior to issuing the search box request.
GetPageContextualization(
base::BindOnce(&LensOverlayController::UpdatePageContextualization,
weak_factory_.GetWeakPtr())
.Then(base::BindOnce(
&LensOverlayController::IssueSearchBoxRequestPart2,
weak_factory_.GetWeakPtr(), search_box_text, match_type,
is_zero_prefix_suggestion, additional_query_params)));
}
void LensOverlayController::IssueSearchBoxRequestPart2(
const std::string& search_box_text,
AutocompleteMatchType::Type match_type,
bool is_zero_prefix_suggestion,
std::map<std::string, std::string> additional_query_params) {
initialization_data_->additional_search_query_params_ =
additional_query_params;
if (initialization_data_->selected_region_.is_null() &&
GetPageClassification() ==
metrics::OmniboxEventProto::SEARCH_SIDE_PANEL_SEARCHBOX) {
// Non-Lens and non-contextual searches should not have a selection type.
lens_selection_type_ = lens::UNKNOWN_SELECTION_TYPE;
} else if (is_zero_prefix_suggestion) {
lens_selection_type_ = lens::MULTIMODAL_SUGGEST_ZERO_PREFIX;
} else if (match_type == AutocompleteMatchType::Type::SEARCH_WHAT_YOU_TYPED) {
lens_selection_type_ = lens::MULTIMODAL_SEARCH;
} else {
lens_selection_type_ = lens::MULTIMODAL_SUGGEST_TYPEAHEAD;
}
if (initialization_data_->selected_region_.is_null() &&
IsContextualSearchbox()) {
lens_overlay_query_controller_->SendContextualTextQuery(
search_box_text, lens_selection_type_,
initialization_data_->additional_search_query_params_);
contextual_zps_used_in_session_ =
contextual_zps_used_in_session_ || is_zero_prefix_suggestion;
contextual_query_issued_in_session_ = true;
} else if (initialization_data_->selected_region_.is_null()) {
lens_overlay_query_controller_->SendTextOnlyQuery(
search_box_text, lens_selection_type_,
initialization_data_->additional_search_query_params_);
} else {
std::optional<SkBitmap> selected_region_bitmap =
initialization_data_->selected_region_bitmap_.drawsNothing()
? std::nullopt
: std::make_optional<SkBitmap>(
initialization_data_->selected_region_bitmap_);
lens_overlay_query_controller_->SendMultimodalRequest(
initialization_data_->selected_region_.Clone(), search_box_text,
lens_selection_type_,
initialization_data_->additional_search_query_params_,
selected_region_bitmap);
}
// If we are in the zero state, this request must have come from CSB. In that
// case, hide the overlay to allow live page to show through.
if (state_ == State::kOverlay) {
BackgroundUI();
}
// If this a search query from the side panel search box with the overlay
// showing, keep the state as kOverlayAndResults. Else, we are in our
// contextual flow and the state needs to stay as State::kLivePageAndResults.
state_ = state_ == State::kOverlayAndResults ? State::kOverlayAndResults
: State::kLivePageAndResults;
// The searchbox text is set once the URL loads in the results frame, however,
// adding it here allows the user to see the text query in the searchbox while
// a long query loads.
SetSearchboxInputText(search_box_text);
results_side_panel_coordinator_->RegisterEntryAndShow();
MaybeLaunchSurvey();
}
void LensOverlayController::HandleStartQueryResponse(
std::vector<lens::mojom::OverlayObjectPtr> objects,
lens::mojom::TextPtr text,
bool is_error) {
// If the side panel is open, then the error page state can change depending
// on whether the query succeeded or not. If the side panel is not open, the
// error page state can only change if the query failed since the first side
// panel navigation will take care of recording whether the result was shown.
if (side_panel_page_) {
MaybeSetSidePanelShowErrorPage(
is_error,
is_error ? lens::SidePanelResultStatus::kErrorPageShownStartQueryError
: lens::SidePanelResultStatus::kResultShown);
} else if (!side_panel_page_ && is_error) {
MaybeSetSidePanelShowErrorPage(
/*should_show_error_page=*/true,
lens::SidePanelResultStatus::kErrorPageShownStartQueryError);
}
if (!objects.empty()) {
SendObjects(std::move(objects));
}
// Text can be null if there was no text within the server response.
if (!text.is_null()) {
SendText(std::move(text));
}
}
void LensOverlayController::HandleInteractionURLResponse(
lens::proto::LensOverlayUrlResponse response) {
LoadURLInResultsFrame(GURL(response.url()));
}
void LensOverlayController::HandleSuggestInputsResponse(
lens::proto::LensOverlaySuggestInputs suggest_inputs) {
if (!initialization_data_) {
// If the initialization data is not ready, store the suggest inputs to be
// attached to the initialization data when it is ready.
pre_initialization_suggest_inputs_ = std::make_optional(suggest_inputs);
return;
}
initialization_data_->suggest_inputs_ = suggest_inputs;
}
void LensOverlayController::HandleThumbnailCreated(
const std::string& thumbnail_bytes) {
selected_region_thumbnail_uri_ =
webui::MakeDataURIForImage(base::as_byte_span(thumbnail_bytes), "jpeg");
SetSearchboxThumbnail(selected_region_thumbnail_uri_);
}
void LensOverlayController::SetSearchboxThumbnail(
const std::string& thumbnail_uri) {
if (side_panel_searchbox_handler_ &&
side_panel_searchbox_handler_->IsRemoteBound()) {
side_panel_searchbox_handler_->SetThumbnail(thumbnail_uri);
} else {
// If the side panel was not bound at the time of request, we store the
// thumbnail as pending to send it to the searchbox on bind.
pending_thumbnail_uri_ = thumbnail_uri;
}
}
void LensOverlayController::RecordTimeToFirstInteraction(
lens::LensOverlayFirstInteractionType interaction_type) {
if (search_performed_in_session_) {
return;
}
DCHECK(!invocation_time_.is_null());
base::TimeDelta time_to_first_interaction =
base::TimeTicks::Now() - invocation_time_;
ukm::SourceId source_id =
tab_->GetContents()->GetPrimaryMainFrame()->GetPageUkmSourceId();
// UMA and UKM TimeToFirstInteraction.
lens::RecordTimeToFirstInteraction(invocation_source_,
time_to_first_interaction,
interaction_type, source_id);
search_performed_in_session_ = true;
}
void LensOverlayController::
RecordContextualSearchboxTimeToInteractionAfterNavigation() {
if (!last_navigation_time_.has_value()) {
return;
}
base::TimeDelta time_to_interaction =
base::TimeTicks::Now() - last_navigation_time_.value();
lens::RecordContextualSearchboxTimeToInteractionAfterNavigation(
time_to_interaction, initialization_data_->page_content_type_);
last_navigation_time_.reset();
}
void LensOverlayController::RecordEndOfSessionMetrics(
lens::LensOverlayDismissalSource dismissal_source) {
// UMA unsliced Dismissed.
lens::RecordDismissal(dismissal_source);
// UMA InvocationResultedInSearch.
lens::RecordInvocationResultedInSearch(invocation_source_,
search_performed_in_session_);
// UMA session duration.
DCHECK(!invocation_time_.is_null());
base::TimeDelta session_duration = base::TimeTicks::Now() - invocation_time_;
lens::RecordSessionDuration(invocation_source_, session_duration);
// UKM session end metrics. Includes invocation source, whether the
// session resulted in a search, invocation document type and session
// duration.
ukm::SourceId source_id =
tab_->GetContents()->GetPrimaryMainFrame()->GetPageUkmSourceId();
lens::RecordUKMSessionEndMetrics(source_id, invocation_source_,
search_performed_in_session_,
session_duration, initial_document_type_);
// UMA and UKM end of session metrics for the CSB. Only recorded if CSB is
// shown in session.
lens::RecordContextualSearchboxSessionEndMetrics(
source_id, contextual_searchbox_shown_in_session_,
contextual_searchbox_focused_in_session_,
contextual_zps_shown_in_session_, contextual_zps_used_in_session_,
contextual_query_issued_in_session_, initial_page_content_type_);
}
void LensOverlayController::RecordDocumentMetrics(
std::optional<uint32_t> page_count) {
auto content_type = initialization_data_->page_content_type_;
lens::RecordDocumentSizeBytes(
content_type, initialization_data_->page_content_bytes_.size());
if (page_count.has_value() && content_type == lens::MimeType::kPdf) {
lens::RecordPdfPageCount(page_count.value());
return;
}
// Fetch and record the other content type for representing the webpage.
auto* render_frame_host = tab_->GetContents()->GetPrimaryMainFrame();
if (content_type == lens::MimeType::kHtml) {
// Fetch the innerText to log the size.
content_extraction::GetInnerText(
*render_frame_host, /*node_id=*/std::nullopt,
base::BindOnce(&LensOverlayController::RecordInnerTextSize,
weak_factory_.GetWeakPtr()));
} else if (content_type == lens::MimeType::kPlainText) {
// Fetch the innerHtml bytes to log the size.
content_extraction::GetInnerHtml(
*render_frame_host,
base::BindOnce(&LensOverlayController::RecordInnerHtmlSize,
weak_factory_.GetWeakPtr()));
}
}
void LensOverlayController::RecordInnerTextSize(
std::unique_ptr<content_extraction::InnerTextResult> result) {
if (!result) {
return;
}
lens::RecordDocumentSizeBytes(lens::MimeType::kPlainText,
result->inner_text.size());
}
void LensOverlayController::RecordInnerHtmlSize(
const std::optional<std::string>& result) {
if (!result) {
return;
}
lens::RecordDocumentSizeBytes(lens::MimeType::kHtml, result->size());
}
void LensOverlayController::MaybeLaunchSurvey() {
if (!base::FeatureList::IsEnabled(lens::features::kLensOverlaySurvey)) {
return;
}
if (hats_triggered_in_session_) {
return;
}
HatsService* hats_service = HatsServiceFactory::GetForProfile(
tab_->GetBrowserWindowInterface()->GetProfile(),
/*create_if_necessary=*/true);
if (!hats_service) {
// HaTS may not be available in e.g. guest profile
return;
}
hats_triggered_in_session_ = true;
hats_service->LaunchDelayedSurveyForWebContents(
kHatsSurveyTriggerLensOverlayResults, tab_->GetContents(),
lens::features::GetLensOverlaySurveyResultsTime().InMilliseconds(),
/*product_specific_bits_data=*/{},
/*product_specific_string_data=*/
{{"ID that's tied to your Google Lens session",
base::NumberToString(lens_overlay_query_controller_->gen204_id())}});
}
void LensOverlayController::InitializeTutorialIPHUrlMatcher() {
if (!base::FeatureList::IsEnabled(
feature_engagement::kIPHLensOverlayFeature)) {
return;
}
tutorial_iph_url_matcher_ = std::make_unique<url_matcher::URLMatcher>();
base::MatcherStringPattern::ID id(0);
url_matcher::util::AddFiltersWithLimit(
tutorial_iph_url_matcher_.get(), true, &id,
JSONArrayToVector(
feature_engagement::kIPHLensOverlayUrlAllowFilters.Get()),
&iph_url_filters_);
url_matcher::util::AddFiltersWithLimit(
tutorial_iph_url_matcher_.get(), false, &id,
JSONArrayToVector(
feature_engagement::kIPHLensOverlayUrlBlockFilters.Get()),
&iph_url_filters_);
}
void LensOverlayController::MaybeShowDelayedTutorialIPH(const GURL& url) {
// If a tutorial IPH was already queued, cancel it.
tutorial_iph_timer_.Stop();
if (IsUrlEligibleForTutorialIPH(url)) {
tutorial_iph_timer_.Start(
FROM_HERE, feature_engagement::kIPHLensOverlayDelayTime.Get(),
base::BindOnce(&LensOverlayController::ShowTutorialIPH,
weak_factory_.GetWeakPtr()));
}
}
void LensOverlayController::UpdateNavigationTime() {
last_navigation_time_ = base::TimeTicks::Now();
}
bool LensOverlayController::IsUrlEligibleForTutorialIPH(const GURL& url) {
if (!tutorial_iph_url_matcher_) {
return false;
}
auto matches = tutorial_iph_url_matcher_.get()->MatchURL(url);
if (!matches.size()) {
return false;
}
for (auto match : matches) {
// Blocks take precedence over allows.
if (!iph_url_filters_[match].allow) {
return false;
}
}
return true;
}
void LensOverlayController::ShowTutorialIPH() {
if (auto* user_ed =
tab_->GetBrowserWindowInterface()->GetUserEducationInterface()) {
user_ed->MaybeShowFeaturePromo(feature_engagement::kIPHLensOverlayFeature);
}
}
void LensOverlayController::NotifyUserEducationAboutOverlayUsed() {
if (auto* user_ed =
tab_->GetBrowserWindowInterface()->GetUserEducationInterface()) {
user_ed->NotifyFeaturePromoFeatureUsed(
feature_engagement::kIPHLensOverlayFeature,
FeaturePromoFeatureUsedAction::kClosePromoIfPresent);
}
}