// ---------------------------------------------------------------------------// Autumn billing service — wraps the autumn-js SDK with Effect// --------------------------------------------------------------------------- import * as Sentry from "@sentry/cloudflare";import * as Cloudflare from "alchemy/Cloudflare/Workers/Runtime";import { Autumn } from "autumn-js";import { Context, Data, Effect, Layer } from "effect"; // ---------------------------------------------------------------------------// Errors// --------------------------------------------------------------------------- export class AutumnError extends Data.TaggedError("AutumnError")<{ message: string; cause?: unknown;}> {} // ---------------------------------------------------------------------------// Service interface// --------------------------------------------------------------------------- export type IAutumnService = Readonly<{ use: <A>(fn: (client: Autumn) => Promise<A>) => Effect.Effect<A, AutumnError, never>; /** * Fire-and-forget-safe execution usage tracker. Errors are caught and * logged; the returned Effect never fails. Callers can fork it inside the * current Effect runtime so the billing call can't stall a user-facing * request. */ trackExecution: (organizationId: string) => Effect.Effect<void, never, never>;}>; // ---------------------------------------------------------------------------// Implementation// --------------------------------------------------------------------------- const make = Effect.gen(function* () { const env = yield* Cloudflare.WorkerEnvironment.typed<Env>(); const secretKey = env.AUTUMN_SECRET_KEY; if (!secretKey) { const notConfigured = Effect.fail( new AutumnError({ message: "Autumn not configured: AUTUMN_SECRET_KEY is empty" }), ); return { use: () => notConfigured, trackExecution: () => Effect.void, } satisfies IAutumnService; } const client = new Autumn({ secretKey }); const use = <A>(fn: (client: Autumn) => Promise<A>) => Effect.tryPromise({ try: () => fn(client), catch: (cause) => new AutumnError({ message: "Autumn SDK request failed", cause }), }).pipe(Effect.withSpan(`autumn.${fn.name ?? "use"}`)); const trackExecution = Effect.fn("autumn.trackExecution")(function* (organizationId: string) { yield* Effect.annotateCurrentSpan({ "autumn.customer.id": organizationId }); yield* use((c) => c.track({ customerId: organizationId, featureId: "executions", value: 1 }), ).pipe( Effect.catchTag("AutumnError", (error) => Effect.gen(function* () { // Silent billing data loss is worth paging on — autumn.trackExecution // is fire-and-forget so the caller doesn't handle it themselves. yield* Effect.sync(() => { console.error("[billing] track failed:", error); Sentry.captureException(error); }); yield* Effect.annotateCurrentSpan({ "autumn.track.failed": true }); }), ), ); }); return { use, trackExecution } satisfies IAutumnService;}); export class AutumnService extends Context.Service<AutumnService, IAutumnService>()( "@executor-js/cloud/AutumnService",) { static Default = Layer.effect(this)(make);}
// ---------------------------------------------------------------------------
// Autumn billing service — wraps the autumn-js SDK with Effect
// ---------------------------------------------------------------------------
import * as Sentry from "@sentry/cloudflare";
import * as Cloudflare from "alchemy/Cloudflare/Workers/Runtime";
import { Autumn } from "autumn-js";
import { Context, Data, Effect, Layer } from "effect";
// ---------------------------------------------------------------------------
// Errors
// ---------------------------------------------------------------------------
export class AutumnError extends Data.TaggedError("AutumnError")<{
message: string;
cause?: unknown;
}> {}
// ---------------------------------------------------------------------------
// Service interface
// ---------------------------------------------------------------------------
export type IAutumnService = Readonly<{
use: <A>(fn: (client: Autumn) => Promise<A>) => Effect.Effect<A, AutumnError, never>;
/**
* Fire-and-forget-safe execution usage tracker. Errors are caught and
* logged; the returned Effect never fails. Callers can fork it inside the
* current Effect runtime so the billing call can't stall a user-facing
* request.
*/
trackExecution: (organizationId: string) => Effect.Effect<void, never, never>;
}>;
// ---------------------------------------------------------------------------
// Implementation
// ---------------------------------------------------------------------------
const make = Effect.gen(function* () {
const env = yield* Cloudflare.WorkerEnvironment.typed<Env>();
const secretKey = env.AUTUMN_SECRET_KEY;
if (!secretKey) {
const notConfigured = Effect.fail(
new AutumnError({ message: "Autumn not configured: AUTUMN_SECRET_KEY is empty" }),
);
return {
use: () => notConfigured,
trackExecution: () => Effect.void,
} satisfies IAutumnService;
}
const client = new Autumn({ secretKey });
const use = <A>(fn: (client: Autumn) => Promise<A>) =>
Effect.tryPromise({
try: () => fn(client),
catch: (cause) => new AutumnError({ message: "Autumn SDK request failed", cause }),
}).pipe(Effect.withSpan(`autumn.${fn.name ?? "use"}`));
const trackExecution = Effect.fn("autumn.trackExecution")(function* (organizationId: string) {
yield* Effect.annotateCurrentSpan({ "autumn.customer.id": organizationId });
yield* use((c) =>
c.track({ customerId: organizationId, featureId: "executions", value: 1 }),
).pipe(
Effect.catchTag("AutumnError", (error) =>
Effect.gen(function* () {
// Silent billing data loss is worth paging on — autumn.trackExecution
// is fire-and-forget so the caller doesn't handle it themselves.
yield* Effect.sync(() => {
console.error("[billing] track failed:", error);
Sentry.captureException(error);
});
yield* Effect.annotateCurrentSpan({ "autumn.track.failed": true });
}),
),
);
});
return { use, trackExecution } satisfies IAutumnService;
});
export class AutumnService extends Context.Service<AutumnService, IAutumnService>()(
"@executor-js/cloud/AutumnService",
) {
static Default = Layer.effect(this)(make);
}