import * as Effect from "effect/Effect"; import * as Binding from "../../Binding.ts"; import * as Output from "../../Output.ts"; import { isBindingHost } from "../Lambda/Function.ts"; import type { Domain } from "./Domain.ts"; import type { Environment } from "./Environment.ts"; /** * Shared scaffolding for Amazon DataZone HTTP bindings. * * NOT exported from `index.ts` — every thin `{Op}Http.ts` in this service is * a `Layer.effect(Cap, make…HttpBinding({ … }))` over one of the two builders * below. Everything except the operation and the IAM action list is * boilerplate: DataZone authorizes every action on the domain resource, so * the deploy-time half always grants `actions` on the bound domain's ARN. */ /** * Build the impl Effect for a domain-scoped DataZone operation: the runtime * callable injects the bound {@link Domain}'s id as `domainIdentifier` into * every request, and the deploy-time half grants `actions` on the domain ARN. */ export const makeDataZoneDomainHttpBinding = < I extends { domainIdentifier: string }, A, E, R, >(options: { /** Fully-qualified binding tag, e.g. `AWS.DataZone.Search`. */ tag: string; /** The distilled operation; `domainIdentifier` is injected. */ operation: Effect.Effect<(input: I) => Effect.Effect, never, R>; /** IAM actions granted on the domain ARN. */ actions: readonly string[]; }) => Effect.gen(function* () { const op = yield* options.operation; return Effect.fn(function* (domain: Domain) { const DomainId = yield* domain.domainId; if (!globalThis.__ALCHEMY_RUNTIME__) { const host = yield* Binding.Host; if (isBindingHost(host)) { yield* host.bind`Allow(${host}, ${options.tag}(${domain}))`({ policyStatements: [ { Effect: "Allow", Action: [...options.actions], Resource: [domain.domainArn], }, ], }); } } return Effect.fn(`${options.tag}(${domain.LogicalId})`)(function* ( request?: Omit, ) { const domainIdentifier = yield* DomainId; return yield* op({ ...request, domainIdentifier } as I); }); }); }); /** * Build the impl Effect for an environment-scoped DataZone operation: the * runtime callable injects the bound {@link Environment}'s domain id and * environment id, and the deploy-time half grants `actions` on the parent * domain's ARN (DataZone authorizes every action on the domain resource). */ export const makeDataZoneEnvironmentHttpBinding = < I extends { domainIdentifier: string; environmentIdentifier: string }, A, E, R, >(options: { /** Fully-qualified binding tag, e.g. `AWS.DataZone.GetEnvironmentCredentials`. */ tag: string; /** The distilled operation; both identifiers are injected. */ operation: Effect.Effect<(input: I) => Effect.Effect, never, R>; /** IAM actions granted on the parent domain ARN. */ actions: readonly string[]; }) => Effect.gen(function* () { const op = yield* options.operation; return Effect.fn(function* (environment: Environment) { const DomainId = yield* environment.domainId; const EnvironmentId = yield* environment.environmentId; if (!globalThis.__ALCHEMY_RUNTIME__) { const host = yield* Binding.Host; if (isBindingHost(host)) { yield* host.bind`Allow(${host}, ${options.tag}(${environment}))`({ policyStatements: [ { Effect: "Allow", Action: [...options.actions], Resource: [ Output.interpolate`arn:aws:datazone:*:*:domain/${environment.domainId}`, ], }, ], }); } } return Effect.fn(`${options.tag}(${environment.LogicalId})`)(function* ( request?: Omit, ) { return yield* op({ ...request, domainIdentifier: yield* DomainId, environmentIdentifier: yield* EnvironmentId, } as I); }); }); });