Function get_pending_for_dev_eui

chirpstack/src/storage/device_queue.rs:178–189

(dev_eui: &EUI64)

}

pub async fn get_pending_for_dev_eui(dev_eui: &EUI64) -> Result<DeviceQueueItem, Error> {
    let qi = device_queue_item::dsl::device_queue_item
        .filter(
            device_queue_item::dev_eui
                .eq(&dev_eui)
                .and(device_queue_item::is_pending.eq(true)),
        )
        .first(&mut get_async_db_conn().await?)
        .await
        .map_err(|e| Error::from_diesel(e, dev_eui.to_string()))?;
    Ok(qi)
}

pub async fn get_max_f_cnt_down(dev_eui: EUI64) -> Result<Option<i64>, Error> {
    Ok(device_queue_item::dsl::device_queue_item