+2

main.go

reviewed

··· 104 104 } 105 105 return nil 106 106 }, retry.Attempts(0)) // retry indefinitly until context canceled 107 107 + 108 108 + slog.Warn("exiting consume loop") 107 109 }

+1 -1

store/feed.go

reviewed

··· 50 50 func (s *Store) GetUsersFeed(usersDID string, cursor int64, limit int) ([]FeedPost, error) { 51 51 sql := `SELECT id, replyURI, userDID, subscribedPostURI, createdAt FROM feed 52 52 WHERE userDID = ? AND createdAt < ? 53 53 - ORDER BY createdAt LIMIT ?;` 53 53 + ORDER BY DESC createdAt LIMIT ?;` 54 54 rows, err := s.db.Query(sql, usersDID, cursor, limit) 55 55 if err != nil { 56 56 return nil, fmt.Errorf("run query to get users feed posts: %w", err)