Function worker

dcompass/src/worker.rs:25–51

Handle a single incoming packet

(
    router: Arc<Router<RuneScript>>,
    socket: Arc<UdpSocket>,
    buf: Bytes,
    src: SocketAddr,
)

/// Handle a single incoming packet
pub async fn worker(
    router: Arc<Router<RuneScript>>,
    socket: Arc<UdpSocket>,
    buf: Bytes,
    src: SocketAddr,
) -> Result<()> {
    socket
        .send_to(
            router
                .resolve(
                    Message::from_octets(buf)?,
                    Some(QueryContext { ip: src.ip() }),
                )
                .await?
                .as_slice(),
            src,
        )
        .await
        .unwrap_or_else(|e| {
            warn!("failed to send back response: {}", e);
            0
        });

    info!("response completed. Sent back to {} successfully.", src);

    Ok(())
}