16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
|
# File 'foobara-0.0.110/projects/persistence/src/entity_base/transaction/concerns/entity_callback_handling.rb', line 16
def install!
Entity.after_dirtied do |record:, **|
transaction = Transaction.open_transaction_for(record)
unless transaction
raise NoCurrentTransactionError,
"Cannot modify #{record} because there's no current transaction"
end
unless transaction.open?
raise CurrentTransactionIsClosedError,
"Cannot modify #{record} because current transaction is not open"
end
transaction.updated(record)
end
Entity.after_undirtied do |record:, **|
transaction = Transaction.open_transaction_for(record)
unless transaction
raise NoCurrentTransactionError,
"Cannot modify #{record} because there's no current transaction"
end
unless transaction.open?
raise CurrentTransactionIsClosedError,
"Cannot modify #{record} because current transaction is not open"
end
transaction.updated(record)
end
Entity.after_hard_deleted do |record:, **|
transaction = Transaction.open_transaction_for(record)
unless transaction
raise NoCurrentTransactionError,
"Cannot modify #{record} because there's no current transaction"
end
unless transaction.open?
raise CurrentTransactionIsClosedError,
"Cannot modify #{record} because current transaction is not open"
end
transaction.hard_deleted(record)
end
Entity.after_unhard_deleted do |record:, **|
transaction = Transaction.open_transaction_for(record)
unless transaction
raise NoCurrentTransactionError,
"Cannot modify #{record} because there's no current transaction"
end
unless transaction.open?
raise CurrentTransactionIsClosedError,
"Cannot modify #{record} because current transaction is not open"
end
transaction.unhard_deleted(record)
end
Entity.after_initialized_loaded do |record:, **|
transaction = Persistence.current_transaction(record)
unless transaction
raise NoCurrentTransactionError,
"Cannot initialize #{record} because there's no current transaction"
end
unless transaction.open?
raise CurrentTransactionIsClosedError,
"Cannot initialize #{record} because current transaction is not open"
end
transaction.track_loaded(record)
end
Entity.after_initialized_created do |record:, **|
transaction = Persistence.current_transaction(record)
unless transaction
raise NoCurrentTransactionError,
"Cannot initialize #{record} because there's no current transaction"
end
unless transaction.open?
raise CurrentTransactionIsClosedError,
"Cannot initialize #{record} because current transaction is not open"
end
transaction.track_created(record)
end
Entity.after_initialized_thunk do |record:, **|
transaction = Persistence.current_transaction(record)
unless transaction
raise NoCurrentTransactionError,
"Cannot initialize #{record} because there's no current transaction"
end
unless transaction.open?
raise CurrentTransactionIsClosedError,
"Cannot initialize #{record} because current transaction is not open"
end
transaction.track_unloaded_thunk(record)
end
end
|