fakecloud 0.15.0

Local AWS cloud emulator — free, open-source LocalStack alternative
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
43
44
45
46
47
48
49
50
51
52

//! Implements the `StepFunctionsDelivery` trait for real Step Functions execution.

use std::sync::Arc;

use fakecloud_core::delivery::{DeliveryBus, StepFunctionsDelivery};
use fakecloud_dynamodb::SharedDynamoDbState;
use fakecloud_stepfunctions::{SharedServiceRegistry, SharedStepFunctionsState};

/// Starts Step Functions executions from cross-service delivery (EventBridge, Scheduler).
pub struct StepFunctionsDeliveryImpl {
    state: SharedStepFunctionsState,
    delivery: Option<Arc<DeliveryBus>>,
    dynamodb_state: Option<SharedDynamoDbState>,
    registry: Option<SharedServiceRegistry>,
}

impl StepFunctionsDeliveryImpl {
    pub fn new(
        state: SharedStepFunctionsState,
        delivery: Option<Arc<DeliveryBus>>,
        dynamodb_state: Option<SharedDynamoDbState>,
    ) -> Self {
        Self {
            state,
            delivery,
            dynamodb_state,
            registry: None,
        }
    }

    pub fn with_registry(mut self, registry: SharedServiceRegistry) -> Self {
        self.registry = Some(registry);
        self
    }
}

impl StepFunctionsDelivery for StepFunctionsDeliveryImpl {
    fn start_execution(&self, state_machine_arn: &str, input: &str) {
        tracing::info!(
            state_machine_arn,
            "Step Functions delivery: starting execution"
        );
        fakecloud_stepfunctions::start_execution_from_delivery(
            &self.state,
            &self.delivery,
            &self.dynamodb_state,
            &self.registry,
            state_machine_arn,
            input,
        );
    }
}