diff --git a/internal/worker/subreddits.go b/internal/worker/subreddits.go index 0c141e9..b1c4339 100644 --- a/internal/worker/subreddits.go +++ b/internal/worker/subreddits.go @@ -438,12 +438,13 @@ func payloadFromPost(post *reddit.Thing) *payload.Payload { payload := payload. NewPayload(). AlertSummaryArg(post.Subreddit). - Category("subreddit-watch"). + Category("subreddit-watcher"). Custom("post_title", post.Title). Custom("post_id", post.ID). Custom("subreddit", post.Subreddit). Custom("author", post.Author). Custom("post_age", post.CreatedAt). + ThreadID("subreddit-watcher"). MutableContent(). Sound("traloop.wav") diff --git a/internal/worker/trending.go b/internal/worker/trending.go index f1cde16..ccdeabd 100644 --- a/internal/worker/trending.go +++ b/internal/worker/trending.go @@ -329,6 +329,7 @@ func payloadFromTrendingPost(post *reddit.Thing) *payload.Payload { Custom("subreddit", post.Subreddit). Custom("author", post.Author). Custom("post_age", post.CreatedAt). + ThreadID("trending-post"). MutableContent(). Sound("traloop.wav")