@@ -36,10 +36,11 @@ func TestRepository_Save(t *testing.T) {
3636 r := repository .New (eventstore .New ())
3737
3838 aggregateID := uuid .New ()
39+ now := time .Now ()
3940 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 )) ),
4344 }
4445
4546 var flushed bool
@@ -204,10 +205,11 @@ func TestRepository_FetchVersion(t *testing.T) {
204205func TestRepository_FetchVersion_zeroOrNegative (t * testing.T ) {
205206 aggregateName := "foo"
206207 aggregateID := uuid .New ()
208+ now := time .Now ()
207209 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 )) ),
211213 }
212214
213215 org := test .NewFoo (aggregateID )
0 commit comments