| 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 |
| 651 | .filter( |
| 652 | multicast_group_queue_item::dsl::multicast_group_id |
| 653 | .eq(&fields::Uuid::from(multicast_group_id)), |
| 654 | ) |
| 655 | .order_by(multicast_group_queue_item::created_at) |
| 656 | .load(&mut get_async_db_conn().await?) |
| 657 | .await |
| 658 | .map_err(|e| Error::from_diesel(e, multicast_group_id.to_string())) |
| 659 | } |
| 660 | |
| 661 | pub async fn get_schedulable_queue_items(limit: usize) -> Result<Vec<MulticastGroupQueueItem>> { |
| 662 | let mut c = get_async_db_conn().await?; |