Skip to content

Fix/dx 2181 sanity delay #408

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
sunil-lakshman merged 2 commits into from
Jul 30, 2025
Merged

Fix/dx 2181 sanity delay #408

Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
7078bde
Added delay in bulk publish test suites
sunil-lakshman Jul 30, 2025
14e7390
Fixed the lint errors
sunil-lakshman Jul 30, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
154 changes: 78 additions & 76 deletions test/sanity-check/api/bulkOperation-test.js
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -19,6 +19,27 @@ let jobId3 = ''
let tokenUidDev = ''
let tokenUid = ''

function delay (ms) {
return new Promise(resolve => setTimeout(resolve, ms))
}

async function waitForJobReady (jobId, maxAttempts = 10) {
for (let attempt = 1; attempt <= maxAttempts; attempt++) {
try {
const response = await doBulkOperationWithManagementToken(tokenUidDev)
.jobStatus({ job_id: jobId, api_version: '3.2' })

if (response && response.status) {
return response
}
} catch (error) {
console.log(`Attempt ${attempt}: Job not ready yet, retrying...`)
}
await delay(2000)
}
throw new Error(`Job ${jobId} did not become ready after ${maxAttempts} attempts`)
}

describe('BulkOperation api test', () => {
setup(() => {
const user = jsonReader('loggedinuser.json')
Expand Down Expand Up @@ -141,91 +162,72 @@ describe('BulkOperation api test', () => {
.catch(done)
})

it('should get job status for the first publish job', done => {
doBulkOperationWithManagementToken(tokenUidDev)
.jobStatus({ job_id: jobId1, api_version: '3.2' })
.then((response) => {
expect(response).to.not.equal(undefined)
expect(response.uid).to.not.equal(undefined)
expect(response.status).to.not.equal(undefined)
expect(response.action).to.not.equal(undefined)
expect(response.summary).to.not.equal(undefined)
expect(response.body).to.not.equal(undefined)
done()
})
.catch((error) => {
console.error('Job status error:', error)
done(error)
})
it('should wait for all jobs to be processed before checking status', async () => {
await delay(5000) // Wait 5 seconds for jobs to be processed
})

it('should validate detailed job status response structure', done => {
doBulkOperationWithManagementToken(tokenUidDev)
.jobStatus({ job_id: jobId1, api_version: '3.2' })
.then((response) => {
expect(response).to.not.equal(undefined)
// Validate main job properties
expect(response.uid).to.not.equal(undefined)
expect(response.api_key).to.not.equal(undefined)
expect(response.status).to.not.equal(undefined)

// Validate body structure
expect(response.body).to.not.equal(undefined)
expect(response.body.locales).to.be.an('array')
expect(response.body.environments).to.be.an('array')
// Validate summary structure
expect(response.summary).to.not.equal(undefined)
done()
})
.catch((error) => {
console.error('Detailed job status error:', error)
done(error)
})
it('should wait for jobs to be ready and get job status for the first publish job', async () => {
const response = await waitForJobReady(jobId1)

expect(response).to.not.equal(undefined)
expect(response.uid).to.not.equal(undefined)
expect(response.status).to.not.equal(undefined)
expect(response.action).to.not.equal(undefined)
expect(response.summary).to.not.equal(undefined)
expect(response.body).to.not.equal(undefined)
})

it('should get job status for the second publish job', done => {
doBulkOperationWithManagementToken(tokenUidDev)
.jobStatus({ job_id: jobId2, api_version: '3.2' })
.then((response) => {
expect(response).to.not.equal(undefined)
expect(response.uid).to.not.equal(undefined)
expect(response.status).to.not.equal(undefined)
expect(response.action).to.not.equal(undefined)
expect(response.summary).to.not.equal(undefined)
expect(response.body).to.not.equal(undefined)
done()
})
.catch(done)
it('should validate detailed job status response structure', async () => {
const response = await waitForJobReady(jobId1)

expect(response).to.not.equal(undefined)
// Validate main job properties
expect(response.uid).to.not.equal(undefined)
expect(response.api_key).to.not.equal(undefined)
expect(response.status).to.not.equal(undefined)

// Validate body structure
expect(response.body).to.not.equal(undefined)
expect(response.body.locales).to.be.an('array')
expect(response.body.environments).to.be.an('array')
// Validate summary structure
expect(response.summary).to.not.equal(undefined)
})

it('should get job status for the third publish job', done => {
doBulkOperationWithManagementToken(tokenUidDev)
.jobStatus({ job_id: jobId3, api_version: '3.2' })
.then((response) => {
expect(response).to.not.equal(undefined)
expect(response.uid).to.not.equal(undefined)
expect(response.status).to.not.equal(undefined)
expect(response.action).to.not.equal(undefined)
expect(response.summary).to.not.equal(undefined)
expect(response.body).to.not.equal(undefined)
done()
})
.catch(done)
it('should get job status for the second publish job', async () => {
const response = await waitForJobReady(jobId2)

expect(response).to.not.equal(undefined)
expect(response.uid).to.not.equal(undefined)
expect(response.status).to.not.equal(undefined)
expect(response.action).to.not.equal(undefined)
expect(response.summary).to.not.equal(undefined)
expect(response.body).to.not.equal(undefined)
})

it('should get job status with bulk_version parameter', done => {
doBulkOperationWithManagementToken(tokenUidDev)
it('should get job status for the third publish job', async () => {
const response = await waitForJobReady(jobId3)

expect(response).to.not.equal(undefined)
expect(response.uid).to.not.equal(undefined)
expect(response.status).to.not.equal(undefined)
expect(response.action).to.not.equal(undefined)
expect(response.summary).to.not.equal(undefined)
expect(response.body).to.not.equal(undefined)
})

it('should get job status with bulk_version parameter', async () => {
await waitForJobReady(jobId1)

const response = await doBulkOperationWithManagementToken(tokenUidDev)
.jobStatus({ job_id: jobId1, bulk_version: 'v3', api_version: '3.2' })
.then((response) => {
expect(response).to.not.equal(undefined)
expect(response.uid).to.not.equal(undefined)
expect(response.status).to.not.equal(undefined)
expect(response.action).to.not.equal(undefined)
expect(response.summary).to.not.equal(undefined)
expect(response.body).to.not.equal(undefined)
done()
})
.catch(done)

expect(response).to.not.equal(undefined)
expect(response.uid).to.not.equal(undefined)
expect(response.status).to.not.equal(undefined)
expect(response.action).to.not.equal(undefined)
expect(response.summary).to.not.equal(undefined)
expect(response.body).to.not.equal(undefined)
})

it('should delete a Management Token', done => {
Expand Down
Loading