Function enqueue_and_drain

nodedb/src/event/trigger/retry.rs:189–202

()

    #[test]
    fn enqueue_and_drain() {
        let mut q = TriggerRetryQueue::new();
        let mut entry = make_entry("t1");
        entry.next_retry_at = Instant::now() - Duration::from_secs(1); // already due
        q.enqueue(entry);

        // Wait a tiny bit for backoff (100ms for attempt 1).
        std::thread::sleep(Duration::from_millis(110));

        let (ready, exhausted) = q.drain_due();
        assert_eq!(ready.len(), 1);
        assert!(exhausted.is_empty());
        assert_eq!(ready[0].attempts, 1);
    }

    #[test]
    fn exhausted_after_max_retries() {