1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
|
// Copyright 2013 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#include "ui/app_list/search_controller.h"
#include <algorithm>
#include <vector>
#include "base/bind.h"
#include "base/memory/scoped_ptr.h"
#include "base/metrics/user_metrics.h"
#include "base/strings/string_util.h"
#include "base/strings/utf_string_conversions.h"
#include "ui/app_list/search/history.h"
#include "ui/app_list/search_box_model.h"
#include "ui/app_list/search_provider.h"
#include "ui/app_list/search_result.h"
namespace {
// Maximum time (in milliseconds) to wait to the search providers to finish.
const int kStopTimeMS = 1500;
}
namespace app_list {
SearchController::SearchController(SearchBoxModel* search_box,
AppListModel::SearchResults* results,
History* history)
: search_box_(search_box),
dispatching_query_(false),
mixer_(new Mixer(results)),
history_(history),
is_voice_query_(false) {
mixer_->Init();
}
SearchController::~SearchController() {
}
void SearchController::Start(bool is_voice_query) {
Stop();
base::string16 query;
base::TrimWhitespace(search_box_->text(), base::TRIM_ALL, &query);
dispatching_query_ = true;
for (Providers::iterator it = providers_.begin();
it != providers_.end();
++it) {
(*it)->Start(is_voice_query, query);
}
dispatching_query_ = false;
is_voice_query_ = is_voice_query;
OnResultsChanged();
stop_timer_.Start(FROM_HERE,
base::TimeDelta::FromMilliseconds(kStopTimeMS),
base::Bind(&SearchController::Stop,
base::Unretained(this)));
}
void SearchController::Stop() {
stop_timer_.Stop();
for (Providers::iterator it = providers_.begin();
it != providers_.end();
++it) {
(*it)->Stop();
}
}
void SearchController::OpenResult(SearchResult* result, int event_flags) {
// Count AppList.Search here because it is composed of search + action.
base::RecordAction(base::UserMetricsAction("AppList_Search"));
result->Open(event_flags);
if (history_ && history_->IsReady()) {
history_->AddLaunchEvent(base::UTF16ToUTF8(search_box_->text()),
result->id());
}
}
void SearchController::InvokeResultAction(SearchResult* result,
int action_index,
int event_flags) {
// TODO(xiyuan): Hook up with user learning.
result->InvokeAction(action_index, event_flags);
}
void SearchController::AddProvider(Mixer::GroupId group,
scoped_ptr<SearchProvider> provider) {
provider->set_result_changed_callback(base::Bind(
&SearchController::OnResultsChanged,
base::Unretained(this)));
mixer_->AddProviderToGroup(group, provider.get());
providers_.push_back(provider.release()); // Takes ownership.
}
void SearchController::OnResultsChanged() {
if (dispatching_query_)
return;
KnownResults known_results;
if (history_ && history_->IsReady()) {
history_->GetKnownResults(base::UTF16ToUTF8(search_box_->text()))
->swap(known_results);
}
mixer_->MixAndPublish(is_voice_query_, known_results);
}
} // namespace app_list
|
