Function validate_deduplication_key

core/station/impl/src/models/request.rs:223–278

(
    deduplication_key: &Option<String>,
    status: &RequestStatus,
)

}

fn validate_deduplication_key(
    deduplication_key: &Option<String>,
    status: &RequestStatus,
) -> ModelValidatorResult<RequestError> {
    // Only check for duplicates when a request is created
    let should_be_checked_for_duplicates = match status {
        RequestStatus::Created => true,
        RequestStatus::Approved
        | RequestStatus::Rejected
        | RequestStatus::Scheduled { .. }
        | RequestStatus::Cancelled { .. }
        | RequestStatus::Processing { .. }
        | RequestStatus::Completed { .. }
        | RequestStatus::Failed { .. } => false,
    };

    if let Some(deduplication_key) = deduplication_key {
        if deduplication_key.len() > Request::MAX_DEDUPLICATION_KEY_LEN as usize {
            return Err(RequestError::ValidationError {
                info: format!(
                    "The deduplication key length exceeds the maximum allowed: {}",
                    Request::MAX_DEDUPLICATION_KEY_LEN
                ),
            });
        }

        if !should_be_checked_for_duplicates {
            return Ok(());
        }

        if deduplication_key.trim().is_empty() {
            return Err(RequestError::ValidationError {
                info: "The deduplication key must not be empty".to_owned(),
            });
        }
        let is_not_unique = REQUEST_REPOSITORY
            .find_by_deduplication_key(deduplication_key.clone())
            .iter()
            .any(|request| {
                matches!(
                    request.status,
                    RequestStatus::Created
                        | RequestStatus::Scheduled { .. }
                        | RequestStatus::Processing { .. }
                        | RequestStatus::Approved
                )
            });
        if is_not_unique {
            return Err(RequestError::ValidationError {
                info: "A request with the same deduplication key already exists".to_owned(),
            });
        }
    }

    Ok(())
}

fn validate_requested_by(requested_by: &UserId) -> ModelValidatorResult<RequestError> {