interprex-test 6.2.0

Stateful in-memory Interprex provider for consumer tests
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
32
33
34
35
36
37
38
39
40
41
42

use async_trait::async_trait;
use interprex::{DispatchInputs, JobsProvider, Repository, Result, RunId, WorkflowRun};

use crate::state::{FakeProvider, missing};

#[async_trait]
impl JobsProvider for FakeProvider {
    async fn dispatch(
        &self,
        repository: &Repository,
        workflow: &str,
        git_ref: &str,
        inputs: &DispatchInputs,
    ) -> Result<()> {
        self.state.write().await.dispatches.push((
            repository.clone(),
            workflow.to_owned(),
            git_ref.to_owned(),
            inputs.clone(),
        ));
        Ok(())
    }

    async fn run(&self, repository: &Repository, run_id: RunId) -> Result<WorkflowRun> {
        self.state
            .read()
            .await
            .runs
            .get(&(repository.clone(), run_id))
            .cloned()
            .ok_or_else(|| missing(format!("workflow run {run_id:?} in {repository}")))
    }

    async fn cancel_run(&self, repository: &Repository, run_id: RunId) -> Result<()> {
        self.state
            .write()
            .await
            .cancelled_runs
            .push((repository.clone(), run_id));
        Ok(())
    }
}