From d10eec4ad8174bd5e75e5c59f0f37a564bcc0c68 Mon Sep 17 00:00:00 2001 From: Adw8 Date: Thu, 24 Oct 2024 17:59:00 +0530 Subject: [PATCH] Add logs to debug why api is not working --- src/deployments.ts | 51 ++++++++++++++++++++++++++++++++++++++-------- 1 file changed, 42 insertions(+), 9 deletions(-) diff --git a/src/deployments.ts b/src/deployments.ts index b30f630..ad3dbcd 100644 --- a/src/deployments.ts +++ b/src/deployments.ts @@ -108,63 +108,93 @@ export class RegHelper { } async deploymentRequestStatus(requestId?: string) { + console.log('Starting deploymentRequestStatus with requestId:', requestId); + const requests: any[] = []; const deployments: any[] = []; + + // Querying for removal requests const removalRequests = await this.queryRecords({ type: 'ApplicationDeploymentRemovalRequest', }); + console.log('Removal requests:', removalRequests); if (requestId) { + console.log('Fetching request by ID:', requestId); const request = await this.getRecordById(requestId); if (request) { requests.push(request); + console.log('Found request:', request); + } else { + console.log('Request not found for requestId:', requestId); } - deployments.push(...await this.queryRecords({ - type: 'ApplicationDeploymentRecord', request: requestId - })); - } else { - requests.push(...await this.queryRecords({ - type: 'ApplicationDeploymentRequest', - })); - deployments.push(...await this.queryRecords({ + + console.log('Fetching deployments for request:', requestId); + const foundDeployments = await this.queryRecords({ type: 'ApplicationDeploymentRecord', - })); + request: requestId + }); + deployments.push(...foundDeployments); + console.log('Deployments for request:', foundDeployments); + } else { + console.log('Fetching all ApplicationDeploymentRequests'); + const allRequests = await this.queryRecords({ + type: 'ApplicationDeploymentRequest', + }); + requests.push(...allRequests); + console.log('All requests:', allRequests); + + console.log('Fetching all ApplicationDeploymentRecords'); + const allDeployments = await this.queryRecords({ + type: 'ApplicationDeploymentRecord', + }); + deployments.push(...allDeployments); + console.log('All deployments:', allDeployments); } + console.log('Sorting requests by createTime'); requests.sort((a, b) => a.createTime === b.createTime ? 0 : a.createTime > b.createTime ? 1 : -1,); requests.reverse(); + console.log('Sorted requests:', requests); const deploymentsByRequest = new Map(); for (const d of deployments) { deploymentsByRequest.set(d.attributes.request, d); } + console.log('Deployments by request:', deploymentsByRequest); + const removalsByRequest = new Map(); for (const rr of removalRequests) { if (rr.attributes.request) { removalsByRequest.set(rr.attributes.request, rr); } } + console.log('Removals by request:', removalsByRequest); const latestByHostname = new Map(); const ret = []; for (const r of requests) { + console.log('Processing request:', r.id); const status = new RequestStatus(r.id, r.createTime); ret.push(status); const app = await this.getRecord(r.attributes.application); if (!app) { + console.log('Error: Application not found for request:', r.id); status.lastState = 'ERROR'; continue; } status.app = r.attributes.application; const hostname = r.attributes.dns ?? generateHostnameForApp(app); + console.log('Hostname for app:', hostname); if (deploymentsByRequest.has(r.id)) { const deployment = deploymentsByRequest.get(r.id); status.url = deployment.attributes.url; status.lastUpdate = deployment.createTime; + console.log('Deployment found for request:', r.id, 'with deployment:', deployment); if (!latestByHostname.has(hostname)) { latestByHostname.set(hostname, status); @@ -179,11 +209,13 @@ export class RegHelper { } if (removalsByRequest.has(r.id)) { + console.log('Removal request found for request:', r.id); status.lastState = 'CANCELLED'; continue; } if (latestByHostname.has(hostname)) { + console.log('Cancellation found for hostname:', hostname); status.lastState = 'CANCELLED'; continue; } @@ -191,6 +223,7 @@ export class RegHelper { latestByHostname.set(hostname, status); } + console.log('Final status array:', ret); return ret; }