1import * as AWS from "@/AWS";
2import {
3 DescribeInstance,
4 DescribeInstanceHttp,
5 DescribeInstanceStatus,
6 DescribeInstanceStatusHttp,
7} from "@/AWS/EC2";
8import * as Duration from "effect/Duration";
9import * as Effect from "effect/Effect";
10import * as Layer from "effect/Layer";
11import { HttpServerRequest } from "effect/http/HttpServerRequest";
12import * as HttpServerResponse from "effect/http/HttpServerResponse";
13import DevInstance from "./dev-instance.ts";
14
15export class Ec2DevProbeFunction extends AWS.Lambda.Function<AWS.Lambda.Function>()(
16 "Ec2DevProbeFunction",
17) {}
18
19/**
20 * Lambda fixture for the EC2 local dev test: binds the EC2 instance
21 * observation capabilities to the hosted {@link DevInstance} and exposes
22 * one route per binding. Under `alchemy dev` the function runs in the
23 * floci emulator, so a 200 from `/describe` proves the full chain —
24 * emulated Lambda → EC2 control plane binding → emulated instance —
25 * without any real cloud.
26 */
27export default Ec2DevProbeFunction.make(
28 {
29 main: import.meta.url,
30 functionUrl: true,
31 timeout: Duration.seconds(30),
32 memorySize: 512,
33 },
34 Effect.gen(function* () {
35 const describeInstance = yield* DescribeInstance(DevInstance);
36 const describeStatus = yield* DescribeInstanceStatus(DevInstance);
37
38 return {
39 fetch: Effect.gen(function* () {
40 const request = yield* HttpServerRequest;
41 const url = new URL(request.url, "http://probe");
42
43 if (url.pathname === "/describe") {
44 const result = yield* describeInstance().pipe(Effect.result);
45 return yield* HttpServerResponse.json({
46 ok: result._tag === "Success",
47 tag: result._tag === "Failure" ? result.failure._tag : "Success",
48 state:
49 result._tag === "Success"
50 ? result.success?.State?.Name
51 : undefined,
52 instanceId:
53 result._tag === "Success"
54 ? result.success?.InstanceId
55 : undefined,
56 });
57 }
58
59 if (url.pathname === "/status") {
60 const result = yield* describeStatus({
61 IncludeAllInstances: true,
62 }).pipe(Effect.result);
63 return yield* HttpServerResponse.json({
64 ok: result._tag === "Success",
65 tag: result._tag === "Failure" ? result.failure._tag : "Success",
66 count:
67 result._tag === "Success"
68 ? (result.success.InstanceStatuses?.length ?? 0)
69 : undefined,
70 });
71 }
72
73 return yield* HttpServerResponse.json(
74 { error: "Not found", pathname: url.pathname },
75 { status: 404 },
76 );
77 }).pipe(Effect.orDie),
78 };
79 }).pipe(
80 Effect.provide(
81 Layer.mergeAll(DescribeInstanceHttp, DescribeInstanceStatusHttp),
82 ),
83 ),
84);