Compare commits

...

9 Commits

Author SHA1 Message Date
IshaVenikar
b5d84470ff Remove check for deployer version number
All checks were successful
Lint / lint (20.x) (pull_request) Successful in 1m46s
2025-02-07 11:33:02 +05:30
IshaVenikar
4476de6faf Update rollback flow to handle multiple custom domains 2025-02-06 12:06:21 +05:30
IshaVenikar
5c9437bf1a Add check for deployer version to support multiple custom domains 2025-02-06 11:54:51 +05:30
IshaVenikar
baaf0a2dd8 Send canonical deployments removal request only if all custom domains change 2025-02-06 11:09:53 +05:30
IshaVenikar
d75be96d70 Send multiple domains in deployment request 2025-02-06 10:29:04 +05:30
Shreerang Kale
285d0e86bf Add custom domain support for auctions flow 2025-02-06 10:01:39 +05:30
Shreerang Kale
13cc0f8b9b Add UI to show multiple domains 2025-02-06 10:01:39 +05:30
Shreerang Kale
93b74074a3 Handle auction deployment when changing to production 2025-02-06 10:01:39 +05:30
Shreerang Kale
b0d3c0593a Enable add domain button for auctions 2025-02-06 10:01:39 +05:30
15 changed files with 450 additions and 224 deletions

View File

