diff --git a/internal/worker/trending.go b/internal/worker/trending.go index 504b423..2629913 100644 --- a/internal/worker/trending.go +++ b/internal/worker/trending.go @@ -4,6 +4,7 @@ import ( "context" "fmt" "os" + "sort" "strconv" "time" @@ -199,6 +200,10 @@ func (tc *trendingConsumer) Consume(delivery rmq.Delivery) { return } + sort.SliceStable(tps.Children, func(i, j int) bool { + return tps.Children[i].Score > tps.Children[j].Score + }) + posts := make([]string, tps.Count) for i, post := range tps.Children { posts[i] = fmt.Sprintf("%s: %d", post.Title, post.Score)