cerc-io/snowballtools-base
16
0
Fork 2
Code Issues 7 Pull Requests Actions Packages Projects Releases Wiki Activity

Check for auction if deployment request id is not present

Browse Source
This commit is contained in:
IshaVenikar 2024-10-07 18:04:02 +05:30 committed by Nabarun
parent 2a011a99cd
commit cedad71c44
2 changed files with 45 additions and 32 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
packages/backend/src/registry.ts
View File

@ -256,6 +256,8 @@ export class Registry {
this.registryConfig.privateKey,
fee
);
log(`Application deployment auction created: ${auctionResult.auction.id}`);
log(`Application deployment auction record published: ${result.id}`);
log('Application deployment auction data:', applicationDeploymentAuction);
@ -337,18 +339,22 @@ export class Registry {
const auctionResult = records[0];
let deployerLrns = [];
const { winnerAddresses } = auctionResult.auction;
const { winnerAddresses } = auctionResult;
for (const auctionWinner of winnerAddresses) {
const deployerRecord = await this.registry.queryRecords(
const deployerRecords = await this.registry.queryRecords(
{
paymentAddress: auctionWinner,
},
true
);
const lrn = deployerRecord.names.length > 0 ? deployerRecord.names[0] : null;
deployerLrns.push(lrn);
for (const record of deployerRecords) {
if (record.names && record.names.length > 0) {
deployerLrns.push(record.names[0]);
break;
}
}
}
return deployerLrns;
@ -449,14 +455,18 @@ export class Registry {
};
}
async getCompletedAuctionIds(auctionIds: string[] | null | undefined): Promise<string[]> {
if(auctionIds === null || auctionIds === undefined) {
return [];
async getCompletedAuctionIds(auctionIds: (string | null | undefined)[]): Promise<string[] | null> {
const validAuctionIds = auctionIds.filter((id): id is string => id !== null && id !== undefined);
if (!validAuctionIds.length) {
return null;
}
const auctions = await this.registry.getAuctionsByIds(auctionIds);
const auctions = await this.registry.getAuctionsByIds(validAuctionIds);
const completedAuctions = auctions
.filter((auction: Auction) => auction.status === 'completed')
.map((auction: Auction) => auction.id);
.filter((auction: Auction) => auction.status === 'completed')
.map((auction: Auction) => auction.id);
return completedAuctions;
}

47
packages/backend/src/service.ts
View File

@ -61,6 +61,8 @@ export class Service {
this.checkDeployRecordsAndUpdate();
// Start check for ApplicationDeploymentRemovalRecords asynchronously
this.checkDeploymentRemovalRecordsAndUpdate();
// Start check for Deployment Auctions asynchronously
this.checkAuctionStatus();
}
/**
@ -267,26 +269,26 @@ export class Service {
* Checks for auction status for all ongoing auctions
* Calls the createDeploymentFromAuction method for deployments with completed auctions
*/
async checkAuctionStatus(
): Promise<void> {
// Deployment should be in building state and should not have domain.
async checkAuctionStatus(): Promise<void> {
const projects = await this.db.getProjects({
where: {
deployerLrn: IsNull()
deployments: {
applicationDeploymentRequestId: IsNull()
}
},
});
const auctionIds = projects
.map(project => project.auctionId) as string[];
// Get all the auctions for those ids with auction status completed
const auctionIds = projects.map((project) => project.auctionId);
const completedAuctionIds = await this.registry.getCompletedAuctionIds(auctionIds);
// If the deplyer lrn array is empty then call createDeploymentFromAuction
const auctionProjects = projects.filter(project =>
completedAuctionIds.includes(project.auctionId!)
);
for (const project of auctionProjects) {
await this.createDeploymentFromAuction(project);
if (completedAuctionIds) {
const auctionProjects = projects.filter((project) =>
completedAuctionIds.includes(project.auctionId!)
);
for (const project of auctionProjects) {
await this.createDeploymentFromAuction(project);
}
}
this.deployRecordCheckTimeout = setTimeout(() => {
@ -692,8 +694,7 @@ export class Service {
await this.db.updateProjectById(project.id!, {
deployerLrn: deployerLrns
})
const octokit = await this.getOctokit(project.owner!.id!);
const octokit = await this.getOctokit(project.ownerId!);
const [owner, repo] = project.repository!.split('/');
const repoUrl = (
@ -739,7 +740,7 @@ export class Service {
applicationRecordData,
domain: deploymentData.domain,
createdBy: Object.assign(new User(), {
id: project.owner!.id!,
id: project.ownerId!,
}),
});
@ -767,7 +768,7 @@ export class Service {
// So publish project DNS deployment first so that ApplicationDeploymentRecord for the same is available when deleting deployment later
await this.registry.createApplicationDeploymentRequest({
deployment: newDeployment,
appName: project.name!,
appName: repo,
repository: repoUrl,
environmentVariables: environmentVariablesObj,
dns: `${newDeployment.project.name}`,
@ -778,7 +779,7 @@ export class Service {
// Create requests for all the deployers
await this.registry.createApplicationDeploymentRequest({
deployment: newDeployment,
appName: project.name!,
appName: repo,
repository: repoUrl,
auctionId: project.auctionId!,
lrn: deployer,
@ -882,10 +883,12 @@ export class Service {
commitMessage: latestCommit.commit.message,
};
await (auctionData
? this.registry.createApplicationDeploymentAuction(repo, octokit, auctionData!, deploymentData)
: this.createDeployment(user.id, octokit, deploymentData, lrn)
);
if (auctionData) {
const { applicationDeploymentAuctionId } = await this.registry.createApplicationDeploymentAuction(repo, octokit, auctionData!, deploymentData);
await this.updateProject(project.id, { auctionId: applicationDeploymentAuctionId })
} else {
await this.createDeployment(user.id, octokit, deploymentData, lrn);
}
await this.createRepoHook(octokit, project);