lambda-durable-functions-examples/examples/basic-error-handling/function.ts at main · lukehedger/lambda-durable-functions-examples · GitHub

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
53
54
import {
	type DurableContext,
	retryPresets,
	withDurableExecution,
} from "@aws/durable-execution-sdk-js";

export const handler = withDurableExecution(
	async (_event: unknown, context: DurableContext) => {
		try {
			await context.step(
				"reserve-inventory",
				async (ctx) => {
					ctx.logger.info("Reserving inventory");
					return {};
				},
				{
					retryStrategy: retryPresets.default,
				},
			);

			await context.step(
				"process-payment",
				async (ctx) => {
					ctx.logger.info("Processing payment");
					return {};
				},
				{
					retryStrategy: retryPresets.default,
				},
			);

			await context.step(
				"create-shipment",
				async (ctx) => {
					ctx.logger.info("Creating shipment");
					return {};
				},
				{
					retryStrategy: retryPresets.default,
				},
			);

			return {
				status: 200,
			};
		} catch (error) {
			context.logger.error(error);

			return {
				status: 500,
			};
		}
	},
);