Sha256: 636c14c5e24404555d23ae247bb2c7112c1dae520bbdffda1fbb1a83ac68584d
Contents?: true
Size: 1.2 KB
Versions: 10
Compression:
Stored size: 1.2 KB
Contents
require 'thread'
module PageRankr
module Trackers
attr_accessor :site_trackers
def initialize
@site_trackers = self.class.constants.collect{|tracker| symbol_for(tracker)}
end
def lookup(site, *trackers)
trackers = site_trackers if trackers.empty?
tracked = trackers.map do |tracker|
name, klass = constant_name(tracker), self.class
next unless klass.const_defined? name
[
tracker,
build_thread(tracker, klass.const_get(name), site)
]
end.each do |_, thread|
thread.join
end.map do |tracker, thread|
[tracker, thread.value]
end
Hash[tracked]
end
private
def build_thread(tracker, instance, site)
Thread.new(tracker, instance, site) do |t, i, s|
i.new(s).run
end
end
def symbol_for(klass)
word = klass.to_s.dup
word.gsub!(/([A-Z]+)([A-Z][a-z])/){|match| "#{$1}_#{$2}" }
word.gsub!(/([a-z\d])([A-Z])/){|match| "#{$1}_#{$2}" }
word.tr!("-", "_")
word.downcase!
word.to_sym
end
def constant_name(sym)
sym.to_s.split('_').collect{|str| str.capitalize}.join
end
end
end
Version data entries
10 entries across 10 versions & 1 rubygems