1import * as Hetzner from "@/Hetzner";
2import * as Provider from "@/Provider";
3import * as Test from "@/Test/Alchemy";
4import * as servers from "@distilled.cloud/hetzner/servers";
5import * as volumes from "@distilled.cloud/hetzner/volumes";
6import { expect } from "alchemy-test";
7import * as Effect from "effect/Effect";
8import { MinimumLogLevel } from "effect/References";
9import * as Schedule from "effect/Schedule";
10
11const { test } = Test.make({ providers: Hetzner.providers() });
12
13const logLevel = Effect.provideService(
14 MinimumLogLevel,
15 process.env.DEBUG ? "Debug" : "Info",
16);
17
18const hasHetznerCreds = !!process.env.HCLOUD_TOKEN;
19
20const waitUntilVolumeGone = (id: number) =>
21 volumes.getVolume({ id }).pipe(
22 Effect.as("found" as const),
23 Effect.catchTag("NotFound", () => Effect.succeed("gone" as const)),
24 Effect.repeat({
25 schedule: Schedule.spaced("1 second"),
26 until: (status) => status === "gone",
27 times: 10,
28 }),
29 );
30
31const waitUntilServerGone = (id: number) =>
32 servers.getServer({ id }).pipe(
33 Effect.as("found" as const),
34 Effect.catchTag("NotFound", () => Effect.succeed("gone" as const)),
35 Effect.repeat({
36 schedule: Schedule.spaced("1 second"),
37 until: (status) => status === "gone",
38 times: 10,
39 }),
40 );
41
42test.provider.skipIf(!hasHetznerCreds)(
43 "create, list, and delete a volume attachment",
44 (stack) =>
45 Effect.gen(function* () {
46 yield* stack.destroy();
47
48 const created = yield* stack.deploy(
49 Effect.gen(function* () {
50 const server = yield* Hetzner.Server("Web", {
51 serverType: "cpx12",
52 image: "ubuntu-24.04",
53 location: "nbg1",
54 });
55 const volume = yield* Hetzner.Volume("Data", {
56 size: 10,
57 format: "ext4",
58 location: "nbg1",
59 });
60 const attachment = yield* Hetzner.VolumeAttachment("DataAttach", {
61 volume,
62 server,
63 automount: false,
64 });
65 return { server, volume, attachment };
66 }),
67 );
68
69 expect(created.attachment.volumeId).toEqual(created.volume.id);
70 expect(created.attachment.serverId).toEqual(created.server.serverId);
71 expect(created.attachment.automount).toEqual(false);
72 expect(created.attachment.linuxDevice).toMatch(/^\/dev\//);
73 expect(created.volume.serverId).toBeNull();
74
75 const fetched = yield* volumes.getVolume({
76 id: created.volume.id,
77 });
78 expect(fetched.volume.server).toEqual(created.server.id);
79 expect(fetched.volume.linux_device).toEqual(
80 created.attachment.linuxDevice,
81 );
82
83 const provider = yield* Provider.findProvider(Hetzner.VolumeAttachment);
84 const listed = yield* provider.list();
85 const found = listed.find(
86 (item) =>
87 item.volumeId === created.volume.id &&
88 item.serverId === created.server.id,
89 );
90 expect(found).toBeDefined();
91 expect(found?.linuxDevice).toEqual(created.attachment.linuxDevice);
92
93 yield* stack.destroy();
94
95 const volumeGone = yield* waitUntilVolumeGone(created.volume.id);
96 expect(volumeGone).toEqual("gone");
97 const serverGone = yield* waitUntilServerGone(created.server.id);
98 expect(serverGone).toEqual("gone");
99 }).pipe(logLevel),
100 {
101 tags: [
102 "provider:hetzner",
103 "provider:hetzner:server",
104 "provider:hetzner:service",
105 "provider:hetzner:volume",
106 "provider:hetzner:volumeattachment",
107 "live",
108 ],
109 timeout: 180_000,
110 exclusive: true,
111 },
112);