diff --git a/cmd/rpdata-server/main.go b/cmd/rpdata-server/main.go index 888ddbc..ef84f6f 100644 --- a/cmd/rpdata-server/main.go +++ b/cmd/rpdata-server/main.go @@ -57,7 +57,7 @@ func main() { } func logListedChanges(changes *services.ChangeService) { - sub := changes.Subscribe(context.Background(), models.ChangeFilter{PassAll: true}) + sub := changes.Subscribe(context.Background(), models.ChangeFilter{}) for change := range sub { log.Printf("Change: Author=%#+v Model=%#+v Op=%#+v", change.Author, change.Model, change.Op) diff --git a/database/mongodb/changes.go b/database/mongodb/changes.go index 3c3cdb9..6832c9f 100644 --- a/database/mongodb/changes.go +++ b/database/mongodb/changes.go @@ -47,7 +47,7 @@ func (r *changeRepository) List(ctx context.Context, filter models.ChangeFilter) } changes := make([]*models.Change, 0, initialSize) - err := r.changes.Find(query).All(&changes) + err := r.changes.Find(query).Sort("-date").Limit(limit).All(&changes) if err != nil { return nil, err } diff --git a/models/change.go b/models/change.go index be22981..e59250e 100644 --- a/models/change.go +++ b/models/change.go @@ -104,10 +104,6 @@ func (change *Change) Objects() []interface{} { } func (change *Change) PassesFilter(filter ChangeFilter) bool { - if filter.PassAll { - return true - } - if filter.Author != nil && change.Author != *filter.Author { return false } @@ -172,6 +168,4 @@ type ChangeFilter struct { EarliestDate *time.Time Author *string Limit *int - - PassAll bool // DO NOT EXPOSE }