Brian Leonard bleonard

bleonard / main.rb

Created December 24, 2016 19:23

	class Main
	def process_all
	mutex = Mutex.new
	queue = self.paths.dup

	self.thread_count.times.map {
	Thread.new do
	while path = mutex.synchronize { queue.pop }
	fetcher = ThreadedFetcher.new(path)
	fetcher.fetch!

bleonard / fetcher.rb

Created December 24, 2016 19:23

	class Fetcher
	def initialize(path)
	@path = path
	end

	def fetch!
	VCR.use_cassette('#{@path}/fetched') do
	response = Net::HTTP.get_response(URI("api.http://example.com/#{@path}"))
	process(response)
	end

bleonard / client.rb

Created December 24, 2016 19:22

bleonard / vcr.rb

Created December 24, 2016 19:21

bleonard / application.html.erb

Created December 24, 2016 19:19

bleonard / task.rb

Created December 24, 2016 19:16

	class Task < ActiveRecord::Base
	after_save :sync_with_external

	def sync_with_external
	response = External.sync!(id: self.id, info: self.info)
	if response.error?
	self.errors.add(:base, "There was a problem, etc ...")
	raise ActiveRecord::RecordInvalid.new(self)
	end
	true # I still do this out of superstition

bleonard / record.rb

Created December 24, 2016 19:15

	def save(*)
	create_or_update
	rescue ActiveRecord::RecordInvalid
	false
	end

bleonard / subscriber.rb

Created December 24, 2016 19:14

	class TaskChangesSubscriber
	include ResqueBus::Subscriber
	subscribe :task_changed
	subscribe :changed_when_opened, "bus_event_type" => "task_changed", "state" => "opened"

	def task_changed(attributes)
	# gets called for all task changes
	end

	def changed_when_opened

bleonard / bus_subscriptions.rb

Created December 24, 2016 19:14

	subscribe "any_id_i_want", "bus_event_type" => "task_changed", "state" => "opened" do \|attributes\|
	TaskIndex.write(attributes["id"])
	end

bleonard / bus_subscritptions.rb

Created December 24, 2016 19:13

	subscribe "task_changed", "bus_event_type" => "task_changed" do \|attributes\|
	if attributes["state"] == 'opened'
	TaskIndex.write(attributes["id"])
	end
	end