@ -613,26 +613,27 @@ export class Database {
id: projectId id: projectId
}, },
...filter ...filter
} },
order: {
createdAt: 'DESC',
},
}); });
return domains; return domains;
} }
async getOldestDomainByProjectId( async getOldestDomainByProjectId(projectId: string): Promise<Domain | null> {
projectId: string,
): Promise<Domain | null> {
const domainRepository = this.dataSource.getRepository(Domain); const domainRepository = this.dataSource.getRepository(Domain);
const domain = await domainRepository.findOne({ const domain = await domainRepository.findOne({
where: { where: {
project: { project: {
id: projectId id: projectId,
}, },
}, },
order: { order: {
createdAt: 'ASC' createdAt: 'ASC',
} },
}); });
return domain; return domain;

View File

@ -24,6 +24,9 @@ export class Deployer {
@Column('varchar', { nullable: true }) @Column('varchar', { nullable: true })
paymentAddress!: string | null; paymentAddress!: string | null;
@Column('varchar', { nullable: true })
version!: string | null;
@ManyToMany(() => Project, (project) => project.deployers) @ManyToMany(() => Project, (project) => project.deployers)
projects!: Project[]; projects!: Project[];
} }

View File

@ -345,10 +345,11 @@ export const createResolvers = async (service: Service): Promise<any> => {
{ {
projectId, projectId,
deploymentId, deploymentId,
}: { deploymentId: string; projectId: string }, deployerId,
}: { deploymentId: string; projectId: string, deployerId: string },
) => { ) => {
try { try {
return await service.rollbackDeployment(projectId, deploymentId); return await service.rollbackDeployment(projectId, deploymentId, deployerId);
} catch (err) { } catch (err) {
log(err); log(err);
return false; return false;

View File

@ -111,6 +111,7 @@ type Deployment {
isCurrent: Boolean! isCurrent: Boolean!
baseDomain: String baseDomain: String
status: DeploymentStatus! status: DeploymentStatus!
dnsRecordData: DNSRecordAttributes
createdAt: String! createdAt: String!
updatedAt: String! updatedAt: String!
createdBy: User! createdBy: User!
@ -271,8 +272,8 @@ type AppDeploymentRecordAttributes {
} }
input AuctionParams { input AuctionParams {
maxPrice: String, maxPrice: String
numProviders: Int, numProviders: Int
} }
type Query { type Query {

View File

@ -7,7 +7,12 @@ import { DateTime } from 'luxon';
import { OAuthApp } from '@octokit/oauth-app'; import { OAuthApp } from '@octokit/oauth-app';
import { Database } from './database'; import { Database } from './database';
import { ApplicationRecord, Deployment, DeploymentStatus, Environment } from './entity/Deployment'; import {
ApplicationRecord,
Deployment,
DeploymentStatus,
Environment,
} from './entity/Deployment';
import { Domain } from './entity/Domain'; import { Domain } from './entity/Domain';
import { EnvironmentVariable } from './entity/EnvironmentVariable'; import { EnvironmentVariable } from './entity/EnvironmentVariable';
import { Organization } from './entity/Organization'; import { Organization } from './entity/Organization';
@ -119,7 +124,8 @@ export class Service {
} }
// Fetch ApplicationDeploymentRecord for deployments // Fetch ApplicationDeploymentRecord for deployments
const records = await this.laconicRegistry.getDeploymentRecords(deployments); const records =
await this.laconicRegistry.getDeploymentRecords(deployments);
log(`Found ${records.length} ApplicationDeploymentRecords`); log(`Found ${records.length} ApplicationDeploymentRecords`);
// Update deployments for which ApplicationDeploymentRecords were returned // Update deployments for which ApplicationDeploymentRecords were returned
@ -204,7 +210,9 @@ export class Service {
return; return;
} }
const registryRecord = await this.laconicRegistry.getRecordById(record.attributes.dns); const registryRecord = await this.laconicRegistry.getRecordById(
record.attributes.dns,
);
if (!registryRecord) { if (!registryRecord) {
log(`DNS record not found for deployment ${deployment.id}`); log(`DNS record not found for deployment ${deployment.id}`);
@ -219,7 +227,7 @@ export class Service {
resourceType: dnsRecord.attributes.resource_type, resourceType: dnsRecord.attributes.resource_type,
value: dnsRecord.attributes.value, value: dnsRecord.attributes.value,
version: dnsRecord.attributes.version, version: dnsRecord.attributes.version,
} };
deployment.applicationDeploymentRecordId = record.id; deployment.applicationDeploymentRecordId = record.id;
deployment.applicationDeploymentRecordData = record.attributes; deployment.applicationDeploymentRecordData = record.attributes;
@ -239,18 +247,38 @@ export class Service {
relations: { relations: {
project: true, project: true,
deployer: true, deployer: true,
} },
}); });
if (previousCanonicalDeployment) { if (previousCanonicalDeployment) {
// If all the DNS in the previous canonical deployment request are different from the new deployment request
// Send removal request for the previous canonical deployment and delete DB entry // Send removal request for the previous canonical deployment and delete DB entry
if (previousCanonicalDeployment.url !== deployment.url) { const previousDnsList =
await this.laconicRegistry.createApplicationDeploymentRemovalRequest({ previousCanonicalDeployment.applicationDeploymentRequestData?.dns ||
deploymentId: previousCanonicalDeployment.applicationDeploymentRecordId!, '';
deployerLrn: previousCanonicalDeployment.deployer.deployerLrn, const newDnsList =
auctionId: previousCanonicalDeployment.project.auctionId, deployment.applicationDeploymentRequestData?.dns || '';
payment: previousCanonicalDeployment.project.txHash
}); const previousDnsSet = new Set(
previousDnsList.split(',').map((item) => item.trim()),
);
const newDnsSet = new Set(
newDnsList.split(',').map((item) => item.trim()),
);
const isMatch = [...previousDnsSet].some((item) => newDnsSet.has(item));
if (!isMatch) {
await this.laconicRegistry.createApplicationDeploymentRemovalRequest(
{
deploymentId:
previousCanonicalDeployment.applicationDeploymentRecordId!,
deployerLrn: previousCanonicalDeployment.deployer.deployerLrn,
auctionId: previousCanonicalDeployment.project.auctionId,
payment: previousCanonicalDeployment.project.txHash,
},
);
} }
await this.db.deleteDeploymentById(previousCanonicalDeployment.id); await this.db.deleteDeploymentById(previousCanonicalDeployment.id);
@ -261,7 +289,9 @@ export class Service {
// Release deployer funds on successful deployment // Release deployer funds on successful deployment
if (!deployment.project.fundsReleased) { if (!deployment.project.fundsReleased) {
const fundsReleased = await this.releaseDeployerFundsByProjectId(deployment.projectId); const fundsReleased = await this.releaseDeployerFundsByProjectId(
deployment.projectId,
);
// Return remaining amount to owner // Return remaining amount to owner
await this.returnUserFundsByProjectId(deployment.projectId, true); await this.returnUserFundsByProjectId(deployment.projectId, true);
@ -485,12 +515,17 @@ export class Service {
return dbProjects; return dbProjects;
} }
async getNonCanonicalDeploymentsByProjectId(projectId: string): Promise<Deployment[]> { async getNonCanonicalDeploymentsByProjectId(
const nonCanonicalDeployments = await this.db.getNonCanonicalDeploymentsByProjectId(projectId); projectId: string,
): Promise<Deployment[]> {
const nonCanonicalDeployments =
await this.db.getNonCanonicalDeploymentsByProjectId(projectId);
return nonCanonicalDeployments; return nonCanonicalDeployments;
} }
async getLatestDNSRecordByProjectId(projectId: string): Promise<DNSRecordAttributes | null> { async getLatestDNSRecordByProjectId(
projectId: string,
): Promise<DNSRecordAttributes | null> {
const dnsRecord = await this.db.getLatestDNSRecordByProjectId(projectId); const dnsRecord = await this.db.getLatestDNSRecordByProjectId(projectId);
return dnsRecord; return dnsRecord;
} }
@ -644,14 +679,23 @@ export class Service {
const octokit = await this.getOctokit(user.id); const octokit = await this.getOctokit(user.id);
const newDeployment = await this.createDeployment(user.id, octokit, { let newDeployment: Deployment;
project: oldDeployment.project,
branch: oldDeployment.branch, if (oldDeployment.project.auctionId) {
environment: Environment.Production, newDeployment = await this.createDeploymentFromAuction(
commitHash: oldDeployment.commitHash, oldDeployment.project,
commitMessage: oldDeployment.commitMessage, oldDeployment.deployer,
deployer: oldDeployment.deployer );
}); } else {
newDeployment = await this.createDeployment(user.id, octokit, {
project: oldDeployment.project,
branch: oldDeployment.branch,
environment: Environment.Production,
commitHash: oldDeployment.commitHash,
commitMessage: oldDeployment.commitMessage,
deployer: oldDeployment.deployer,
});
}
return newDeployment; return newDeployment;
} }
@ -660,7 +704,7 @@ export class Service {
userId: string, userId: string,
octokit: Octokit, octokit: Octokit,
data: DeepPartial<Deployment>, data: DeepPartial<Deployment>,
deployerLrn?: string deployerLrn?: string,
): Promise<Deployment> { ): Promise<Deployment> {
assert(data.project?.repository, 'Project repository not found'); assert(data.project?.repository, 'Project repository not found');
log( log(
@ -683,34 +727,56 @@ export class Service {
deployer = data.deployer; deployer = data.deployer;
} }
const deployment = await this.createDeploymentFromData(userId, data, deployer!.deployerLrn!, applicationRecordId, applicationRecordData, false); const deployment = await this.createDeploymentFromData(
userId,
data,
deployer!.deployerLrn!,
applicationRecordId,
applicationRecordData,
false,
);
const address = await this.getAddress(); const address = await this.getAddress();
const { repo, repoUrl } = await getRepoDetails(octokit, data.project.repository, data.commitHash); const { repo, repoUrl } = await getRepoDetails(
const environmentVariablesObj = await this.getEnvVariables(data.project!.id!); octokit,
data.project.repository,
data.commitHash,
);
const environmentVariablesObj = await this.getEnvVariables(
data.project!.id!,
);
// To set project DNS // To set project DNS
if (data.environment === Environment.Production) { if (data.environment === Environment.Production) {
const canonicalDeployment = await this.createDeploymentFromData(userId, data, deployer!.deployerLrn!, applicationRecordId, applicationRecordData, true); const canonicalDeployment = await this.createDeploymentFromData(
// If a custom domain is present then use that as the DNS in the deployment request userId,
const customDomain = await this.db.getOldestDomainByProjectId(data.project!.id!); data,
deployer!.deployerLrn!,
applicationRecordId,
applicationRecordData,
true,
);
const dns = await this.getDnsForDeployerByProjectId(data.project.id!, deployer!.version, canonicalDeployment.project.name);
// On deleting deployment later, project canonical deployment is also deleted // On deleting deployment later, project canonical deployment is also deleted
// So publish project canonical deployment first so that ApplicationDeploymentRecord for the same is available when deleting deployment later // So publish project canonical deployment first so that ApplicationDeploymentRecord for the same is available when deleting deployment later
const { applicationDeploymentRequestData, applicationDeploymentRequestId } = const {
await this.laconicRegistry.createApplicationDeploymentRequest({ applicationDeploymentRequestData,
deployment: canonicalDeployment, applicationDeploymentRequestId,
appName: repo, } = await this.laconicRegistry.createApplicationDeploymentRequest({
repository: repoUrl, deployment: canonicalDeployment,
environmentVariables: environmentVariablesObj, appName: repo,
dns: customDomain?.name ?? `${canonicalDeployment.project.name}`, repository: repoUrl,
lrn: deployer!.deployerLrn!, environmentVariables: environmentVariablesObj,
apiUrl: deployer!.deployerApiUrl!, dns,
payment: data.project.txHash, lrn: deployer!.deployerLrn!,
auctionId: data.project.auctionId, apiUrl: deployer!.deployerApiUrl!,
requesterAddress: address, payment: data.project.txHash,
publicKey: deployer!.publicKey! auctionId: data.project.auctionId,
}); requesterAddress: address,
publicKey: deployer!.publicKey!,
});
await this.db.updateDeploymentById(canonicalDeployment.id, { await this.db.updateDeploymentById(canonicalDeployment.id, {
applicationDeploymentRequestId, applicationDeploymentRequestId,
@ -730,7 +796,7 @@ export class Service {
payment: data.project.txHash, payment: data.project.txHash,
auctionId: data.project.auctionId, auctionId: data.project.auctionId,
requesterAddress: address, requesterAddress: address,
publicKey: deployer!.publicKey! publicKey: deployer!.publicKey!,
}); });
await this.db.updateDeploymentById(deployment.id, { await this.db.updateDeploymentById(deployment.id, {
@ -743,7 +809,7 @@ export class Service {
async createDeploymentFromAuction( async createDeploymentFromAuction(
project: DeepPartial<Project>, project: DeepPartial<Project>,
deployer: Deployer deployer: Deployer,
): Promise<Deployment> { ): Promise<Deployment> {
const octokit = await this.getOctokit(project.ownerId!); const octokit = await this.getOctokit(project.ownerId!);
const [owner, repo] = project.repository!.split('/'); const [owner, repo] = project.repository!.split('/');
@ -769,7 +835,7 @@ export class Service {
const applicationRecordId = record.id; const applicationRecordId = record.id;
const applicationRecordData = record.attributes; const applicationRecordData = record.attributes;
const deployerLrn = deployer!.deployerLrn const deployerLrn = deployer!.deployerLrn;
// Create deployment with prod branch and latest commit // Create deployment with prod branch and latest commit
const deploymentData = { const deploymentData = {
@ -781,31 +847,49 @@ export class Service {
commitMessage: latestCommit.commit.message, commitMessage: latestCommit.commit.message,
}; };
const deployment = await this.createDeploymentFromData(project.ownerId!, deploymentData, deployerLrn, applicationRecordId, applicationRecordData, false); const deployment = await this.createDeploymentFromData(
project.ownerId!,
deploymentData,
deployerLrn,
applicationRecordId,
applicationRecordData,
false,
);
const address = await this.getAddress(); const address = await this.getAddress();
const environmentVariablesObj = await this.getEnvVariables(project!.id!); const environmentVariablesObj = await this.getEnvVariables(project!.id!);
// To set project DNS // To set project DNS
if (deploymentData.environment === Environment.Production) { if (deploymentData.environment === Environment.Production) {
const canonicalDeployment = await this.createDeploymentFromData(project.ownerId!, deploymentData, deployerLrn, applicationRecordId, applicationRecordData, true); const canonicalDeployment = await this.createDeploymentFromData(
project.ownerId!,
deploymentData,
deployerLrn,
applicationRecordId,
applicationRecordData,
true,
);
// If a custom domain is present then use that as the DNS in the deployment request // If a custom domain is present then use that as the DNS in the deployment request
const customDomain = await this.db.getOldestDomainByProjectId(project!.id!); const dns = await this.getDnsForDeployerByProjectId(project.id!, deployer.version, project.name!);
// On deleting deployment later, project canonical deployment is also deleted // On deleting deployment later, project canonical deployment is also deleted
// So publish project canonical deployment first so that ApplicationDeploymentRecord for the same is available when deleting deployment later // So publish project canonical deployment first so that ApplicationDeploymentRecord for the same is available when deleting deployment later
const { applicationDeploymentRequestId, applicationDeploymentRequestData } = const {
await this.laconicRegistry.createApplicationDeploymentRequest({ applicationDeploymentRequestId,
deployment: canonicalDeployment, applicationDeploymentRequestData,
appName: repo, } = await this.laconicRegistry.createApplicationDeploymentRequest({
repository: repoUrl, deployment: canonicalDeployment,
environmentVariables: environmentVariablesObj, appName: repo,
dns: customDomain?.name ?? `${canonicalDeployment.project.name}`, repository: repoUrl,
auctionId: project.auctionId!, environmentVariables: environmentVariablesObj,
lrn: deployerLrn, dns,
apiUrl: deployer!.deployerApiUrl!, auctionId: project.auctionId!,
requesterAddress: address, lrn: deployerLrn,
publicKey: deployer!.publicKey! apiUrl: deployer!.deployerApiUrl!,
}); requesterAddress: address,
publicKey: deployer!.publicKey!,
});
await this.db.updateDeploymentById(canonicalDeployment.id, { await this.db.updateDeploymentById(canonicalDeployment.id, {
applicationDeploymentRequestId, applicationDeploymentRequestId,
@ -825,7 +909,7 @@ export class Service {
environmentVariables: environmentVariablesObj, environmentVariables: environmentVariablesObj,
dns: `${deployment.project.name}-${deployment.id}`, dns: `${deployment.project.name}-${deployment.id}`,
requesterAddress: address, requesterAddress: address,
publicKey: deployer!.publicKey! publicKey: deployer!.publicKey!,
}); });
await this.db.updateDeploymentById(deployment.id, { await this.db.updateDeploymentById(deployment.id, {
@ -859,7 +943,7 @@ export class Service {
deployer: Object.assign(new Deployer(), { deployer: Object.assign(new Deployer(), {
deployerLrn, deployerLrn,
}), }),
isCanonical isCanonical,
}); });
log(`Created deployment ${newDeployment.id}`); log(`Created deployment ${newDeployment.id}`);
@ -869,11 +953,11 @@ export class Service {
async updateProjectWithDeployer( async updateProjectWithDeployer(
projectId: string, projectId: string,
deployer: Deployer deployer: Deployer,
): Promise<Deployer> { ): Promise<Deployer> {
const deploymentProject = await this.db.getProjects({ const deploymentProject = await this.db.getProjects({
where: { id: projectId }, where: { id: projectId },
relations: ['deployers'] relations: ['deployers'],
}); });
if (!deploymentProject[0].deployers) { if (!deploymentProject[0].deployers) {
@ -918,15 +1002,22 @@ export class Service {
const prodBranch = createdTemplateRepo.data.default_branch ?? 'main'; const prodBranch = createdTemplateRepo.data.default_branch ?? 'main';
const project = await this.addProject(user, organizationSlug, { const project = await this.addProject(
name: `${gitRepo.data.owner!.login}-${gitRepo.data.name}`, user,
prodBranch, organizationSlug,
repository: gitRepo.data.full_name, {
// TODO: Set selected template name: `${gitRepo.data.owner!.login}-${gitRepo.data.name}`,
template: 'webapp', prodBranch,
paymentAddress: data.paymentAddress, repository: gitRepo.data.full_name,
txHash: data.txHash // TODO: Set selected template
}, lrn, auctionParams, environmentVariables); template: 'webapp',
paymentAddress: data.paymentAddress,
txHash: data.txHash,
},
lrn,
auctionParams,
environmentVariables,
);
if (!project || !project.id) { if (!project || !project.id) {
throw new Error('Failed to create project from template'); throw new Error('Failed to create project from template');
@ -985,7 +1076,9 @@ export class Service {
commitHash: latestCommit.sha, commitHash: latestCommit.sha,
commitMessage: latestCommit.commit.message, commitMessage: latestCommit.commit.message,
}; };
const { applicationDeploymentAuctionId } = await this.laconicRegistry.createApplicationDeploymentAuction(repo, octokit, auctionParams!, deploymentData); const { applicationDeploymentAuctionId } = await this.laconicRegistry.createApplicationDeploymentAuction(repo, octokit, auctionParams!, deploymentData);
await this.updateProject(project.id, { auctionId: applicationDeploymentAuctionId }); await this.updateProject(project.id, { auctionId: applicationDeploymentAuctionId });
} else { } else {
const deployer = await this.db.getDeployerByLRN(lrn!); const deployer = await this.db.getDeployerByLRN(lrn!);
@ -1167,19 +1260,20 @@ export class Service {
let newDeployment: Deployment; let newDeployment: Deployment;
if (oldDeployment.project.auctionId) { if (oldDeployment.project.auctionId) {
newDeployment = await this.createDeploymentFromAuction(oldDeployment.project, oldDeployment.deployer); newDeployment = await this.createDeploymentFromAuction(
} else { oldDeployment.project,
newDeployment = await this.createDeployment(user.id, octokit, oldDeployment.deployer,
{
project: oldDeployment.project,
// TODO: Put isCurrent field in project
branch: oldDeployment.branch,
environment: Environment.Production,
commitHash: oldDeployment.commitHash,
commitMessage: oldDeployment.commitMessage,
deployer: oldDeployment.deployer
}
); );
} else {
newDeployment = await this.createDeployment(user.id, octokit, {
project: oldDeployment.project,
// TODO: Put isCurrent field in project
branch: oldDeployment.branch,
environment: Environment.Production,
commitHash: oldDeployment.commitHash,
commitMessage: oldDeployment.commitMessage,
deployer: oldDeployment.deployer,
});
} }
return newDeployment; return newDeployment;
@ -1188,6 +1282,7 @@ export class Service {
async rollbackDeployment( async rollbackDeployment(
projectId: string, projectId: string,
deploymentId: string, deploymentId: string,
deployerId: string,
): Promise<boolean> { ): Promise<boolean> {
// TODO: Implement transactions // TODO: Implement transactions
const oldCurrentDeployment = await this.db.getDeployment({ const oldCurrentDeployment = await this.db.getDeployment({
@ -1199,6 +1294,9 @@ export class Service {
project: { project: {
id: projectId, id: projectId,
}, },
deployer: {
deployerId
},
isCurrent: true, isCurrent: true,
isCanonical: false, isCanonical: false,
}, },
@ -1218,23 +1316,25 @@ export class Service {
{ isCurrent: true }, { isCurrent: true },
); );
if (!newCurrentDeploymentUpdate || !oldCurrentDeploymentUpdate){ if (!newCurrentDeploymentUpdate || !oldCurrentDeploymentUpdate) {
return false; return false;
} }
const newCurrentDeployment = await this.db.getDeployment({ where: { id: deploymentId }, relations: { project: true, deployer: true } }); const newCurrentDeployment = await this.db.getDeployment({
where: { id: deploymentId },
relations: { project: true, deployer: true },
});
if (!newCurrentDeployment) { if (!newCurrentDeployment) {
throw new Error(`Deployment with Id ${deploymentId} not found`); throw new Error(`Deployment with Id ${deploymentId} not found`);
} }
const applicationDeploymentRequestData = newCurrentDeployment.applicationDeploymentRequestData; const applicationDeploymentRequestData =
newCurrentDeployment.applicationDeploymentRequestData;
const customDomain = await this.db.getOldestDomainByProjectId(projectId); const dns = await this.getDnsForDeployerByProjectId(projectId, newCurrentDeployment.deployer!.version, newCurrentDeployment.project.name)
if (customDomain && applicationDeploymentRequestData) { applicationDeploymentRequestData!.dns = dns
applicationDeploymentRequestData.dns = customDomain.name
}
// Create a canonical deployment for the new current deployment // Create a canonical deployment for the new current deployment
const canonicalDeployment = await this.createDeploymentFromData( const canonicalDeployment = await this.createDeploymentFromData(
@ -1249,20 +1349,23 @@ export class Service {
applicationDeploymentRequestData!.meta = JSON.stringify({ applicationDeploymentRequestData!.meta = JSON.stringify({
...JSON.parse(applicationDeploymentRequestData!.meta), ...JSON.parse(applicationDeploymentRequestData!.meta),
note: `Updated by Snowball @ ${DateTime.utc().toFormat( note: `Updated by Snowball @ ${DateTime.utc().toFormat(
"EEE LLL dd HH:mm:ss 'UTC' yyyy" "EEE LLL dd HH:mm:ss 'UTC' yyyy",
)}` )}`,
}); });
const result = await this.laconicRegistry.publishRecord( const result = await this.laconicRegistry.publishRecord(
applicationDeploymentRequestData, applicationDeploymentRequestData,
); );
log(`Application deployment request record published: ${result.id}`) log(`Application deployment request record published: ${result.id}`);
const updateResult = await this.db.updateDeploymentById(canonicalDeployment.id, { const updateResult = await this.db.updateDeploymentById(
applicationDeploymentRequestId: result.id, canonicalDeployment.id,
applicationDeploymentRequestData, {
}); applicationDeploymentRequestId: result.id,
applicationDeploymentRequestData,
},
);
return updateResult; return updateResult;
} }
@ -1589,6 +1692,8 @@ export class Service {
const minimumPayment = record.attributes.minimumPayment; const minimumPayment = record.attributes.minimumPayment;
const paymentAddress = record.attributes.paymentAddress; const paymentAddress = record.attributes.paymentAddress;
const publicKey = record.attributes.publicKey; const publicKey = record.attributes.publicKey;
const version = record.attributes.deployerVersion;
const baseDomain = deployerApiUrl.substring(deployerApiUrl.indexOf('.') + 1); const baseDomain = deployerApiUrl.substring(deployerApiUrl.indexOf('.') + 1);
const deployerData = { const deployerData = {
@ -1598,7 +1703,8 @@ export class Service {
baseDomain, baseDomain,
minimumPayment, minimumPayment,
paymentAddress, paymentAddress,
publicKey publicKey,
version,
}; };
// TODO: Update deployers table in a separate job // TODO: Update deployers table in a separate job
@ -1637,4 +1743,28 @@ export class Service {
return amount === amountSent && sender === senderAddress && recipient === recipientAddress; return amount === amountSent && sender === senderAddress && recipient === recipientAddress;
} }
async getDnsForDeployerByProjectId(projectId: string, deployerVersion: string | undefined | null, projectName: string): Promise<string> {
let dns;
// If a custom domain is present then use that as the DNS in the deployment request
// Only deployers with version > 1 support multiple custom domains
// TODO: Check version number
if (deployerVersion) {
const customDomains = await this.db.getDomainsByProjectId(
projectId,
);
dns =
customDomains.length > 0
? customDomains.map((d) => d.name).join(',')
: `${projectName}`;
} else {
const domain = await this.db.getOldestDomainByProjectId(
projectId
);
dns = domain?.name ?? `${projectName}`;
}
return dns;
}
} }

View File

@ -120,5 +120,6 @@ export interface DeployerRecord {
publicKey: string; publicKey: string;
type: string; type: string;
version: string; version: string;
deployerVersion: string;
}; };
} }

View File

@ -99,6 +99,7 @@ export const DeploymentMenu = ({
const isRollbacked = await client.rollbackDeployment( const isRollbacked = await client.rollbackDeployment(
project.id, project.id,
deployment.id, deployment.id,
deployment.deployer.deployerId
); );
if (isRollbacked.rollbackDeployment) { if (isRollbacked.rollbackDeployment) {
await onUpdate(); await onUpdate();

View File

@ -8,13 +8,14 @@ import {
MenuList, MenuList,
MenuItem, MenuItem,
Card, Card,
Tooltip,
} from '@snowballtools/material-tailwind-react-fork'; } from '@snowballtools/material-tailwind-react-fork';
import EditDomainDialog from './EditDomainDialog'; import EditDomainDialog from './EditDomainDialog';
import { useGQLClient } from 'context/GQLClientContext'; import { useGQLClient } from 'context/GQLClientContext';
import { DeleteDomainDialog } from 'components/projects/Dialog/DeleteDomainDialog'; import { DeleteDomainDialog } from 'components/projects/Dialog/DeleteDomainDialog';
import { useToast } from 'components/shared/Toast'; import { useToast } from 'components/shared/Toast';
import { GearIcon } from 'components/shared/CustomIcon'; import { GearIcon, InfoRoundFilledIcon } from 'components/shared/CustomIcon';
import { Heading } from 'components/shared/Heading'; import { Heading } from 'components/shared/Heading';
import { Button } from 'components/shared/Button'; import { Button } from 'components/shared/Button';
import { useParams } from 'react-router-dom'; import { useParams } from 'react-router-dom';
@ -44,7 +45,6 @@ interface DomainCardProps {
onUpdate: () => Promise<void>; onUpdate: () => Promise<void>;
} }
const DomainCard = ({ const DomainCard = ({
domains, domains,
domain, domain,
@ -56,7 +56,9 @@ const DomainCard = ({
const { id } = useParams(); const { id } = useParams();
const [deleteDialogOpen, setDeleteDialogOpen] = useState(false); const [deleteDialogOpen, setDeleteDialogOpen] = useState(false);
const [editDialogOpen, setEditDialogOpen] = useState(false); const [editDialogOpen, setEditDialogOpen] = useState(false);
const [dnsRecord, setDnsRecord] = useState<DNSRecordAttributes | null>(null); const [dnsRecordsWithLRN, setDnsRecordsWithLRN] = useState<
{ dnsRecord: DNSRecordAttributes; deployerLRN: string }[]
>([]);
// const [refreshStatus, SetRefreshStatus] = useState(RefreshStatus.IDLE); // const [refreshStatus, SetRefreshStatus] = useState(RefreshStatus.IDLE);
const client = useGQLClient(); const client = useGQLClient();
@ -94,9 +96,26 @@ const DomainCard = ({
return; return;
} }
const dnsRecordResponse = await client.getLatestDNSRecordByProjectId(id); const dnsRecordResponse = await client.getProject(id);
setDnsRecord(dnsRecordResponse.latestDNSRecord); if (!dnsRecordResponse.project) {
return;
}
const tempDNSRecords: {
dnsRecord: DNSRecordAttributes;
deployerLRN: string;
}[] = [];
for (const deployment of dnsRecordResponse.project.deployments) {
if (deployment.dnsRecordData.value) {
tempDNSRecords.push({
dnsRecord: deployment.dnsRecordData,
deployerLRN: deployment.deployer.deployerLrn,
});
}
}
setDnsRecordsWithLRN(tempDNSRecords);
}; };
fetchDNSData(); fetchDNSData();
@ -182,11 +201,16 @@ const DomainCard = ({
<Typography variant="small">Production</Typography> <Typography variant="small">Production</Typography>
{domain.status === DomainStatus.Pending && ( {domain.status === DomainStatus.Pending && (
<Card className="bg-slate-100 p-4 text-sm"> <Card className="bg-slate-100 p-4 text-sm">
{/* {refreshStatus === RefreshStatus.IDLE ? ( */} {dnsRecordsWithLRN.length ? (
<Heading> <>
^ Add these records to your domain {/* and refresh to check */} {/* {refreshStatus === RefreshStatus.IDLE ? ( */}
</Heading> <Heading>
{/* ) : refreshStatus === RefreshStatus.CHECKING ? ( <p className="text-blue-gray-500 pb-3">
^ Add these records to your domain{' '}
{/* and refresh to check */}
</p>
</Heading>
{/* ) : refreshStatus === RefreshStatus.CHECKING ? (
<Heading className="text-blue-500"> <Heading className="text-blue-500">
^ Checking records for {domain.name} ^ Checking records for {domain.name}
</Heading> </Heading>
@ -199,26 +223,49 @@ const DomainCard = ({
</div> </div>
)} */} )} */}
<table> <table>
<thead> <thead>
<tr> <tr>
<th className="text-left">Type</th> <th></th>
<th className="text-left">Name</th> <th className="text-left">Type</th>
<th className="text-left">Value</th> <th className="text-left">Name</th>
</tr> <th className="text-left">Value</th>
</thead> </tr>
<tbody> </thead>
{dnsRecord ? ( {dnsRecordsWithLRN.map((record) => {
<tr> return (
<td>{dnsRecord.resourceType}</td> <>
<td>@</td> <tbody>
<td>{dnsRecord.value ?? 'Not Configured'}</td> <tr>
</tr> <Tooltip
) : ( content={
<p className={'text-red-500'}>DNS record data not available</p> <div>
)} <p className="inline text-white">
</tbody> Service Provider:
</table> </p>
<p className="text-blue-gray-300 pl-2 inline">
{record.deployerLRN}
</p>
</div>
}
>
<td>
<InfoRoundFilledIcon />
</td>
</Tooltip>
<td>{record.dnsRecord.resourceType}</td>
<td>@</td>
<td>{record.dnsRecord.value}</td>
</tr>
</tbody>
</>
);
})}
</table>
</>
) : (
<p className="text-red-500">DNS record data not available</p>
)}
</Card> </Card>
)} )}

View File

@ -13,6 +13,7 @@ import {
AppDeploymentRecordAttributes, AppDeploymentRecordAttributes,
Deployment, Deployment,
DeploymentStatus, DeploymentStatus,
DNSRecordAttributes,
Domain, Domain,
DomainStatus, DomainStatus,
Environment, Environment,
@ -50,6 +51,7 @@ const deployment: Deployment = {
applicationDeploymentRequestId: applicationDeploymentRequestId:
'bafyreiaycvq6imoppnpwdve4smj6t6ql5svt5zl3x6rimu4qwyzgjorize', 'bafyreiaycvq6imoppnpwdve4smj6t6ql5svt5zl3x6rimu4qwyzgjorize',
applicationDeploymentRecordData: {} as AppDeploymentRecordAttributes, applicationDeploymentRecordData: {} as AppDeploymentRecordAttributes,
dnsRecordData: {} as DNSRecordAttributes,
}; };
const domains: Domain[] = [ const domains: Domain[] = [

View File

@ -60,39 +60,31 @@ const Domains = () => {
return ( return (
<ProjectSettingContainer <ProjectSettingContainer
headingText="Domains" headingText="Domains"
{...(!project.auctionId && { button={
button: ( <Button
<Button as="a"
as="a" href="add"
href="add" variant="secondary"
variant="secondary" leftIcon={<PlusIcon />}
leftIcon={<PlusIcon />} size="md"
size="md" >
> Add domain
Add domain </Button>
</Button> }
),
})}
> >
{project.auctionId ? ( {domains.map((domain) => {
<p className="text-gray-500"> return (
Custom domains not supported for auction driven deployments. <DomainCard
</p> domains={domains}
) : ( domain={domain}
domains.map((domain) => { key={domain.id}
return ( // TODO: Use github API for getting linked repository
<DomainCard branches={branches}
domains={domains} project={project}
domain={domain} onUpdate={fetchDomains}
key={domain.id} />
// TODO: Use github API for getting linked repository );
branches={branches} })}
project={project}
onUpdate={fetchDomains}
/>
);
})
)}
</ProjectSettingContainer> </ProjectSettingContainer>
); );
}; };

View File

@ -18,7 +18,9 @@ const Config = () => {
const primaryDomainName = searchParams.get('name'); const primaryDomainName = searchParams.get('name');
const { toast, dismiss } = useToast(); const { toast, dismiss } = useToast();
const [dnsRecord, setDnsRecord] = useState<DNSRecordAttributes | null>(null); const [dnsRecordsWithLRN, setDnsRecordsWithLRN] = useState<
{ dnsRecord: DNSRecordAttributes; deployerLRN: string }[]
>([]);
const handleSubmitDomain = async () => { const handleSubmitDomain = async () => {
if (primaryDomainName === null) { if (primaryDomainName === null) {
@ -75,68 +77,100 @@ const Config = () => {
return; return;
} }
const dnsRecordResponse = await client.getLatestDNSRecordByProjectId(id); const dnsRecordResponse = await client.getProject(id);
setDnsRecord(dnsRecordResponse.latestDNSRecord); if (!dnsRecordResponse.project) {
return;
}
const tempDNSRecords: {
dnsRecord: DNSRecordAttributes;
deployerLRN: string;
}[] = [];
for (const deployment of dnsRecordResponse.project.deployments) {
if (deployment.dnsRecordData.value) {
tempDNSRecords.push({
dnsRecord: deployment.dnsRecordData,
deployerLRN: deployment.deployer.deployerLrn,
});
}
}
setDnsRecordsWithLRN(tempDNSRecords);
// console.log('DNS RECORD', dnsRecordResponse)
// setDnsRecord({} as DNSRecordAttributes);
}; };
fetchDNSData(); fetchDNSData();
}, [id, client]); }, [id, client]);
// TODO: Figure out DNS Provider if possible and update appropriatly // TODO: Figure out DNS Provider if possible and update appropriatly
// TODO: Handle case where dnsRecords only have one entry and IP address for that record is not availble
return ( return (
<ProjectSettingContainer headingText="Setup domain name"> <ProjectSettingContainer headingText="Setup domain name">
{dnsRecord ? ( {dnsRecordsWithLRN.length ? (
<> <>
<p className="text-blue-gray-500"> <p className="text-blue-gray-500">
Add the following records to your domain. Add the following records to your domain.
</p> </p>
{dnsRecordsWithLRN.map((record) => {
<Table> if (record.dnsRecord.value) {
<Table.Header> return (
<Table.Row> <>
<Table.ColumnHeaderCell>Type</Table.ColumnHeaderCell> <div className="pt-6">
<Table.ColumnHeaderCell>Host</Table.ColumnHeaderCell> <p className="text-gray-100 inline">Service Provider:</p>
<Table.ColumnHeaderCell>Value</Table.ColumnHeaderCell> <p className="text-blue-gray-500 pl-2 inline">
</Table.Row> {record.deployerLRN}
</Table.Header> </p>
</div>
<Table.Body> <Table>
<Table.Row> <Table.Header>
<Table.RowHeaderCell> <Table.Row>
{dnsRecord.resourceType} <Table.ColumnHeaderCell>Type</Table.ColumnHeaderCell>
</Table.RowHeaderCell> <Table.ColumnHeaderCell>Host</Table.ColumnHeaderCell>
<Table.Cell>@</Table.Cell> <Table.ColumnHeaderCell>Value</Table.ColumnHeaderCell>
<Table.Cell> </Table.Row>
<p className={!dnsRecord.value ? 'text-red-500' : ''}> </Table.Header>
{dnsRecord.value ?? 'Not available'} <Table.Body>
</p> <Table.Row>
</Table.Cell> <Table.RowHeaderCell>
</Table.Row> {record.dnsRecord.resourceType}
</Table.Body> </Table.RowHeaderCell>
</Table> <Table.Cell>@</Table.Cell>
<Table.Cell>
{dnsRecord?.value && ( <p>{record.dnsRecord.value}</p>
<InlineNotification </Table.Cell>
variant="info" </Table.Row>
title={`It can take up to 48 hours for these updates to reflect </Table.Body>
globally.`} </Table>
/> </>
)} );
<Button }
className="w-fit" })}
disabled={!dnsRecord?.value}
onClick={handleSubmitDomain}
variant="primary"
shape="default"
rightIcon={<ArrowRightCircleIcon />}
>
FINISH
</Button>
</> </>
) : ( ) : (
<p className={'text-red-500'}>DNS record data not available</p> <p className={'text-red-500'}>DNS record data not available</p>
)} )}
{dnsRecordsWithLRN.length && (
<InlineNotification
variant="info"
title={`It can take up to 48 hours for these updates to reflect
globally.`}
/>
)}
<Button
className="w-fit"
disabled={!dnsRecordsWithLRN.length}
onClick={handleSubmitDomain}
variant="primary"
shape="default"
rightIcon={<ArrowRightCircleIcon />}
>
FINISH
</Button>
;
</ProjectSettingContainer> </ProjectSettingContainer>
); );
}; };

View File

@ -13,6 +13,7 @@ import {
Environment, Environment,
Permission, Permission,
AppDeploymentRecordAttributes, AppDeploymentRecordAttributes,
DNSRecordAttributes,
} from 'gql-client'; } from 'gql-client';
export const user: User = { export const user: User = {
@ -112,6 +113,7 @@ export const deployment0: Deployment = {
applicationDeploymentRequestId: applicationDeploymentRequestId:
'bafyreiaycvq6imoppnpwdve4smj6t6ql5svt5zl3x6rimu4qwyzgjorize', 'bafyreiaycvq6imoppnpwdve4smj6t6ql5svt5zl3x6rimu4qwyzgjorize',
applicationDeploymentRecordData: {} as AppDeploymentRecordAttributes, applicationDeploymentRecordData: {} as AppDeploymentRecordAttributes,
dnsRecordData: {} as DNSRecordAttributes,
}; };
export const project: Project = { export const project: Project = {

View File

@ -337,13 +337,15 @@ export class GQLClient {
async rollbackDeployment( async rollbackDeployment(
projectId: string, projectId: string,
deploymentId: string deploymentId: string,
deployerId: string,
): Promise<types.RollbackDeploymentResponse> { ): Promise<types.RollbackDeploymentResponse> {
const { data } = await this.client.mutate({ const { data } = await this.client.mutate({
mutation: mutations.rollbackDeployment, mutation: mutations.rollbackDeployment,
variables: { variables: {
projectId, projectId,
deploymentId, deploymentId,
deployerId,
}, },
}); });

View File

@ -62,11 +62,19 @@ query ($projectId: String!) {
} }
deployer { deployer {
baseDomain baseDomain
deployerLrn
} }
createdBy { createdBy {
id id
name name
} }
dnsRecordData {
name
value
request
resourceType
version
}
} }
} }
} }

View File

@ -112,6 +112,7 @@ export type Deployment = {
createdBy: User; createdBy: User;
createdAt: string; createdAt: string;
updatedAt: string; updatedAt: string;
dnsRecordData: DNSRecordAttributes;
applicationDeploymentRequestId: string; applicationDeploymentRequestId: string;
}; };