Add logs to debug why api is not working
This commit is contained in:
parent
16276e80d0
commit
d10eec4ad8
@ -108,63 +108,93 @@ export class RegHelper {
|
|||||||
}
|
}
|
||||||
|
|
||||||
async deploymentRequestStatus(requestId?: string) {
|
async deploymentRequestStatus(requestId?: string) {
|
||||||
|
console.log('Starting deploymentRequestStatus with requestId:', requestId);
|
||||||
|
|
||||||
const requests: any[] = [];
|
const requests: any[] = [];
|
||||||
const deployments: any[] = [];
|
const deployments: any[] = [];
|
||||||
|
|
||||||
|
// Querying for removal requests
|
||||||
const removalRequests = await this.queryRecords({
|
const removalRequests = await this.queryRecords({
|
||||||
type: 'ApplicationDeploymentRemovalRequest',
|
type: 'ApplicationDeploymentRemovalRequest',
|
||||||
});
|
});
|
||||||
|
console.log('Removal requests:', removalRequests);
|
||||||
|
|
||||||
if (requestId) {
|
if (requestId) {
|
||||||
|
console.log('Fetching request by ID:', requestId);
|
||||||
const request = await this.getRecordById(requestId);
|
const request = await this.getRecordById(requestId);
|
||||||
if (request) {
|
if (request) {
|
||||||
requests.push(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
|
console.log('Fetching deployments for request:', requestId);
|
||||||
}));
|
const foundDeployments = await this.queryRecords({
|
||||||
} else {
|
|
||||||
requests.push(...await this.queryRecords({
|
|
||||||
type: 'ApplicationDeploymentRequest',
|
|
||||||
}));
|
|
||||||
deployments.push(...await this.queryRecords({
|
|
||||||
type: 'ApplicationDeploymentRecord',
|
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.sort((a, b) => a.createTime === b.createTime ? 0 : a.createTime > b.createTime ? 1 : -1,);
|
||||||
requests.reverse();
|
requests.reverse();
|
||||||
|
console.log('Sorted requests:', requests);
|
||||||
|
|
||||||
const deploymentsByRequest = new Map<string, any>();
|
const deploymentsByRequest = new Map<string, any>();
|
||||||
for (const d of deployments) {
|
for (const d of deployments) {
|
||||||
deploymentsByRequest.set(d.attributes.request, d);
|
deploymentsByRequest.set(d.attributes.request, d);
|
||||||
}
|
}
|
||||||
|
console.log('Deployments by request:', deploymentsByRequest);
|
||||||
|
|
||||||
const removalsByRequest = new Map<string, any>();
|
const removalsByRequest = new Map<string, any>();
|
||||||
for (const rr of removalRequests) {
|
for (const rr of removalRequests) {
|
||||||
if (rr.attributes.request) {
|
if (rr.attributes.request) {
|
||||||
removalsByRequest.set(rr.attributes.request, rr);
|
removalsByRequest.set(rr.attributes.request, rr);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
console.log('Removals by request:', removalsByRequest);
|
||||||
|
|
||||||
const latestByHostname = new Map<string, any>();
|
const latestByHostname = new Map<string, any>();
|
||||||
|
|
||||||
const ret = [];
|
const ret = [];
|
||||||
for (const r of requests) {
|
for (const r of requests) {
|
||||||
|
console.log('Processing request:', r.id);
|
||||||
const status = new RequestStatus(r.id, r.createTime);
|
const status = new RequestStatus(r.id, r.createTime);
|
||||||
ret.push(status);
|
ret.push(status);
|
||||||
|
|
||||||
const app = await this.getRecord(r.attributes.application);
|
const app = await this.getRecord(r.attributes.application);
|
||||||
if (!app) {
|
if (!app) {
|
||||||
|
console.log('Error: Application not found for request:', r.id);
|
||||||
status.lastState = 'ERROR';
|
status.lastState = 'ERROR';
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
|
|
||||||
status.app = r.attributes.application;
|
status.app = r.attributes.application;
|
||||||
const hostname = r.attributes.dns ?? generateHostnameForApp(app);
|
const hostname = r.attributes.dns ?? generateHostnameForApp(app);
|
||||||
|
console.log('Hostname for app:', hostname);
|
||||||
|
|
||||||
if (deploymentsByRequest.has(r.id)) {
|
if (deploymentsByRequest.has(r.id)) {
|
||||||
const deployment = deploymentsByRequest.get(r.id);
|
const deployment = deploymentsByRequest.get(r.id);
|
||||||
status.url = deployment.attributes.url;
|
status.url = deployment.attributes.url;
|
||||||
status.lastUpdate = deployment.createTime;
|
status.lastUpdate = deployment.createTime;
|
||||||
|
console.log('Deployment found for request:', r.id, 'with deployment:', deployment);
|
||||||
|
|
||||||
if (!latestByHostname.has(hostname)) {
|
if (!latestByHostname.has(hostname)) {
|
||||||
latestByHostname.set(hostname, status);
|
latestByHostname.set(hostname, status);
|
||||||
@ -179,11 +209,13 @@ export class RegHelper {
|
|||||||
}
|
}
|
||||||
|
|
||||||
if (removalsByRequest.has(r.id)) {
|
if (removalsByRequest.has(r.id)) {
|
||||||
|
console.log('Removal request found for request:', r.id);
|
||||||
status.lastState = 'CANCELLED';
|
status.lastState = 'CANCELLED';
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
|
|
||||||
if (latestByHostname.has(hostname)) {
|
if (latestByHostname.has(hostname)) {
|
||||||
|
console.log('Cancellation found for hostname:', hostname);
|
||||||
status.lastState = 'CANCELLED';
|
status.lastState = 'CANCELLED';
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
@ -191,6 +223,7 @@ export class RegHelper {
|
|||||||
latestByHostname.set(hostname, status);
|
latestByHostname.set(hostname, status);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
console.log('Final status array:', ret);
|
||||||
return ret;
|
return ret;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user