تست کردن گردش کار تابع مرحله به صورت محلی

// code above omitted
const flow = this.buildStateMachine(scope);

this._stateMachine = new stepfunctions.StateMachine(this, "StateMachine", {
    stateMachineName: "SimpleStateMachine",
    definition: flow,
    stateMachineType: stepfunctions.StateMachineType.EXPRESS,
    timeout: Duration.seconds(30),
    logs: {
        level: LogLevel.ALL,
        destination: logGroup,
        includeExecutionData: true,
    },
});

// code above omitted
buildStateMachine = (scope: Construct): stepfunctions.IChainable => {
    const succeed = new Succeed(scope, "Succeed");
    const failure = new Fail(scope, "Fail");

    return (
        new Choice(this, "Success or Failure")
            // Look at the "status" field
            .when(Condition.stringEquals("$.path", "Succeed"), succeed)
            .when(Condition.stringEquals("$.path", "Fail"), failure)
            .otherwise(failure)
    );
};

version: "3.4"

services:
    localstack:
        container_name: sf_localstack
        image: localstack/localstack:latest
        environment:
            - AWS_DEFAULT_REGION=us-west-2
            - HOSTNAME_EXTERNAL=localhost
            - SERVICES=sqs # which services to start
            - DEBUG=0
        ports:
            - 4566:4566

    step-functions:
        container_name: step-functions
        image: amazon/aws-stepfunctions-local
        depends_on:
            - localstack
        environment:
            - AWS_DEFAULT_REGION=us-west-2 # this is used when resources are created
            - AWS_ACCESS_KEY_ID=12345 # just to fill in the blanks
            - AWS_SECRET_ACCESS_KEY=12345 # just to fill in the blanks
            - SQS_ENDPOINT=host.docker.internal:4566 # connected to Localstack
        ports:
            - 8083:8083

[{"identifier":"SimpleStateMachine3C32178E","definition":"{\"StartAt\":\"Success or Failure\",\"States\":{\"Success or Failure\":{\"Type\":\"Choice\",\"Choices\":[{\"Variable\":\"$.path\",\"StringEquals\":\"Succeed\",\"Next\":\"Succeed\"},{\"Variable\":\"$.path\",\"StringEquals\":\"Fail\",\"Next\":\"Fail\"}],\"Default\":\"Fail\"},\"Fail\":{\"Type\":\"Fail\"},\"Succeed\":{\"Type\":\"Succeed\"}},\"TimeoutSeconds\":30}"}]

aws stepfunctions --endpoint-url http://localhost:8083 create-state-machine --definition <the body> --name <the id> --role-arn "arn:aws:iam::012345678901:role/DummyRole" --type "EXPRESS"

# AWS CLI Command
aws stepfunctions --endpoint-url http://localhost:8083 list-state-machines

# the output
{
    "stateMachines": [
        {
            "stateMachineArn": "arn:aws:states:us-west-2:123456789012:stateMachine:SimpleStateMachine3C32178E",
            "name": "SimpleStateMachine3C32178E",
            "type": "EXPRESS",
            "creationDate": "2023-04-14T13:56:45.260000-05:00"
        }
    ]
}

import { SFNClient, StartSyncExecutionCommand } from "@aws-sdk/client-sfn";

describe("SF Integration Tests", () => {
    const client = new SFNClient({
        region: "us-west-2",
        endpoint: "http://localhost:8083",
        disableHostPrefix: true,
    });
});

it("Should Succeed Success Path", async () => {
    const startCommand = new StartSyncExecutionCommand({
        stateMachineArn:
            "arn:aws:states:us-west-2:123456789012:stateMachine:SimpleStateMachine3C32178E",
        input: '{"path": "Succeed"}',
    });

    const startOutput = await client.send(startCommand);
    expect(startOutput.status).toBe("SUCCEEDED");
});

const client = new SFNClient({
    region: "us-west-2",
    endpoint: "http://localhost:8083",
    disableHostPrefix: true, // <----- HERE
});

export class PipelineStack extends Stack {
    constructor(scope: Construct, id: string) {
        super(scope, id);
        const pipeline = new CodePipeline(this, "Pipeline", {
            pipelineName: "SamplePipeline",
            dockerEnabledForSynth: true,
            synth: new ShellStep("Synth", {
                input: CodePipelineSource.gitHub(
                    "benbpyle/cdk-step-functions-local-testing",
                    "main",
                    {
                        authentication: SecretValue.secretsManager(
                            "sf-sample",
                            {
                                jsonField: "github",
                            }
                        ),
                    }
                ),
                commands: [
                    "npm i",
                    "npm i cdk-asl-definition-extractor -g",
                    "make test-start-local",
                ],
            }),
            synthCodeBuildDefaults: {
                buildEnvironment: {
                    buildImage: LinuxBuildImage.STANDARD_6_0,
                    environmentVariables: {
                        DOCKERHUB_USERNAME: {
                            type: BuildEnvironmentVariableType.SECRETS_MANAGER,
                            value: "dockerhub:username",
                        },
                        DOCKERHUB_PASSWORD: {
                            type: BuildEnvironmentVariableType.SECRETS_MANAGER,
                            value: "dockerhub:password",
                        },
                    },
                },
                partialBuildSpec: BuildSpec.fromObject({
                    phases: {
                        install: {
                            "runtime-versions": {
                                nodejs: "16",
                            },
                            commands: [
                                "docker login --username $DOCKERHUB_USERNAME --password $DOCKERHUB_PASSWORD",
                            ],
                        },
                    },
                }),
            },
        });

        pipeline.addStage(new PipelineStage(this, "PipelineStage"));
    }
}

input: CodePipelineSource.gitHub(
    "benbpyle/cdk-step-functions-local-testing",
    "main",
    {
        // the IAM policy gets added by default
        authentication: SecretValue.secretsManager(
            "sf-sample",
            {
                jsonField: "github",
            }
        ),
    }
),

commands: [
    "npm i",
    "npm i cdk-asl-definition-extractor -g",
    "make test-start-local",
],

test-start-local:
    npx cdk synth --quiet # build
    docker-compose up -d --quiet-pull # run the containers
    sleep 10 # pause to let localstack startup
    node scripts/index.js # a runner for posting the state machine into the local container
    npm run test-sf # executes the Jest tests
    make test-end-local # teardown

synthCodeBuildDefaults: {
    buildEnvironment: {
        buildImage: LinuxBuildImage.STANDARD_6_0,
        environmentVariables: {
            DOCKERHUB_USERNAME: {
                type: BuildEnvironmentVariableType.SECRETS_MANAGER,
                value: "dockerhub:username",
            },
            DOCKERHUB_PASSWORD: {
                type: BuildEnvironmentVariableType.SECRETS_MANAGER,
                value: "dockerhub:password",
            },
        },
    },
    partialBuildSpec: BuildSpec.fromObject({
        phases: {
            install: {
                "runtime-versions": {
                    nodejs: "16",
                },
                commands: [
                    "docker login --username $DOCKERHUB_USERNAME --password $DOCKERHUB_PASSWORD",
                ],
            },
        },
    }),
},