/api/qmail/net/beacon/ping

async function pollForMail(timeoutSeconds = 600) {
    const url = 'http://localhost:8082/api/qmail/net/beacon/ping'
        + `?timeout=${timeoutSeconds}`;

    // Set a client-side abort timeout slightly longer than the server timeout
    const controller = new AbortController();
    const clientTimeout = setTimeout(() => controller.abort(), (timeoutSeconds + 10) * 1000);

    try {
        const response = await fetch(url, { signal: controller.signal });
        const result = await response.json();

        if (response.ok && result.success) {
            console.log(`New mail! ${result.new_mail_count} notification(s).`);
            console.log(`${result.total_remaining} more remaining in queue.`);
            result.notifications.forEach(n => {
                console.log(`  File: ${n.file_guid}, Sender SN: ${n.sender_sn}, Size: ${n.total_file_size} bytes`);
            });
        } else {
            console.log(`Poll ended: ${result.message} (HTTP ${result.code ?? response.status})`);
            if (result.detail) {
                console.log(`Detail: ${result.detail}`);
            }
        }

        return result;
    } catch (error) {
        if (error.name === 'AbortError') {
            console.log('Poll request timed out on client side.');
        } else {
            console.error('Poll error:', error);
        }
    } finally {
        clearTimeout(clientTimeout);
    }
}

// Continuous long-poll loop
async function startPolling() {
    while (true) {
        const result = await pollForMail(300);
        if (result && result.success) {
            // Process new mail notifications here
        }
        // Immediately re-poll (the server handles the wait)
    }
}

pollForMail(60);

import requests

def poll_for_mail(timeout_seconds=600):
    """Long-poll for new mail notifications."""
    url = 'http://localhost:8082/api/qmail/net/beacon/ping'
    params = {'timeout': timeout_seconds}

    # Set a client-side timeout slightly longer than the server timeout
    response = requests.get(url, params=params, timeout=timeout_seconds + 10)
    result = response.json()

    if response.ok and result.get('success'):
        print(f"New mail! {result['new_mail_count']} notification(s).")
        print(f"{result['total_remaining']} more remaining in queue.")
        for n in result['notifications']:
            print(f"  File: {n['file_guid']}, Sender SN: {n['sender_sn']}, Size: {n['total_file_size']} bytes")
    else:
        print(f"Poll ended: {result['message']} (HTTP {result.get('code', response.status_code)})")
        if result.get('detail'):
            print(f"Detail: {result['detail']}")

    return result

# Continuous long-poll loop
def start_polling():
    while True:
        try:
            result = poll_for_mail(timeout_seconds=300)
            if result.get('success'):
                # Process new mail notifications here
                pass
        except requests.exceptions.Timeout:
            print('Poll request timed out, restarting...')
        except requests.exceptions.RequestException as e:
            print(f'Poll error: {e}')

poll_for_mail(timeout_seconds=60)