import * as Effect from "effect/Effect"; import * as Binding from "../../Binding.ts"; import * as Output from "../../Output.ts"; import type { Role } from "../IAM/Role.ts"; import { isBindingHost } from "../Lambda/Function.ts"; /** * Shared scaffolding for AWS Transcribe HTTP bindings. * * NOT exported from `index.ts` — every `{Op}Http.ts` in this service is a * thin `Layer.effect(Cap, make…HttpBinding({ … }))` over one of the two * builders below. Everything except the operation and the IAM action list is * boilerplate: Amazon Transcribe's batch APIs have no resource-level IAM, so * every grant is on `*`. The role-bound operations (`StartCallAnalyticsJob`, * `StartMedicalScribeJob`, `CreateLanguageModel`) additionally inject the * bound data-access role and a scoped `iam:PassRole` grant. */ /** * Build the impl Effect for a Transcribe operation with no bound resource * (start/get/list/delete jobs, vocabulary/filter/category lifecycle, tags). * The deploy-time half grants `actions` on `*` — Transcribe batch IAM * actions do not support resource-level scoping. */ export const makeTranscribeHttpBinding = (options: { /** Fully-qualified binding tag, e.g. `AWS.Transcribe.GetTranscriptionJob`. */ tag: string; /** The distilled operation, invoked with the caller's request as-is. */ operation: Effect.Effect<(input: I) => Effect.Effect, never, R>; /** IAM actions granted on `*`. */ actions: readonly string[]; }) => Effect.gen(function* () { const op = yield* options.operation; return Effect.fn(function* () { if (!globalThis.__ALCHEMY_RUNTIME__) { const host = yield* Binding.Host; if (isBindingHost(host)) { yield* host.bind`Allow(${host}, ${options.tag}())`({ policyStatements: [ { Effect: "Allow", Action: [...options.actions], Resource: ["*"], }, ], }); } } return Effect.fn(options.tag)(function* (request?: I) { return yield* op((request ?? {}) as I); }); }); }); /** * Build the impl Effect for a role-bound Transcribe operation * (`StartCallAnalyticsJob`, `StartMedicalScribeJob`, `CreateLanguageModel`): * the binding is constructed with the **data-access role** (the IAM role * Amazon Transcribe assumes to read your Amazon S3 media/training data and * write results; its trust policy must allow `transcribe.amazonaws.com`). * The role's ARN is injected as `DataAccessRoleArn` on every runtime request * and the deploy-time half grants `actions` on `*` plus `iam:PassRole` on * the role — without the PassRole grant, the operation fails only at runtime * with an AccessDenied. */ export const makeTranscribeRoleHttpBinding = < I extends { DataAccessRoleArn?: string }, A, E, R, >(options: { /** Fully-qualified binding tag, e.g. `AWS.Transcribe.StartMedicalScribeJob`. */ tag: string; /** The distilled operation; `DataAccessRoleArn` is injected from the role. */ operation: Effect.Effect<(input: I) => Effect.Effect, never, R>; /** IAM actions granted on `*`. */ actions: readonly string[]; }) => Effect.gen(function* () { const op = yield* options.operation; return Effect.fn(function* (dataAccessRole: Rl) { const RoleArn = yield* dataAccessRole.roleArn; if (!globalThis.__ALCHEMY_RUNTIME__) { const host = yield* Binding.Host; if (isBindingHost(host)) { yield* host.bind`Allow(${host}, ${options.tag}(${dataAccessRole}))`({ policyStatements: [ { Effect: "Allow", Action: [...options.actions], Resource: ["*"], }, // CRITICAL: without iam:PassRole on the data-access role, the // operation fails only at runtime with an AccessDenied. { Effect: "Allow", Action: ["iam:PassRole"], Resource: [Output.interpolate`${dataAccessRole.roleArn}`], Condition: { StringEquals: { "iam:PassedToService": "transcribe.amazonaws.com", }, }, }, ], }); } } return Effect.fn(`${options.tag}(${dataAccessRole.LogicalId})`)( function* ( request: Omit & { DataAccessRoleArn?: string; }, ) { return yield* op({ ...request, DataAccessRoleArn: request.DataAccessRoleArn ?? (yield* RoleArn), } as I); }, ); }); });