diff --git a/internal/reddit/client.go b/internal/reddit/client.go
index 2a2e989..c7af450 100644
--- a/internal/reddit/client.go
+++ b/internal/reddit/client.go
@@ -128,6 +128,10 @@ func (rc *Client) NewAuthenticatedClient(redditId, refreshToken, accessToken str
 		panic("requires an access token")
 	}
 
+	if refreshToken == "" {
+		panic("requires a refresh token")
+	}
+
 	return &AuthenticatedClient{rc, redditId, refreshToken, accessToken}
 }
 
diff --git a/internal/worker/notifications.go b/internal/worker/notifications.go
index 1c11a68..750af91 100644
--- a/internal/worker/notifications.go
+++ b/internal/worker/notifications.go
@@ -178,7 +178,7 @@ func (nc *notificationsConsumer) Consume(delivery rmq.Delivery) {
 	}(&account)
 
 	rac := nc.reddit.NewAuthenticatedClient(account.AccountID, account.RefreshToken, account.AccessToken)
-	if account.TokenExpiresAt.Before(now.Add(1 * time.Minute)) {
+	if account.TokenExpiresAt.Before(now.Add(5 * time.Minute)) {
 		nc.logger.Debug("refreshing reddit token",
 			zap.Int64("account#id", id),
 			zap.String("account#username", account.NormalizedUsername()),