Contents

module ChangeManager
	class Manager
		def self.queue_change(owner, change_type, context, target)
			change_id = Change.new_change(owner, change_type, context, target)
			Resque.enqueue(MakeChange, change_id)
			# Resque.enqueue_in(
			# 	30.seconds,
			# 	MakeChange,
			# 	change_id
			# 	)
		end

		def self.notify(change_id)
			unless Change.find(change_id).cancelled?
				change = Change.find(change_id)
				similar_changes = group_similar_changes(change.owner, change.target)
				mailer = ChangeManager::NotificationMailer
				mailer.send_email(mailer.construct_email(similar_changes))
			end
		end

		def self.group_similar_changes(owner, target)
			similar_changes = Change.where(owner: owner, target: target, cancelled: false)
			if similar_changes.length > 1
				cancel_inverse_changes(similar_changes)
			end
			return similar_changes
		end

		def self.cancel_inverse_changes(similar_changes)
			similar_changes.each do |change|
				similar_changes.each do |next_change|
					if change.inverse_of?(next_change)
						change.cancel
						next_change.cancel
						similar_changes.delete_if { |change| change.cancelled? }
					end
				end
			end
			return similar_changes
		end
	end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
change_manager-0.0.1	app/services/change_manager/manager.rb