1#!/usr/bin/env bun
2/**
3 * Delete every Neon project visible to `NEON_API_KEY`.
4 *
5 * Usage:
6 * doppler run -c dev --project alchemy-v2 -- bun packages/alchemy/scripts/cleanup-neon-projects.ts
7 * DRY_RUN=1 doppler run -c dev --project alchemy-v2 -- bun packages/alchemy/scripts/cleanup-neon-projects.ts
8 * CONCURRENCY=4 doppler run -c dev --project alchemy-v2 -- bun packages/alchemy/scripts/cleanup-neon-projects.ts
9 *
10 * Environment:
11 * NEON_API_KEY Required. Injected by Doppler (`alchemy-v2` / `dev`) or `.env` via `bun download:env`.
12 * DRY_RUN Set to `1` to list projects without deleting.
13 * CONCURRENCY Parallel deletes (default 4).
14 */
15import {
16 CredentialsFromEnv,
17 deleteProject,
18 listProjects,
19 Retry,
20} from "@distilled.cloud/neon";
21import * as Effect from "effect/Effect";
22import * as Layer from "effect/Layer";
23import * as Stream from "effect/Stream";
24import * as FetchHttpClient from "effect/http/FetchHttpClient";
25
26const DRY_RUN = process.env.DRY_RUN === "1";
27const CONCURRENCY = Math.max(1, Number(process.env.CONCURRENCY ?? 4));
28
29if (!process.env.NEON_API_KEY) {
30 console.error("NEON_API_KEY is not set");
31 process.exit(1);
32}
33
34console.log(
35 `→ neon cleanup dryRun=${DRY_RUN} concurrency=${CONCURRENCY} (listing projects…)`,
36);
37
38let total = 0;
39let ok = 0;
40let fail = 0;
41
42const program = listProjects.pages({ limit: 400 }).pipe(
43 Stream.tap((page) =>
44 Effect.sync(() => console.log(`→ page: ${page.projects.length} projects`)),
45 ),
46 Stream.flatMap((page) => Stream.fromIterable(page.projects)),
47 Stream.tap((p: { id: string; name: string }) =>
48 Effect.sync(() => {
49 total += 1;
50 console.log(` - ${p.name} (${p.id})`);
51 }),
52 ),
53 Stream.mapEffect(
54 (p) =>
55 DRY_RUN
56 ? Effect.void
57 : deleteProject({ project_id: p.id }).pipe(
58 Effect.tap(() =>
59 Effect.sync(() => {
60 ok += 1;
61 console.log(`✓ deleted ${p.name} (${ok})`);
62 }),
63 ),
64 Effect.catchTag("NotFound", () =>
65 Effect.sync(() => {
66 ok += 1;
67 console.log(`✓ already gone ${p.name}`);
68 }),
69 ),
70 Effect.catch((e) =>
71 Effect.sync(() => {
72 fail += 1;
73 console.error(`✗ ${p.name} (${p.id}): ${String(e)}`);
74 }),
75 ),
76 ),
77 { concurrency: CONCURRENCY },
78 ),
79 Stream.runDrain,
80 Effect.tap(() =>
81 Effect.sync(() =>
82 console.log(`→ done: total=${total} deleted=${ok} failed=${fail}`),
83 ),
84 ),
85);
86
87const runtime = Layer.mergeAll(
88 CredentialsFromEnv,
89 FetchHttpClient.layer,
90 Layer.succeed(Retry.Retry, { while: () => false }),
91);
92
93Effect.runPromise(program.pipe(Effect.provide(runtime))).catch((error) => {
94 console.error(error);
95 process.exit(1);
96});