(dev_eui: &EUI64)
| 140 | } |
| 141 | |
| 142 | pub async fn get_for_dev_eui(dev_eui: &EUI64) -> Result<Vec<DeviceQueueItem>, Error> { |
| 143 | let items = device_queue_item::dsl::device_queue_item |
| 144 | .filter(device_queue_item::dev_eui.eq(&dev_eui)) |
| 145 | .order_by(device_queue_item::created_at) |
| 146 | .load(&mut get_async_db_conn().await?) |
| 147 | .await |
| 148 | .map_err(|e| Error::from_diesel(e, dev_eui.to_string()))?; |
| 149 | Ok(items) |
| 150 | } |
| 151 | |
| 152 | pub async fn flush_for_dev_eui(dev_eui: &EUI64) -> Result<(), Error> { |
| 153 | let count: usize = diesel::delete( |