Merge pull request #24 from Clarilab/fix-invalid-mongodb-aggregation-synthax

nicoandrewss · web-flow · commit e813dde5347b · 2025-09-24T13:03:33.000+02:00
chore[eventstore/mongodb]: fix invalid aggregation syntax
diff --git a/eventstore/mongodb/eventstore.go b/eventstore/mongodb/eventstore.go
@@ -299,7 +299,7 @@ func (s *EventStore) LoadFrom(ctx context.Context, id uuid.UUID, version int) ([
 				"input": "$events",
 				"as":    "events",
 				"cond": bson.M{
-					"version": bson.M{"$gte": version},
+					"$gte": []interface{}{"$$events.version", version},
 				},
 			},
 		},
@@ -318,7 +318,7 @@ func (s *EventStore) LoadUntil(ctx context.Context, id uuid.UUID, version int) (
 				"input": "$events",
 				"as":    "events",
 				"cond": bson.M{
-					"version": bson.M{"$lte": version},
+					"$lte": []interface{}{"$$events.version", version},
 				},
 			},
 		},
diff --git a/examples/guestlist/mongodb/mongodb_test.go b/examples/guestlist/mongodb/mongodb_test.go
@@ -35,7 +35,7 @@ import (
 	"github.com/Clarilab/eventhorizon/examples/guestlist/domains/guestlist"
 )
 
-func ExampleIntegration() {
+func Example() {
 	if testing.Short() {
 		// Skip test when not running integration, fake success by printing.
 		fmt.Println(`invitation: Athena - confirmed
diff --git a/examples/guestlist/outbox/outbox_test.go b/examples/guestlist/outbox/outbox_test.go
@@ -36,7 +36,7 @@ import (
 	"github.com/Clarilab/eventhorizon/examples/guestlist/domains/guestlist"
 )
 
-func ExampleIntegration() {
+func Example() {
 	if testing.Short() {
 		// Skip test when not running integration, fake success by printing.
 		fmt.Println(`invitation: Athena - confirmed

Original file line number	Diff line number	Diff line change
`@@ -35,7 +35,7 @@ import (`
`35`	`35`	`"github.com/Clarilab/eventhorizon/examples/guestlist/domains/guestlist"`
`36`	`36`	`)`
`37`	`37`
`38`		`-func ExampleIntegration() {`
	`38`	`+func Example() {`
`39`	`39`	`if testing.Short() {`
`40`	`40`	`// Skip test when not running integration, fake success by printing.`
`41`	`41`	fmt.Println(`invitation: Athena - confirmed
Original file line number	Diff line number	Diff line change
`@@ -36,7 +36,7 @@ import (`
`36`	`36`	`"github.com/Clarilab/eventhorizon/examples/guestlist/domains/guestlist"`
`37`	`37`	`)`
`38`	`38`
`39`		`-func ExampleIntegration() {`
	`39`	`+func Example() {`
`40`	`40`	`if testing.Short() {`
`41`	`41`	`// Skip test when not running integration, fake success by printing.`
`42`	`42`	fmt.Println(`invitation: Athena - confirmed