pub(crate) async fn get_pending(
pool: &PgPool,
limit: i64,
) -> Result<Vec<StreamRow>, Error>Expand description
Returns streams awaiting upload, ordered by creation time.
Filters for upload_status = 'pending' AND audio_mp3 IS NOT NULL (the
stream must have finished recording and MP3 encoding). Results are capped
at limit rows and ordered oldest-first so that the upload processor
works through the backlog in FIFO order.
ยงErrors
Returns sqlx::Error on query failure.