helix
/
invidious
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Check /browse_ajax for channel blocks

Browse Source
pull/1011/head
Omar Roth 5 years ago
parent b7a7abed48
commit a2c5211b20
No known key found for this signature in database
GPG Key ID: B8254FB7EC3D37F2
1 changed files with 83 additions and 88 deletions
Show Stats Download Patch File Download Diff File

171
src/invidious/helpers/jobs.cr
Unescape Escape View File

@ -236,114 +236,109 @@ end
def bypass_captcha(captcha_key, logger) def bypass_captcha(captcha_key, logger)
loop do loop do
begin begin
response = YT_POOL.client &.get("/watch?v=CvFH_6DNRCY&gl=US&hl=en&disable_polymer=1&has_verified=1&bpctr=9999999999") {"/watch?v=CvFH_6DNRCY&gl=US&hl=en&disable_polymer=1&has_verified=1&bpctr=9999999999", produce_channel_videos_url(ucid: "UCXuqSBlHAE6Xw-yeJA0Tunw")}.each do |path|
if response.body.includes?("To continue with your YouTube experience, please fill out the form below.") response = YT_POOL.client &.get(path)
html = XML.parse_html(response.body) if response.body.includes?("To continue with your YouTube experience, please fill out the form below.")
form = html.xpath_node(%(//form[@action="/das_captcha"])).not_nil! html = XML.parse_html(response.body)
site_key = form.xpath_node(%(.//div[@class="g-recaptcha"])).try &.["data-sitekey"] form = html.xpath_node(%(//form[@action="/das_captcha"])).not_nil!
site_key = form.xpath_node(%(.//div[@class="g-recaptcha"])).try &.["data-sitekey"]
inputs = {} of String => String
form.xpath_nodes(%(.//input[@name])).map do |node| inputs = {} of String => String
inputs[node["name"]] = node["value"] form.xpath_nodes(%(.//input[@name])).map do |node|
end inputs[node["name"]] = node["value"]
end
headers = response.cookies.add_request_headers(HTTP::Headers.new)
response = JSON.parse(HTTP::Client.post("https://api.anti-captcha.com/createTask", body: {
"clientKey" => CONFIG.captcha_key,
"task" => {
"type" => "NoCaptchaTaskProxyless",
# "type" => "NoCaptchaTask",
"websiteURL" => "https://www.youtube.com/watch?v=CvFH_6DNRCY&gl=US&hl=en&disable_polymer=1&has_verified=1&bpctr=9999999999",
"websiteKey" => site_key,
# "proxyType" => "http",
# "proxyAddress" => CONFIG.proxy_address,
# "proxyPort" => CONFIG.proxy_port,
# "proxyLogin" => CONFIG.proxy_user,
# "proxyPassword" => CONFIG.proxy_pass,
# "userAgent" => "User-Agent: Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/78.0.3904.97 Safari/537.36",
},
}.to_json).body)
if response["error"]?
raise response["error"].as_s
end
task_id = response["taskId"].as_i
loop do headers = response.cookies.add_request_headers(HTTP::Headers.new)
sleep 10.seconds
response = JSON.parse(HTTP::Client.post("https://api.anti-captcha.com/getTaskResult", body: { response = JSON.parse(HTTP::Client.post("https://api.anti-captcha.com/createTask", body: {
"clientKey" => CONFIG.captcha_key, "clientKey" => CONFIG.captcha_key,
"taskId" => task_id, "task" => {
"type" => "NoCaptchaTaskProxyless",
"websiteURL" => "https://www.youtube.com/watch?v=CvFH_6DNRCY&gl=US&hl=en&disable_polymer=1&has_verified=1&bpctr=9999999999",
"websiteKey" => site_key,
},
}.to_json).body) }.to_json).body)
if response["status"]?.try &.== "ready" if response["error"]?
break raise response["error"].as_s
elsif response["errorId"]?.try &.as_i != 0
raise response["errorDescription"].as_s
end end
end
inputs["g-recaptcha-response"] = response["solution"]["gRecaptchaResponse"].as_s task_id = response["taskId"].as_i
response = YT_POOL.client &.post("/das_captcha", headers, form: inputs)
yield response.cookies.select { |cookie| cookie.name != "PREF" } loop do
elsif response.headers["Location"]?.try &.includes?("/sorry/index") sleep 10.seconds
location = response.headers["Location"].try { |u| URI.parse(u) }
client = QUIC::Client.new(location.host.not_nil!)
response = client.get(location.full_path)
html = XML.parse_html(response.body) response = JSON.parse(HTTP::Client.post("https://api.anti-captcha.com/getTaskResult", body: {
form = html.xpath_node(%(//form[@action="index"])).not_nil! "clientKey" => CONFIG.captcha_key,
site_key = form.xpath_node(%(.//div[@class="g-recaptcha"])).try &.["data-sitekey"] "taskId" => task_id,
}.to_json).body)
inputs = {} of String => String if response["status"]?.try &.== "ready"
form.xpath_nodes(%(.//input[@name])).map do |node| break
inputs[node["name"]] = node["value"] elsif response["errorId"]?.try &.as_i != 0
end raise response["errorDescription"].as_s
end
end
response = JSON.parse(HTTP::Client.post("https://api.anti-captcha.com/createTask", body: { inputs["g-recaptcha-response"] = response["solution"]["gRecaptchaResponse"].as_s
"clientKey" => CONFIG.captcha_key, response = YT_POOL.client &.post("/das_captcha", headers, form: inputs)
"task" => {
"type" => "NoCaptchaTaskProxyless",
"websiteURL" => location.to_s,
"websiteKey" => site_key,
},
}.to_json).body)
if response["error"]?
raise response["error"].as_s
end
task_id = response["taskId"].as_i yield response.cookies.select { |cookie| cookie.name != "PREF" }
elsif response.headers["Location"]?.try &.includes?("/sorry/index")
location = response.headers["Location"].try { |u| URI.parse(u) }
client = QUIC::Client.new(location.host.not_nil!)
response = client.get(location.full_path)
loop do html = XML.parse_html(response.body)
sleep 10.seconds form = html.xpath_node(%(//form[@action="index"])).not_nil!
site_key = form.xpath_node(%(.//div[@class="g-recaptcha"])).try &.["data-sitekey"]
response = JSON.parse(HTTP::Client.post("https://api.anti-captcha.com/getTaskResult", body: { inputs = {} of String => String
form.xpath_nodes(%(.//input[@name])).map do |node|
inputs[node["name"]] = node["value"]
end
response = JSON.parse(HTTP::Client.post("https://api.anti-captcha.com/createTask", body: {
"clientKey" => CONFIG.captcha_key, "clientKey" => CONFIG.captcha_key,
"taskId" => task_id, "task" => {
"type" => "NoCaptchaTaskProxyless",
"websiteURL" => location.to_s,
"websiteKey" => site_key,
},
}.to_json).body) }.to_json).body)
if response["status"]?.try &.== "ready" if response["error"]?
break raise response["error"].as_s
elsif response["errorId"]?.try &.as_i != 0
raise response["errorDescription"].as_s
end end
end
inputs["g-recaptcha-response"] = response["solution"]["gRecaptchaResponse"].as_s task_id = response["taskId"].as_i
client.close
client = QUIC::Client.new("www.google.com") loop do
response = client.post(location.full_path, form: inputs) sleep 10.seconds
headers = HTTP::Headers{
"Cookie" => URI.parse(response.headers["location"]).query_params["google_abuse"].split(";")[0], response = JSON.parse(HTTP::Client.post("https://api.anti-captcha.com/getTaskResult", body: {
} "clientKey" => CONFIG.captcha_key,
cookies = HTTP::Cookies.from_headers(headers) "taskId" => task_id,
}.to_json).body)
yield cookies if response["status"]?.try &.== "ready"
break
elsif response["errorId"]?.try &.as_i != 0
raise response["errorDescription"].as_s
end
end
inputs["g-recaptcha-response"] = response["solution"]["gRecaptchaResponse"].as_s
client.close
client = QUIC::Client.new("www.google.com")
response = client.post(location.full_path, form: inputs)
headers = HTTP::Headers{
"Cookie" => URI.parse(response.headers["location"]).query_params["google_abuse"].split(";")[0],
}
cookies = HTTP::Cookies.from_headers(headers)
yield cookies
end
end end
rescue ex rescue ex
logger.puts("Exception: #{ex.message}") logger.puts("Exception: #{ex.message}")

Write Preview
Loading…
Cancel
Save