Include messages that do not set an expiry.

This commit is contained in:
Antony 2025-03-27 21:36:20 +13:00
parent e7b1924616
commit f743947821
2 changed files with 3 additions and 2 deletions

View File

@ -12,5 +12,6 @@
"@types/google-protobuf": "^3.15.12",
"google-protobuf": "^3.21.2",
"grpc-web": "^1.5.0"
}
},
"packageManager": "yarn@1.22.22+sha512.a6b2f7906b721bba3d67d4aff083df04dad64c399707841b7acf00f6b133b7ac24255f2652fa22ae3534329dc6180534e98d17432037ff6fd140556e2bb3137e"
}

View File

@ -675,7 +675,7 @@ pub async fn get_schedulable_queue_items(limit: usize) -> Result<Vec<MulticastGr
$2 - make_interval(secs => g.stats_interval_secs * 2) <= g.last_seen_at
)
-- ignore expired messages
and not (qi.expires_at < $2)
and not (qi.expires_at is not null and qi.expires_at < $2)
order by
qi.created_at
limit $1