@@ -36,10 +36,11 @@ func TestRepository_Save(t *testing.T) {
36
36
r := repository .New (eventstore .New ())
37
37
38
38
aggregateID := uuid .New ()
39
+ now := time .Now ()
39
40
events := []event.Event {
40
- event .New [any ]("foo" , etest.FooEventData {}, event .Aggregate (aggregateID , "foo" , 1 )),
41
- event .New [any ]("foo" , etest.FooEventData {}, event .Aggregate (aggregateID , "foo" , 2 )),
42
- event .New [any ]("foo" , etest.FooEventData {}, event .Aggregate (aggregateID , "foo" , 3 )),
41
+ event .New [any ]("foo" , etest.FooEventData {}, event .Aggregate (aggregateID , "foo" , 1 ), event . Time ( now ) ),
42
+ event .New [any ]("foo" , etest.FooEventData {}, event .Aggregate (aggregateID , "foo" , 2 ), event . Time ( now . Add ( time . Nanosecond )) ),
43
+ event .New [any ]("foo" , etest.FooEventData {}, event .Aggregate (aggregateID , "foo" , 3 ), event . Time ( now . Add ( 2 * time . Nanosecond )) ),
43
44
}
44
45
45
46
var flushed bool
@@ -204,10 +205,11 @@ func TestRepository_FetchVersion(t *testing.T) {
204
205
func TestRepository_FetchVersion_zeroOrNegative (t * testing.T ) {
205
206
aggregateName := "foo"
206
207
aggregateID := uuid .New ()
208
+ now := time .Now ()
207
209
events := []event.Event {
208
- event .New [any ]("foo" , etest.FooEventData {A : "foo" }, event .Aggregate (aggregateID , aggregateName , 1 )),
209
- event .New [any ]("foo" , etest.FooEventData {A : "foo" }, event .Aggregate (aggregateID , aggregateName , 2 )),
210
- event .New [any ]("foo" , etest.FooEventData {A : "foo" }, event .Aggregate (aggregateID , aggregateName , 3 )),
210
+ event .New [any ]("foo" , etest.FooEventData {A : "foo" }, event .Aggregate (aggregateID , aggregateName , 1 ), event . Time ( now ) ),
211
+ event .New [any ]("foo" , etest.FooEventData {A : "foo" }, event .Aggregate (aggregateID , aggregateName , 2 ), event . Time ( now . Add ( time . Nanosecond )) ),
212
+ event .New [any ]("foo" , etest.FooEventData {A : "foo" }, event .Aggregate (aggregateID , aggregateName , 3 ), event . Time ( now . Add ( 2 * time . Nanosecond )) ),
211
213
}
212
214
213
215
org := test .NewFoo (aggregateID )
0 commit comments