Method create_request

core/station/impl/src/services/request.rs:324–363

Creates a new request adding the caller user as the requester. By default, the request has an expiration date of 7 days from the creation date.

(
        &self,
        input: CreateRequestInput,
        ctx: &CallContext,
    )

    ///
    /// By default, the request has an expiration date of 7 days from the creation date.
    pub async fn create_request(
        &self,
        input: CreateRequestInput,
        ctx: &CallContext,
    ) -> ServiceResult<Request> {
        let requester = self.user_service.get_user_by_identity(&ctx.caller())?;
        let mut request = RequestFactory::create_request(requester.id, input).await?;

        // Different request types may have different validation rules.
        request.validate()?;

        // Insert the request into the repository before adding approvals so checks that depend on the
        // request being in the repository pass.
        self.request_repository
            .insert(request.to_key(), request.to_owned());

        if request.can_approve(&requester.id) {
            request.add_approval(requester.id, RequestApprovalStatus::Approved, None)?;
        }

        // When a request is created, it is immediately evaluated to determine its status.
        // This is done because the request may be immediately rejected or approved based on the policies.
        let maybe_evaluation = request.reevaluate().await?;

        self.request_repository
            .insert(request.to_key(), request.to_owned());

        if let Some(evaluation) = maybe_evaluation {
            self.evaluation_result_repository
                .insert(request.id, evaluation);
        }

        if request.status == RequestStatus::Created {
            self.created_request_hook(&request).await;
        } else if request.status == RequestStatus::Rejected {
            self.rejected_request_hook(&request).await;
        }

        Ok(request)
    }

    async fn rejected_request_hook(&self, request: &Request) {
        self.notification_service