Skip to content

Commit 3840d95

Browse files
nicktrnnicktrn
committed
feat: optional v4 deploy registry overrides
1 parent af14621 commit 3840d95

7 files changed

Lines changed: 376 additions & 81 deletions

‎apps/webapp/app/env.server.ts‎

Lines changed: 34 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -230,14 +230,47 @@ const EnvironmentSchema = z.object({
230230
DEPOT_ORG_ID: z.string().optional(),
231231
DEPOT_REGION: z.string().default("us-east-1"),
232232

233-
// Deployment registry
233+
// Deployment registry (v3)
234234
DEPLOY_REGISTRY_HOST: z.string().min(1),
235235
DEPLOY_REGISTRY_USERNAME: z.string().optional(),
236236
DEPLOY_REGISTRY_PASSWORD: z.string().optional(),
237237
DEPLOY_REGISTRY_NAMESPACE: z.string().min(1).default("trigger"),
238238
DEPLOY_REGISTRY_ECR_TAGS: z.string().optional(), // csv, for example: "key1=value1,key2=value2"
239239
DEPLOY_REGISTRY_ECR_ASSUME_ROLE_ARN: z.string().optional(),
240240
DEPLOY_REGISTRY_ECR_ASSUME_ROLE_EXTERNAL_ID: z.string().optional(),
241+
242+
// Deployment registry (v4) - falls back to v3 registry if not specified
243+
V4_DEPLOY_REGISTRY_HOST: z
244+
.string()
245+
.optional()
246+
.transform((v) => v ?? process.env.DEPLOY_REGISTRY_HOST)
247+
.pipe(z.string().min(1)), // Ensure final type is required string
248+
V4_DEPLOY_REGISTRY_USERNAME: z
249+
.string()
250+
.optional()
251+
.transform((v) => v ?? process.env.DEPLOY_REGISTRY_USERNAME),
252+
V4_DEPLOY_REGISTRY_PASSWORD: z
253+
.string()
254+
.optional()
255+
.transform((v) => v ?? process.env.DEPLOY_REGISTRY_PASSWORD),
256+
V4_DEPLOY_REGISTRY_NAMESPACE: z
257+
.string()
258+
.optional()
259+
.transform((v) => v ?? process.env.DEPLOY_REGISTRY_NAMESPACE)
260+
.pipe(z.string().min(1).default("trigger")), // Ensure final type is required string
261+
V4_DEPLOY_REGISTRY_ECR_TAGS: z
262+
.string()
263+
.optional()
264+
.transform((v) => v ?? process.env.DEPLOY_REGISTRY_ECR_TAGS),
265+
V4_DEPLOY_REGISTRY_ECR_ASSUME_ROLE_ARN: z
266+
.string()
267+
.optional()
268+
.transform((v) => v ?? process.env.DEPLOY_REGISTRY_ECR_ASSUME_ROLE_ARN),
269+
V4_DEPLOY_REGISTRY_ECR_ASSUME_ROLE_EXTERNAL_ID: z
270+
.string()
271+
.optional()
272+
.transform((v) => v ?? process.env.DEPLOY_REGISTRY_ECR_ASSUME_ROLE_EXTERNAL_ID),
273+
241274
DEPLOY_IMAGE_PLATFORM: z.string().default("linux/amd64"),
242275
DEPLOY_TIMEOUT_MS: z.coerce
243276
.number()

‎apps/webapp/app/v3/getDeploymentImageRef.server.ts‎

Lines changed: 13 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -10,6 +10,7 @@ import {
1010
import { STSClient, AssumeRoleCommand } from "@aws-sdk/client-sts";
1111
import { tryCatch } from "@trigger.dev/core";
1212
import { logger } from "~/services/logger.server";
13+
import { type RegistryConfig } from "./registryConfig.server";
1314

1415
// Optional configuration for cross-account access
1516
export type AssumeRoleConfig = {
@@ -97,30 +98,24 @@ export async function createEcrClient({
9798
}
9899

99100
export async function getDeploymentImageRef({
100-
host,
101-
namespace,
101+
registry,
102102
projectRef,
103103
nextVersion,
104104
environmentSlug,
105-
registryTags,
106-
assumeRole,
107105
}: {
108-
host: string;
109-
namespace: string;
106+
registry: RegistryConfig;
110107
projectRef: string;
111108
nextVersion: string;
112109
environmentSlug: string;
113-
registryTags?: string;
114-
assumeRole?: AssumeRoleConfig;
115110
}): Promise<{
116111
imageRef: string;
117112
isEcr: boolean;
118113
repoCreated: boolean;
119114
}> {
120-
const repositoryName = `${namespace}/${projectRef}`;
121-
const imageRef = `${host}/${repositoryName}:${nextVersion}.${environmentSlug}`;
115+
const repositoryName = `${registry.namespace}/${projectRef}`;
116+
const imageRef = `${registry.host}/${repositoryName}:${nextVersion}.${environmentSlug}`;
122117

123-
if (!isEcrRegistry(host)) {
118+
if (!isEcrRegistry(registry.host)) {
124119
return {
125120
imageRef,
126121
isEcr: false,
@@ -131,16 +126,19 @@ export async function getDeploymentImageRef({
131126
const [ecrRepoError, ecrData] = await tryCatch(
132127
ensureEcrRepositoryExists({
133128
repositoryName,
134-
registryHost: host,
135-
registryTags,
136-
assumeRole,
129+
registryHost: registry.host,
130+
registryTags: registry.ecrTags,
131+
assumeRole: {
132+
roleArn: registry.ecrAssumeRoleArn,
133+
externalId: registry.ecrAssumeRoleExternalId,
134+
},
137135
})
138136
);
139137

140138
if (ecrRepoError) {
141139
logger.error("Failed to ensure ECR repository exists", {
142140
repositoryName,
143-
host,
141+
host: registry.host,
144142
ecrRepoError: ecrRepoError.message,
145143
});
146144
throw ecrRepoError;

‎apps/webapp/app/v3/registryConfig.server.ts‎

Lines changed: 35 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,35 @@
1+
import { env } from "~/env.server";
2+
3+
export type RegistryConfig = {
4+
host: string;
5+
username?: string;
6+
password?: string;
7+
namespace: string;
8+
ecrTags?: string;
9+
ecrAssumeRoleArn?: string;
10+
ecrAssumeRoleExternalId?: string;
11+
};
12+
13+
export function getRegistryConfig(isV4Deployment: boolean): RegistryConfig {
14+
if (isV4Deployment) {
15+
return {
16+
host: env.V4_DEPLOY_REGISTRY_HOST,
17+
username: env.V4_DEPLOY_REGISTRY_USERNAME,
18+
password: env.V4_DEPLOY_REGISTRY_PASSWORD,
19+
namespace: env.V4_DEPLOY_REGISTRY_NAMESPACE,
20+
ecrTags: env.V4_DEPLOY_REGISTRY_ECR_TAGS,
21+
ecrAssumeRoleArn: env.V4_DEPLOY_REGISTRY_ECR_ASSUME_ROLE_ARN,
22+
ecrAssumeRoleExternalId: env.V4_DEPLOY_REGISTRY_ECR_ASSUME_ROLE_EXTERNAL_ID,
23+
};
24+
}
25+
26+
return {
27+
host: env.DEPLOY_REGISTRY_HOST,
28+
username: env.DEPLOY_REGISTRY_USERNAME,
29+
password: env.DEPLOY_REGISTRY_PASSWORD,
30+
namespace: env.DEPLOY_REGISTRY_NAMESPACE,
31+
ecrTags: env.DEPLOY_REGISTRY_ECR_TAGS,
32+
ecrAssumeRoleArn: env.DEPLOY_REGISTRY_ECR_ASSUME_ROLE_ARN,
33+
ecrAssumeRoleExternalId: env.DEPLOY_REGISTRY_ECR_ASSUME_ROLE_EXTERNAL_ID,
34+
};
35+
}

‎apps/webapp/app/v3/services/finalizeDeploymentV2.server.ts‎

Lines changed: 29 additions & 36 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,8 @@
1-
import { ExternalBuildData, FinalizeDeploymentRequestBody } from "@trigger.dev/core/v3/schemas";
2-
import { AuthenticatedEnvironment } from "~/services/apiAuth.server";
1+
import {
2+
ExternalBuildData,
3+
type FinalizeDeploymentRequestBody,
4+
} from "@trigger.dev/core/v3/schemas";
5+
import type { AuthenticatedEnvironment } from "~/services/apiAuth.server";
36
import { logger } from "~/services/logger.server";
47
import { BaseService, ServiceValidationError } from "./baseService.server";
58
import { join } from "node:path";
@@ -11,6 +14,7 @@ import { FinalizeDeploymentService } from "./finalizeDeployment.server";
1114
import { remoteBuildsEnabled } from "../remoteImageBuilder.server";
1215
import { getEcrAuthToken, isEcrRegistry } from "../getDeploymentImageRef.server";
1316
import { tryCatch } from "@trigger.dev/core";
17+
import { getRegistryConfig, type RegistryConfig } from "../registryConfig.server";
1418

1519
export class FinalizeDeploymentV2Service extends BaseService {
1620
public async call(
@@ -37,6 +41,7 @@ export class FinalizeDeploymentV2Service extends BaseService {
3741
externalBuildData: true,
3842
environment: true,
3943
imageReference: true,
44+
type: true,
4045
worker: {
4146
select: {
4247
project: true,
@@ -78,11 +83,10 @@ export class FinalizeDeploymentV2Service extends BaseService {
7883
throw new ServiceValidationError("External build data is invalid");
7984
}
8085

81-
if (
82-
!env.DEPLOY_REGISTRY_HOST ||
83-
!env.DEPLOY_REGISTRY_USERNAME ||
84-
!env.DEPLOY_REGISTRY_PASSWORD
85-
) {
86+
const isV4Deployment = deployment.type === "MANAGED";
87+
const registryConfig = getRegistryConfig(isV4Deployment);
88+
89+
if (!registryConfig.host || !registryConfig.username || !registryConfig.password) {
8690
throw new ServiceValidationError("Missing deployment registry credentials");
8791
}
8892

@@ -104,12 +108,7 @@ export class FinalizeDeploymentV2Service extends BaseService {
104108
orgToken: env.DEPOT_TOKEN,
105109
projectId: externalBuildData.data.projectId,
106110
},
107-
registry: {
108-
host: env.DEPLOY_REGISTRY_HOST,
109-
namespace: env.DEPLOY_REGISTRY_NAMESPACE,
110-
username: env.DEPLOY_REGISTRY_USERNAME,
111-
password: env.DEPLOY_REGISTRY_PASSWORD,
112-
},
111+
registry: registryConfig,
113112
deployment: {
114113
version: deployment.version,
115114
environmentSlug: deployment.environment.slug,
@@ -144,12 +143,7 @@ type ExecutePushToRegistryOptions = {
144143
orgToken: string;
145144
projectId: string;
146145
};
147-
registry: {
148-
host: string;
149-
namespace: string;
150-
username: string;
151-
password: string;
152-
};
146+
registry: RegistryConfig;
153147
deployment: {
154148
version: string;
155149
environmentSlug: string;
@@ -175,12 +169,7 @@ async function executePushToRegistry(
175169
writer?: WritableStreamDefaultWriter
176170
): Promise<ExecutePushResult> {
177171
// Step 1: We need to "login" to the registry
178-
const [loginError, configDir] = await tryCatch(
179-
ensureLoggedIntoDockerRegistry(registry.host, {
180-
username: registry.username,
181-
password: registry.password,
182-
})
183-
);
172+
const [loginError, configDir] = await tryCatch(ensureLoggedIntoDockerRegistry(registry));
184173

185174
if (loginError) {
186175
logger.error("Failed to login to registry", {
@@ -260,31 +249,35 @@ async function executePushToRegistry(
260249
}
261250
}
262251

263-
async function ensureLoggedIntoDockerRegistry(
264-
registryHost: string,
265-
auth: { username: string; password: string } | undefined = undefined
266-
) {
252+
async function ensureLoggedIntoDockerRegistry(registryConfig: RegistryConfig) {
267253
const tmpDir = await createTempDir();
268254
const dockerConfigPath = join(tmpDir, "config.json");
269255

256+
let auth: { username: string; password: string };
257+
270258
// If this is an ECR registry, get fresh credentials
271-
if (isEcrRegistry(registryHost)) {
259+
if (isEcrRegistry(registryConfig.host)) {
272260
auth = await getEcrAuthToken({
273-
registryHost,
274-
assumeRole: env.DEPLOY_REGISTRY_ECR_ASSUME_ROLE_ARN
261+
registryHost: registryConfig.host,
262+
assumeRole: registryConfig.ecrAssumeRoleArn
275263
? {
276-
roleArn: env.DEPLOY_REGISTRY_ECR_ASSUME_ROLE_ARN,
277-
externalId: env.DEPLOY_REGISTRY_ECR_ASSUME_ROLE_EXTERNAL_ID,
264+
roleArn: registryConfig.ecrAssumeRoleArn,
265+
externalId: registryConfig.ecrAssumeRoleExternalId,
278266
}
279267
: undefined,
280268
});
281-
} else if (!auth) {
269+
} else if (!registryConfig.username || !registryConfig.password) {
282270
throw new Error("Authentication required for non-ECR registry");
271+
} else {
272+
auth = {
273+
username: registryConfig.username,
274+
password: registryConfig.password,
275+
};
283276
}
284277

285278
await writeJSONFile(dockerConfigPath, {
286279
auths: {
287-
[registryHost]: {
280+
[registryConfig.host]: {
288281
auth: Buffer.from(`${auth.username}:${auth.password}`).toString("base64"),
289282
},
290283
},

‎apps/webapp/app/v3/services/initializeDeployment.server.ts‎

Lines changed: 5 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -10,6 +10,7 @@ import { BaseService, ServiceValidationError } from "./baseService.server";
1010
import { TimeoutDeploymentService } from "./timeoutDeployment.server";
1111
import { getDeploymentImageRef } from "../getDeploymentImageRef.server";
1212
import { tryCatch } from "@trigger.dev/core";
13+
import { getRegistryConfig } from "../registryConfig.server";
1314

1415
const nanoid = customAlphabet("1234567890abcdefghijklmnopqrstuvwxyz", 8);
1516

@@ -69,20 +70,15 @@ export class InitializeDeploymentService extends BaseService {
6970
})
7071
: undefined;
7172

73+
const isV4Deployment = payload.type === "MANAGED";
74+
const registryConfig = getRegistryConfig(isV4Deployment);
75+
7276
const [imageRefError, imageRefResult] = await tryCatch(
7377
getDeploymentImageRef({
74-
host: env.DEPLOY_REGISTRY_HOST,
75-
namespace: env.DEPLOY_REGISTRY_NAMESPACE,
78+
registry: registryConfig,
7679
projectRef: environment.project.externalRef,
7780
nextVersion,
7881
environmentSlug: environment.slug,
79-
registryTags: env.DEPLOY_REGISTRY_ECR_TAGS,
80-
assumeRole: env.DEPLOY_REGISTRY_ECR_ASSUME_ROLE_ARN
81-
? {
82-
roleArn: env.DEPLOY_REGISTRY_ECR_ASSUME_ROLE_ARN,
83-
externalId: env.DEPLOY_REGISTRY_ECR_ASSUME_ROLE_EXTERNAL_ID,
84-
}
85-
: undefined,
8682
})
8783
);
8884

0 commit comments

Comments
 (0)