@distilled.cloud/cloudflare

Effect-native Cloudflare SDK generated from the Cloudflare TypeScript SDK source. Covers Workers, R2, KV, D1, Queues, DNS, and more with exhaustive error typing.

Installation

npm install @distilled.cloud/cloudflare effect

Quick Start

import { Effect, Layer } from "effect";
import * as Stream from "effect/Stream";
import * as FetchHttpClient from "effect/unstable/http/FetchHttpClient";
import * as DNS from "@distilled.cloud/cloudflare/dns";
import * as R2 from "@distilled.cloud/cloudflare/r2";
import { CredentialsFromEnv } from "@distilled.cloud/cloudflare";

const program = Effect.gen(function* () {
  yield* R2.listBuckets({ account_id: "your-account-id" });

  const records = yield* DNS.listRecords
    .items({ zone_id: "your-zone-id" })
    .pipe(Stream.take(10), Stream.runCollect);
});

const CloudflareLive = Layer.mergeAll(FetchHttpClient.layer, CredentialsFromEnv);

program.pipe(Effect.provide(CloudflareLive), Effect.runPromise);

Configuration

Set the following environment variable:

CLOUDFLARE_API_TOKEN=your-api-token

Create an API token in the Cloudflare dashboard under My Profile > API Tokens. Use a custom token scoped to the resources you need (e.g. R2 read/write, DNS edit, Workers edit).

Error Handling

R2.getBucket({ account_id: "...", bucket_name: "missing" }).pipe(
  Effect.catchTags({
    NoSuchBucket: () => Effect.succeed({ found: false }),
    UnknownCloudflareError: (e) => Effect.fail(new Error(`Unknown: ${e.message}`)),
  }),
);

Services

import * as R2 from "@distilled.cloud/cloudflare/r2";
import * as Workers from "@distilled.cloud/cloudflare/workers";
import * as KV from "@distilled.cloud/cloudflare/kv";
import * as Queues from "@distilled.cloud/cloudflare/queues";
import * as DNS from "@distilled.cloud/cloudflare/dns";

License

MIT