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
|
#!/usr/bin/env ruby
# frozen_string_literal: true
require_relative '../../lib/async'
require 'async/http/endpoint'
require 'async/http/server'
require 'async/http/internet'
# To query the web server:
# curl http://localhost:9292/kittens
Async do |parent|
endpoint = Async::HTTP::Endpoint.parse("http://localhost:9292")
internet = Async::HTTP::Internet.new
server = Async::HTTP::Server.for(endpoint) do |request|
if request.path =~ /\/(.*)/
keyword = $1
response = internet.get("https://www.google.com/search?q=#{keyword}")
count = response.read.scan(keyword).size
Protocol::HTTP::Response[200, [], ["Google found #{count} instance(s) of #{keyword}.\n"]]
else
Protocol::HTTP::Response[404, [], []]
end
end
tasks = server.run
#while true
parent.sleep(10)
parent.reactor.print_hierarchy
#end
parent.stop # -> Async::Stop
tasks.each(&:stop)
end
|
