aboutsummaryrefslogtreecommitdiff
path: root/src/plugins
diff options
context:
space:
mode:
Diffstat (limited to 'src/plugins')
-rw-r--r--src/plugins/Youtube.cpp70
1 files changed, 54 insertions, 16 deletions
diff --git a/src/plugins/Youtube.cpp b/src/plugins/Youtube.cpp
index c0180d8..3ab405c 100644
--- a/src/plugins/Youtube.cpp
+++ b/src/plugins/Youtube.cpp
@@ -3,6 +3,60 @@
#include <string.h>
namespace QuickMedia {
+ static void iterate_suggestion_result(const Json::Value &value, std::vector<std::string> &result_items, int &iterate_count) {
+ ++iterate_count;
+ if(value.isArray()) {
+ for(const Json::Value &child : value) {
+ iterate_suggestion_result(child, result_items, iterate_count);
+ }
+ } else if(value.isString() && iterate_count > 2) {
+ result_items.push_back(value.asString());
+ }
+ }
+
+ std::string Youtube::autocomplete_search(const std::string &query) {
+ // Return the last result if the query is a substring of the autocomplete result
+ if(last_autocomplete_result.size() >= query.size() && memcmp(query.data(), last_autocomplete_result.data(), query.size()) == 0)
+ return last_autocomplete_result;
+
+ std::string url = "https://clients1.google.com/complete/search?client=youtube&hl=en&gs_rn=64&gs_ri=youtube&ds=yt&cp=7&gs_id=x&q=";
+ url += url_param_encode(query);
+
+ std::string server_response;
+ if(download_to_string(url, server_response, {}, use_tor, true) != DownloadResult::OK)
+ return query;
+
+ size_t json_start = server_response.find_first_of('(');
+ if(json_start == std::string::npos)
+ return query;
+ ++json_start;
+
+ size_t json_end = server_response.find_last_of(')');
+ if(json_end == std::string::npos)
+ return query;
+
+ if(json_end == 0 || json_start >= json_end)
+ return query;
+
+ Json::Value json_root;
+ Json::CharReaderBuilder json_builder;
+ std::unique_ptr<Json::CharReader> json_reader(json_builder.newCharReader());
+ std::string json_errors;
+ if(!json_reader->parse(&server_response[json_start], &server_response[json_end], &json_root, &json_errors)) {
+ fprintf(stderr, "Youtube autocomplete search json error: %s\n", json_errors.c_str());
+ return query;
+ }
+
+ int iterate_count = 0;
+ std::vector<std::string> result_items;
+ iterate_suggestion_result(json_root, result_items, iterate_count);
+ if(result_items.empty())
+ return query;
+
+ last_autocomplete_result = result_items[0];
+ return result_items[0];
+ }
+
static size_t find_end_of_json(const std::string &website_data, size_t data_start) {
int brace_count = 0;
char string_char = '\0';
@@ -228,14 +282,6 @@ namespace QuickMedia {
}
}
- static std::string get_playlist_id_from_url(const std::string &url) {
- std::string playlist_id = url;
- size_t list_index = playlist_id.find("&list=");
- if(list_index == std::string::npos)
- return playlist_id;
- return playlist_id.substr(list_index);
- }
-
static std::string remove_index_from_playlist_url(const std::string &url) {
std::string result = url;
size_t index = result.rfind("&index=");
@@ -280,14 +326,6 @@ namespace QuickMedia {
BodyItems result_items;
std::string modified_url = remove_index_from_playlist_url(url);
- std::string playlist_id = get_playlist_id_from_url(modified_url);
- if(playlist_id == last_related_media_playlist_id) {
- result_items.reserve(last_playlist_data.size());
- for(auto &data : last_playlist_data) {
- result_items.push_back(std::make_unique<BodyItem>(*data));
- }
- return result_items;
- }
std::string website_data;
if(download_to_string(modified_url, website_data, {}, use_tor, true) != DownloadResult::OK)