| 633 | } |
| 634 | |
| 635 | pub async fn flush_queue(multicast_group_id: &Uuid) -> Result<(), Error> { |
| 636 | let _ = diesel::delete( |
| 637 | multicast_group_queue_item::dsl::multicast_group_queue_item.filter( |
| 638 | multicast_group_queue_item::multicast_group_id |
| 639 | .eq(&fields::Uuid::from(multicast_group_id)), |
| 640 | ), |
| 641 | ) |
| 642 | .execute(&mut get_async_db_conn().await?) |
| 643 | .await |
| 644 | .map_err(|e| Error::from_diesel(e, multicast_group_id.to_string()))?; |
| 645 | info!(multicast_group_id = %multicast_group_id, "Multicast-group queue flushed"); |
| 646 | Ok(()) |
| 647 | } |
| 648 | |
| 649 | pub async fn get_queue(multicast_group_id: &Uuid) -> Result<Vec<MulticastGroupQueueItem>, Error> { |
| 650 | multicast_group_queue_item::dsl::multicast_group_queue_item |