Method try_execute_request

core/station/impl/src/services/request.rs:510–563

(&self, id: UUID)

    }

    pub async fn try_execute_request(&self, id: UUID) -> Result<(), RequestExecuteError> {
        let mut request =
            self.get_request(&id)
                .map_err(|e| RequestExecuteError::InternalError {
                    reason: e.to_string(),
                })?;

        if let Err(err) = request.validate() {
            match err {
                RequestError::ValidationError { info } => {
                    return Err(RequestExecuteError::ValidationError { info });
                }
                _ => {
                    let reason = format!("Unexpected validation result: {err:?}");
                    return Err(RequestExecuteError::InternalError { reason });
                }
            }
        }

        if !matches!(request.status, RequestStatus::Processing { .. }) {
            let reason = format!(
                "The request {} is not processing and thus cannot be executed.",
                Uuid::from_bytes(id.to_owned()).hyphenated()
            );
            return Err(RequestExecuteError::InternalError { reason });
        }

        let executor = RequestFactory::executor(&request);

        let execute_state = executor.execute().await?;

        drop(executor);

        let request_execution_time = next_time();

        request.status = match execute_state {
            RequestExecuteStage::Completed(_) => RequestStatus::Completed {
                completed_at: request_execution_time,
            },
            RequestExecuteStage::Processing(_) => RequestStatus::Processing {
                started_at: request_execution_time,
            },
        };

        request.operation = match execute_state {
            RequestExecuteStage::Completed(operation) => operation,
            RequestExecuteStage::Processing(operation) => operation,
        };

        self.request_repository
            .save_modified(&mut request, request_execution_time);

        Ok(())
    }
}

#[cfg(test)]