mirror of
https://github.com/HoneyryderChuck/httpx.git
synced 2025-10-09 00:02:50 -04:00
43 lines
1.1 KiB
Ruby
43 lines
1.1 KiB
Ruby
require "httpx"
|
|
require "oga"
|
|
|
|
http = HTTPX.plugin(:persistent).with(timeout: { request_timeout: 5 })
|
|
|
|
PAGES = (ARGV.first || 10).to_i
|
|
pages = PAGES.times.map do |page|
|
|
"https://news.ycombinator.com/?p=#{page+1}"
|
|
end
|
|
|
|
links = Array.new(PAGES) { [] }
|
|
Array(http.get(*pages)).each_with_index.map do |response, i|
|
|
if response.is_a?(HTTPX::ErrorResponse)
|
|
puts "error: #{response.error}"
|
|
next
|
|
end
|
|
html = Oga.parse_html(response.to_s)
|
|
# binding.irb
|
|
page_links = html.css('.athing .title a').map{|link| link.get('href') }.select { |link| URI(link).absolute? }
|
|
puts "page(#{i+1}): #{page_links.size}"
|
|
if page_links.size == 0
|
|
puts "error(#{response.status}) on page #{i+1}"
|
|
next
|
|
end
|
|
# page_links.each do |link|
|
|
# puts "link: #{link}"
|
|
# links[i] << http.get(link)
|
|
# end
|
|
links[i].concat(http.get(*page_links))
|
|
end
|
|
|
|
links = links.each_with_index do |pages, i|
|
|
puts "Page: #{i+1}\t Links: #{pages.size}"
|
|
pages.each do |page|
|
|
case page
|
|
in status:
|
|
puts "URL: #{page.uri} (#{status})"
|
|
in error:
|
|
puts "URL: #{page.uri} (#{error.message})"
|
|
end
|
|
end
|
|
end
|