Brian Leonard bleonard

bleonard / hard_worker.rb

Created April 14, 2017 22:01

	class HardWorker
	include TResque::Worker
	inputs :name, :count

	def work
	# do something with self.name, self.count
	end
	end

	# enqueue

bleonard / hard_worker.rb

Created April 14, 2017 22:00

	class HardWorker
	include Sidekiq::Worker
	def perform(name, count)
	# do something with name, count
	end
	end

	# enqueue
	HardWorker.perform_async('bob', 5)

bleonard / bus_subscriptions.rb

Created April 11, 2017 04:11

	# Whenever the user changes
	subscribe 'user_may_have_changed', bus_observer_touched: 'user' do \|attributes\|
	# update the profile in ElasticSearch
	ProfileStoreWorker.enqueue(user_id: attributes['id'])
	end

bleonard / jobs_controller.rb

Created March 5, 2017 22:11

	class JobsController < ApplicationController
	def confirm
	@job = Job.find(params[:id])
	authorize @job, :confirm? # authorization
	op = Organic::JobConfirmOp.new(current_user)
	op.submit!(params.merge(job_id: @job.id)) # perform action
	render :show # render template
	end
	end

bleonard / invoice_job_op.rb

Created March 5, 2017 22:10

	class InvoiceJobOp < ::Backend::Op
	include Mixins::AtomicOperation # all in same transaction

	field :hours
	field :job_id

	validates :job_id, presence: true
	validate :validate_hour # hours given
	validate :validate_assignment # tasker is assigned
	# ... other checks

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