actrpc-orchestrator 0.1.0

Configuration and orchestration utilities for ActRPC.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31

use crate::{
    action::{
        ActionHandlerFuture,
        actions::request_review::{RequestReviewParams, RequestReviewResult},
    },
    error::ActionExecutionError,
};

pub trait ReviewProvider: Send + Sync {
    fn request_review<'a>(
        &'a self,
        params: RequestReviewParams,
    ) -> ActionHandlerFuture<'a, Result<RequestReviewResult, ActionExecutionError>>;
}

#[derive(Debug, Default)]
pub struct UnavailableReviewProvider;

impl ReviewProvider for UnavailableReviewProvider {
    fn request_review<'a>(
        &'a self,
        _params: RequestReviewParams,
    ) -> ActionHandlerFuture<'a, Result<RequestReviewResult, ActionExecutionError>> {
        Box::pin(async move {
            Err(ActionExecutionError::InvalidState {
                message: "request_review action was invoked, but no ReviewProvider is configured"
                    .to_owned(),
            })
        })
    }
}