Class: Weary::Request
- Inherits:
-
Object
- Object
- Weary::Request
- Defined in:
- lib/sleepy.rb
Class Method Summary collapse
Instance Method Summary collapse
- #perform_sleepily(timeout = 60*60*1000, &block) ⇒ Object
-
#perform_sleepily!(timeout = 60*60*1000, &block) ⇒ Object
Redefine the perform method.
- #round_time(integer, factor) ⇒ Object
- #sleepy ⇒ Object
Class Method Details
.sleepy ⇒ Object
9 10 11 |
# File 'lib/sleepy.rb', line 9 def self.sleepy @@sleepy ||= Memcached.new end |
Instance Method Details
#perform_sleepily(timeout = 60*60*1000, &block) ⇒ Object
22 23 24 25 26 |
# File 'lib/sleepy.rb', line 22 def perform_sleepily(timeout=60*60*1000, &block) @on_complete = block if block_given? response = perform_sleepily!(timeout) response.value end |
#perform_sleepily!(timeout = 60*60*1000, &block) ⇒ Object
Redefine the perform method
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 |
# File 'lib/sleepy.rb', line 29 def perform_sleepily!(timeout=60*60*1000, &block) @on_complete = block if block_given? Thread.new { STDERR.puts "Before send: #{uri}" before_send.call(self) if before_send STDERR.puts "try nap" nap = sleepy.get("#{round_time(Time.new.to_i, timeout)}:#{uri}") rescue nil unless nap.blank? STDERR.puts "Return cached result #{nap.inspect}" nap else req = http.request(request) response = Response.new(req, self) begin if response.redirected? response.follow_redirect else on_complete.call(response) if on_complete response end sleepy.set("#{round_time(Time.new.to_i, timeout)}:#{uri}", response) sleepy.set("0:#{uri}", response) rescue sleepy.get("0:#{uri}") rescue nil end response end } end |
#round_time(integer, factor) ⇒ Object
17 18 19 20 |
# File 'lib/sleepy.rb', line 17 def round_time(integer, factor) return integer if(integer % factor == 0) return integer - (integer % factor) end |
#sleepy ⇒ Object
13 14 15 |
# File 'lib/sleepy.rb', line 13 def sleepy self.class.sleepy end |