joe/kami-parse-server
Public Access
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

test: improve PushController tests (#7760)

Browse Source
This commit is contained in:
Corey
2022-01-02 09:51:49 -05:00
committed by GitHub
parent 75b9a56e0a
commit 7af5de4b98
1 changed files with 24 additions and 50 deletions
Download Patch File Download Diff File Expand all files Collapse all files

74
spec/PushController.spec.js
View File

@@ -562,11 +562,7 @@ describe('PushController', () => {
}); });
const pushStatusId = await sendPush(payload, {}, config, auth); const pushStatusId = await sendPush(payload, {}, config, auth);
// it is enqueued so it can take time // it is enqueued so it can take time
await new Promise(resolve => { await sleep(1000);
setTimeout(() => {
resolve();
}, 1000);
});
Parse.serverURL = 'http://localhost:8378/1'; // GOOD url Parse.serverURL = 'http://localhost:8378/1'; // GOOD url
const result = await Parse.Push.getPushStatus(pushStatusId); const result = await Parse.Push.getPushStatus(pushStatusId);
expect(result).toBeDefined(); expect(result).toBeDefined();
@@ -767,7 +763,7 @@ describe('PushController', () => {
}); });
}); });
it('should not schedule push when not configured', done => { it('should not schedule push when not configured', async () => {
const config = Config.get(Parse.applicationId); const config = Config.get(Parse.applicationId);
const auth = { const auth = {
isMaster: true, isMaster: true,
@@ -800,33 +796,20 @@ describe('PushController', () => {
installations.push(installation); installations.push(installation);
} }
reconfigureServer({ await reconfigureServer({
push: { adapter: pushAdapter }, push: { adapter: pushAdapter },
}) });
.then(() => { await Parse.Object.saveAll(installations);
return Parse.Object.saveAll(installations) await pushController.sendPush(payload, {}, config, auth);
.then(() => { await sleep(1000);
return pushController.sendPush(payload, {}, config, auth); const query = new Parse.Query('_PushStatus');
}) const results = await query.find({ useMasterKey: true });
.then(() => new Promise(resolve => setTimeout(resolve, 300))); expect(results.length).toBe(1);
}) const pushStatus = results[0];
.then(() => { expect(pushStatus.get('status')).not.toBe('scheduled');
const query = new Parse.Query('_PushStatus');
return query.find({ useMasterKey: true }).then(results => {
expect(results.length).toBe(1);
const pushStatus = results[0];
expect(pushStatus.get('status')).not.toBe('scheduled');
done();
});
})
.catch(err => {
console.error(err);
fail('should not fail');
done();
});
}); });
it('should schedule push when configured', done => { it('should schedule push when configured', async () => {
const auth = { const auth = {
isMaster: true, isMaster: true,
}; };
@@ -866,28 +849,19 @@ describe('PushController', () => {
installation.set('deviceType', 'ios'); installation.set('deviceType', 'ios');
installations.push(installation); installations.push(installation);
} }
reconfigureServer({ await reconfigureServer({
push: { adapter: pushAdapter }, push: { adapter: pushAdapter },
scheduledPush: true, scheduledPush: true,
}) });
.then(() => { const config = Config.get(Parse.applicationId);
const config = Config.get(Parse.applicationId); await Parse.Object.saveAll(installations);
return Parse.Object.saveAll(installations) await pushController.sendPush(payload, {}, config, auth);
.then(() => { await sleep(1000);
return pushController.sendPush(payload, {}, config, auth); const query = new Parse.Query('_PushStatus');
}) const results = await query.find({ useMasterKey: true });
.then(() => new Promise(resolve => setTimeout(resolve, 300))); expect(results.length).toBe(1);
}) const pushStatus = results[0];
.then(() => { expect(pushStatus.get('status')).toBe('scheduled');
const query = new Parse.Query('_PushStatus');
return query.find({ useMasterKey: true }).then(results => {
expect(results.length).toBe(1);
const pushStatus = results[0];
expect(pushStatus.get('status')).toBe('scheduled');
});
})
.then(done)
.catch(done.err);
}); });
it('should not enqueue push when device token is not set', async () => { it('should not enqueue push when device token is not set', async () => {