mirror of
https://github.com/laurent22/joplin.git
synced 2024-12-12 08:54:00 +02:00
71efff6827
* Update eslint config * Applied linter to lib * Applied eslint config to CliClient/app * Removed prettier due to https://github.com/prettier/prettier/pull/4765 * First pass on test units * Applied linter config to test units * Applied eslint config to clipper * Applied to plugin dir * Applied to root of ElectronClient * Applied on RN root * Applied on CLI root * Applied on Clipper root * Applied config to tools * test hook * test hook * test hook * Added pre-commit hook * Applied rule no-trailing-spaces * Make sure root packages are installed when installing sub-dir * Added doc
60 lines
1.8 KiB
JavaScript
60 lines
1.8 KiB
JavaScript
/* eslint-disable no-unused-vars */
|
|
|
|
require('app-module-path').addPath(__dirname);
|
|
|
|
const { asyncTest, fileContentEqual, setupDatabase, revisionService, setupDatabaseAndSynchronizer, db, synchronizer, fileApi, sleep, clearDatabase, switchClient, syncTargetId, objectsEqual, checkThrowAsync } = require('test-utils.js');
|
|
const TaskQueue = require('lib/TaskQueue.js');
|
|
|
|
process.on('unhandledRejection', (reason, p) => {
|
|
console.log('Unhandled Rejection at: Promise', p, 'reason:', reason);
|
|
});
|
|
|
|
describe('TaskQueue', function() {
|
|
|
|
beforeEach(async (done) => {
|
|
await setupDatabaseAndSynchronizer(1);
|
|
await switchClient(1);
|
|
done();
|
|
});
|
|
|
|
it('should queue and execute tasks', asyncTest(async () => {
|
|
const queue = new TaskQueue();
|
|
|
|
queue.push(1, async () => { await sleep(0.5); return 'a'; });
|
|
queue.push(2, async () => { await sleep(0.5); return 'b'; });
|
|
queue.push(3, async () => { await sleep(0.5); return 'c'; });
|
|
|
|
const results = [];
|
|
|
|
results.push(await queue.waitForResult(1));
|
|
results.push(await queue.waitForResult(2));
|
|
results.push(await queue.waitForResult(3));
|
|
|
|
expect(results[0].id).toBe(1);
|
|
expect(results[0].result).toBe('a');
|
|
expect(results[1].id).toBe(2);
|
|
expect(results[1].result).toBe('b');
|
|
expect(results[2].id).toBe(3);
|
|
expect(results[2].result).toBe('c');
|
|
}));
|
|
|
|
it('should handle errors', asyncTest(async () => {
|
|
const queue = new TaskQueue();
|
|
|
|
queue.push(1, async () => { await sleep(0.5); return 'a'; });
|
|
queue.push(2, async () => { await sleep(0.5); throw new Error('e'); });
|
|
|
|
const results = [];
|
|
|
|
results.push(await queue.waitForResult(1));
|
|
results.push(await queue.waitForResult(2));
|
|
|
|
expect(results[0].id).toBe(1);
|
|
expect(results[0].result).toBe('a');
|
|
expect(results[1].id).toBe(2);
|
|
expect(!results[1].result).toBe(true);
|
|
expect(results[1].error.message).toBe('e');
|
|
}));
|
|
|
|
});
|