| 150 | } |
| 151 | |
| 152 | pub async fn flush_for_dev_eui(dev_eui: &EUI64) -> Result<(), Error> { |
| 153 | let count: usize = diesel::delete( |
| 154 | device_queue_item::dsl::device_queue_item.filter(device_queue_item::dev_eui.eq(&dev_eui)), |
| 155 | ) |
| 156 | .execute(&mut get_async_db_conn().await?) |
| 157 | .await |
| 158 | .map_err(|e| Error::from_diesel(e, dev_eui.to_string()))?; |
| 159 | info!(dev_eui = %dev_eui, count = count, "Device queue flushed"); |
| 160 | Ok(()) |
| 161 | } |
| 162 | |
| 163 | pub async fn flush_non_pending_for_dev_eui(dev_eui: &EUI64) -> Result<(), Error> { |
| 164 | let count: usize = diesel::delete( |