Class: EventProcessor

Inherits:
Object
  • Object
show all
Defined in:
lib/ObjectModel/Repository/EventProcessor.rb

Instance Method Summary collapse

Constructor Details

#initialize(transaction) ⇒ EventProcessor

Returns a new instance of EventProcessor.



2
3
4
5
 
# File 'lib/ObjectModel/Repository/EventProcessor.rb', line 2

def initialize transaction
	@transaction = transaction
	@before_history = []
end

Instance Method Details

#fire_after(entity, event, *params) ⇒ Object 



18
19
20
21
22
23
24
25
26
27
 
# File 'lib/ObjectModel/Repository/EventProcessor.rb', line 18

def fire_after entity, event, *params
	entity.should! :be_a, Entity
	event.should! :be_in, Metadata::AFTER_EVENT_TYPES
	
	l_event = :"after_#{event}"
	@transaction.repository.entity_listeners.each{|l| l.respond_to l_event, entity, *params}
	@transaction.system_listener.respond_to l_event, entity, *params
	
	entity.meta.after.fire entity, event, *params
end

#fire_after_commit ⇒ Object 



41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
 
# File 'lib/ObjectModel/Repository/EventProcessor.rb', line 41

def fire_after_commit
	entities = []
	@transaction.copies.each do |entity_id, c|
		entity = if @transaction.deleted_entities.include? entity_id
			@transaction.deleted_entities[entity_id]
		else
			@transaction.repository.by_id entity_id
		end
		entities << entity			
	end		
	
	# :after_commit
	@transaction.repository.entity_listeners.each{|l| l.respond_to :after_commit, entities}
	@transaction.system_listener.respond_to :after_commit, entities					
	
	entities.each{|e| e.meta.after.fire e, :commit}
end

#fire_before(entity, event, *params) ⇒ Object 



7
8
9
10
11
12
13
14
15
16
 
# File 'lib/ObjectModel/Repository/EventProcessor.rb', line 7

def fire_before entity, event, *params
	entity.should! :be_a, Entity
	event.should! :be_in, Metadata::BEFORE_EVENT_TYPES
	
	l_event = :"before_#{event}"
	@transaction.repository.entity_listeners.each{|l| l.respond_to l_event, entity, *params}
	@transaction.system_listener.respond_to l_event, entity, *params
	
	entity.meta.before.fire entity, event, *params		
end

#fire_before_commit ⇒ Object 



29
30
31
32
33
34
35
36
37
38
39
 
# File 'lib/ObjectModel/Repository/EventProcessor.rb', line 29

def fire_before_commit
	entities = []
	@transaction.copies.each do |entity_id, c|
		entities << @transaction.resolve(entity_id)												
	end
	
	@transaction.repository.entity_listeners.each{|l| l.respond_to :before_commit, entities}
	@transaction.system_listener.respond_to :before_commit, entities					
	
	entities.each{|e| e.meta.before.fire e, :commit}
end