@@ -6,7 +6,7 @@ context EventContext is {
6
6
include "eventTypeDefinitions"
7
7
include "eventSources"
8
8
9
- function incrementDelayedEventTime is {
9
+ function IncrementDelayedEventTime is {
10
10
requires {originalTime: DateTime, duration: Duration}
11
11
returns { newTime: DateTime }
12
12
body ???
@@ -41,7 +41,7 @@ context EventContext is {
41
41
42
42
handler EventHandler is {
43
43
on command CreateEvent {
44
- send event EventCreated to outlet EventEvents .Events
44
+ send event EventCreated to outlet EventEventsSource .Events
45
45
morph entity Event to state DraftEvent with record DraftEventState
46
46
}
47
47
on other {
@@ -60,20 +60,20 @@ context EventContext is {
60
60
on command ScheduleEvent{
61
61
if "all required info fields are present" then {
62
62
"set a scheduled Akka call for emitting StartEvent at DraftEventState.info.expectedStart"
63
- send event EventScheduled to outlet EventEvents .Events
63
+ send event EventScheduled to outlet EventEventsSource .Events
64
64
morph entity Event to state ScheduledEvent with record ScheduledEventState
65
65
}
66
66
}
67
67
on command EditEventInfo{
68
68
set field DraftEventState.info to "EventContext.newEditableInfoFromFieldsPresentInEditable"
69
69
set field DraftEventState.meta to "EventMetaInfo"
70
70
send event EventRescheduled
71
- to outlet EventEvents .Events
71
+ to outlet EventEventsSource .Events
72
72
}
73
73
on command CancelEvent{
74
74
if "all required info fields are present" then {
75
75
"cancel associated scheduled call to emit StartEvent"
76
- send event EventCancelled to outlet EventEvents .Events
76
+ send event EventCancelled to outlet EventEventsSource .Events
77
77
morph entity Event to state ScheduledEvent with record ScheduledEventState
78
78
}
79
79
}
@@ -82,13 +82,13 @@ context EventContext is {
82
82
"adjust associated scheduled call to emit StartEvent"
83
83
set field DraftEventState.info to "EditableEventInfo"
84
84
set field DraftEventState.meta to "EventMetaInfo"
85
- send event EventRescheduled to outlet EventEvents .Events
85
+ send event EventRescheduled to outlet EventEventsSource .Events
86
86
}
87
87
}
88
88
on command DelayEvent{
89
89
if "all required info fields are present" then {
90
90
"adjust associated scheduled call to emit StartEvent"
91
- send event EventDelayed to outlet EventEvents .Events
91
+ send event EventDelayed to outlet EventEventsSource .Events
92
92
morph entity Event to state ScheduledEvent with record ScheduledEventState
93
93
}
94
94
}
@@ -127,29 +127,29 @@ context EventContext is {
127
127
on command EditEventInfo {
128
128
set field ScheduledEventState.info to "EventContext.newInfoFromFieldsPresentInEditable"
129
129
set field ScheduledEventState.meta to "EventMetaInfo"
130
- send event EventInfoEdited to outlet EventEvents .Events
130
+ send event EventInfoEdited to outlet EventEventsSource .Events
131
131
}
132
132
on command CancelEvent {
133
133
"cancel associated scheduled call to emit StartEvent"
134
- send event EventCancelled to outlet EventEvents .Events
134
+ send event EventCancelled to outlet EventEventsSource .Events
135
135
become entity Event to handler CancelledEventHandler
136
136
}
137
137
on command DelayEvent {
138
138
"adjust associated scheduled Akka call to emit StartEvent"
139
- send event EventDelayed to outlet EventEvents .Events
139
+ send event EventDelayed to outlet EventEventsSource .Events
140
140
become entity Event to handler DelayedEventHandler
141
141
}
142
142
on command StartEvent{
143
143
"create scheduled Akka call using ScheduledEventState.info.expectedEnd to emit EndEvent"
144
- send event EventStarted to outlet EventEvents .Events
144
+ send event EventStarted to outlet EventEventsSource .Events
145
145
become entity Event to handler InProgressEventHandler
146
146
} briefly "to be invoked by Akka scheduler upon ScheduleEvent reception"
147
147
on command RescheduleEvent {
148
148
if "start is validated to be before end in command" then {
149
149
"adjust associated scheduled call to emit StartEvent"
150
150
set field ScheduledEventState.info to "EventInfo"
151
151
set field ScheduledEventState.meta to "EventMetaInfo"
152
- send event EventRescheduled to outlet EventEvents .Events
152
+ send event EventRescheduled to outlet EventEventsSource .Events
153
153
}
154
154
}
155
155
on command EndEvent{
@@ -178,14 +178,14 @@ context EventContext is {
178
178
}
179
179
on command DelayEvent{
180
180
"adjust associated scheduled Akka call to emit StartEvent"
181
- send event EventDelayed to outlet EventEvents .Events
181
+ send event EventDelayed to outlet EventEventsSource .Events
182
182
become entity Event to handler DelayedEventHandler
183
183
}
184
184
on command StartEvent {
185
185
error "Event is already started. Cannot start an event that is already in progress"
186
186
}
187
187
on command EndEvent {
188
- send event EventEnded to outlet EventEvents .Events
188
+ send event EventEnded to outlet EventEventsSource .Events
189
189
become entity Event to handler PastEventHandler
190
190
}
191
191
// TODO: specify AddLiveUpdate on clause
@@ -203,27 +203,27 @@ context EventContext is {
203
203
on command EditEventInfo{
204
204
set field ScheduledEventState.info to "EventContext.newInfoFromFieldsPresentInEditable"
205
205
set field ScheduledEventState.meta to "EventMetaInfo"
206
- send event EventInfoEdited to outlet EventEvents .Events
206
+ send event EventInfoEdited to outlet EventEventsSource .Events
207
207
}
208
208
on command CancelEvent{
209
209
"cancel associated scheduled call to emit StartEvent"
210
- send event EventCancelled to outlet EventEvents .Events
210
+ send event EventCancelled to outlet EventEventsSource .Events
211
211
become entity Event to handler CancelledEventHandler
212
212
}
213
213
on command RescheduleEvent{
214
214
if "start is validated to be before end in command" then {
215
215
"adjust associated scheduled call to emit StartEvent"
216
216
set field ScheduledEventState.info to "EventInfo"
217
217
set field ScheduledEventState.meta to "EventMetaInfo"
218
- send event EventRescheduled to outlet EventEvents .Events
218
+ send event EventRescheduled to outlet EventEventsSource .Events
219
219
}
220
220
}
221
221
on command DelayEvent{
222
222
error "Cannot delay a delayed event again, must be rescheduled"
223
223
}
224
224
on command StartEvent{
225
225
"create scheduled Akka call using ScheduledEventState.info.expectedEnd to emit EndEvent"
226
- send event EventStarted to outlet EventEvents .Events
226
+ send event EventStarted to outlet EventEventsSource .Events
227
227
become entity Event to handler InProgressEventHandler
228
228
} briefly "to be invoked by Akka scheduler upon ScheduleEvent reception"
229
229
on command EndEvent{
@@ -240,7 +240,7 @@ context EventContext is {
240
240
"adjust associated scheduled call to emit StartEvent"
241
241
set field ScheduledEventState.info to "EventInfo"
242
242
set field ScheduledEventState.meta to "EventMetaInfo"
243
- send event EventRescheduled to outlet EventEvents .Events
243
+ send event EventRescheduled to outlet EventEventsSource .Events
244
244
}
245
245
}
246
246
on other {
0 commit comments