pub async fn ensure_table(db: &Db) -> Result<()>
Ensure the rustio_notifications table + its unread-lookup index exist. Idempotent.
rustio_notifications