(requests_to_insert: u64)
| 1651 | use station_api::RequestStatusCodeDTO; |
| 1652 | |
| 1653 | fn create_test_requests(requests_to_insert: u64) -> u64 { |
| 1654 | let end_creation_time = requests_to_insert * 1_000_000_000; |
| 1655 | for i in 0..requests_to_insert { |
| 1656 | let mut request = mock_request(); |
| 1657 | request.created_timestamp = i * 1_000_000_000; |
| 1658 | request.status = match i % 2 { |
| 1659 | 0 => RequestStatus::Created, |
| 1660 | 1 => RequestStatus::Approved, |
| 1661 | _ => RequestStatus::Rejected, |
| 1662 | }; |
| 1663 | |
| 1664 | REQUEST_REPOSITORY.insert(request.to_key(), request.to_owned()); |
| 1665 | } |
| 1666 | |
| 1667 | let mut users = Vec::new(); |
| 1668 | // adding some users that will be added to the access control repository later |
| 1669 | for i in 0..10 { |
| 1670 | let mut user = mock_user(); |
| 1671 | user.identities = vec![Principal::from_slice(&[i; 29])]; |
| 1672 | user.status = UserStatus::Active; |
| 1673 | |
| 1674 | USER_REPOSITORY.insert(user.to_key(), user.to_owned()); |
| 1675 | |
| 1676 | users.push(user); |
| 1677 | } |
| 1678 | |
| 1679 | // adding some permissions since the filter will check for access |
| 1680 | let permission = Permission::new( |
| 1681 | Allow::users(users.iter().map(|u| u.id).collect()), |
| 1682 | Resource::Request(RequestResourceAction::Read(ResourceId::Any)), |
| 1683 | ); |
| 1684 | |
| 1685 | PERMISSION_REPOSITORY.insert(permission.key(), permission.to_owned()); |
| 1686 | |
| 1687 | end_creation_time |
| 1688 | } |
| 1689 | |
| 1690 | #[bench(raw)] |
| 1691 | fn service_find_all_requests_from_2k_dataset() -> BenchResult { |
no test coverage detected