#!/usr/bin/env node import * as NodeRuntime from "@effect/platform-node/NodeRuntime";import { AdoptPolicy } from "alchemy/AdoptPolicy";import { AlchemyContext, AlchemyContextLive } from "alchemy/AlchemyContext";import * as Apply from "alchemy/Apply";import { provideFreshArtifactStore } from "alchemy/Artifacts";import { AuthProviders } from "alchemy/Auth/AuthProvider";import { CredentialsStoreLive } from "alchemy/Auth/Credentials";import { ProfileLive } from "alchemy/Auth/Profile";import * as Cloudflare from "alchemy/Cloudflare";import { Cli } from "alchemy/Cli/Cli";import { LoggingCli } from "alchemy/Cli/LoggingCli";import * as Plan from "alchemy/Plan";import * as Stage from "alchemy/Stage";import * as State from "alchemy/State/State";import { TelemetryLive } from "alchemy/Telemetry/Layer";import { PlatformServices } from "alchemy/Util/PlatformServices";import * as Config from "effect/Config";import * as ConfigProvider from "effect/ConfigProvider";import * as Console from "effect/Console";import * as Data from "effect/Data";import * as Effect from "effect/Effect";import * as FileSystem from "effect/FileSystem";import * as Layer from "effect/Layer";import * as Option from "effect/Option";import * as Path from "effect/Path";import * as Redacted from "effect/Redacted";import { Command, Flag, Prompt } from "effect/unstable/cli";import * as FetchHttpClient from "effect/unstable/http/FetchHttpClient"; import RelayStack from "../alchemy.run.ts"; export class RelayDeployError extends Data.TaggedError("RelayDeployError")<{ readonly message: string;}> {} export interface RelayDeployOptions { readonly dryRun: boolean; readonly force: boolean; readonly envFile: Option.Option<string>; readonly stage: Option.Option<string>; readonly yes: boolean; readonly adopt: boolean; readonly githubOutput: boolean; readonly githubEnvFile: Option.Option<string>; readonly readState: boolean;} export interface RelayPublicConfig { readonly relayUrl: string; readonly mobileTracingUrl: string; readonly mobileTracingDataset: string; readonly mobileTracingToken: string; readonly clientTracingUrl: string; readonly clientTracingDataset: string; readonly clientTracingToken: string;} const publicConfigEnvEntries = (config: RelayPublicConfig) => ({ T3CODE_RELAY_URL: config.relayUrl, T3CODE_MOBILE_OTLP_TRACES_URL: config.mobileTracingUrl, T3CODE_MOBILE_OTLP_TRACES_DATASET: config.mobileTracingDataset, T3CODE_MOBILE_OTLP_TRACES_TOKEN: config.mobileTracingToken, T3CODE_RELAY_CLIENT_OTLP_TRACES_URL: config.clientTracingUrl, T3CODE_RELAY_CLIENT_OTLP_TRACES_DATASET: config.clientTracingDataset, T3CODE_RELAY_CLIENT_OTLP_TRACES_TOKEN: config.clientTracingToken, }) as const; export function reconcileRootEnvPublicConfig(contents: string, config: RelayPublicConfig): string { let next = contents; for (const [name, value] of Object.entries(publicConfigEnvEntries(config))) { const entry = `${name}=${value}`; const pattern = new RegExp(`^${name}=.*$`, "mu"); if (pattern.test(next)) { next = next.replace(pattern, entry); continue; } if (!next) { next = `${entry}\n`; continue; } next = `${next}${next.endsWith("\n") ? "" : "\n"}${entry}\n`; } return next;} export function reconcileRootEnvRelayUrl(contents: string, relayUrl: string): string { return reconcileRootEnvPublicConfig(contents, { relayUrl, mobileTracingUrl: "", mobileTracingDataset: "", mobileTracingToken: "", clientTracingUrl: "", clientTracingDataset: "", clientTracingToken: "", }) .split("\n") .filter((line) => !line.startsWith("T3CODE_MOBILE_OTLP_TRACES_")) .filter((line) => !line.startsWith("T3CODE_RELAY_CLIENT_OTLP_TRACES_")) .join("\n");} export function hasDeployChanges(plan: Plan.Plan): boolean { return ( Object.keys(plan.deletions).length > 0 || Object.values(plan.resources).some( (node) => node.action !== "noop" || node.bindings.some((binding) => binding.action !== "noop"), ) );} export type RelayDeployResult = "applied" | "noop" | "dry-run" | "cancelled" | "state"; export interface RelayDeployOutcome { readonly result: RelayDeployResult; readonly changed: boolean; readonly publicConfig: Option.Option<RelayPublicConfig>;} export function serializeGithubOutput(entries: Readonly<Record<string, string | boolean>>): string { return Object.entries(entries) .map(([key, value]) => `${key}=${value}\n`) .join("");} export function serializeRelayClientTracingEnvironment(config: RelayPublicConfig): string { return serializeGithubOutput({ T3CODE_RELAY_CLIENT_OTLP_TRACES_URL: config.clientTracingUrl, T3CODE_RELAY_CLIENT_OTLP_TRACES_DATASET: config.clientTracingDataset, T3CODE_RELAY_CLIENT_OTLP_TRACES_TOKEN: config.clientTracingToken, });} const relayRoot = Effect.service(Path.Path).pipe( Effect.flatMap((path) => path.fromFileUrl(new URL("..", import.meta.url))),);const repoRoot = Effect.service(Path.Path).pipe( Effect.flatMap((path) => path.fromFileUrl(new URL("../../..", import.meta.url))),); const loadDeployConfigProvider = Effect.fn("relay.deploy.loadConfigProvider")(function* ( envFileOverride: Option.Option<string>,) { const path = yield* Path.Path; const root = yield* relayRoot; if (Option.isSome(envFileOverride)) { return yield* ConfigProvider.fromDotEnv({ path: path.resolve(root, envFileOverride.value) }); } return yield* ConfigProvider.fromDotEnv({ path: path.join(root, ".env") }).pipe( Effect.orElseSucceed(() => ConfigProvider.fromEnv()), );}); const relayDeployStage = Config.nonEmptyString("stage").pipe( Config.option, Config.map( Option.getOrElse(() => `dev_${process.env.USER ?? process.env.USERNAME ?? "unknown"}`), ),); const reconcileRootEnv = Effect.fn("relay.deploy.reconcileRootEnv")(function* ( config: RelayPublicConfig,) { const fs = yield* FileSystem.FileSystem; const path = yield* Path.Path; const root = yield* repoRoot; const rootEnvPath = path.join(root, ".env"); const contents = (yield* fs.exists(rootEnvPath)) ? yield* fs.readFileString(rootEnvPath) : ""; yield* fs.writeFileString(rootEnvPath, reconcileRootEnvPublicConfig(contents, config)); yield* Console.log(`Updated ${rootEnvPath} with relay public client configuration`);}); const writeGithubOutput = Effect.fn("relay.deploy.writeGithubOutput")(function* ( outcome: RelayDeployOutcome,) { const fs = yield* FileSystem.FileSystem; const githubOutputPath = yield* Config.nonEmptyString("GITHUB_OUTPUT"); yield* fs.writeFileString( githubOutputPath, serializeGithubOutput({ changed: outcome.changed, result: outcome.result, ...(Option.isSome(outcome.publicConfig) ? { relay_url: outcome.publicConfig.value.relayUrl, } : {}), }), { flag: "a" }, );}); const writeGithubEnvFile = Effect.fn("relay.deploy.writeGithubEnvFile")(function* ( outcome: RelayDeployOutcome, outputPath: string,) { if (Option.isNone(outcome.publicConfig)) { return yield* new RelayDeployError({ message: "Relay public client config is unavailable for the GitHub environment file", }); } const fs = yield* FileSystem.FileSystem; yield* Console.log(`::add-mask::${outcome.publicConfig.value.clientTracingToken}`); yield* fs.writeFileString( outputPath, serializeRelayClientTracingEnvironment(outcome.publicConfig.value), );}); const deployBaseServices = Layer.mergeAll( Layer.succeed(AuthProviders, {}), Layer.provideMerge(AlchemyContextLive, PlatformServices), Layer.provide(ProfileLive, PlatformServices), Layer.provide(CredentialsStoreLive, PlatformServices), FetchHttpClient.layer, TelemetryLive, LoggingCli,);const deployServices = deployBaseServices; export function publicConfigFromOutput(output: unknown): RelayPublicConfig | null { if (typeof output !== "object" || output === null) { return null; } const value = output as Record<string, unknown>; const text = (name: string) => (typeof value[name] === "string" ? value[name] : undefined); const secret = (name: string): string | undefined => { const candidate = value[name]; if (!Redacted.isRedacted(candidate)) { return text(name); } const redacted = Redacted.value(candidate); return typeof redacted === "string" ? redacted : undefined; }; const relayUrl = text("url"); const mobileTracingUrl = text("mobileTracingUrl"); const mobileTracingDataset = text("mobileTracingDataset"); const mobileTracingToken = secret("mobileTracingToken"); const clientTracingUrl = text("clientTracingUrl"); const clientTracingDataset = text("clientTracingDataset"); const clientTracingToken = secret("clientTracingToken"); return relayUrl && mobileTracingUrl && mobileTracingDataset && mobileTracingToken && clientTracingUrl && clientTracingDataset && clientTracingToken ? { relayUrl, mobileTracingUrl, mobileTracingDataset, mobileTracingToken, clientTracingUrl, clientTracingDataset, clientTracingToken, } : null;} const readRelayPublicConfig = Effect.fn("relay.deploy.readState")(function* (stage: string) { const state = yield* State.State; const service = yield* state; const output = yield* service.getOutput({ stack: "T3CodeRelay", stage }); const publicConfig = publicConfigFromOutput(output); if (publicConfig === null) { return yield* new RelayDeployError({ message: `Alchemy relay state for stage ${stage} did not include complete public client config`, }); } return { result: "state", changed: false, publicConfig: Option.some(publicConfig), } satisfies RelayDeployOutcome;}); const runRelayDeploy = Effect.fn("relay.deploy.run")( function* ( options: RelayDeployOptions, _configProvider: ConfigProvider.ConfigProvider, _stage: string, ) { const stack = yield* RelayStack; const cli = yield* Cli; const plan = yield* Plan.make(stack, { force: options.force }).pipe( Effect.provide(stack.services), ); const changed = hasDeployChanges(plan); if (options.dryRun) { yield* cli.displayPlan(plan); return { result: "dry-run", changed, publicConfig: Option.none<RelayPublicConfig>(), } satisfies RelayDeployOutcome; } if (!options.yes && changed) { yield* cli.displayPlan(plan); const approved = yield* Prompt.run( Prompt.confirm({ message: "Apply this relay deployment?", }), ); if (!approved) { yield* Console.log("Deployment cancelled."); return { result: "cancelled", changed, publicConfig: Option.none<RelayPublicConfig>(), } satisfies RelayDeployOutcome; } } const output = yield* Apply.apply(plan).pipe(Effect.provide(stack.services)); if ( output.url === undefined || output.mobileTracingUrl === undefined || output.mobileTracingDataset === undefined || output.mobileTracingToken === undefined || output.clientTracingUrl === undefined || output.clientTracingDataset === undefined || output.clientTracingToken === undefined ) { return yield* new RelayDeployError({ message: "Alchemy relay deploy output did not include complete public client config", }); } return { result: changed ? "applied" : "noop", changed, publicConfig: Option.some({ relayUrl: output.url, mobileTracingUrl: output.mobileTracingUrl, mobileTracingDataset: output.mobileTracingDataset, mobileTracingToken: Redacted.value(output.mobileTracingToken), clientTracingUrl: output.clientTracingUrl, clientTracingDataset: output.clientTracingDataset, clientTracingToken: Redacted.value(output.clientTracingToken), }), } satisfies RelayDeployOutcome; }, (effect, options, configProvider, stage) => effect.pipe( Effect.provide( Layer.mergeAll( Layer.effect( AlchemyContext, AlchemyContext.pipe(Effect.map((context) => ({ ...context, adopt: options.adopt }))), ), Layer.succeed(AdoptPolicy, options.adopt), Layer.succeed(AuthProviders, {}), ConfigProvider.layer(configProvider), Layer.succeed(Stage.Stage, stage), ), ), provideFreshArtifactStore, ),); export const deploy = Effect.fn("relay.deploy")(function* (options: RelayDeployOptions) { const configProvider = yield* loadDeployConfigProvider(options.envFile); const configuredStage = yield* relayDeployStage.pipe( Effect.provide(ConfigProvider.layer(configProvider)), ); const stage = Option.getOrElse(options.stage, () => configuredStage); const outcome = options.readState ? yield* readRelayPublicConfig(stage).pipe(Effect.provide(Cloudflare.state())) : yield* runRelayDeploy(options, configProvider, stage); if (Option.isSome(outcome.publicConfig)) { yield* reconcileRootEnv(outcome.publicConfig.value); } if (options.githubOutput) { yield* writeGithubOutput(outcome); } if (Option.isSome(options.githubEnvFile)) { yield* writeGithubEnvFile(outcome, options.githubEnvFile.value); }}); export const relayDeployCommand = Command.make( "relay-deploy", { dryRun: Flag.boolean("dry-run").pipe( Flag.withDescription("Dry run the deployment without applying changes."), Flag.withDefault(false), ), force: Flag.boolean("force").pipe( Flag.withDescription("Force updates for resources that would otherwise no-op."), Flag.withDefault(false), ), envFile: Flag.string("env-file").pipe( Flag.withDescription( "Environment file to load. Defaults to infra/relay/.env with process env fallback.", ), Flag.optional, ), stage: Flag.string("stage").pipe( Flag.withDescription("Stage to deploy. Defaults to dev_${USER}."), Flag.optional, ), yes: Flag.boolean("yes").pipe( Flag.withDescription("Skip the deployment confirmation prompt."), Flag.withDefault(false), ), adopt: Flag.boolean("adopt").pipe( Flag.withDescription("Adopt pre-existing cloud resources that conflict with this stack."), Flag.withDefault(false), ), githubOutput: Flag.boolean("github-output").pipe( Flag.withDescription("Append relay deployment metadata to GITHUB_OUTPUT."), Flag.withDefault(false), ), githubEnvFile: Flag.string("github-env-file").pipe( Flag.withDescription( "Write relay client tracing variables to a file suitable for GITHUB_ENV.", ), Flag.optional, ), readState: Flag.boolean("read-state").pipe( Flag.withDescription("Read the deployed stack output without planning or applying changes."), Flag.withDefault(false), ), }, deploy,).pipe(Command.withDescription("Deploy the T3 Code relay through Alchemy.")); if (import.meta.main) { Command.run(relayDeployCommand, { version: "0.0.0" }).pipe( Effect.provide(deployServices), Effect.scoped, NodeRuntime.runMain, );}
#!/usr/bin/env node
import * as NodeRuntime from "@effect/platform-node/NodeRuntime";
import { AdoptPolicy } from "alchemy/AdoptPolicy";
import { AlchemyContext, AlchemyContextLive } from "alchemy/AlchemyContext";
import * as Apply from "alchemy/Apply";
import { provideFreshArtifactStore } from "alchemy/Artifacts";
import { AuthProviders } from "alchemy/Auth/AuthProvider";
import { CredentialsStoreLive } from "alchemy/Auth/Credentials";
import { ProfileLive } from "alchemy/Auth/Profile";
import * as Cloudflare from "alchemy/Cloudflare";
import { Cli } from "alchemy/Cli/Cli";
import { LoggingCli } from "alchemy/Cli/LoggingCli";
import * as Plan from "alchemy/Plan";
import * as Stage from "alchemy/Stage";
import * as State from "alchemy/State/State";
import { TelemetryLive } from "alchemy/Telemetry/Layer";
import { PlatformServices } from "alchemy/Util/PlatformServices";
import * as Config from "effect/Config";
import * as ConfigProvider from "effect/ConfigProvider";
import * as Console from "effect/Console";
import * as Data from "effect/Data";
import * as Effect from "effect/Effect";
import * as FileSystem from "effect/FileSystem";
import * as Layer from "effect/Layer";
import * as Option from "effect/Option";
import * as Path from "effect/Path";
import * as Redacted from "effect/Redacted";
import { Command, Flag, Prompt } from "effect/unstable/cli";
import * as FetchHttpClient from "effect/unstable/http/FetchHttpClient";
import RelayStack from "../alchemy.run.ts";
export class RelayDeployError extends Data.TaggedError("RelayDeployError")<{
readonly message: string;
}> {}
export interface RelayDeployOptions {
readonly dryRun: boolean;
readonly force: boolean;
readonly envFile: Option.Option<string>;
readonly stage: Option.Option<string>;
readonly yes: boolean;
readonly adopt: boolean;
readonly githubOutput: boolean;
readonly githubEnvFile: Option.Option<string>;
readonly readState: boolean;
}
export interface RelayPublicConfig {
readonly relayUrl: string;
readonly mobileTracingUrl: string;
readonly mobileTracingDataset: string;
readonly mobileTracingToken: string;
readonly clientTracingUrl: string;
readonly clientTracingDataset: string;
readonly clientTracingToken: string;
}
const publicConfigEnvEntries = (config: RelayPublicConfig) =>
({
T3CODE_RELAY_URL: config.relayUrl,
T3CODE_MOBILE_OTLP_TRACES_URL: config.mobileTracingUrl,
T3CODE_MOBILE_OTLP_TRACES_DATASET: config.mobileTracingDataset,
T3CODE_MOBILE_OTLP_TRACES_TOKEN: config.mobileTracingToken,
T3CODE_RELAY_CLIENT_OTLP_TRACES_URL: config.clientTracingUrl,
T3CODE_RELAY_CLIENT_OTLP_TRACES_DATASET: config.clientTracingDataset,
T3CODE_RELAY_CLIENT_OTLP_TRACES_TOKEN: config.clientTracingToken,
}) as const;
export function reconcileRootEnvPublicConfig(contents: string, config: RelayPublicConfig): string {
let next = contents;
for (const [name, value] of Object.entries(publicConfigEnvEntries(config))) {
const entry = `${name}=${value}`;
const pattern = new RegExp(`^${name}=.*$`, "mu");
if (pattern.test(next)) {
next = next.replace(pattern, entry);
continue;
}
if (!next) {
next = `${entry}\n`;
continue;
}
next = `${next}${next.endsWith("\n") ? "" : "\n"}${entry}\n`;
}
return next;
}
export function reconcileRootEnvRelayUrl(contents: string, relayUrl: string): string {
return reconcileRootEnvPublicConfig(contents, {
relayUrl,
mobileTracingUrl: "",
mobileTracingDataset: "",
mobileTracingToken: "",
clientTracingUrl: "",
clientTracingDataset: "",
clientTracingToken: "",
})
.split("\n")
.filter((line) => !line.startsWith("T3CODE_MOBILE_OTLP_TRACES_"))
.filter((line) => !line.startsWith("T3CODE_RELAY_CLIENT_OTLP_TRACES_"))
.join("\n");
}
export function hasDeployChanges(plan: Plan.Plan): boolean {
return (
Object.keys(plan.deletions).length > 0 ||
Object.values(plan.resources).some(
(node) =>
node.action !== "noop" || node.bindings.some((binding) => binding.action !== "noop"),
)
);
}
export type RelayDeployResult = "applied" | "noop" | "dry-run" | "cancelled" | "state";
export interface RelayDeployOutcome {
readonly result: RelayDeployResult;
readonly changed: boolean;
readonly publicConfig: Option.Option<RelayPublicConfig>;
}
export function serializeGithubOutput(entries: Readonly<Record<string, string | boolean>>): string {
return Object.entries(entries)
.map(([key, value]) => `${key}=${value}\n`)
.join("");
}
export function serializeRelayClientTracingEnvironment(config: RelayPublicConfig): string {
return serializeGithubOutput({
T3CODE_RELAY_CLIENT_OTLP_TRACES_URL: config.clientTracingUrl,
T3CODE_RELAY_CLIENT_OTLP_TRACES_DATASET: config.clientTracingDataset,
T3CODE_RELAY_CLIENT_OTLP_TRACES_TOKEN: config.clientTracingToken,
});
}
const relayRoot = Effect.service(Path.Path).pipe(
Effect.flatMap((path) => path.fromFileUrl(new URL("..", import.meta.url))),
);
const repoRoot = Effect.service(Path.Path).pipe(
Effect.flatMap((path) => path.fromFileUrl(new URL("../../..", import.meta.url))),
);
const loadDeployConfigProvider = Effect.fn("relay.deploy.loadConfigProvider")(function* (
envFileOverride: Option.Option<string>,
) {
const path = yield* Path.Path;
const root = yield* relayRoot;
if (Option.isSome(envFileOverride)) {
return yield* ConfigProvider.fromDotEnv({ path: path.resolve(root, envFileOverride.value) });
}
return yield* ConfigProvider.fromDotEnv({ path: path.join(root, ".env") }).pipe(
Effect.orElseSucceed(() => ConfigProvider.fromEnv()),
);
});
const relayDeployStage = Config.nonEmptyString("stage").pipe(
Config.option,
Config.map(
Option.getOrElse(() => `dev_${process.env.USER ?? process.env.USERNAME ?? "unknown"}`),
),
);
const reconcileRootEnv = Effect.fn("relay.deploy.reconcileRootEnv")(function* (
config: RelayPublicConfig,
) {
const fs = yield* FileSystem.FileSystem;
const path = yield* Path.Path;
const root = yield* repoRoot;
const rootEnvPath = path.join(root, ".env");
const contents = (yield* fs.exists(rootEnvPath)) ? yield* fs.readFileString(rootEnvPath) : "";
yield* fs.writeFileString(rootEnvPath, reconcileRootEnvPublicConfig(contents, config));
yield* Console.log(`Updated ${rootEnvPath} with relay public client configuration`);
});
const writeGithubOutput = Effect.fn("relay.deploy.writeGithubOutput")(function* (
outcome: RelayDeployOutcome,
) {
const fs = yield* FileSystem.FileSystem;
const githubOutputPath = yield* Config.nonEmptyString("GITHUB_OUTPUT");
yield* fs.writeFileString(
githubOutputPath,
serializeGithubOutput({
changed: outcome.changed,
result: outcome.result,
...(Option.isSome(outcome.publicConfig)
? {
relay_url: outcome.publicConfig.value.relayUrl,
}
: {}),
}),
{ flag: "a" },
);
});
const writeGithubEnvFile = Effect.fn("relay.deploy.writeGithubEnvFile")(function* (
outcome: RelayDeployOutcome,
outputPath: string,
) {
if (Option.isNone(outcome.publicConfig)) {
return yield* new RelayDeployError({
message: "Relay public client config is unavailable for the GitHub environment file",
});
}
const fs = yield* FileSystem.FileSystem;
yield* Console.log(`::add-mask::${outcome.publicConfig.value.clientTracingToken}`);
yield* fs.writeFileString(
outputPath,
serializeRelayClientTracingEnvironment(outcome.publicConfig.value),
);
});
const deployBaseServices = Layer.mergeAll(
Layer.succeed(AuthProviders, {}),
Layer.provideMerge(AlchemyContextLive, PlatformServices),
Layer.provide(ProfileLive, PlatformServices),
Layer.provide(CredentialsStoreLive, PlatformServices),
FetchHttpClient.layer,
TelemetryLive,
LoggingCli,
);
const deployServices = deployBaseServices;
export function publicConfigFromOutput(output: unknown): RelayPublicConfig | null {
if (typeof output !== "object" || output === null) {
return null;
}
const value = output as Record<string, unknown>;
const text = (name: string) => (typeof value[name] === "string" ? value[name] : undefined);
const secret = (name: string): string | undefined => {
const candidate = value[name];
if (!Redacted.isRedacted(candidate)) {
return text(name);
}
const redacted = Redacted.value(candidate);
return typeof redacted === "string" ? redacted : undefined;
};
const relayUrl = text("url");
const mobileTracingUrl = text("mobileTracingUrl");
const mobileTracingDataset = text("mobileTracingDataset");
const mobileTracingToken = secret("mobileTracingToken");
const clientTracingUrl = text("clientTracingUrl");
const clientTracingDataset = text("clientTracingDataset");
const clientTracingToken = secret("clientTracingToken");
return relayUrl &&
mobileTracingUrl &&
mobileTracingDataset &&
mobileTracingToken &&
clientTracingUrl &&
clientTracingDataset &&
clientTracingToken
? {
relayUrl,
mobileTracingUrl,
mobileTracingDataset,
mobileTracingToken,
clientTracingUrl,
clientTracingDataset,
clientTracingToken,
}
: null;
}
const readRelayPublicConfig = Effect.fn("relay.deploy.readState")(function* (stage: string) {
const state = yield* State.State;
const service = yield* state;
const output = yield* service.getOutput({ stack: "T3CodeRelay", stage });
const publicConfig = publicConfigFromOutput(output);
if (publicConfig === null) {
return yield* new RelayDeployError({
message: `Alchemy relay state for stage ${stage} did not include complete public client config`,
});
}
return {
result: "state",
changed: false,
publicConfig: Option.some(publicConfig),
} satisfies RelayDeployOutcome;
});
const runRelayDeploy = Effect.fn("relay.deploy.run")(
function* (
options: RelayDeployOptions,
_configProvider: ConfigProvider.ConfigProvider,
_stage: string,
) {
const stack = yield* RelayStack;
const cli = yield* Cli;
const plan = yield* Plan.make(stack, { force: options.force }).pipe(
Effect.provide(stack.services),
);
const changed = hasDeployChanges(plan);
if (options.dryRun) {
yield* cli.displayPlan(plan);
return {
result: "dry-run",
changed,
publicConfig: Option.none<RelayPublicConfig>(),
} satisfies RelayDeployOutcome;
}
if (!options.yes && changed) {
yield* cli.displayPlan(plan);
const approved = yield* Prompt.run(
Prompt.confirm({
message: "Apply this relay deployment?",
}),
);
if (!approved) {
yield* Console.log("Deployment cancelled.");
return {
result: "cancelled",
changed,
publicConfig: Option.none<RelayPublicConfig>(),
} satisfies RelayDeployOutcome;
}
}
const output = yield* Apply.apply(plan).pipe(Effect.provide(stack.services));
if (
output.url === undefined ||
output.mobileTracingUrl === undefined ||
output.mobileTracingDataset === undefined ||
output.mobileTracingToken === undefined ||
output.clientTracingUrl === undefined ||
output.clientTracingDataset === undefined ||
output.clientTracingToken === undefined
) {
return yield* new RelayDeployError({
message: "Alchemy relay deploy output did not include complete public client config",
});
}
return {
result: changed ? "applied" : "noop",
changed,
publicConfig: Option.some({
relayUrl: output.url,
mobileTracingUrl: output.mobileTracingUrl,
mobileTracingDataset: output.mobileTracingDataset,
mobileTracingToken: Redacted.value(output.mobileTracingToken),
clientTracingUrl: output.clientTracingUrl,
clientTracingDataset: output.clientTracingDataset,
clientTracingToken: Redacted.value(output.clientTracingToken),
}),
} satisfies RelayDeployOutcome;
},
(effect, options, configProvider, stage) =>
effect.pipe(
Effect.provide(
Layer.mergeAll(
Layer.effect(
AlchemyContext,
AlchemyContext.pipe(Effect.map((context) => ({ ...context, adopt: options.adopt }))),
),
Layer.succeed(AdoptPolicy, options.adopt),
Layer.succeed(AuthProviders, {}),
ConfigProvider.layer(configProvider),
Layer.succeed(Stage.Stage, stage),
),
),
provideFreshArtifactStore,
),
);
export const deploy = Effect.fn("relay.deploy")(function* (options: RelayDeployOptions) {
const configProvider = yield* loadDeployConfigProvider(options.envFile);
const configuredStage = yield* relayDeployStage.pipe(
Effect.provide(ConfigProvider.layer(configProvider)),
);
const stage = Option.getOrElse(options.stage, () => configuredStage);
const outcome = options.readState
? yield* readRelayPublicConfig(stage).pipe(Effect.provide(Cloudflare.state()))
: yield* runRelayDeploy(options, configProvider, stage);
if (Option.isSome(outcome.publicConfig)) {
yield* reconcileRootEnv(outcome.publicConfig.value);
}
if (options.githubOutput) {
yield* writeGithubOutput(outcome);
}
if (Option.isSome(options.githubEnvFile)) {
yield* writeGithubEnvFile(outcome, options.githubEnvFile.value);
}
});
export const relayDeployCommand = Command.make(
"relay-deploy",
{
dryRun: Flag.boolean("dry-run").pipe(
Flag.withDescription("Dry run the deployment without applying changes."),
Flag.withDefault(false),
),
force: Flag.boolean("force").pipe(
Flag.withDescription("Force updates for resources that would otherwise no-op."),
Flag.withDefault(false),
),
envFile: Flag.string("env-file").pipe(
Flag.withDescription(
"Environment file to load. Defaults to infra/relay/.env with process env fallback.",
),
Flag.optional,
),
stage: Flag.string("stage").pipe(
Flag.withDescription("Stage to deploy. Defaults to dev_${USER}."),
Flag.optional,
),
yes: Flag.boolean("yes").pipe(
Flag.withDescription("Skip the deployment confirmation prompt."),
Flag.withDefault(false),
),
adopt: Flag.boolean("adopt").pipe(
Flag.withDescription("Adopt pre-existing cloud resources that conflict with this stack."),
Flag.withDefault(false),
),
githubOutput: Flag.boolean("github-output").pipe(
Flag.withDescription("Append relay deployment metadata to GITHUB_OUTPUT."),
Flag.withDefault(false),
),
githubEnvFile: Flag.string("github-env-file").pipe(
Flag.withDescription(
"Write relay client tracing variables to a file suitable for GITHUB_ENV.",
),
Flag.optional,
),
readState: Flag.boolean("read-state").pipe(
Flag.withDescription("Read the deployed stack output without planning or applying changes."),
Flag.withDefault(false),
),
},
deploy,
).pipe(Command.withDescription("Deploy the T3 Code relay through Alchemy."));
if (import.meta.main) {
Command.run(relayDeployCommand, { version: "0.0.0" }).pipe(
Effect.provide(deployServices),
Effect.scoped,
NodeRuntime.runMain,
);
}